feat: support redis stream as event source (#2192)

* chore: initial server logic separation

* fix: dummy import

* fix: imports

* fix: export ibd

* chore: client

* feat: use new client

* chore: add pre-release

.env

@@ -60,6 +60,10 @@ PG_APPLICATION_NAME=stacks-blockchain-api
 # (with both Event Server and API endpoints).
 # STACKS_API_MODE=
 
+# If this API instance should consume events from a Stacks node (`stacks` or `default`) or a Store-and-forward Redis service (`redis`).
+# STACKS_API_EVENT_SOURCE=
+# REDIS_URL=
+
 # To avoid running unnecessary mempool stats during transaction influx, we use a debounce mechanism for the process.
 # This variable controls the duration it waits until there are no further mempool updates
 # MEMPOOL_STATS_DEBOUNCE_INTERVAL=1000

.github/workflows/ci.yml

@@ -6,7 +6,7 @@ on:
       - master
       - develop
       - beta
-      - nakamoto
+      - redis-stream
     tags-ignore:
       - "**"
     paths-ignore:

.releaserc

@@ -7,8 +7,8 @@
       "prerelease": true
     },
     {
-      "name": "nakamoto",
-      "channel": "nakamoto",
+      "name": "redis-stream",
+      "channel": "redis-stream",
       "prerelease": true
     }
   ],

.vscode/launch.json

@@ -25,7 +25,8 @@
       "env": {
         "NODE_ENV": "development",
         "TS_NODE_SKIP_IGNORE": "true"
-      }
+      },
+      "killBehavior": "polite",
     },
     {
       "type": "node",

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');
+};