fix: creating sse connection for each gql subscribe (#1154)

kordis-leitstelle · Jan 1, 2025 · 9a355bc · 9a355bc
1 parent fc13451
commit 9a355bc
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 4 deletions.
diff --git a/apps/api/src/app/controllers/graphql-subscriptions.controller.ts b/apps/api/src/app/controllers/graphql-subscriptions.controller.ts
@@ -1,7 +1,7 @@
 import {
+	All,
 	Controller,
 	OnModuleInit,
-	Post,
 	Req,
 	Res,
 	ServiceUnavailableException,
@@ -28,7 +28,7 @@ export class GraphqlSubscriptionsController implements OnModuleInit {
 		});
 	}
 
-	@Post()
+	@All()
 	subscriptionHandler(
 		@Req() req: KordisRequest,
 		@Res() res: Response,

diff --git a/libs/spa/core/graphql/src/lib/graphql.module.ts b/libs/spa/core/graphql/src/lib/graphql.module.ts
@@ -39,6 +39,7 @@ export class GraphqlModule {
 							},
 							new SSELink({
 								url: sseEndpoint,
+								singleConnection: true,
 								headers: () => ({
 									...authHeaderFactory(),
 								}),

diff --git a/libs/spa/core/graphql/src/lib/sse-link.ts b/libs/spa/core/graphql/src/lib/sse-link.ts
@@ -8,9 +8,9 @@ import { print } from 'graphql';
 import { Client, ClientOptions, createClient } from 'graphql-sse';
 
 export class SSELink extends ApolloLink {
-	private client: Client;
+	private client: Client<true>;
 
-	constructor(options: ClientOptions) {
+	constructor(options: ClientOptions<true>) {
 		super();
 		this.client = createClient(options);
 	}