Revert "Renderer file logging through IPC" (#7393)

This reverts commit 48db54ec9e.

packages/core/src/common/logger.injectable.ts

@@ -3,13 +3,20 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { getInjectable } from "@ogre-tools/injectable";
+import { createLogger, format } from "winston";
 import type { Logger } from "./logger";
-import winstonLoggerInjectable from "./winston-logger.injectable";
+import { loggerTransportInjectionToken } from "./logger/transports";
 
 const loggerInjectable = getInjectable({
   id: "logger",
   instantiate: (di): Logger => {
-    const baseLogger = di.inject(winstonLoggerInjectable);
+    const baseLogger = createLogger({
+      format: format.combine(
+        format.splat(),
+        format.simple(),
+      ),
+      transports: di.injectMany(loggerTransportInjectionToken),
+    });
 
     return {
       debug: (message, ...data) => baseLogger.debug(message, ...data),

packages/core/src/common/logger/ipc-file-logger-channel.ts

@@ -1,24 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import type { MessageChannel } from "../utils/channel/message-channel-listener-injection-token";
-
-export interface IpcFileLogObject {
-  fileId: string;
-  entry: {
-    level: string;
-    message: string;
-    internalMessage: string;
-  };
-}
-
-export type IpcFileLoggerChannel = MessageChannel<IpcFileLogObject>;
-
-export const ipcFileLoggerChannel: IpcFileLoggerChannel = {
-  id: "ipc-file-logger-channel",
-};
-
-export const closeIpcFileLoggerChannel: MessageChannel<string> = {
-  id: "close-ipc-file-logger-channel",
-};

packages/core/src/common/winston-logger.global-override-for-injectable.ts

@@ -1,23 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-
-import type winston from "winston";
-import { getGlobalOverride } from "@k8slens/test-utils";
-import { noop } from "@k8slens/utilities";
-import winstonLoggerInjectable from "./winston-logger.injectable";
-
-export default getGlobalOverride(winstonLoggerInjectable, () => ({
-  log: noop,
-  add: noop,
-  remove: noop,
-  clear: noop,
-  close: noop,
-
-  warn: noop,
-  debug: noop,
-  error: noop,
-  info: noop,
-  silly: noop,
-}) as winston.Logger);

packages/core/src/common/winston-logger.injectable.ts

@@ -1,18 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import { getInjectable } from "@ogre-tools/injectable";
-import { createLogger, format } from "winston";
-import { loggerTransportInjectionToken } from "./logger/transports";
-
-const winstonLoggerInjectable = getInjectable({
-  id: "winston-logger",
-  instantiate: (di) =>
-    createLogger({
-      format: format.combine(format.splat(), format.simple()),
-      transports: di.injectMany(loggerTransportInjectionToken),
-    }),
-});
-
-export default winstonLoggerInjectable;

packages/core/src/main/logger/close-ipc-logging-listener.injectable.ts

@@ -1,21 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import ipcFileLoggerInjectable from "./ipc-file-logger.injectable";
-import { getMessageChannelListenerInjectable } from "../../common/utils/channel/message-channel-listener-injection-token";
-import {
-  closeIpcFileLoggerChannel,
-} from "../../common/logger/ipc-file-logger-channel";
-
-const closeIpcFileLoggingListenerInjectable = getMessageChannelListenerInjectable({
-  id: "close-ipc-file-logging",
-  channel: closeIpcFileLoggerChannel,
-  handler: (di) => {
-    const ipcFileLogger = di.inject(ipcFileLoggerInjectable);
-
-    return (fileId) => ipcFileLogger.close(fileId);
-  },
-});
-
-export default closeIpcFileLoggingListenerInjectable;

packages/core/src/main/logger/create-ipc-file-transport.global-override-for-injectable.ts

@@ -1,18 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-
-import type { transports } from "winston";
-import { getGlobalOverride } from "@k8slens/test-utils";
-import { noop } from "@k8slens/utilities";
-import createIpcFileLoggerTransportInjectable from "./create-ipc-file-transport.injectable";
-
-export default getGlobalOverride(
-  createIpcFileLoggerTransportInjectable,
-  () => () =>
-    ({
-      log: noop,
-      close: noop,
-    } as typeof transports.File),
-);

packages/core/src/main/logger/create-ipc-file-transport.injectable.ts

@@ -1,28 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import { getInjectable } from "@ogre-tools/injectable";
-import { transports } from "winston";
-import directoryForLogsInjectable from "../../common/app-paths/directory-for-logs.injectable";
-
-const createIpcFileLoggerTransportInjectable = getInjectable({
-  id: "create-ipc-file-logger-transport",
-  instantiate: (di) => {
-    const options = {
-      dirname: di.inject(directoryForLogsInjectable),
-      maxsize: 1024 * 1024,
-      maxFiles: 2,
-      tailable: true,
-    };
-
-    return (fileId: string) =>
-      new transports.File({
-        ...options,
-        filename: `lens-${fileId}.log`,
-      });
-  },
-  causesSideEffects: true,
-});
-
-export default createIpcFileLoggerTransportInjectable;

packages/core/src/main/logger/file-transport.injectable.ts

@@ -7,8 +7,8 @@ import { transports } from "winston";
 import directoryForLogsInjectable from "../../common/app-paths/directory-for-logs.injectable";
 import { loggerTransportInjectionToken } from "../../common/logger/transports";
 
-const fileLoggerTransportInjectable = getInjectable({
+const fileLoggerTranportInjectable = getInjectable({
-  id: "file-logger-transport",
+  id: "file-logger-tranport",
   instantiate: (di) => new transports.File({
     handleExceptions: false,
     level: "debug",
@@ -26,4 +26,4 @@ const fileLoggerTransportInjectable = getInjectable({
   decorable: false,
 });
 
-export default fileLoggerTransportInjectable;
+export default fileLoggerTranportInjectable;

packages/core/src/main/logger/ipc-file-logger.injectable.ts

@@ -1,55 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import { getInjectable } from "@ogre-tools/injectable";
-import { getOrInsertWith } from "@k8slens/utilities";
-import type { LogEntry, transports } from "winston";
-import createIpcFileLoggerTransportInjectable from "./create-ipc-file-transport.injectable";
-
-export interface IpcFileLogger {
-  log: (fileLog: { fileId: string; entry: LogEntry }) => void;
-  close: (fileId: string) => void;
-  closeAll: () => void;
-}
-
-const ipcFileLoggerInjectable = getInjectable({
-  id: "ipc-file-logger",
-  instantiate: (di): IpcFileLogger => {
-    const createIpcFileTransport = di.inject(createIpcFileLoggerTransportInjectable);
-    const fileTransports = new Map<string, transports.FileTransportInstance>();
-
-    function log({ fileId, entry }: { fileId: string; entry: LogEntry }) {
-      const transport = getOrInsertWith(
-        fileTransports,
-        fileId,
-        () => createIpcFileTransport(fileId),
-      );
-
-      transport?.log?.(entry, () => {});
-    }
-
-    function close(fileId: string) {
-      const transport = fileTransports.get(fileId);
-
-      if (transport) {
-        transport.close?.();
-        fileTransports.delete(fileId);
-      }
-    }
-
-    function closeAll() {
-      for (const fileId of fileTransports.keys()) {
-        close(fileId);
-      }
-    }
-
-    return {
-      log,
-      close,
-      closeAll,
-    };
-  },
-});
-
-export default ipcFileLoggerInjectable;

packages/core/src/main/logger/ipc-file-logger.test.ts

@@ -1,160 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import { getDiForUnitTesting } from "../getDiForUnitTesting";
-import createIpcFileLoggerTransportInjectable from "./create-ipc-file-transport.injectable";
-import type { IpcFileLogger } from "./ipc-file-logger.injectable";
-import ipcFileLoggerInjectable from "./ipc-file-logger.injectable";
-
-describe("ipc file logger in main", () => {
-  let logMock: jest.Mock;
-  let closeMock: jest.Mock;
-  let createFileTransportMock: jest.Mock;
-  let logger: IpcFileLogger;
-
-  beforeEach(() => {
-    logMock = jest.fn();
-    closeMock = jest.fn();
-    createFileTransportMock = jest.fn(() => ({
-      log: logMock,
-      close: closeMock,
-    }));
-
-    const di = getDiForUnitTesting();
-
-    di.override(createIpcFileLoggerTransportInjectable, () => createFileTransportMock);
-    logger = di.inject(ipcFileLoggerInjectable);
-  });
-
-  it("creates a transport for new log file", () => {
-    logger.log({
-      fileId: "some-log-file",
-      entry: { level: "irrelevant", message: "irrelevant" },
-    });
-
-    expect(createFileTransportMock).toHaveBeenCalledWith("some-log-file");
-  });
-
-  it("uses existing transport for log file", () => {
-    logger.log({
-      fileId: "some-log-file",
-      entry: { level: "irrelevant", message: "irrelevant" },
-    });
-
-    logger.log({
-      fileId: "some-log-file",
-      entry: { level: "irrelevant", message: "irrelevant" },
-    });
-
-    logger.log({
-      fileId: "some-log-file",
-      entry: { level: "irrelevant", message: "irrelevant" },
-    });
-
-    expect(createFileTransportMock).toHaveBeenCalledTimes(1);
-
-    expect(createFileTransportMock).toHaveBeenCalledWith("some-log-file");
-  });
-
-  it("creates separate transport for each log file", () => {
-    logger.log({
-      fileId: "some-log-file",
-      entry: { level: "irrelevant", message: "irrelevant" },
-    });
-
-    logger.log({
-      fileId: "some-other-log-file",
-      entry: { level: "irrelevant", message: "irrelevant" },
-    });
-
-    logger.log({
-      fileId: "some-yet-another-log-file",
-      entry: { level: "irrelevant", message: "irrelevant" },
-    });
-
-    expect(createFileTransportMock).toHaveBeenCalledTimes(3);
-
-    expect(createFileTransportMock).toHaveBeenCalledWith("some-log-file");
-
-    expect(createFileTransportMock).toHaveBeenCalledWith("some-other-log-file");
-
-    expect(createFileTransportMock).toHaveBeenCalledWith("some-yet-another-log-file");
-  });
-
-  it("logs using file transport", () => {
-    logger.log({
-      fileId: "some-log-file",
-      entry: { level: "irrelevant", message: "some-log-message" },
-    });
-    expect(logMock.mock.calls[0][0]).toEqual({
-      level: "irrelevant",
-      message: "some-log-message",
-    });
-  });
-
-  it("logs to correct files", () => {
-    const someLogMock = jest.fn();
-    const someOthertLogMock = jest.fn();
-
-    createFileTransportMock.mockImplementation((fileId: string) => {
-      if (fileId === "some-log-file") {
-        return { log: someLogMock };
-      }
-
-      if (fileId === "some-other-log-file") {
-        return { log: someOthertLogMock };
-      }
-
-      return null;
-    });
-
-    logger.log({
-      fileId: "some-log-file",
-      entry: { level: "irrelevant", message: "some-log-message" },
-    });
-    logger.log({
-      fileId: "some-other-log-file",
-      entry: { level: "irrelevant", message: "some-other-log-message" },
-    });
-
-    expect(someLogMock).toHaveBeenCalledTimes(1);
-    expect(someLogMock.mock.calls[0][0]).toEqual({
-      level: "irrelevant",
-      message: "some-log-message",
-    });
-    expect(someOthertLogMock).toHaveBeenCalledTimes(1);
-    expect(someOthertLogMock.mock.calls[0][0]).toEqual({
-      level: "irrelevant",
-      message: "some-other-log-message",
-    });
-  });
-
-  it("closes transport (to ensure no file handles are left open)", () => {
-    logger.log({
-      fileId: "some-log-file",
-      entry: { level: "irrelevant", message: "irrelevant" },
-    });
-
-    logger.close("some-log-file");
-
-    expect(closeMock).toHaveBeenCalled();
-  });
-
-  it("creates a new transport once needed after closing previous", () => {
-    logger.log({
-      fileId: "some-log-file",
-      entry: { level: "irrelevant", message: "irrelevant" },
-    });
-
-    logger.close("some-log-file");
-
-    logger.log({
-      fileId: "some-log-file",
-      entry: { level: "irrelevant", message: "irrelevant" },
-    });
-
-    expect(createFileTransportMock).toHaveBeenCalledTimes(2);
-    expect(logMock).toHaveBeenCalledTimes(2);
-  });
-});

packages/core/src/main/logger/ipc-logging-listener.injectable.ts

@@ -1,39 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import ipcFileLoggerInjectable from "./ipc-file-logger.injectable";
-import { getMessageChannelListenerInjectable } from "../../common/utils/channel/message-channel-listener-injection-token";
-import type { IpcFileLogObject } from "../../common/logger/ipc-file-logger-channel";
-import { ipcFileLoggerChannel } from "../../common/logger/ipc-file-logger-channel";
-import { MESSAGE } from "triple-beam";
-
-/**
- * Winston uses symbol property for the actual message.
- *
- * For that to get through IPC, use the internalMessage property instead
- */
-export function deserializeLogFromIpc(ipcFileLogObject: IpcFileLogObject) {
-  const { internalMessage, ...standardEntry } = ipcFileLogObject.entry;
-
-  return {
-    ...ipcFileLogObject,
-    entry: {
-      ...standardEntry,
-      [MESSAGE]: internalMessage,
-    },
-  };
-}
-
-const ipcFileLoggingListenerInjectable = getMessageChannelListenerInjectable({
-  id: "ipc-file-logging",
-  channel: ipcFileLoggerChannel,
-  handler: (di) => {
-    const logger = di.inject(ipcFileLoggerInjectable);
-
-    return (ipcFileLogObject) =>
-      logger.log(deserializeLogFromIpc(ipcFileLogObject));
-  },
-});
-
-export default ipcFileLoggingListenerInjectable;

packages/core/src/main/logger/ipc-logging-listener.test.ts

@@ -1,31 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-
-import { MESSAGE } from "triple-beam";
-import { deserializeLogFromIpc } from "./ipc-logging-listener.injectable";
-
-describe("Ipc log deserialization", () => {
-  it("fills in the unique symbol message property Winston transports use internally", () => {
-    const logObject = {
-      fileId: "irrelevant",
-      entry: {
-        level: "irrelevant",
-        message: "some public message",
-        internalMessage: "some internal message",
-        someProperty: "irrelevant",
-      },
-    };
-
-    expect(deserializeLogFromIpc(logObject)).toEqual({
-      entry: {
-        level: "irrelevant",
-        message: "some public message",
-        [MESSAGE]: "some internal message",
-        someProperty: "irrelevant",
-      },
-      fileId: "irrelevant",
-    });
-  });
-});

packages/core/src/main/logger/stop-ipc-logging.injectable.ts

@@ -1,27 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import { getInjectable } from "@ogre-tools/injectable";
-import { beforeQuitOfFrontEndInjectionToken } from "../start-main-application/runnable-tokens/phases";
-import ipcFileLoggerInjectable from "./ipc-file-logger.injectable";
-
-const stopIpcLoggingInjectable = getInjectable({
-  id: "stop-ipc-logging",
-
-  instantiate: (di) => {
-    const ipcFileLogger = di.inject(ipcFileLoggerInjectable);
-
-    return {
-      run: () => {
-        ipcFileLogger.closeAll();
-
-        return undefined;
-      },
-    };
-  },
-
-  injectionToken: beforeQuitOfFrontEndInjectionToken,
-});
-
-export default stopIpcLoggingInjectable;

packages/core/src/renderer/before-frame-starts/runnables/listen-unload.injectable.ts

@@ -1,46 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import { getInjectable } from "@ogre-tools/injectable";
-import currentlyInClusterFrameInjectable from "../../routes/currently-in-cluster-frame.injectable";
-import { beforeFrameStartsSecondInjectionToken } from "../tokens";
-import loggerInjectable from "../../../common/logger.injectable";
-import hostedClusterInjectable from "../../cluster-frame-context/hosted-cluster.injectable";
-import frameRoutingIdInjectable from "../../frames/cluster-frame/init-cluster-frame/frame-routing-id/frame-routing-id.injectable";
-import closeRendererLogFileInjectable from "../../logger/close-renderer-log-file.injectable";
-import { unmountComponentAtNode } from "react-dom";
-
-const listenUnloadInjectable = getInjectable({
-  id: "listen-unload",
-  instantiate: (di) => ({
-    run: () => {
-      const closeRendererLogFile = di.inject(closeRendererLogFileInjectable);
-      const isClusterFrame = di.inject(currentlyInClusterFrameInjectable);
-      const logger = di.inject(loggerInjectable);
-
-      window.addEventListener("beforeunload", () => {
-        if (isClusterFrame) {
-          const hostedCluster = di.inject(hostedClusterInjectable);
-          const frameRoutingId = di.inject(frameRoutingIdInjectable);
-
-          logger.info(
-            `[CLUSTER-FRAME] Unload dashboard, clusterId=${hostedCluster?.id}, frameId=${frameRoutingId}`,
-          );
-        } else {
-          logger.info("[ROOT-FRAME]: Unload app");
-        }
-
-        closeRendererLogFile();
-        const rootElem = document.getElementById("app");
-
-        if (rootElem) {
-          unmountComponentAtNode(rootElem);
-        }
-      });
-    },
-  }),
-  injectionToken: beforeFrameStartsSecondInjectionToken,
-});
-
-export default listenUnloadInjectable;

packages/core/src/renderer/bootstrap.tsx

@@ -6,7 +6,7 @@
 import "./components/app.scss";
 
 import React from "react";
-import { render } from "react-dom";
+import { render, unmountComponentAtNode } from "react-dom";
 import { DefaultProps } from "./mui-base-theme";
 import { DiContextProvider } from "@ogre-tools/injectable-react";
 import type {
@@ -43,7 +43,7 @@ export async function bootstrap(di: DiContainerForInjection) {
   }
 
   try {
-    await initializeApp();
+    await initializeApp(() => unmountComponentAtNode(rootElem));
   } catch (error) {
     console.error(`[BOOTSTRAP]: view initialization error: ${error}`, {
       origin: location.href,

packages/core/src/renderer/frames/cluster-frame/init-cluster-frame/init-cluster-frame.ts

@@ -22,51 +22,62 @@ interface Dependencies {
 
 const logPrefix = "[CLUSTER-FRAME]:";
 
-export const initClusterFrame =
+export const initClusterFrame = ({
-  ({
+  hostedCluster,
-    hostedCluster,
+  loadExtensions,
-    loadExtensions,
+  catalogEntityRegistry,
-    catalogEntityRegistry,
+  frameRoutingId,
-    frameRoutingId,
+  emitAppEvent,
-    emitAppEvent,
+  logger,
-    logger,
+  showErrorNotification,
-    showErrorNotification,
+}: Dependencies) =>
-  }: Dependencies) =>
+  async (unmountRoot: () => void) => {
-    async () => {
     // TODO: Make catalogEntityRegistry already initialized when passed as dependency
-      catalogEntityRegistry.init();
+    catalogEntityRegistry.init();
 
-      logger.info(
+    logger.info(
-        `${logPrefix} Init dashboard, clusterId=${hostedCluster.id}, frameId=${frameRoutingId}`,
+      `${logPrefix} Init dashboard, clusterId=${hostedCluster.id}, frameId=${frameRoutingId}`,
-      );
+    );
 
-      await requestSetClusterFrameId(hostedCluster.id);
+    await requestSetClusterFrameId(hostedCluster.id);
-      await when(() => hostedCluster.ready.get()); // cluster.activate() is done at this point
+    await when(() => hostedCluster.ready.get()); // cluster.activate() is done at this point
 
-      catalogEntityRegistry.activeEntity = hostedCluster.id;
+    catalogEntityRegistry.activeEntity = hostedCluster.id;
 
-      // Only load the extensions once the catalog has been populated.
+    // Only load the extensions once the catalog has been populated.
-      // Note that the Catalog might still have unprocessed entities until the extensions are fully loaded.
+    // Note that the Catalog might still have unprocessed entities until the extensions are fully loaded.
-      when(
+    when(
-        () => catalogEntityRegistry.items.get().length > 0,
+      () => catalogEntityRegistry.items.get().length > 0,
-        () => loadExtensions(),
+      () =>
-        {
+        loadExtensions(),
-          timeout: 15_000,
+      {
-          onError: (error) => {
+        timeout: 15_000,
-            logger.warn("[CLUSTER-FRAME]: error from activeEntity when()", error);
+        onError: (error) => {
+          logger.warn(
+            "[CLUSTER-FRAME]: error from activeEntity when()",
+            error,
+          );
 
-            showErrorNotification("Failed to get KubernetesCluster for this view. Extensions will not be loaded.");
+          showErrorNotification("Failed to get KubernetesCluster for this view. Extensions will not be loaded.");
-          },
         },
+      },
+    );
+
+    setTimeout(() => {
+      emitAppEvent({
+        name: "cluster",
+        action: "open",
+        params: {
+          clusterId: hostedCluster.id,
+        },
+      });
+    });
+
+    window.onbeforeunload = () => {
+      logger.info(
+        `${logPrefix} Unload dashboard, clusterId=${(hostedCluster.id)}, frameId=${frameRoutingId}`,
       );
 
-      setTimeout(() => {
+      unmountRoot();
-        emitAppEvent({
-          name: "cluster",
-          action: "open",
-          params: {
-            clusterId: hostedCluster.id,
-          },
-        });
-      });
     };
+  };

packages/core/src/renderer/frames/root-frame/init-root-frame.injectable.ts

@@ -9,6 +9,7 @@ import lensProtocolRouterRendererInjectable from "../../protocol-handler/lens-pr
 import catalogEntityRegistryInjectable from "../../api/catalog/entity/registry.injectable";
 import registerIpcListenersInjectable from "../../ipc/register-ipc-listeners.injectable";
 import loadExtensionsInjectable from "../load-extensions.injectable";
+import loggerInjectable from "../../../common/logger.injectable";
 import { delay } from "@k8slens/utilities";
 import { broadcastMessage } from "../../../common/ipc";
 import { bundledExtensionsLoaded } from "../../../common/ipc/extension-handling";
@@ -22,8 +23,9 @@ const initRootFrameInjectable = getInjectable({
     const bindProtocolAddRouteHandlers = di.inject(bindProtocolAddRouteHandlersInjectable);
     const lensProtocolRouterRenderer = di.inject(lensProtocolRouterRendererInjectable);
     const catalogEntityRegistry = di.inject(catalogEntityRegistryInjectable);
+    const logger = di.inject(loggerInjectable);
 
-    return async () => {
+    return async (unmountRoot: () => void) => {
       catalogEntityRegistry.init();
 
       try {
@@ -54,6 +56,12 @@ const initRootFrameInjectable = getInjectable({
       window.addEventListener("online", () => broadcastMessage("network:online"));
 
       registerIpcListeners();
+
+      window.addEventListener("beforeunload", () => {
+        logger.info("[ROOT-FRAME]: Unload app");
+
+        unmountRoot();
+      });
     };
   },
 });

packages/core/src/renderer/logger/close-renderer-log-file-id.test.ts

@@ -1,56 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import winstonLoggerInjectable from "../../common/winston-logger.injectable";
-import { getDiForUnitTesting } from "../getDiForUnitTesting";
-import closeRendererLogFileInjectable from "./close-renderer-log-file.injectable";
-import type { DiContainer } from "@ogre-tools/injectable";
-import type winston from "winston";
-import type { SendMessageToChannel } from "../../common/utils/channel/message-to-channel-injection-token";
-import { sendMessageToChannelInjectionToken } from "../../common/utils/channel/message-to-channel-injection-token";
-import rendererLogFileIdInjectable from "./renderer-log-file-id.injectable";
-import ipcLogTransportInjectable from "./ipc-transport.injectable";
-import type IpcLogTransport from "./ipc-transport";
-
-describe("close renderer file logging", () => {
-  let di: DiContainer;
-  let sendIpcMock: SendMessageToChannel;
-  let winstonMock: winston.Logger;
-  let ipcTransportMock: IpcLogTransport;
-
-  beforeEach(() => {
-    di = getDiForUnitTesting();
-    sendIpcMock = jest.fn();
-    winstonMock = {
-      remove: jest.fn(),
-    } as any as winston.Logger;
-    ipcTransportMock = { name: "ipc-renderer-transport" } as IpcLogTransport;
-
-    di.override(winstonLoggerInjectable, () => winstonMock);
-    di.override(sendMessageToChannelInjectionToken, () => sendIpcMock);
-    di.override(rendererLogFileIdInjectable, () => "some-log-id");
-    di.override(ipcLogTransportInjectable, () => ipcTransportMock);
-  });
-
-  it("sends the ipc close message with correct log id", () => {
-    const closeLog = di.inject(closeRendererLogFileInjectable);
-
-    closeLog();
-
-    expect(sendIpcMock).toHaveBeenCalledWith(
-      { id: "close-ipc-file-logger-channel" },
-      "some-log-id",
-    );
-  });
-
-  it("removes the transport to prevent further logging to closed file", () => {
-    const closeLog = di.inject(closeRendererLogFileInjectable);
-
-    closeLog();
-
-    expect(winstonMock.remove).toHaveBeenCalledWith({
-      name: "ipc-renderer-transport",
-    });
-  });
-});

packages/core/src/renderer/logger/close-renderer-log-file.injectable.ts

@@ -1,28 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import { getInjectable } from "@ogre-tools/injectable";
-import winstonLoggerInjectable from "../../common/winston-logger.injectable";
-import { closeIpcFileLoggerChannel } from "../../common/logger/ipc-file-logger-channel";
-import { sendMessageToChannelInjectionToken } from "../../common/utils/channel/message-to-channel-injection-token";
-import rendererLogFileIdInjectable from "./renderer-log-file-id.injectable";
-import ipcLogTransportInjectable from "./ipc-transport.injectable";
-
-const closeRendererLogFileInjectable = getInjectable({
-  id: "close-renderer-log-file",
-  instantiate: (di) => {
-    const winstonLogger = di.inject(winstonLoggerInjectable);
-    const ipcLogTransport = di.inject(ipcLogTransportInjectable);
-    const messageToChannel = di.inject(sendMessageToChannelInjectionToken);
-    const fileId = di.inject(rendererLogFileIdInjectable);
-
-
-    return () => {
-      messageToChannel(closeIpcFileLoggerChannel, fileId);
-      winstonLogger.remove(ipcLogTransport);
-    };
-  },
-});
-
-export default closeRendererLogFileInjectable;

packages/core/src/renderer/logger/ipc-transport.injectable.ts

@@ -1,60 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import { getInjectable } from "@ogre-tools/injectable";
-import { loggerTransportInjectionToken } from "../../common/logger/transports";
-import type winston from "winston";
-import { MESSAGE } from "triple-beam";
-
-import IpcLogTransport from "./ipc-transport";
-import { sendMessageToChannelInjectionToken } from "../../common/utils/channel/message-to-channel-injection-token";
-import type {
-  IpcFileLogObject } from "../../common/logger/ipc-file-logger-channel";
-import {
-  closeIpcFileLoggerChannel,
-  ipcFileLoggerChannel,
-} from "../../common/logger/ipc-file-logger-channel";
-import rendererLogFileIdInjectable from "./renderer-log-file-id.injectable";
-
-/**
- * Winston uses symbol property for the actual message.
- *
- * For that to get through IPC, use the internalMessage property instead
- */
-function serializeLogForIpc(
-  fileId: string,
-  entry: winston.LogEntry,
-): IpcFileLogObject {
-  return {
-    fileId,
-    entry: {
-      level: entry.level,
-      message: entry.message,
-      internalMessage: Object.getOwnPropertyDescriptor(entry, MESSAGE)?.value,
-    },
-  };
-}
-
-const ipcLogTransportInjectable = getInjectable({
-  id: "renderer-file-logger-transport",
-  instantiate: (di) => {
-    const messageToChannel = di.inject(sendMessageToChannelInjectionToken);
-    const fileId = di.inject(rendererLogFileIdInjectable);
-
-    return new IpcLogTransport({
-      sendIpcLogMessage: (entry) =>
-        messageToChannel(
-          ipcFileLoggerChannel,
-          serializeLogForIpc(fileId, entry),
-        ),
-      closeIpcLogging: () =>
-        messageToChannel(closeIpcFileLoggerChannel, fileId),
-      handleExceptions: false,
-      level: "info",
-    });
-  },
-  injectionToken: loggerTransportInjectionToken,
-});
-
-export default ipcLogTransportInjectable;

packages/core/src/renderer/logger/ipc-transport.test.ts

@@ -1,48 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import type { DiContainer } from "@ogre-tools/injectable";
-import type { SendMessageToChannel } from "../../common/utils/channel/message-to-channel-injection-token";
-import { sendMessageToChannelInjectionToken } from "../../common/utils/channel/message-to-channel-injection-token";
-import { getDiForUnitTesting } from "../getDiForUnitTesting";
-import rendererLogFileIdInjectable from "./renderer-log-file-id.injectable";
-import ipcLogTransportInjectable from "./ipc-transport.injectable";
-import { MESSAGE } from "triple-beam";
-
-describe("renderer log transport through ipc", () => {
-  let di: DiContainer;
-  let sendIpcMock: SendMessageToChannel;
-
-  beforeEach(() => {
-    sendIpcMock = jest.fn();
-    di = getDiForUnitTesting();
-    di.override(sendMessageToChannelInjectionToken, () => sendIpcMock);
-    di.override(rendererLogFileIdInjectable, () => "some-log-id");
-  });
-
-  it("send serialized ipc messages on log", () => {
-    const logTransport = di.inject(ipcLogTransportInjectable);
-
-    logTransport.log(
-      {
-        level: "info",
-        message: "some log text",
-        [MESSAGE]: "actual winston log text",
-      },
-      () => {},
-    );
-
-    expect(sendIpcMock).toHaveBeenCalledWith(
-      { id: "ipc-file-logger-channel" },
-      {
-        entry: {
-          level: "info",
-          message: "some log text",
-          internalMessage: "actual winston log text",
-        },
-        fileId: "some-log-id",
-      },
-    );
-  });
-});

packages/core/src/renderer/logger/ipc-transport.ts

@@ -1,41 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import type { LogEntry } from "winston";
-import type { TransportStreamOptions } from "winston-transport";
-import TransportStream from "winston-transport";
-
-interface IpcLogTransportOptions extends TransportStreamOptions {
-  sendIpcLogMessage: (entry: LogEntry) => void;
-  closeIpcLogging: () => void;
-}
-
-class IpcLogTransport extends TransportStream {
-  sendIpcLogMessage: (entry: LogEntry) => void;
-  closeIpcLogging: () => void;
-  name = "ipc-renderer-transport";
-
-  constructor(options: IpcLogTransportOptions) {
-    const { sendIpcLogMessage, closeIpcLogging, ...winstonOptions } = options;
-
-    super(winstonOptions);
-
-    this.sendIpcLogMessage = sendIpcLogMessage;
-    this.closeIpcLogging = closeIpcLogging;
-  }
-
-  log(logEntry: LogEntry, next: () => void) {
-    setImmediate(() => {
-      this.emit("logged", logEntry);
-    });
-    this.sendIpcLogMessage(logEntry);
-    next();
-  }
-
-  close() {
-    this.closeIpcLogging();
-  }
-}
-
-export default IpcLogTransport;

packages/core/src/renderer/logger/renderer-log-file-id.injectable.ts

@@ -1,29 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import { getInjectable } from "@ogre-tools/injectable";
-import windowLocationInjectable from "../../common/k8s-api/window-location.injectable";
-import currentlyInClusterFrameInjectable from "../routes/currently-in-cluster-frame.injectable";
-import { getClusterIdFromHost } from "../../common/utils";
-
-const rendererLogFileIdInjectable = getInjectable({
-  id: "renderer-log-file-id",
-  instantiate: (di) => {
-    let frameId: string;
-    const currentlyInClusterFrame = di.inject(currentlyInClusterFrameInjectable);
-
-    if (currentlyInClusterFrame) {
-      const { host } = di.inject(windowLocationInjectable);
-      const clusterId = getClusterIdFromHost(host);
-
-      frameId = `cluster-${clusterId}`;
-    } else {
-      frameId = "main";
-    }
-
-    return `renderer-${frameId}`;
-  },
-});
-
-export default rendererLogFileIdInjectable;

packages/core/src/renderer/logger/renderer-log-file-id.test.ts

@@ -1,34 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import windowLocationInjectable from "../../common/k8s-api/window-location.injectable";
-import { getDiForUnitTesting } from "../getDiForUnitTesting";
-import currentlyInClusterFrameInjectable from "../routes/currently-in-cluster-frame.injectable";
-import rendererLogFileIdInjectable from "./renderer-log-file-id.injectable";
-
-describe("renderer log file id", () => {
-
-  it("clearly names log for renderer main frame", () => {
-    const di = getDiForUnitTesting();
-
-    di.override(currentlyInClusterFrameInjectable, () => false);
-
-    const mainFileId = di.inject(rendererLogFileIdInjectable);
-
-    expect(mainFileId).toBe("renderer-main");
-  });
-
-  it("includes cluster id in renderer log file names", () => {
-    const di = getDiForUnitTesting();
-
-    di.override(currentlyInClusterFrameInjectable, () => true);
-    di.override(windowLocationInjectable, () => ({
-      host: "some-cluster.lens.app",
-      port: "irrelevant",
-    }));
-    const clusterFileId = di.inject(rendererLogFileIdInjectable);
-
-    expect(clusterFileId).toBe("renderer-cluster-some-cluster");
-  });
-});