chore(core-manager): await log generation on log.download (#4260)

Author: sebastijankuzner

__tests__/unit/core-manager/server/server-boot-dispose.test.ts

@@ -10,16 +10,23 @@ import { defaults } from "@packages/core-manager/src/defaults";
 
 let sandbox: Sandbox;
 let server: Server;
-let pluginsConfiguration = defaults.plugins;
+const pluginsConfiguration = defaults.plugins;
 
-let logger = {
+const logger = {
     info: jest.fn(),
     notice: jest.fn(),
     error: jest.fn(),
 };
 
 let mockStart = jest.fn();
 let mockStop = jest.fn();
+const mockJsonRPCRoute = {
+    method: "post",
+    path: "/",
+    settings: {
+        timeout: {},
+    },
+};
 
 jest.mock("@hapi/hapi", () => {
     return {
@@ -32,6 +39,7 @@ jest.mock("@hapi/hapi", () => {
                 register: jest.fn(),
                 start: jest.fn().mockImplementation(mockStart),
                 stop: jest.fn().mockImplementation(mockStop),
+                table: jest.fn().mockReturnValue([mockJsonRPCRoute]),
             };
         }),
     };

packages/core-manager/src/actions/log-download.ts

@@ -49,7 +49,7 @@ export class Action implements Actions.Action {
             throw new Error("Previous log generation is still in progress.");
         }
 
-        this.workerManager.generateLog(
+        await this.workerManager.generateLog(
             this.database.getDBFilePath(),
             this.database.getSchema(),
             this.prepareQueryConditions(params),

packages/core-manager/src/server/server.ts

@@ -1,5 +1,5 @@
 import { Container, Contracts, Types } from "@arkecosystem/core-kernel";
-import { Server as HapiServer, ServerInjectOptions, ServerInjectResponse } from "@hapi/hapi";
+import { Server as HapiServer, ServerInjectOptions, ServerInjectResponse, ServerRoute } from "@hapi/hapi";
 import { readFileSync } from "fs";
 
 import { Plugins } from "../contracts";
@@ -26,6 +26,9 @@ export class Server {
         this.server.app.app = this.app;
 
         await this.server.register(this.pluginFactory.preparePlugins());
+
+        // Disable 2 minute socket timout
+        this.getRoute("POST", "/").settings.timeout.socket = false;
     }
 
     public async register(plugins: any | any[]): Promise<void> {
@@ -68,4 +71,8 @@ export class Server {
 
         return options;
     }
+
+    private getRoute(method: string, path: string): ServerRoute | undefined {
+        return this.server.table().find((route) => route.method === method.toLowerCase() && route.path === path);
+    }
 }