add integration tests

Author: icebob

package-lock.json

@@ -7,6 +7,7 @@
     "dev": "nodemon examples/index.js",
     "ci": "jest --watch",
     "test": "jest --coverage",
+    "ci:integration": "jest \"**/integration/**spec.js\" --watch",
     "lint": "eslint --ext=.js src test",
     "lint:fix": "eslint --fix --ext=.js src test",
     "deps": "npm-check -u",
@@ -45,6 +46,7 @@
     "moleculer": "^0.14.0-beta5",
     "moleculer-repl": "^0.6.1",
     "moleculer-web": "^0.9.0-beta6",
+    "node-fetch": "^2.6.0",
     "nodemon": "^1.19.4",
     "npm-check": "^5.9.0",
     "prettier": "^1.18.2"

package.json

@@ -0,0 +1,185 @@
+const { ServiceBroker } = require("moleculer");
+const { MoleculerClientError } = require("moleculer").Errors;
+
+const ApiGateway = require("moleculer-web");
+const { ApolloService } = require("../../index");
+
+const fetch = require("node-fetch");
+
+describe("Integration test for greeter service", () => {
+	const broker = new ServiceBroker({ logger: false });
+
+	let port;
+	const apiSvc = broker.createService({
+		name: "api",
+
+		mixins: [
+			// Gateway
+			ApiGateway,
+
+			// GraphQL Apollo Server
+			ApolloService({
+				// API Gateway route options
+				routeOptions: {
+					path: "/graphql",
+					cors: true,
+					mappingPolicy: "restrict",
+				},
+
+				// https://www.apollographql.com/docs/apollo-server/v2/api/apollo-server.html
+				serverOptions: {},
+			}),
+		],
+
+		settings: {
+			port: 0, // Random
+		},
+	});
+
+	broker.createService({
+		name: "greeter",
+
+		actions: {
+			hello: {
+				graphql: {
+					query: "hello: String!",
+				},
+				handler() {
+					return "Hello Moleculer!";
+				},
+			},
+			welcome: {
+				graphql: {
+					query: `
+						welcome(name: String!): String!
+					`,
+				},
+				handler(ctx) {
+					return `Hello ${ctx.params.name}`;
+				},
+			},
+			/*update: {
+				graphql: {
+					subscription: "update: String!",
+					tags: ["TEST"],
+				},
+				handler(ctx) {
+					return ctx.params.payload;
+				},
+			},*/
+
+			danger: {
+				graphql: {
+					query: "danger: String!",
+				},
+				async handler() {
+					throw new MoleculerClientError(
+						"I've said it's a danger action!",
+						422,
+						"DANGER"
+					);
+				},
+			},
+		},
+	});
+
+	beforeAll(async () => {
+		await broker.start();
+		port = apiSvc.server.address().port;
+	});
+	afterAll(() => broker.stop());
+
+	it("should call the greeter.hello action", async () => {
+		const res = await fetch(`http://localhost:${port}/graphql`, {
+			method: "post",
+			body: JSON.stringify({
+				operationName: null,
+				variables: {},
+				query: "{ hello }",
+			}),
+			headers: { "Content-Type": "application/json" },
+		});
+
+		expect(res.status).toBe(200);
+		expect(await res.json()).toStrictEqual({
+			data: {
+				hello: "Hello Moleculer!",
+			},
+		});
+	});
+
+	it("should call the greeter.welcome action with parameter", async () => {
+		const res = await fetch(`http://localhost:${port}/graphql`, {
+			method: "post",
+			body: JSON.stringify({
+				operationName: null,
+				variables: {},
+				query: 'query { welcome(name: "GraphQL") }',
+			}),
+			headers: { "Content-Type": "application/json" },
+		});
+
+		expect(res.status).toBe(200);
+		expect(await res.json()).toStrictEqual({
+			data: {
+				welcome: "Hello GraphQL",
+			},
+		});
+	});
+
+	it("should call the greeter.welcome action with query variable", async () => {
+		const res = await fetch(`http://localhost:${port}/graphql`, {
+			method: "post",
+			body: JSON.stringify({
+				operationName: null,
+				variables: { name: "Moleculer GraphQL" },
+				query: "query ($name: String!) { welcome(name: $name) }",
+			}),
+			headers: { "Content-Type": "application/json" },
+		});
+
+		expect(res.status).toBe(200);
+		expect(await res.json()).toStrictEqual({
+			data: {
+				welcome: "Hello Moleculer GraphQL",
+			},
+		});
+	});
+
+	it("should call the greeter.danger and receives an error", async () => {
+		const res = await fetch(`http://localhost:${port}/graphql`, {
+			method: "post",
+			body: JSON.stringify({
+				operationName: null,
+				variables: {},
+				query: "query { danger }",
+			}),
+			headers: { "Content-Type": "application/json" },
+		});
+
+		expect(res.status).toBe(200);
+		expect(await res.json()).toStrictEqual({
+			data: null,
+			errors: [
+				{
+					extensions: {
+						code: "INTERNAL_SERVER_ERROR",
+						exception: {
+							code: 422,
+							retryable: false,
+							type: "DANGER",
+						},
+					},
+					locations: [
+						{
+							column: 9,
+							line: 1,
+						},
+					],
+					message: "I've said it's a danger action!",
+					path: ["danger"],
+				},
+			],
+		});
+	});
+});