Merge pull request #123 from shawnmcknight/fix-unhandled-promises

Await graphql handler to avoid unhandled promise rejections
moleculerjs · Feb 6, 2024 · f25fe16 · f25fe16
2 parents cef1659 + 26fabda
commit f25fe16
Show file tree

Hide file tree

Showing 2 changed files with 59 additions and 11 deletions.
diff --git a/src/service.js b/src/service.js
@@ -770,14 +770,15 @@ module.exports = function (mixinOptions) {
 					async "/"(req, res) {
 						try {
 							await this.prepareGraphQLSchema();
-							return this.graphqlHandler(req, res);
+							return await this.graphqlHandler(req, res);
 						} catch (err) {
 							this.sendError(req, res, err);
 						}
 					},
 					async "GET /.well-known/apollo/server-health"(req, res) {
 						try {
 							await this.prepareGraphQLSchema();
+							return await this.graphqlHandler(req, res);
 						} catch (err) {
 							res.statusCode = 503;
 							return this.sendResponse(
@@ -787,7 +788,6 @@ module.exports = function (mixinOptions) {
 								{ responseType: "application/health+json" }
 							);
 						}
-						return this.graphqlHandler(req, res);
 					},
 				},
 

diff --git a/test/unit/service.spec.js b/test/unit/service.spec.js
@@ -77,7 +77,7 @@ describe("Test Service", () => {
 				await stop();
 			});
 
-			it("should call sendError if error occured", async () => {
+			it("should call sendError if error occurs when preparing graphql schema", async () => {
 				const { svc, stop } = await startService();
 
 				const err = new Error("Something happened");
@@ -99,6 +99,29 @@ describe("Test Service", () => {
 
 				await stop();
 			});
+
+			it("should call sendError if error occurs when handling graphql request", async () => {
+				const { svc, stop } = await startService();
+
+				const err = new Error("Something happened");
+				svc.sendError = jest.fn();
+				svc.prepareGraphQLSchema = jest.fn();
+				svc.graphqlHandler = jest.fn(() => {
+					throw err;
+				});
+				const fakeReq = { req: 1 };
+				const fakeRes = { res: 1 };
+
+				const res = await svc.settings.routes[0].aliases["/"].call(svc, fakeReq, fakeRes);
+
+				expect(res).toBeUndefined();
+				expect(svc.prepareGraphQLSchema).toBeCalledTimes(1);
+				expect(svc.graphqlHandler).toBeCalledTimes(1);
+				expect(svc.sendError).toBeCalledTimes(1);
+				expect(svc.sendError).toBeCalledWith(fakeReq, fakeRes, err);
+
+				await stop();
+			});
 		});
 
 		describe("Test `GET /.well-known/apollo/server-health` route handler", () => {
@@ -123,7 +146,7 @@ describe("Test Service", () => {
 				await stop();
 			});
 
-			it("should call sendError if error occured", async () => {
+			it("should call sendError if error occurs when preparing graphql schema", async () => {
 				const { svc, stop } = await startService();
 
 				const err = new Error("Something happened");
@@ -146,13 +169,38 @@ describe("Test Service", () => {
 				expect(svc.sendResponse).toBeCalledWith(
 					fakeReq,
 					fakeRes,
-					{
-						status: "fail",
-						schema: false,
-					},
-					{
-						responseType: "application/health+json",
-					}
+					{ status: "fail", schema: false },
+					{ responseType: "application/health+json" }
+				);
+
+				await stop();
+			});
+
+			it("should call sendError if error occurs when handling graphql request", async () => {
+				const { svc, stop } = await startService();
+
+				const err = new Error("Something happened");
+				svc.sendResponse = jest.fn();
+				svc.prepareGraphQLSchema = jest.fn();
+				svc.graphqlHandler = jest.fn(() => {
+					throw err;
+				});
+				const fakeReq = { req: 1 };
+				const fakeRes = { res: 1 };
+
+				const res = await svc.settings.routes[0].aliases[
+					"GET /.well-known/apollo/server-health"
+				].call(svc, fakeReq, fakeRes);
+
+				expect(res).toBeUndefined();
+				expect(svc.prepareGraphQLSchema).toBeCalledTimes(1);
+				expect(svc.graphqlHandler).toBeCalledTimes(1);
+				expect(svc.sendResponse).toBeCalledTimes(1);
+				expect(svc.sendResponse).toBeCalledWith(
+					fakeReq,
+					fakeRes,
+					{ status: "fail", schema: false },
+					{ responseType: "application/health+json" }
 				);
 
 				await stop();