Fix failures on the pipelines due to memory issues

packages/testkit-backend/deno/controller.ts

@@ -64,12 +64,14 @@ export function createHandler(
   ) {
     const context = newContext();
     const wire = newWire(context, (response) => {
-      console.log("response:", response);
+      console.log("response:", response.name);
+      console.debug(response.data);
       return reply(response);
     });
 
     for await (const request of requests()) {
-      console.log("request:", request);
+      console.log("request:", request.name);
+      console.debug(request.data);
       const { data, name } = request;
       if (!(name in requestHandlers)) {
         console.log("Unknown request: " + name);

packages/testkit-backend/deno/deps.ts

@@ -6,3 +6,4 @@ export { default as neo4j } from "../../neo4j-driver-deno/lib/mod.ts";
 export { createGetFeatures } from "../src/feature/index.js";
 export * as handlers from "../src/request-handlers.js";
 export { default as CypherNativeBinders } from "../src/cypher-native-binders.js";
+export { default as configurableConsole } from "../src/console.configurable.js";

packages/testkit-backend/deno/index.ts

@@ -1,4 +1,5 @@
 import {
+  configurableConsole,
   Context,
   createGetFeatures,
   CypherNativeBinders,
@@ -29,6 +30,7 @@ const logLevel = Deno.env.get("TEST_LOG_LEVEL");
 const createContext = () =>
   new Context(shouldRunTest, getFeatures, binder, logLevel);
 
+configurableConsole.install(logLevel);
 const listener = channel.listen(9876);
 const handle = controller.createHandler(neo4j, createContext, requestHandlers);
 

packages/testkit-backend/src/channel/testkit-protocol.js

@@ -62,14 +62,16 @@ export default class Protocol extends EventEmitter {
 
   serializeResponse (response) {
     const responseStr = stringify(response)
-    console.log('> writing response', responseStr)
+    console.log('> writing response', response.name)
+    console.debug(responseStr)
     return ['#response begin', responseStr, '#response end'].join('\n') + '\n'
   }
 
   _emitRequest () {
     const request = JSON.parse(this._request)
     const { name, data } = request
-    console.log('> Got request ' + name, data)
+    console.log('> Got request ' + name)
+    console.debug(data)
     this.emit('request', { name, data })
   }
 }

packages/testkit-backend/src/console.configurable.js

@@ -0,0 +1,42 @@
+const originalConsole = console
+
+const config = {
+  level: 'info',
+  canRun: (method) => {
+    if (config.level === 'debug') {
+      return true
+    } else if (config.level === 'info') {
+      return method !== 'debug'
+    } else if (config.level === 'warn') {
+      return method !== 'debug' &&
+               method !== 'log'
+    } else if (config.level === 'error') {
+      return method !== 'debug' &&
+                method !== 'log' &&
+                method !== 'warn'
+    }
+    return true
+  }
+}
+
+export default {
+  install (level = 'info') {
+    this.setLevel(level)
+    // eslint-disable-next-line no-global-assign
+    console = new Proxy({}, {
+      get: (_, method) => (...args) => {
+        if (config.canRun(method)) {
+          originalConsole[method].apply(originalConsole, args)
+        }
+      }
+    })
+  },
+  setLevel (level) {
+    config.level = (level || 'info').toLowerCase()
+  },
+  uninstall () {
+    config.level = 'info'
+    // eslint-disable-next-line no-global-assign
+    console = originalConsole
+  }
+}

packages/testkit-backend/src/index.js

@@ -8,6 +8,7 @@ import { createGetFeatures } from './feature'
 import * as REQUEST_HANDLERS from './request-handlers.js'
 import * as RX_REQUEST_HANDLERS from './request-handlers-rx.js'
 import remoteConsole from './console.remote.js'
+import configurableConsole from './console.configurable.js'
 
 const SUPPORTED_TLS = (() => {
   if (tls.DEFAULT_MAX_VERSION) {
@@ -39,6 +40,8 @@ function main () {
   const shouldRunTest = getShouldRunTest([...driverDescriptorList, sessionTypeDescriptor])
   const getFeatures = createGetFeatures([sessionTypeDescriptor], SUPPORTED_TLS)
 
+  configurableConsole.install(process.env.TEST_LOG_LEVEL || 'info')
+
   const newChannel = () => {
     if (channelType.toUpperCase() === 'WEBSOCKET') {
       const channel = new WebSocketChannel(new URL(`ws://localhost:${backendPort}`))

packages/testkit-backend/src/request-handlers.js

@@ -1,4 +1,5 @@
 import * as responses from './responses.js'
+import configurableConsole from './console.configurable.js'
 
 export function throwFrontendError () {
   throw new Error('TestKit FrontendError')
@@ -376,6 +377,9 @@ export function StartTest (_, context, { testName }, wire) {
   } else {
     context.logLevel = null
   }
+
+  configurableConsole.setLevel(context.logLevel || context.environmentLogLevel)
+
   const shouldRunTest = context.getShouldRunTestFunction()
   shouldRunTest(testName, {
     onRun: () => {