From 82a70ea04ed551df8d18cb11acfe26b3c8c03065 Mon Sep 17 00:00:00 2001 From: Brendan Chen Date: Tue, 4 Feb 2025 10:12:19 -0800 Subject: [PATCH] add notification service to server context --- src/ServerContext.ts | 4 +++- src/index.ts | 6 ++++-- 2 files changed, 7 insertions(+), 3 deletions(-) diff --git a/src/ServerContext.ts b/src/ServerContext.ts index c380583..7acfab3 100644 --- a/src/ServerContext.ts +++ b/src/ServerContext.ts @@ -1,5 +1,7 @@ import { GetterRepository } from "./repositories/GetterRepository"; +import { NotificationService } from "./services/NotificationService"; export interface ServerContext { repository: GetterRepository; -} \ No newline at end of file + notificationService: NotificationService; +} diff --git a/src/index.ts b/src/index.ts index b90d962..9e93dcc 100644 --- a/src/index.ts +++ b/src/index.ts @@ -5,6 +5,7 @@ import { MergedResolvers } from "./MergedResolvers"; import { ServerContext } from "./ServerContext"; import { UnoptimizedInMemoryRepository } from "./repositories/UnoptimizedInMemoryRepository"; import { TimedApiBasedRepositoryLoader } from "./loaders/TimedApiBasedRepositoryLoader"; +import { NotificationService } from "./services/NotificationService"; const typeDefs = readFileSync("./schema.graphqls", "utf8"); @@ -16,13 +17,13 @@ async function main() { }); const repository = new UnoptimizedInMemoryRepository(); - // await loadTestData(repository); - const repositoryDataUpdater = new TimedApiBasedRepositoryLoader( repository ); await repositoryDataUpdater.start(); + const notificationService = new NotificationService(repository); + const { url } = await startStandaloneServer(server, { listen: { port: process.env.PORT ? parseInt(process.env.PORT) : 4000, @@ -30,6 +31,7 @@ async function main() { context: async ({ req, res }) => { return { repository, + notificationService, } }, });