refactor(filler): read SHIP through @atomichub/antelope-ship-utils

CHANGELOG.md

@@ -10,6 +10,24 @@ order; the entry is the editorial text of the version's GitHub Release. The 1.7
 maintenance line continues in `CHANGELOG.md` on the `release/1.7` branch. This
 project follows semantic versioning.
 
+## [2.2.0]
+
+Moves the filler's SHIP reader onto a published package.
+
+### Upgrading
+
+- Image `ghcr.io/atomicassets/atomicassets-api:2.2.0`. The `2.2` and `latest` tags move to it.
+- The migration set is unchanged from 2.0.0, so the filler performs no database work on boot.
+- A heartbeat runs every 30 seconds and the socket is torn down after 300 seconds without a message or a pong. The previous client had neither and hung on a half-open connection. (#175)
+- Reconnect backoff runs 5 seconds to 60 seconds instead of a fixed 5 second retry. (#175)
+- A block, trace or delta payload the node serves empty escalates to a reconnect instead of pausing the queue permanently. Empty payloads at `block_num <= 1` only warn. (#175)
+- A failure on the prepare path rejects into an unhandled rejection, which the filler turns into `process.exit(1)` and a supervisor restart. The previous client paused the queue until the stall watchdog fired. (#175)
+- `ship_min_block_confirmation`, `ds_ship_threads`, `ship_prefetch_blocks`, `ship_ds_queue_size` and `ship_max_blocks_queue` keep their meaning. Heartbeat and idle timeout are not configurable in `readers.config.json`. (#175)
+
+### Other changes
+
+- The filler's SHIP reader is the `@atomichub/antelope-ship-utils` package (repository `atomicassets/antelope-ship-utils`) rather than an in-tree client. The in-tree reader, its deserializer worker and the direct `ws` and `node-worker-threads-pool` dependencies are gone, and the block-shape types are re-exported from the package. (#175)
+
 ## [2.1.0] - 2026-08-10
 
 Splits the Redis pub/sub subscriber onto its own optional endpoint.

knip.json

@@ -2,7 +2,6 @@
     "$schema": "https://unpkg.com/knip@5/schema.json",
     "entry": [
         "src/bin/**/*.ts",
-        "src/workers/**/*.ts",
         "src/scripts/**/*.ts",
         "src/**/*.test.ts"
     ],

package.json

@@ -52,6 +52,7 @@
     "db:migrate:up": "pnpm build && node --trace-warnings ./build/bin/migrate.js"
   },
   "dependencies": {
+    "@atomichub/antelope-ship-utils": "^1.0.0",
     "@atomichub/atomicassets": "^2.0.2",
     "@wharfkit/antelope": "^1.1.1",
     "async-exit-hook": "^2.0.1",
@@ -64,15 +65,13 @@
     "express-rate-limit": "^8.5.2",
     "iovalkey": "^0.3.3",
     "moize": "^6.1.1",
-    "node-worker-threads-pool": "^1.5.1",
     "p-queue": "^9.3.1",
     "pg": "^8.22.0",
     "prom-client": "^15.1.3",
     "rate-limit-redis": "^5.0.0",
     "socket.io": "^4.8.3",
     "swagger-ui-express": "^5.0.1",
-    "winston": "^3.7.2",
-    "ws": "^8.21.1"
+    "winston": "^3.7.2"
   },
   "devDependencies": {
     "@eslint/js": "^10.0.1",
@@ -93,7 +92,6 @@
     "@types/sinon": "^21.0.0",
     "@types/supertest": "^7.2.1",
     "@types/swagger-ui-express": "^4.1.6",
-    "@types/ws": "^8.18.1",
     "c8": "^11.0.0",
     "chai": "^6.2.2",
     "chai-as-promised": "^8.0.2",

pnpm-workspace.yaml

@@ -13,9 +13,10 @@ overrides:
 
 # The release-age gate exists to keep a freshly published third-party package
 # out of the lockfile before anyone has had a chance to notice it is hostile.
-# This entry is first-party: the version is pinned, published from a tag in our
-# own repository, and its tarball contents were checked against that tag. It can
-# be dropped once the version is older than the gate; nothing depends on it
-# staying.
+# These entries are first-party: each version is pinned, published from a tag in
+# our own repositories, and its tarball contents were checked against that tag.
+# An entry can be dropped once the version is older than the gate; nothing
+# depends on it staying.
 minimumReleaseAgeExclude:
   - '@atomichub/atomicassets@2.0.2'
+  - '@atomichub/antelope-ship-utils@1.0.0'

src/connections/manager.ts

@@ -1,9 +1,10 @@
-import StateHistoryBlockReader from './ship';
+import { EOSJsDeserializer, StateHistoryConnection } from '@atomichub/antelope-ship-utils';
+import type { IShipConnectionOptions } from '@atomichub/antelope-ship-utils';
+
 import ChainApi from './chain';
 import RedisConnection from './redis';
 import PostgresConnection from './postgres';
 import { IConnectionsConfig } from '../types/config';
-import { IBlockReaderOptions } from '../types/ship';
 
 export default class ConnectionManager {
     readonly chain: ChainApi;
@@ -96,13 +97,11 @@ export default class ConnectionManager {
         }
     }
 
-    createShipBlockReader(options?: IBlockReaderOptions): StateHistoryBlockReader {
-        const reader = new StateHistoryBlockReader(process.env.CHAIN_SHIP || this.config.chain.ship);
-
-        if (options) {
-            reader.setOptions(options);
-        }
-
-        return reader;
+    createShipConnection(connectionOptions: IShipConnectionOptions, deserializer: EOSJsDeserializer): StateHistoryConnection {
+        return new StateHistoryConnection({
+            endpoint: process.env.CHAIN_SHIP || this.config.chain.ship,
+            connectionOptions,
+            deserializer
+        });
     }
 }