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