feat(queue): sort messages by timestamp asc

opensumi · Apr 10, 2024 · 020135f · 020135f
1 parent b9dd4b5
commit 020135f
Showing 1 changed file with 5 additions and 1 deletion.
diff --git 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]) => {