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, } }, });