WIP Server side events

src/routes/events/events.controller.spec.ts

@@ -0,0 +1,18 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { EventsController } from './events.controller';
+
+describe('EventsController', () => {
+  let controller: EventsController;
+
+  beforeEach(async () => {
+    const module: TestingModule = await Test.createTestingModule({
+      controllers: [EventsController],
+    }).compile();
+
+    controller = module.get<EventsController>(EventsController);
+  });
+
+  it('should be defined', () => {
+    expect(controller).toBeDefined();
+  });
+});

src/routes/events/events.controller.ts

@@ -0,0 +1,13 @@
+import { Controller, Param, Sse } from '@nestjs/common';
+import { Observable } from 'rxjs';
+import { EventsService } from './events.service';
+
+@Controller('events')
+export class EventsController {
+  constructor(private eventsService: EventsService) {}
+
+  @Sse('/sse/:safe')
+  sse(@Param('safe') safe: string): Observable<MessageEvent> {
+    return interval(1000).pipe(map((_) => ({ data: { hello: 'world' } })));
+  }
+}

src/routes/events/events.service.spec.ts

@@ -36,8 +36,6 @@ describe('EventsService', () => {
     webhookService = module.get<WebhookService>(WebhookService);
   });
 
-
-
   describe('listenToEvents', () => {
     it('should return consumer tag', async () => {
       const expected = 'exampleTag';