feat: use new client

migrations/1736275393880_stacks-node-event-sequence-id.js

@@ -0,0 +1,15 @@
+/* eslint-disable camelcase */
+
+exports.shorthands = undefined;
+
+exports.up = pgm => {
+  pgm.addColumn('event_observer_requests', {
+    sequence_id: {
+      type: 'string'
+    }
+  });
+};
+
+exports.down = pgm => {
+  pgm.dropColumn('event_observer_requests', 'sequence_id');
+};

package.json

@@ -95,6 +95,7 @@
     "@fastify/swagger": "8.15.0",
     "@fastify/type-provider-typebox": "4.0.0",
     "@hirosystems/api-toolkit": "1.6.2",
+    "@hirosystems/salt-n-pepper-client": "0.1.0",
     "@scure/base": "1.1.1",
     "@sinclair/typebox": "0.32.35",
     "@stacks/common": "6.10.0",
@@ -140,7 +141,6 @@
     "postgres": "3.3.1",
     "prom-client": "15.1.3",
     "rpc-bitcoin": "2.0.0",
-    "salt-and-pepper-client": "file:../salt-and-pepper/client",
     "socket.io": "4.8.0",
     "source-map-support": "0.5.21",
     "split2": "3.2.2",

src/datastore/pg-store.ts

@@ -4524,4 +4524,11 @@ export class PgStore extends BasePgStore {
     `;
     if (result.count) return result[0];
   }
+
+  async getLastEventObserverRequestSequenceId(): Promise<string | undefined> {
+    const result = await this.sql<{ sequence_id: string }[]>`
+      SELECT sequence_id FROM event_observer_requests ORDER BY id DESC LIMIT 1
+    `;
+    return result[0]?.sequence_id ?? undefined;
+  }
 }