fix(matrix): avoid async event listener promises

liaoandi · liaoandi · commit 3928f865da48 · 2026-06-09T17:59:29.000+08:00
diff --git a/extensions/matrix/src/matrix/monitor/auto-join.ts b/extensions/matrix/src/matrix/monitor/auto-join.ts
@@ -69,8 +69,7 @@ export function registerMatrixAutoJoin(params: {
       });
   };
 
-  // Handle invites directly so both "always" and "allowlist" modes share the same path.
-  client.on("room.invite", (roomId: string, _inviteEvent: unknown) => {
+  const handleRoomInvite = (roomId: string, _inviteEvent: unknown) => {
     runInviteTask(roomId, async () => {
       if (autoJoin === "allowlist") {
         const allowedAliasRoomIds = await resolveAllowedAliasRoomIds();
@@ -92,5 +91,8 @@ export function registerMatrixAutoJoin(params: {
         runtime.error?.(`matrix: failed to join room ${roomId}: ${String(err)}`);
       }
     });
-  });
+  };
+
+  // Handle invites directly so both "always" and "allowlist" modes share the same path.
+  client.on("room.invite", handleRoomInvite);
 }
diff --git a/extensions/matrix/src/matrix/monitor/events.ts b/extensions/matrix/src/matrix/monitor/events.ts
@@ -272,7 +272,7 @@ export function registerMatrixMonitorEvents(params: {
     );
   });
 
-  client.on("room.failed_decryption", (roomId: string, event: MatrixRawEvent, error: Error) => {
+  const handleFailedDecryption = (roomId: string, event: MatrixRawEvent, error: Error) => {
     void runMonitorTask(
       `failed decryption handler room=${roomId} id=${event.event_id ?? "unknown"}`,
       async () => {
@@ -328,7 +328,8 @@ export function registerMatrixMonitorEvents(params: {
         );
       },
     );
-  });
+  };
+  client.on("room.failed_decryption", handleFailedDecryption);
 
   client.on("verification.summary", (summary) => {
     void runMonitorTask("verification summary handler", async () => {
