142 lines
3.7 KiB
TypeScript
142 lines
3.7 KiB
TypeScript
import type { IncomingMessage, ServerResponse } from "http";
|
|
import type { ServiceBroker } from "moleculer";
|
|
import { Service } from "moleculer";
|
|
import ApiGateway from "moleculer-web";
|
|
|
|
interface GraphQLRequest extends IncomingMessage {
|
|
body: {
|
|
query: string;
|
|
variables?: Record<string, unknown>;
|
|
operationName?: string;
|
|
};
|
|
$params: {
|
|
query?: string;
|
|
variables?: string;
|
|
operationName?: string;
|
|
};
|
|
$ctx: {
|
|
broker: ServiceBroker;
|
|
};
|
|
}
|
|
|
|
interface GraphQLError {
|
|
message: string;
|
|
}
|
|
|
|
export default class ApiService extends Service {
|
|
constructor(broker: ServiceBroker) {
|
|
super(broker);
|
|
this.parseServiceSchema({
|
|
name: "api",
|
|
mixins: [ApiGateway],
|
|
// More info about settings: https://moleculer.services/docs/0.14/moleculer-web.html
|
|
settings: {
|
|
port: process.env.PORT || 3060,
|
|
routes: [
|
|
{
|
|
path: "/api",
|
|
whitelist: ["**"],
|
|
cors: {
|
|
origin: "*",
|
|
methods: ["GET", "OPTIONS", "POST", "PUT", "DELETE"],
|
|
allowedHeaders: ["*"],
|
|
exposedHeaders: [],
|
|
credentials: false,
|
|
maxAge: 3600,
|
|
},
|
|
use: [],
|
|
mergeParams: true,
|
|
authentication: false,
|
|
authorization: false,
|
|
autoAliases: true,
|
|
aliases: {},
|
|
callingOptions: {},
|
|
|
|
bodyParsers: {
|
|
json: {
|
|
strict: false,
|
|
limit: "1MB",
|
|
},
|
|
urlencoded: {
|
|
extended: true,
|
|
limit: "1MB",
|
|
},
|
|
},
|
|
mappingPolicy: "all", // Available values: "all", "restrict"
|
|
logging: true,
|
|
},
|
|
|
|
{
|
|
path: "/acquisition-graphql",
|
|
whitelist: ["acquisition-graphql.query"],
|
|
cors: {
|
|
origin: "*",
|
|
methods: ["GET", "POST", "OPTIONS"],
|
|
allowedHeaders: ["*"],
|
|
credentials: false,
|
|
maxAge: 3600,
|
|
},
|
|
aliases: {
|
|
// eslint-disable-next-line @typescript-eslint/naming-convention
|
|
"POST /": async (req: GraphQLRequest, res: ServerResponse) => {
|
|
try {
|
|
const { query, variables, operationName } = req.body;
|
|
const result = await req.$ctx.broker.call("acquisition-graphql.query", {
|
|
query,
|
|
variables,
|
|
operationName,
|
|
});
|
|
res.setHeader("Content-Type", "application/json");
|
|
res.end(JSON.stringify(result));
|
|
} catch (error: unknown) {
|
|
res.statusCode = 500;
|
|
res.setHeader("Content-Type", "application/json");
|
|
res.end(JSON.stringify({ errors: [{ message: (error as GraphQLError).message }] }));
|
|
}
|
|
},
|
|
// eslint-disable-next-line @typescript-eslint/naming-convention
|
|
"GET /": async (req: GraphQLRequest, res: ServerResponse) => {
|
|
try {
|
|
const { query, variables: variablesStr, operationName } = req.$params;
|
|
const variables = variablesStr ? JSON.parse(variablesStr) : undefined;
|
|
const result = await req.$ctx.broker.call("acquisition-graphql.query", {
|
|
query,
|
|
variables,
|
|
operationName,
|
|
});
|
|
res.setHeader("Content-Type", "application/json");
|
|
res.end(JSON.stringify(result));
|
|
} catch (error: unknown) {
|
|
res.statusCode = 500;
|
|
res.setHeader("Content-Type", "application/json");
|
|
res.end(JSON.stringify({ errors: [{ message: (error as GraphQLError).message }] }));
|
|
}
|
|
},
|
|
},
|
|
bodyParsers: { json: { strict: false, limit: "1MB" } },
|
|
mappingPolicy: "restrict",
|
|
logging: true,
|
|
},
|
|
|
|
{
|
|
path: "/logs",
|
|
use: [ApiGateway.serveStatic("logs")],
|
|
},
|
|
],
|
|
log4XXResponses: false,
|
|
logRequestParams: true,
|
|
logResponseData: true,
|
|
assets: {
|
|
folder: "public",
|
|
// Options to `server-static` module
|
|
options: {},
|
|
},
|
|
},
|
|
events: {},
|
|
|
|
methods: {},
|
|
started(): void {},
|
|
});
|
|
}
|
|
}
|