mirror of
https://github.com/brendan-ch/project-inter-server.git
synced 2026-04-17 07:50:31 +00:00
add notification service to server context
This commit is contained in:
@@ -1,5 +1,7 @@
|
|||||||
import { GetterRepository } from "./repositories/GetterRepository";
|
import { GetterRepository } from "./repositories/GetterRepository";
|
||||||
|
import { NotificationService } from "./services/NotificationService";
|
||||||
|
|
||||||
export interface ServerContext {
|
export interface ServerContext {
|
||||||
repository: GetterRepository;
|
repository: GetterRepository;
|
||||||
|
notificationService: NotificationService;
|
||||||
}
|
}
|
||||||
@@ -5,6 +5,7 @@ import { MergedResolvers } from "./MergedResolvers";
|
|||||||
import { ServerContext } from "./ServerContext";
|
import { ServerContext } from "./ServerContext";
|
||||||
import { UnoptimizedInMemoryRepository } from "./repositories/UnoptimizedInMemoryRepository";
|
import { UnoptimizedInMemoryRepository } from "./repositories/UnoptimizedInMemoryRepository";
|
||||||
import { TimedApiBasedRepositoryLoader } from "./loaders/TimedApiBasedRepositoryLoader";
|
import { TimedApiBasedRepositoryLoader } from "./loaders/TimedApiBasedRepositoryLoader";
|
||||||
|
import { NotificationService } from "./services/NotificationService";
|
||||||
|
|
||||||
const typeDefs = readFileSync("./schema.graphqls", "utf8");
|
const typeDefs = readFileSync("./schema.graphqls", "utf8");
|
||||||
|
|
||||||
@@ -16,13 +17,13 @@ async function main() {
|
|||||||
});
|
});
|
||||||
|
|
||||||
const repository = new UnoptimizedInMemoryRepository();
|
const repository = new UnoptimizedInMemoryRepository();
|
||||||
// await loadTestData(repository);
|
|
||||||
|
|
||||||
const repositoryDataUpdater = new TimedApiBasedRepositoryLoader(
|
const repositoryDataUpdater = new TimedApiBasedRepositoryLoader(
|
||||||
repository
|
repository
|
||||||
);
|
);
|
||||||
await repositoryDataUpdater.start();
|
await repositoryDataUpdater.start();
|
||||||
|
|
||||||
|
const notificationService = new NotificationService(repository);
|
||||||
|
|
||||||
const { url } = await startStandaloneServer(server, {
|
const { url } = await startStandaloneServer(server, {
|
||||||
listen: {
|
listen: {
|
||||||
port: process.env.PORT ? parseInt(process.env.PORT) : 4000,
|
port: process.env.PORT ? parseInt(process.env.PORT) : 4000,
|
||||||
@@ -30,6 +31,7 @@ async function main() {
|
|||||||
context: async ({ req, res }) => {
|
context: async ({ req, res }) => {
|
||||||
return {
|
return {
|
||||||
repository,
|
repository,
|
||||||
|
notificationService,
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|||||||
Reference in New Issue
Block a user