diff --git a/packages/shuttle/CHANGELOG.md b/packages/shuttle/CHANGELOG.md index bf91d5f199..019239cf87 100644 --- a/packages/shuttle/CHANGELOG.md +++ b/packages/shuttle/CHANGELOG.md @@ -1,5 +1,11 @@ # @farcaster/hub-shuttle +## 0.5.1 + +### Patch Changes + +- Fix reset of limit for total batch bytes + ## 0.5.0 ### Minor Changes diff --git a/packages/shuttle/package.json b/packages/shuttle/package.json index 2e5e04158f..c7f1801cf8 100644 --- a/packages/shuttle/package.json +++ b/packages/shuttle/package.json @@ -1,6 +1,6 @@ { "name": "@farcaster/shuttle", - "version": "0.5.0", + "version": "0.5.1", "main": "./dist/index.js", "module": "./dist/index.mjs", "types": "./dist/index.d.ts", diff --git a/packages/shuttle/src/shuttle/hubSubscriber.ts b/packages/shuttle/src/shuttle/hubSubscriber.ts index b596d3fdcf..bf42c65fb6 100644 --- a/packages/shuttle/src/shuttle/hubSubscriber.ts +++ b/packages/shuttle/src/shuttle/hubSubscriber.ts @@ -222,6 +222,7 @@ export class EventStreamHubSubscriber extends BaseHubSubscriber { ) { // Empties the current batch const eventBatch = this.eventsToAdd.splice(0, this.eventsToAdd.length); + this.eventBatchBytes = 0; // Copies the removed events to the stream await this.eventStream.add(