fix: event-server requested ending incorrectly

hirosystems · Apr 5, 2024 · e5299b9 · e5299b9
1 parent 72c1306
commit e5299b9
Showing 1 changed file with 5 additions and 10 deletions.
diff --git a/src/event-stream/event-server.ts b/src/event-stream/event-server.ts
@@ -910,7 +910,7 @@ export async function startEventServer(opts: {
 
   app.post(
     '/new_block',
-    asyncHandler(async (req, res, next) => {
+    asyncHandler(async (req, res) => {
       try {
         const blockMessage: CoreNodeBlockMessage = JSON.parse(req.body);
         await messageHandler.handleBlockMessage(opts.chainId, blockMessage, db);
@@ -919,7 +919,6 @@ export async function startEventServer(opts: {
         }
         await handleRawEventRequest(req);
         res.status(200).json({ result: 'ok' });
-        next();
       } catch (error) {
         logger.error(error, 'error processing core-node /new_block');
         res.status(500).json({ error: error });
@@ -929,13 +928,12 @@ export async function startEventServer(opts: {
 
   app.post(
     '/new_burn_block',
-    asyncHandler(async (req, res, next) => {
+    asyncHandler(async (req, res) => {
       try {
         const msg: CoreNodeBurnBlockMessage = JSON.parse(req.body);
         await messageHandler.handleBurnBlock(msg, db);
         await handleRawEventRequest(req);
         res.status(200).json({ result: 'ok' });
-        next();
       } catch (error) {
         logger.error(error, 'error processing core-node /new_burn_block');
         res.status(500).json({ error: error });
@@ -945,13 +943,12 @@ export async function startEventServer(opts: {
 
   app.post(
     '/new_mempool_tx',
-    asyncHandler(async (req, res, next) => {
+    asyncHandler(async (req, res) => {
       try {
         const rawTxs: string[] = JSON.parse(req.body);
         await messageHandler.handleMempoolTxs(rawTxs, db);
         await handleRawEventRequest(req);
         res.status(200).json({ result: 'ok' });
-        next();
       } catch (error) {
         logger.error(error, 'error processing core-node /new_mempool_tx');
         res.status(500).json({ error: error });
@@ -977,13 +974,12 @@ export async function startEventServer(opts: {
 
   app.post(
     '/attachments/new',
-    asyncHandler(async (req, res, next) => {
+    asyncHandler(async (req, res) => {
       try {
         const msg: CoreNodeAttachmentMessage[] = JSON.parse(req.body);
         await messageHandler.handleNewAttachment(msg, db);
         await handleRawEventRequest(req);
         res.status(200).json({ result: 'ok' });
-        next();
       } catch (error) {
         logger.error(error, 'error processing core-node /attachments/new');
         res.status(500).json({ error: error });
@@ -993,13 +989,12 @@ export async function startEventServer(opts: {
 
   app.post(
     '/new_microblocks',
-    asyncHandler(async (req, res, next) => {
+    asyncHandler(async (req, res) => {
       try {
         const msg: CoreNodeMicroblockMessage = JSON.parse(req.body);
         await messageHandler.handleMicroblockMessage(opts.chainId, msg, db);
         await handleRawEventRequest(req);
         res.status(200).json({ result: 'ok' });
-        next();
       } catch (error) {
         logger.error(error, 'error processing core-node /new_microblocks');
         res.status(500).json({ error: error });