-
Notifications
You must be signed in to change notification settings - Fork 56
/
index.js
93 lines (78 loc) · 2.18 KB
/
index.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
"use strict";
const fs = require("fs");
const { Kind } = require("graphql");
const { ServiceBroker } = require("moleculer");
const ApiGateway = require("moleculer-web");
const { ApolloService } = require("../../index");
const broker = new ServiceBroker({
logLevel: process.env.LOGLEVEL || "info" /*, transporter: "NATS"*/,
});
broker.createService({
name: "api",
mixins: [
// Gateway
ApiGateway,
// GraphQL Apollo Server
ApolloService({
// Global GraphQL typeDefs
typeDefs: ["scalar Date", "scalar Timestamp"],
// Global resolvers
resolvers: {
Date: {
__parseValue(value) {
return new Date(value); // value from the client
},
__serialize(value) {
return value.toISOString().split("T")[0]; // value sent to the client
},
__parseLiteral(ast) {
if (ast.kind === Kind.INT) {
return parseInt(ast.value, 10); // ast value is always in string format
}
return null;
},
},
Timestamp: {
__parseValue(value) {
return new Date(value); // value from the client
},
__serialize(value) {
return value.toISOString(); // value sent to the client
},
__parseLiteral(ast) {
if (ast.kind === Kind.INT) {
return parseInt(ast.value, 10); // ast value is always in string format
}
return null;
},
},
},
// API Gateway route options
routeOptions: {
path: "/graphql",
cors: true,
mappingPolicy: "restrict",
},
// https://www.apollographql.com/docs/apollo-server/v2/api/apollo-server.html
serverOptions: {
tracing: false,
engine: {
apiKey: process.env.APOLLO_ENGINE_KEY,
},
},
}),
],
events: {
"graphql.schema.updated"({ schema }) {
fs.writeFileSync(__dirname + "/generated-schema.gql", schema, "utf8");
this.logger.info("Generated GraphQL schema:\n\n" + schema);
},
},
});
broker.loadServices(__dirname);
broker.start().then(async () => {
broker.repl();
broker.logger.info("----------------------------------------------------------");
broker.logger.info("Open the http://localhost:3000/graphql URL in your browser");
broker.logger.info("----------------------------------------------------------");
});