events-backend: fix event bus timeout handling

Signed-off-by: Patrik Oldsberg <poldsberg@gmail.com>

plugins/events-backend/src/service/hub/DatabaseEventBusStore.ts

@@ -113,6 +113,7 @@ class DatabaseEventBusListener {
       signal.addEventListener('abort', () => {
         this.#listeners.delete(listener);
         this.#maybeTimeoutConnection();
+        reject(signal.reason);
       });
     });
   }

plugins/events-backend/src/service/hub/createEventBusRouter.ts

@@ -227,6 +227,12 @@ export async function createEventBusRouter(options: {
               `Received notification for subscription '${id}' for topic '${topic}'`,
               { subject: credentials.principal.subject },
             );
+          } catch (error) {
+            if (error === controller.signal.reason) {
+              res.end();
+            } else {
+              throw error;
+            }
           } finally {
             // A small extra delay ensures a more even spread of events across
             // consumers in case some consumers are faster than others