From 020135f4e9c9cfd01f1782d9b2e1f84af2dcf125 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=87=8E=E5=A3=B0?= <lijiacheng.ljc@antgroup.com>
Date: Wed, 10 Apr 2024 15:27:06 +0800
Subject: [PATCH] feat(queue): sort messages by timestamp asc

---
 src/queue/worker/github.ts | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/queue/worker/github.ts b/src/queue/worker/github.ts
index dda04932..ee5198dd 100644
--- a/src/queue/worker/github.ts
+++ b/src/queue/worker/github.ts
@@ -1,4 +1,5 @@
 import { EmitterWebhookEventName, Webhooks } from '@octokit/webhooks';
+import { orderBy, sortBy } from 'lodash';
 import chunk from 'lodash/chunk';
 import groupBy from 'lodash/groupBy';
 import DefaultMap from 'mnemonist/default-map';
@@ -106,7 +107,10 @@ export class GitHubEventWorker extends BaseWorker<IGitHubEventQueueMessage> {
   }
 
   async run() {
-    const byId = groupBy(this.queue, (v) => v.body.botId);
+    const byId = groupBy(
+      orderBy(this.queue, 'timestamp', 'asc'),
+      (v) => v.body.botId,
+    );
 
     const result = await Promise.allSettled(
       Object.entries(byId).map(async ([botId, messages]) => {