feat: update FastifySseReplyFromResponseBuilder

update builder with custom cors origins

Author: notaphplover

.changeset/happy-months-stare.md

@@ -0,0 +1,5 @@
+---
+"@cornie-js/backend-http": minor
+---
+
+Updated FastifySseReplyFromResponseBuilder with custom cors origins

.changeset/nine-days-act.md

@@ -0,0 +1,5 @@
+---
+"@cornie-js/backend-service-game": patch
+---
+
+Updated SseControllers to rely on custom FastifySseReplyFromResponseBuilder

packages/backend/libraries/backend-http/src/http/adapter/fastify/builders/FastifySseReplyFromResponseBuilder.ts

@@ -7,13 +7,24 @@ import { FastifyReply } from 'fastify';
 
 import { Response } from '../../../application/models/Response';
 
+const CORS_ORIGINS_SEPARATOR: string = ',';
+
 @Injectable()
 export class FastifySseReplyFromResponseBuilder
   implements Builder<FastifyReply, [Response, FastifyReply]>
 {
+  readonly #accessControlAllowOriginValue: string;
+
+  constructor(corsOrigins: string[]) {
+    this.#accessControlAllowOriginValue = corsOrigins.join(
+      CORS_ORIGINS_SEPARATOR,
+    );
+  }
+
   public build(response: Response, fastifyReply: FastifyReply): FastifyReply {
     const sseHeaders: http.OutgoingHttpHeaders | http2.OutgoingHttpHeaders = {
       ...response.headers,
+      'access-control-allow-origin': this.#accessControlAllowOriginValue,
       // Consider https://html.spec.whatwg.org/multipage/server-sent-events.html as reference
       // Disable cache, even for old browsers and proxies
       'cache-control':

packages/backend/libraries/backend-http/src/http/adapter/nest/controllers/HttpNestFastifySseController.spec.ts

@@ -15,7 +15,6 @@ import { DelayedSseConsumer } from '../../../application/modules/DelayedSseConsu
 import { SsePublisher } from '../../../application/modules/SsePublisher';
 import { SseTeardownExecutor } from '../../../application/modules/SseTeardownExecutor';
 import { FastifyReplySseConsumerFromFastifyReplyBuilder } from '../../fastify/builders/FastifyReplySseConsumerFromFastifyReplyBuilder';
-import { FastifySseReplyFromResponseBuilder } from '../../fastify/builders/FastifySseReplyFromResponseBuilder';
 import { HttpNestFastifySseController } from './HttpNestFastifySseController';
 
 describe(HttpNestFastifySseController.name, () => {
@@ -35,7 +34,9 @@ describe(HttpNestFastifySseController.name, () => {
   let resultBuilderMock: jest.Mocked<
     Builder<FastifyReply, [Response | ResponseWithBody<unknown>, FastifyReply]>
   >;
-  let sseResultBuilderMock: jest.Mocked<FastifySseReplyFromResponseBuilder>;
+  let sseResultBuilderMock: jest.Mocked<
+    Builder<FastifyReply, [Response, FastifyReply]>
+  >;
 
   let httpNestFastifySseController: HttpNestFastifySseController;
 

packages/backend/libraries/backend-http/src/http/adapter/nest/controllers/HttpNestFastifySseController.ts

@@ -11,7 +11,6 @@ import { DelayedSseConsumer } from '../../../application/modules/DelayedSseConsu
 import { SsePublisher } from '../../../application/modules/SsePublisher';
 import { SseTeardownExecutor } from '../../../application/modules/SseTeardownExecutor';
 import { FastifyReplySseConsumerFromFastifyReplyBuilder } from '../../fastify/builders/FastifyReplySseConsumerFromFastifyReplyBuilder';
-import { FastifySseReplyFromResponseBuilder } from '../../fastify/builders/FastifySseReplyFromResponseBuilder';
 
 @Injectable()
 export class HttpNestFastifySseController<
@@ -31,7 +30,7 @@ export class HttpNestFastifySseController<
     FastifyReply,
     [Response | ResponseWithBody<unknown>, FastifyReply]
   >;
-  readonly #sseResultBuilder: FastifySseReplyFromResponseBuilder;
+  readonly #sseResultBuilder: Builder<FastifyReply, [Response, FastifyReply]>;
 
   constructor(
     fastifyReplyConsumerFromFastifyReplyBuilder: FastifyReplySseConsumerFromFastifyReplyBuilder,
@@ -47,7 +46,7 @@ export class HttpNestFastifySseController<
       FastifyReply,
       [Response | ResponseWithBody<unknown>, FastifyReply]
     >,
-    sseResultBuilder: FastifySseReplyFromResponseBuilder,
+    sseResultBuilder: Builder<FastifyReply, [Response, FastifyReply]>,
   ) {
     this.#fastifyReplySseConsumerFromFastifyReplyBuilder =
       fastifyReplyConsumerFromFastifyReplyBuilder;

packages/backend/services/backend-service-game/src/foundation/http/adapter/fastify/builders/FastifySseReplyFromResponseBuilder.ts

@@ -0,0 +1,13 @@
+import { EnvironmentService } from '@cornie-js/backend-app-game-env';
+import { FastifySseReplyFromResponseBuilder as BaseFastifySseReplyFromResponseBuilder } from '@cornie-js/backend-http';
+import { Inject, Injectable } from '@nestjs/common';
+
+@Injectable()
+export class FastifySseReplyFromResponseBuilder extends BaseFastifySseReplyFromResponseBuilder {
+  constructor(
+    @Inject(EnvironmentService)
+    environmentService: EnvironmentService,
+  ) {
+    super(environmentService.getEnvironment().corsOrigins);
+  }
+}

packages/backend/services/backend-service-game/src/foundation/http/adapter/nest/modules/HttpModule.ts

@@ -1,15 +1,17 @@
+import { EnvModule } from '@cornie-js/backend-app-game-env';
 import {
   ErrorV1ResponseFromErrorBuilder,
   FastifyReplyFromResponseBuilder,
   FastifyReplySseConsumerFromFastifyReplyBuilder,
-  FastifySseReplyFromResponseBuilder,
   HttpStatusCodeFromErrorBuilder,
   RequestFromFastifyRequestBuilder,
   RequestWithBodyFromFastifyRequestBuilder,
   StringifiedSseFromMessageEventBuilder,
 } from '@cornie-js/backend-http';
 import { Module } from '@nestjs/common';
 
+import { FastifySseReplyFromResponseBuilder } from '../../fastify/builders/FastifySseReplyFromResponseBuilder';
+
 @Module({
   exports: [
     ErrorV1ResponseFromErrorBuilder,
@@ -19,6 +21,7 @@ import { Module } from '@nestjs/common';
     RequestFromFastifyRequestBuilder,
     RequestWithBodyFromFastifyRequestBuilder,
   ],
+  imports: [EnvModule],
   providers: [
     ErrorV1ResponseFromErrorBuilder,
     FastifyReplyFromResponseBuilder,

packages/backend/services/backend-service-game/src/games/adapter/nest/controllers/GetV2EventsGamesGameIdRequestNestController.ts

@@ -3,7 +3,6 @@ import { GetV2GamesGameIdEventsSseController } from '@cornie-js/backend-game-app
 import {
   FastifyReplyFromResponseBuilder,
   FastifyReplySseConsumerFromFastifyReplyBuilder,
-  FastifySseReplyFromResponseBuilder,
   HttpNestFastifySseController,
   MessageEvent,
   Request,
@@ -16,6 +15,8 @@ import {
 import { Controller, Get, Inject, Req, Res } from '@nestjs/common';
 import { FastifyReply, FastifyRequest } from 'fastify';
 
+import { FastifySseReplyFromResponseBuilder } from '../../../../foundation/http/adapter/fastify/builders/FastifySseReplyFromResponseBuilder';
+
 @Controller(`v2/events/games`)
 export class GetV2EventsGamesGameIdRequestNestController extends HttpNestFastifySseController {
   constructor(