Switch to using messaging and startable stoppable from NPM package (#7368)

* Add custom jest resolver to fix requiring "uuid" module

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Update dependencies

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Introduce test utils for rendering and running with thrown mobx reactions

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Extract startable-stoppable to NPM package

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Extract messaging to NPM package

Co-authored-by: Mikko Aspiala <mikko.aspiala@gmail.com>

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Switch to using startable-stoppable from NPM package

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Switch to using messaging from the Feature

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Remove old implementation of messaging

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Make setupping app paths happen earlier in renderer

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Fix typo

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Add kludge to make testing-library work properly from test-utils package

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Fix code style

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Add lint:fix -root script

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Fix unrelated failing unit tests

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Turn of no-floating-promises from typescript linting for being broken

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Make linting not happen for dist -directories

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Make linting failures appear as failure

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Stop running prettier twice

It already gets ran as eslint-plugin.

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Make CI run unit tests for all packages by consolidating name of NPM script

Co-authored-by: Mikko Aspiala <mikko.aspiala@gmail.com>

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Add missing unit tests for coverage

Co-authored-by: Mikko Aspiala <mikko.aspiala@gmail.com>

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Skip coverage for test utils

Co-authored-by: Mikko Aspiala <mikko.aspiala@gmail.com>

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Remove check for coverage in packages which are not ready for it

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Stop collecting coverage from index.ts files them being indirections to the implementation

Co-authored-by: Mikko Aspiala <mikko.aspiala@gmail.com>

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Implement sending message to channel in main

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Add missing feature dependencies

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Add dummy implementations for requesting in main from renderer

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Re-enable communicating from main to cluster frames

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Ignore trivial files from coverage

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Update package-lock

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Extract message-bridge to separate NPM package to prevent dev dependencies being in the production bundle

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Extract computed channel to own NPM package for clear dependencies

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Consolidate electron related stuff to a directory

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Add missing publish configurations

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

* Ignore test implementation from coverage being not interesting

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

---------

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

package.json

@@ -19,6 +19,7 @@
     "clean:node_modules": "lerna clean -y && rimraf node_modules",
     "dev": "lerna run dev --stream --skip-nx-cache",
     "lint": "lerna run lint --stream",
+    "lint:fix": "lerna run lint:fix --stream",
     "mkdocs:serve-local": "docker build -t mkdocs-serve-local:latest mkdocs/ && docker run --rm -it -p 8000:8000 -v ${PWD}:/docs mkdocs-serve-local:latest",
     "mkdocs:verify": "docker build -t mkdocs-serve-local:latest mkdocs/ && docker run --rm -v ${PWD}:/docs mkdocs-serve-local:latest build --strict",
     "test:unit": "lerna run --stream test:unit",

packages/core/package.json

@@ -189,6 +189,7 @@
   },
   "devDependencies": {
     "@async-fn/jest": "1.6.4",
+    "@k8slens/messaging-fake-bridge": "^1.0.0-alpha.1",
     "@material-ui/core": "^4.12.3",
     "@material-ui/icons": "^4.11.2",
     "@material-ui/lab": "^4.0.0-alpha.60",
@@ -322,7 +323,11 @@
     "@k8slens/application": "^6.5.0-alpha.0",
     "@k8slens/application-for-electron-main": "^6.5.0-alpha.0",
     "@k8slens/legacy-extensions": "^1.0.0-alpha.0",
+    "@k8slens/messaging": "^1.0.0-alpha.1",
+    "@k8slens/messaging-for-main": "^1.0.0-alpha.1",
+    "@k8slens/messaging-for-renderer": "^1.0.0-alpha.1",
     "@k8slens/run-many": "^1.0.0-alpha.1",
+    "@k8slens/startable-stoppable": "^1.0.0-alpha.1",
     "@k8slens/test-utils": "^1.0.0-alpha.1",
     "@k8slens/utilities": "^1.0.0-alpha.1",
     "@types/byline": "^4.2.33",

packages/core/src/common/app-paths/app-paths-channel.ts

@@ -3,11 +3,7 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import type { AppPaths } from "./app-path-injection-token";
-import type { RequestChannel } from "../utils/channel/request-channel-listener-injection-token";
+import { getRequestChannel } from "@k8slens/messaging";
 
-export type AppPathsChannel = RequestChannel<void, AppPaths>;
+export const appPathsChannel = getRequestChannel<void, AppPaths>("app-paths");
-
-export const appPathsChannel: AppPathsChannel = {
-  id: "app-paths",
-};
 

packages/core/src/common/base-store/base-store.ts

@@ -15,7 +15,7 @@ import type { GetConfigurationFileModel } from "../get-configuration-file-model/
 import type { Logger } from "../logger";
 import type { PersistStateToConfig } from "./save-to-file";
 import type { GetBasenameOfPath } from "../path/get-basename.injectable";
-import type { EnlistMessageChannelListener } from "../utils/channel/enlist-message-channel-listener-injection-token";
+import type { EnlistMessageChannelListener } from "@k8slens/messaging";
 import { toJS } from "../utils";
 
 export interface BaseStoreParams<T> extends Omit<ConfOptions<T>, "migrations"> {
@@ -108,6 +108,7 @@ export abstract class BaseStore<T extends object> {
           this.params.syncOptions,
         ),
         this.dependencies.enlistMessageChannelListener({
+          id: this.displayName,
           channel: {
             id: `${this.dependencies.ipcChannelPrefixes.local}:${config.path}`,
           },

packages/core/src/common/certificate/lens-proxy-certificate-channel.ts

@@ -4,6 +4,6 @@
  */
 
 import type { SelfSignedCert } from "selfsigned";
-import { getRequestChannel } from "../utils/channel/get-request-channel";
+import { getRequestChannel } from "@k8slens/messaging";
 
 export const lensProxyCertificateChannel = getRequestChannel<void, SelfSignedCert>("request-lens-proxy-certificate");

packages/core/src/common/cluster-store/cluster-store.injectable.ts

@@ -16,7 +16,7 @@ import { baseStoreIpcChannelPrefixesInjectionToken } from "../base-store/channel
 import { shouldBaseStoreDisableSyncInIpcListenerInjectionToken } from "../base-store/disable-sync";
 import { persistStateToConfigInjectionToken } from "../base-store/save-to-file";
 import getBasenameOfPathInjectable from "../path/get-basename.injectable";
-import { enlistMessageChannelListenerInjectionToken } from "../utils/channel/enlist-message-channel-listener-injection-token";
+import { enlistMessageChannelListenerInjectionToken } from "@k8slens/messaging";
 
 const clusterStoreInjectable = getInjectable({
   id: "cluster-store",

packages/core/src/common/cluster/current-cluster-channel.ts

@@ -4,7 +4,7 @@
  */
 
 import type { ClusterId } from "../cluster-types";
-import type { MessageChannel } from "../utils/channel/message-channel-listener-injection-token";
+import type { MessageChannel } from "@k8slens/messaging";
 
 export const currentClusterMessageChannel: MessageChannel<ClusterId> = {
   id: "current-visible-cluster",

packages/core/src/common/cluster/visibility-channel.ts

@@ -4,7 +4,7 @@
  */
 
 import type { ClusterId } from "../cluster-types";
-import type { MessageChannel } from "../utils/channel/message-channel-listener-injection-token";
+import type { MessageChannel } from "@k8slens/messaging";
 
 export const clusterVisibilityChannel: MessageChannel<ClusterId | null> = {
   id: "cluster-visibility",

packages/core/src/common/front-end-routing/app-navigation-channel.ts

@@ -3,7 +3,7 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { IpcRendererNavigationEvents } from "../ipc/navigation-events";
-import type { MessageChannel } from "../utils/channel/message-channel-listener-injection-token";
+import type { MessageChannel } from "@k8slens/messaging";
 
 export type AppNavigationChannel = MessageChannel<string>;
 

packages/core/src/common/front-end-routing/cluster-frame-navigation-channel.ts

@@ -3,7 +3,7 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { IpcRendererNavigationEvents } from "../ipc/navigation-events";
-import type { MessageChannel } from "../utils/channel/message-channel-listener-injection-token";
+import type { MessageChannel } from "@k8slens/messaging";
 
 export type ClusterFrameNavigationChannel = MessageChannel<string>;
 

packages/core/src/common/helm/add-helm-repository-channel.ts

@@ -3,11 +3,10 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import type { HelmRepo } from "./helm-repo";
-import type { AsyncResult } from "@k8slens/utilities";
+import type { Result } from "@k8slens/utilities";
-import type { RequestChannel } from "../utils/channel/request-channel-listener-injection-token";
+import { getRequestChannel } from "@k8slens/messaging";
 
-export type AddHelmRepositoryChannel = RequestChannel<HelmRepo, AsyncResult<void, string>>;
+export const addHelmRepositoryChannel = getRequestChannel<
-
+  HelmRepo,
-export const addHelmRepositoryChannel: AddHelmRepositoryChannel = {
+  Result<void, string>
-  id: "add-helm-repository-channel",
+>("add-helm-repository-channel");
-};

packages/core/src/common/helm/get-active-helm-repositories-channel.ts

@@ -4,10 +4,9 @@
  */
 import type { HelmRepo } from "./helm-repo";
 import type { AsyncResult } from "@k8slens/utilities";
-import type { RequestChannel } from "../utils/channel/request-channel-listener-injection-token";
+import { getRequestChannel } from "@k8slens/messaging";
 
-export type GetActiveHelmRepositoriesChannel = RequestChannel<void, AsyncResult<HelmRepo[]>>;
+export const getActiveHelmRepositoriesChannel = getRequestChannel<
-
+  void,
-export const getActiveHelmRepositoriesChannel: GetActiveHelmRepositoriesChannel = {
+  AsyncResult<HelmRepo[]>
-  id: "get-helm-active-list-repositories",
+>("get-helm-active-list-repositories");
-};

packages/core/src/common/helm/remove-helm-repository-channel.ts

@@ -3,11 +3,10 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import type { AsyncResult } from "@k8slens/utilities";
-import type { RequestChannel } from "../utils/channel/request-channel-listener-injection-token";
+import { getRequestChannel } from "@k8slens/messaging";
 import type { HelmRepo } from "./helm-repo";
 
-export type RemoveHelmRepositoryChannel = RequestChannel<HelmRepo, AsyncResult<void, string>>;
+export const removeHelmRepositoryChannel = getRequestChannel<
-
+  HelmRepo,
-export const removeHelmRepositoryChannel: RemoveHelmRepositoryChannel = {
+  AsyncResult<void, string>
-  id: "remove-helm-repository-channel",
+>("remove-helm-repository-channel");
-};

packages/core/src/common/hotbars/store.injectable.ts

@@ -14,7 +14,7 @@ import { hotbarStoreMigrationInjectionToken } from "./migrations-token";
 import getBasenameOfPathInjectable from "../path/get-basename.injectable";
 import { baseStoreIpcChannelPrefixesInjectionToken } from "../base-store/channel-prefix";
 import { persistStateToConfigInjectionToken } from "../base-store/save-to-file";
-import { enlistMessageChannelListenerInjectionToken } from "../utils/channel/enlist-message-channel-listener-injection-token";
+import { enlistMessageChannelListenerInjectionToken } from "@k8slens/messaging";
 import { shouldBaseStoreDisableSyncInIpcListenerInjectionToken } from "../base-store/disable-sync";
 
 const hotbarStoreInjectable = getInjectable({

packages/core/src/common/kube-helpers/channels.ts

@@ -4,11 +4,9 @@
  */
 
 import { getInjectionToken } from "@ogre-tools/injectable";
-import type { Asyncify } from "type-fest";
-import type { RequestChannelHandler } from "../../main/utils/channel/channel-listeners/listener-tokens";
 import type { ClusterId } from "../cluster-types";
-import type { AsyncResult } from "@k8slens/utilities";
+import type { AsyncResult, Result } from "@k8slens/utilities";
-import type { RequestChannel } from "../utils/channel/request-channel-listener-injection-token";
+import { getRequestChannel } from "@k8slens/messaging";
 
 export interface KubectlApplyAllArgs {
   clusterId: ClusterId;
@@ -16,11 +14,12 @@ export interface KubectlApplyAllArgs {
   extraArgs: string[];
 }
 
-export const kubectlApplyAllChannel: RequestChannel<KubectlApplyAllArgs, AsyncResult<string, string>> = {
+export const kubectlApplyAllChannel = getRequestChannel<
-  id: "kubectl-apply-all",
+  KubectlApplyAllArgs,
-};
+  Result<string, string>
+>("kubectl-apply-all");
 
-export type KubectlApplyAll = Asyncify<RequestChannelHandler<typeof kubectlApplyAllChannel>>;
+export type KubectlApplyAll = (req: KubectlApplyAllArgs) => AsyncResult<string, string>;
 
 export const kubectlApplyAllInjectionToken = getInjectionToken<KubectlApplyAll>({
   id: "kubectl-apply-all",
@@ -32,11 +31,12 @@ export interface KubectlDeleteAllArgs {
   extraArgs: string[];
 }
 
-export const kubectlDeleteAllChannel: RequestChannel<KubectlDeleteAllArgs, AsyncResult<string, string>> = {
+export const kubectlDeleteAllChannel = getRequestChannel<
-  id: "kubectl-delete-all",
+  KubectlDeleteAllArgs,
-};
+  Result<string, string>
+>("kubectl-delete-all");
 
-export type KubectlDeleteAll = Asyncify<RequestChannelHandler<typeof kubectlDeleteAllChannel>>;
+export type KubectlDeleteAll = (req: KubectlDeleteAllArgs) => AsyncResult<string, string>;
 
 export const kubectlDeleteAllInjectionToken = getInjectionToken<KubectlDeleteAll>({
   id: "kubectl-delete-all",

packages/core/src/common/root-frame/root-frame-rendered-channel.ts

@@ -2,7 +2,7 @@
  * 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";
+import type { MessageChannel } from "@k8slens/messaging";
 
 export type RootFrameHasRenderedChannel = MessageChannel<void>;
 

packages/core/src/common/user-store/user-store.injectable.ts

@@ -16,7 +16,7 @@ import { baseStoreIpcChannelPrefixesInjectionToken } from "../base-store/channel
 import { shouldBaseStoreDisableSyncInIpcListenerInjectionToken } from "../base-store/disable-sync";
 import { persistStateToConfigInjectionToken } from "../base-store/save-to-file";
 import getBasenameOfPathInjectable from "../path/get-basename.injectable";
-import { enlistMessageChannelListenerInjectionToken } from "../utils/channel/enlist-message-channel-listener-injection-token";
+import { enlistMessageChannelListenerInjectionToken } from "@k8slens/messaging";
 import userStorePreferenceDescriptorsInjectable from "./preference-descriptors.injectable";
 
 const userStoreInjectable = getInjectable({

packages/core/src/common/utils/channel/channel.test.ts

@@ -1,245 +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 { getInjectable } from "@ogre-tools/injectable";
-import type { SendMessageToChannel } from "./message-to-channel-injection-token";
-import { sendMessageToChannelInjectionToken } from "./message-to-channel-injection-token";
-import type { ApplicationBuilder } from "../../../renderer/components/test-utils/get-application-builder";
-import { getApplicationBuilder } from "../../../renderer/components/test-utils/get-application-builder";
-import type { LensWindow } from "../../../main/start-main-application/lens-window/application-window/create-lens-window.injectable";
-import type { MessageChannel } from "./message-channel-listener-injection-token";
-import { messageChannelListenerInjectionToken } from "./message-channel-listener-injection-token";
-import type { RequestFromChannel } from "./request-from-channel-injection-token";
-import { requestFromChannelInjectionToken } from "./request-from-channel-injection-token";
-import type { RequestChannel } from "./request-channel-listener-injection-token";
-import type { AsyncFnMock } from "@async-fn/jest";
-import asyncFn from "@async-fn/jest";
-import { getPromiseStatus } from "@k8slens/test-utils";
-import { runInAction } from "mobx";
-import type { RequestChannelHandler } from "../../../main/utils/channel/channel-listeners/listener-tokens";
-import {
-  getRequestChannelListenerInjectable,
-  requestChannelListenerInjectionToken,
-} from "../../../main/utils/channel/channel-listeners/listener-tokens";
-
-type TestMessageChannel = MessageChannel<string>;
-type TestRequestChannel = RequestChannel<string, string>;
-
-describe("channel", () => {
-  describe("messaging from main to renderer, given listener for channel in a window and application has started", () => {
-    let messageListenerInWindowMock: jest.Mock;
-    let mainDi: DiContainer;
-    let messageToChannel: SendMessageToChannel;
-    let builder: ApplicationBuilder;
-
-    beforeEach(async () => {
-      builder = getApplicationBuilder();
-
-      messageListenerInWindowMock = jest.fn();
-
-      const testChannelListenerInTestWindowInjectable = getInjectable({
-        id: "test-channel-listener-in-test-window",
-
-        instantiate: () => ({
-          channel: testMessageChannel,
-          handler: messageListenerInWindowMock,
-        }),
-
-        injectionToken: messageChannelListenerInjectionToken,
-      });
-
-      builder.beforeWindowStart(({ windowDi }) => {
-        runInAction(() => {
-          windowDi.register(testChannelListenerInTestWindowInjectable);
-        });
-      });
-
-      mainDi = builder.mainDi;
-
-      await builder.startHidden();
-
-      messageToChannel = mainDi.inject(sendMessageToChannelInjectionToken);
-    });
-
-    describe("given window is started", () => {
-      let someWindowFake: LensWindow;
-
-      beforeEach(async () => {
-        someWindowFake = builder.applicationWindow.create("some-window");
-
-        await someWindowFake.start();
-      });
-
-      it("when sending message, triggers listener in window", () => {
-        messageToChannel(testMessageChannel, "some-message");
-
-        expect(messageListenerInWindowMock).toHaveBeenCalledWith("some-message");
-      });
-
-      it("given window is hidden, when sending message, does not trigger listener in window", () => {
-        someWindowFake.close();
-
-        messageToChannel(testMessageChannel, "some-message");
-
-        expect(messageListenerInWindowMock).not.toHaveBeenCalled();
-      });
-    });
-
-    it("given multiple started windows, when sending message, triggers listeners in all windows", async () => {
-      const someWindowFake = builder.applicationWindow.create("some-window");
-      const someOtherWindowFake = builder.applicationWindow.create("some-other-window");
-
-      await someWindowFake.start();
-      await someOtherWindowFake.start();
-
-      messageToChannel(testMessageChannel, "some-message");
-
-      expect(messageListenerInWindowMock.mock.calls).toEqual([
-        ["some-message"],
-        ["some-message"],
-      ]);
-    });
-  });
-
-  describe("messaging from renderer to main, given listener for channel in a main and application has started", () => {
-    let messageListenerInMainMock: jest.Mock;
-    let messageToChannel: SendMessageToChannel;
-
-    beforeEach(async () => {
-      const applicationBuilder = getApplicationBuilder();
-
-      messageListenerInMainMock = jest.fn();
-
-      const testChannelListenerInMainInjectable = getInjectable({
-        id: "test-channel-listener-in-main",
-
-        instantiate: () => ({
-          channel: testMessageChannel,
-          handler: messageListenerInMainMock,
-        }),
-
-        injectionToken: messageChannelListenerInjectionToken,
-      });
-
-      applicationBuilder.beforeApplicationStart(({ mainDi }) => {
-        runInAction(() => {
-          mainDi.register(testChannelListenerInMainInjectable);
-        });
-      });
-
-      await applicationBuilder.render();
-
-      const windowDi = applicationBuilder.applicationWindow.only.di;
-
-      messageToChannel = windowDi.inject(sendMessageToChannelInjectionToken);
-    });
-
-    it("when sending message, triggers listener in main", () => {
-      messageToChannel(testMessageChannel, "some-message");
-
-      expect(messageListenerInMainMock).toHaveBeenCalledWith("some-message");
-    });
-  });
-
-  describe("requesting from main in renderer, given listener for channel in a main and application has started", () => {
-    let requestListenerInMainMock: AsyncFnMock<RequestChannelHandler<TestRequestChannel>>;
-    let requestFromChannel: RequestFromChannel;
-
-    beforeEach(async () => {
-      const applicationBuilder = getApplicationBuilder();
-
-      requestListenerInMainMock = asyncFn();
-
-      const testChannelListenerInMainInjectable = getRequestChannelListenerInjectable({
-        channel: testRequestChannel,
-        handler: () => requestListenerInMainMock,
-      });
-
-      applicationBuilder.beforeApplicationStart(({ mainDi }) => {
-        runInAction(() => {
-          mainDi.register(testChannelListenerInMainInjectable);
-        });
-      });
-
-      await applicationBuilder.render();
-
-      const windowDi = applicationBuilder.applicationWindow.only.di;
-
-      requestFromChannel = windowDi.inject(
-        requestFromChannelInjectionToken,
-      );
-    });
-
-    describe("when requesting from channel", () => {
-      let actualPromise: Promise<string>;
-
-      beforeEach(() => {
-        actualPromise = requestFromChannel(testRequestChannel, "some-request");
-      });
-
-      it("triggers listener in main", () => {
-        expect(requestListenerInMainMock).toHaveBeenCalledWith("some-request");
-      });
-
-      it("does not resolve yet", async () => {
-        const promiseStatus = await getPromiseStatus(actualPromise);
-
-        expect(promiseStatus.fulfilled).toBe(false);
-      });
-
-      it("when main resolves with response, resolves with response", async () => {
-        await requestListenerInMainMock.resolve("some-response");
-
-        const actual = await actualPromise;
-
-        expect(actual).toBe("some-response");
-      });
-    });
-  });
-
-  it("when registering multiple handlers for the same channel, throws", async () => {
-    const applicationBuilder = getApplicationBuilder();
-
-    const someChannelListenerInjectable = getInjectable({
-      id: "some-channel-listener",
-
-      instantiate: () => ({
-        channel: testRequestChannel,
-        handler: () => () => "irrelevant",
-      }),
-
-      injectionToken: requestChannelListenerInjectionToken,
-    });
-
-    const someOtherChannelListenerInjectable = getInjectable({
-      id: "some-other-channel-listener",
-
-      instantiate: () => ({
-        channel: testRequestChannel,
-        handler: () => () => "irrelevant",
-      }),
-
-      injectionToken: requestChannelListenerInjectionToken,
-    });
-
-    applicationBuilder.beforeApplicationStart(({ mainDi }) => {
-      runInAction(() => {
-        mainDi.register(someChannelListenerInjectable);
-        mainDi.register(someOtherChannelListenerInjectable);
-      });
-    });
-
-    await expect(applicationBuilder.render()).rejects.toThrow('Tried to register a multiple channel handlers for "some-request-channel-id", only one handler is supported for a request channel.');
-  });
-});
-
-const testMessageChannel: TestMessageChannel = {
-  id: "some-message-channel-id",
-};
-
-const testRequestChannel: TestRequestChannel = {
-  id: "some-request-channel-id",
-};
-

packages/core/src/common/utils/channel/enlist-message-channel-listener-injection-token.ts

@@ -1,13 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import { getInjectionToken } from "@ogre-tools/injectable";
-import type { Disposer } from "@k8slens/utilities";
-import type { MessageChannel, MessageChannelListener } from "./message-channel-listener-injection-token";
-
-export type EnlistMessageChannelListener = (listener: MessageChannelListener<MessageChannel<unknown>>) => Disposer;
-
-export const enlistMessageChannelListenerInjectionToken = getInjectionToken<EnlistMessageChannelListener>({
-  id: "enlist-message-channel-listener",
-});

packages/core/src/common/utils/channel/get-request-channel.ts

@@ -1,9 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import type { RequestChannel } from "./request-channel-listener-injection-token";
-
-export const getRequestChannel = <Request, Response>(id: string): RequestChannel<Request, Response> => ({
-  id,
-});

packages/core/src/common/utils/channel/listening-on-message-channels.injectable.ts

@@ -1,25 +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 { getStartableStoppable } from "../get-startable-stoppable";
-import { messageChannelListenerInjectionToken } from "./message-channel-listener-injection-token";
-import { enlistMessageChannelListenerInjectionToken } from "./enlist-message-channel-listener-injection-token";
-import { disposer } from "@k8slens/utilities";
-
-const listeningOnMessageChannelsInjectable = getInjectable({
-  id: "listening-on-message-channels",
-
-  instantiate: (di) => {
-    const enlistMessageChannelListener = di.inject(enlistMessageChannelListenerInjectionToken);
-    const messageChannelListeners = di.injectMany(messageChannelListenerInjectionToken);
-
-    return getStartableStoppable("listening-on-channels", () => (
-      disposer(messageChannelListeners.map(enlistMessageChannelListener))
-    ));
-  },
-});
-
-
-export default listeningOnMessageChannelsInjectable;

packages/core/src/common/utils/channel/message-channel-listener-injection-token.ts

@@ -1,51 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-import type { DiContainerForInjection } from "@ogre-tools/injectable";
-import { getInjectable, getInjectionToken } from "@ogre-tools/injectable";
-
-export interface MessageChannel<Message> {
-  id: string;
-  _messageSignature?: Message; // only used to mark `Message` as used
-}
-
-export type MessageChannelHandler<Channel> = Channel extends MessageChannel<infer Message>
-  ? (message: Message) => void
-  : never;
-
-export interface MessageChannelListener<Channel> {
-  channel: Channel;
-  handler: MessageChannelHandler<Channel>;
-}
-
-export const messageChannelListenerInjectionToken = getInjectionToken<MessageChannelListener<MessageChannel<unknown>>>(
-  {
-    id: "message-channel-listener",
-  },
-);
-
-export interface GetMessageChannelListenerInfo<
-  Channel extends MessageChannel<Message>,
-  Message,
-> {
-  id: string;
-  channel: Channel;
-  handler: (di: DiContainerForInjection) => MessageChannelHandler<Channel>;
-  causesSideEffects?: boolean;
-}
-
-export function getMessageChannelListenerInjectable<
-  Channel extends MessageChannel<Message>,
-  Message,
->(info: GetMessageChannelListenerInfo<Channel, Message>) {
-  return getInjectable({
-    id: `${info.channel.id}-listener-${info.id}`,
-    instantiate: (di) => ({
-      channel: info.channel,
-      handler: info.handler(di),
-    }),
-    injectionToken: messageChannelListenerInjectionToken,
-    causesSideEffects: info.causesSideEffects,
-  });
-}

packages/core/src/common/utils/channel/request-channel-listener-injection-token.ts

@@ -1,10 +0,0 @@
-/**
- * Copyright (c) OpenLens Authors. All rights reserved.
- * Licensed under MIT License. See LICENSE in root directory for more information.
- */
-
-export interface RequestChannel<Request, Response> {
-  id: string;
-  _requestSignature?: Request; // used only to mark `Request` as "used"
-  _responseSignature?: Response; // used only to mark `Response` as "used"
-}

packages/core/src/common/utils/resolve-system-proxy/resolve-system-proxy-channel.ts

@@ -2,10 +2,8 @@
  * Copyright (c) OpenLens Authors. All rights reserved.
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
-import type { RequestChannel } from "../channel/request-channel-listener-injection-token";
+import { getRequestChannel } from "@k8slens/messaging";
 
-export type ResolveSystemProxyChannel = RequestChannel<string, string>;
+export const resolveSystemProxyChannel = getRequestChannel<string, string>(
-
+  "resolve-system-proxy-channel",
-export const resolveSystemProxyChannel: ResolveSystemProxyChannel = {
+);
-  id: "resolve-system-proxy-channel",
-};

packages/core/src/common/utils/sync-box/channel-listener.injectable.ts

@@ -3,13 +3,13 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { syncBoxChannel } from "./channels";
-import { getMessageChannelListenerInjectable } from "../channel/message-channel-listener-injection-token";
+import { getMessageChannelListenerInjectable } from "@k8slens/messaging";
 import syncBoxStateInjectable from "./sync-box-state.injectable";
 
 const syncBoxChannelListenerInjectable = getMessageChannelListenerInjectable({
   id: "init",
   channel: syncBoxChannel,
-  handler: (di) => ({ id, value }) => di.inject(syncBoxStateInjectable, id).set(value),
+  getHandler: (di) => ({ id, value }) => di.inject(syncBoxStateInjectable, id).set(value),
 });
 
 export default syncBoxChannelListenerInjectable;

packages/core/src/common/utils/sync-box/channels.ts

@@ -2,20 +2,12 @@
  * Copyright (c) OpenLens Authors. All rights reserved.
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
-import type { MessageChannel } from "../channel/message-channel-listener-injection-token";
+import { getMessageChannel, getRequestChannel } from "@k8slens/messaging";
-import type { RequestChannel } from "../channel/request-channel-listener-injection-token";
 
-export type SyncBoxChannel = MessageChannel<{ id: string; value: any }>;
+export const syncBoxChannel =
+  getMessageChannel<{ id: string; value: any }>("sync-box-channel");
 
-export const syncBoxChannel: SyncBoxChannel = {
+export const syncBoxInitialValueChannel = getRequestChannel<
-  id: "sync-box-channel",
-};
-
-export type SyncBoxInitialValueChannel = RequestChannel<
   void,
   { id: string; value: any }[]
->;
+>("sync-box-initial-value-channel");
-
-export const syncBoxInitialValueChannel: SyncBoxInitialValueChannel = {
-  id: "sync-box-initial-value-channel",
-};

packages/core/src/common/utils/sync-box/create-sync-box.injectable.ts

@@ -6,7 +6,7 @@ import { getInjectable } from "@ogre-tools/injectable";
 import type { IObservableValue } from "mobx";
 import { computed } from "mobx";
 import { syncBoxChannel } from "./channels";
-import { sendMessageToChannelInjectionToken } from "../channel/message-to-channel-injection-token";
+import { sendMessageToChannelInjectionToken } from "@k8slens/messaging";
 import syncBoxStateInjectable from "./sync-box-state.injectable";
 import type { SyncBox } from "./sync-box-injection-token";
 import { toJS } from "../toJS";

packages/core/src/common/utils/sync-box/handler.injectable.ts

@@ -1,19 +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 type { MessageChannelHandler } from "../channel/message-channel-listener-injection-token";
-import type { SyncBoxChannel } from "./channels";
-import syncBoxStateInjectable from "./sync-box-state.injectable";
-
-const syncBoxChannelHandlerInjectable = getInjectable({
-  id: "sync-box-channel-handler",
-  instantiate: (di): MessageChannelHandler<SyncBoxChannel> => {
-    const getSyncBoxState = (id: string) => di.inject(syncBoxStateInjectable, id);
-
-    return ({ id, value }) => getSyncBoxState(id)?.set(value);
-  },
-});
-
-export default syncBoxChannelHandlerInjectable;

packages/core/src/common/vars/build-semantic-version.injectable.ts

@@ -7,7 +7,7 @@ import { getInjectionToken } from "@ogre-tools/injectable";
 import { SemVer } from "semver";
 import type { InitializableState } from "../initializable-state/create";
 import { createInitializableState } from "../initializable-state/create";
-import type { RequestChannel } from "../utils/channel/request-channel-listener-injection-token";
+import type { RequestChannel } from "@k8slens/messaging";
 
 export const buildVersionInjectionToken = getInjectionToken<InitializableState<string>>({
   id: "build-version-token",

packages/core/src/common/weblinks-store/weblink-store.injectable.ts

@@ -11,7 +11,7 @@ import { persistStateToConfigInjectionToken } from "../base-store/save-to-file";
 import getConfigurationFileModelInjectable from "../get-configuration-file-model/get-configuration-file-model.injectable";
 import loggerInjectable from "../logger.injectable";
 import getBasenameOfPathInjectable from "../path/get-basename.injectable";
-import { enlistMessageChannelListenerInjectionToken } from "../utils/channel/enlist-message-channel-listener-injection-token";
+import { enlistMessageChannelListenerInjectionToken } from "@k8slens/messaging";
 import storeMigrationVersionInjectable from "../vars/store-migration-version.injectable";
 import { weblinkStoreMigrationInjectionToken } from "./migration-token";
 import { WeblinkStore } from "./weblink-store";

packages/core/src/extensions/extension-loader/file-system-provisioner-store/file-system-provisioner-store.injectable.ts

@@ -12,7 +12,7 @@ import { baseStoreIpcChannelPrefixesInjectionToken } from "../../../common/base-
 import { shouldBaseStoreDisableSyncInIpcListenerInjectionToken } from "../../../common/base-store/disable-sync";
 import { persistStateToConfigInjectionToken } from "../../../common/base-store/save-to-file";
 import getBasenameOfPathInjectable from "../../../common/path/get-basename.injectable";
-import { enlistMessageChannelListenerInjectionToken } from "../../../common/utils/channel/enlist-message-channel-listener-injection-token";
+import { enlistMessageChannelListenerInjectionToken } from "@k8slens/messaging";
 import ensureHashedDirectoryForExtensionInjectable from "./ensure-hashed-directory-for-extension.injectable";
 import { registeredExtensionsInjectable } from "./registered-extensions.injectable";
 

packages/core/src/extensions/extension-store.ts

@@ -20,7 +20,7 @@ import { baseStoreIpcChannelPrefixesInjectionToken } from "../common/base-store/
 import { shouldBaseStoreDisableSyncInIpcListenerInjectionToken } from "../common/base-store/disable-sync";
 import { persistStateToConfigInjectionToken } from "../common/base-store/save-to-file";
 import getBasenameOfPathInjectable from "../common/path/get-basename.injectable";
-import { enlistMessageChannelListenerInjectionToken } from "../common/utils/channel/enlist-message-channel-listener-injection-token";
+import { enlistMessageChannelListenerInjectionToken } from "@k8slens/messaging";
 
 export interface ExtensionStoreParams<T extends object> extends BaseStoreParams<T> {
   migrations?: Migrations<T>;

packages/core/src/extensions/extensions-store/extensions-store.injectable.ts

@@ -10,7 +10,7 @@ import { persistStateToConfigInjectionToken } from "../../common/base-store/save
 import getConfigurationFileModelInjectable from "../../common/get-configuration-file-model/get-configuration-file-model.injectable";
 import loggerInjectable from "../../common/logger.injectable";
 import getBasenameOfPathInjectable from "../../common/path/get-basename.injectable";
-import { enlistMessageChannelListenerInjectionToken } from "../../common/utils/channel/enlist-message-channel-listener-injection-token";
+import { enlistMessageChannelListenerInjectionToken } from "@k8slens/messaging";
 import storeMigrationVersionInjectable from "../../common/vars/store-migration-version.injectable";
 import { ExtensionsStore } from "./extensions-store";
 

packages/core/src/features/application-menu/main/application-menu-reactivity.injectable.ts

@@ -4,7 +4,7 @@
  */
 import { getInjectable } from "@ogre-tools/injectable";
 import { autorun } from "mobx";
-import { getStartableStoppable } from "../../../common/utils/get-startable-stoppable";
+import { getStartableStoppable } from "@k8slens/startable-stoppable";
 import populateApplicationMenuInjectable from "./populate-application-menu.injectable";
 import applicationMenuItemCompositeInjectable from "./application-menu-item-composite.injectable";
 

packages/core/src/features/application-update/child-features/periodical-checking-of-updates/main/periodical-check-for-updates.injectable.ts

@@ -3,7 +3,7 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { getInjectable } from "@ogre-tools/injectable";
-import { getStartableStoppable } from "../../../../../common/utils/get-startable-stoppable";
+import { getStartableStoppable } from "@k8slens/startable-stoppable";
 import processCheckingForUpdatesInjectable from "../../../main/process-checking-for-updates.injectable";
 import withOrphanPromiseInjectable from "../../../../../common/utils/with-orphan-promise/with-orphan-promise.injectable";
 

packages/core/src/features/application-update/common/restart-and-install-update-channel.ts

@@ -2,7 +2,7 @@
  * Copyright (c) OpenLens Authors. All rights reserved.
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
-import type { MessageChannel } from "../../../common/utils/channel/message-channel-listener-injection-token";
+import type { MessageChannel } from "@k8slens/messaging";
 
 export type RestartAndInstallUpdateChannel = MessageChannel<void>;
 

packages/core/src/features/application-update/main/restart-and-install-update/restart-and-install-update-listener.injectable.ts

@@ -3,13 +3,13 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { restartAndInstallUpdateChannel } from "../../common/restart-and-install-update-channel";
-import { getMessageChannelListenerInjectable } from "../../../../common/utils/channel/message-channel-listener-injection-token";
+import { getMessageChannelListenerInjectable } from "@k8slens/messaging";
 import quitAndInstallUpdateInjectable from "../quit-and-install-update.injectable";
 
 const restartAndInstallUpdateListenerInjectable = getMessageChannelListenerInjectable({
   id: "restart",
   channel: restartAndInstallUpdateChannel,
-  handler: (di) => di.inject(quitAndInstallUpdateInjectable),
+  getHandler: (di) => di.inject(quitAndInstallUpdateInjectable),
 });
 
 export default restartAndInstallUpdateListenerInjectable;

packages/core/src/features/application-update/main/watch-if-update-should-happen-on-quit/watch-if-update-should-happen-on-quit.injectable.ts

@@ -4,7 +4,7 @@
  */
 import { getInjectable } from "@ogre-tools/injectable";
 import { autorun } from "mobx";
-import { getStartableStoppable } from "../../../../common/utils/get-startable-stoppable";
+import { getStartableStoppable } from "@k8slens/startable-stoppable";
 import setUpdateOnQuitInjectable from "../../../../main/electron-app/features/set-update-on-quit.injectable";
 import selectedUpdateChannelInjectable from "../../common/selected-update-channel/selected-update-channel.injectable";
 import type { ReleaseChannel, UpdateChannel } from "../../common/update-channels";

packages/core/src/features/application-update/renderer/restart-and-install-update.injectable.ts

@@ -4,13 +4,13 @@
  */
 import { getInjectable } from "@ogre-tools/injectable";
 import { restartAndInstallUpdateChannel } from "../common/restart-and-install-update-channel";
-import messageToChannelInjectable from "../../../renderer/utils/channel/message-to-channel.injectable";
+import { sendMessageToChannelInjectionToken } from "@k8slens/messaging";
 
 const restartAndInstallUpdateInjectable = getInjectable({
   id: "restart-and-install-update",
 
   instantiate: (di) => {
-    const messageToChannel = di.inject(messageToChannelInjectable);
+    const messageToChannel = di.inject(sendMessageToChannelInjectionToken);
 
     return () => {
       messageToChannel(restartAndInstallUpdateChannel);

packages/core/src/features/certificate-authorities/common/channel.ts

@@ -2,7 +2,6 @@
  * Copyright (c) OpenLens Authors. All rights reserved.
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
-
+import { getRequestChannel } from "@k8slens/messaging";
-import { getRequestChannel } from "../../../common/utils/channel/get-request-channel";
 
 export const casChannel = getRequestChannel<void, string[]>("certificate-authorities");

packages/core/src/features/certificate-authorities/main/channel-handler.global-override-for-injectable.ts

@@ -8,6 +8,7 @@ import { casChannel } from "../common/channel";
 import certificateAuthoritiesChannelListenerInjectable from "./channel-handler.injectable";
 
 export default getGlobalOverride(certificateAuthoritiesChannelListenerInjectable, () => ({
+  id: "certificate-authorities-channel-listener",
   channel: casChannel,
   handler: () => [],
 }));

packages/core/src/features/certificate-authorities/main/channel-handler.injectable.ts

@@ -2,14 +2,15 @@
  * Copyright (c) OpenLens Authors. All rights reserved.
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
-import { getRequestChannelListenerInjectable } from "../../../main/utils/channel/channel-listeners/listener-tokens";
+import { getRequestChannelListenerInjectable } from "@k8slens/messaging";
 import { casChannel } from "../common/channel";
 import { globalAgent } from "https";
 import { isString } from "@k8slens/utilities";
 
 const certificateAuthoritiesChannelListenerInjectable = getRequestChannelListenerInjectable({
+  id: "certificate-authorities-channel-listener",
   channel: casChannel,
-  handler: () => () => {
+  getHandler: () => () => {
     if (Array.isArray(globalAgent.options.ca)) {
       return globalAgent.options.ca.filter(isString);
     }

packages/core/src/features/certificate-authorities/renderer/request-system-cas.injectable.ts

@@ -3,7 +3,7 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { getInjectable } from "@ogre-tools/injectable";
-import { requestFromChannelInjectionToken } from "../../../common/utils/channel/request-from-channel-injection-token";
+import { requestFromChannelInjectionToken } from "@k8slens/messaging";
 import { casChannel } from "../common/channel";
 import { requestSystemCAsInjectionToken } from "../common/request-system-cas-token";
 

packages/core/src/features/cluster/activation/common/channels.ts

@@ -4,7 +4,7 @@
  */
 
 import type { ClusterId } from "../../../../common/cluster-types";
-import { getRequestChannel } from "../../../../common/utils/channel/get-request-channel";
+import { getRequestChannel } from "@k8slens/messaging";
 
 export interface ActivateCluster {
   clusterId: ClusterId;

packages/core/src/features/cluster/activation/common/request-token.ts

@@ -4,7 +4,7 @@
  */
 
 import { getInjectionToken } from "@ogre-tools/injectable";
-import type { ChannelRequester } from "../../../../common/utils/channel/request-from-channel-injection-token";
+import type { ChannelRequester } from "@k8slens/messaging";
 import type { activateClusterChannel, deactivateClusterChannel } from "./channels";
 
 export type RequestClusterActivation = ChannelRequester<typeof activateClusterChannel>;

packages/core/src/features/cluster/activation/main/activate-listener.injectable.ts

@@ -2,13 +2,14 @@
  * Copyright (c) OpenLens Authors. All rights reserved.
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
-import { getRequestChannelListenerInjectable } from "../../../../main/utils/channel/channel-listeners/listener-tokens";
+import { getRequestChannelListenerInjectable } from "@k8slens/messaging";
 import { activateClusterChannel } from "../common/channels";
 import requestClusterActivationInjectable from "./request-activation.injectable";
 
 const activateClusterRequestChannelListenerInjectable = getRequestChannelListenerInjectable({
+  id: "activate-cluster-request-channel-listener",
   channel: activateClusterChannel,
-  handler: (di) => di.inject(requestClusterActivationInjectable),
+  getHandler: (di) => di.inject(requestClusterActivationInjectable),
 });
 
 export default activateClusterRequestChannelListenerInjectable;

packages/core/src/features/cluster/activation/main/deactivate-listener.injectable.ts

@@ -2,13 +2,14 @@
  * Copyright (c) OpenLens Authors. All rights reserved.
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
-import { getRequestChannelListenerInjectable } from "../../../../main/utils/channel/channel-listeners/listener-tokens";
+import { getRequestChannelListenerInjectable } from "@k8slens/messaging";
 import { deactivateClusterChannel } from "../common/channels";
 import requestClusterDeactivationInjectable from "./request-deactivation.injectable";
 
 const clusterDeactivationRequestChannelListenerInjectable = getRequestChannelListenerInjectable({
+  id: "cluster-deactivation-request-channel-listener",
   channel: deactivateClusterChannel,
-  handler: (di) => di.inject(requestClusterDeactivationInjectable),
+  getHandler: (di) => di.inject(requestClusterDeactivationInjectable),
 });
 
 export default clusterDeactivationRequestChannelListenerInjectable;

packages/core/src/features/cluster/activation/renderer/request-activation.injectable.ts

@@ -3,14 +3,14 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { getInjectable } from "@ogre-tools/injectable";
-import requestFromChannelInjectable from "../../../../renderer/utils/channel/request-from-channel.injectable";
+import { requestFromChannelInjectionToken } from "@k8slens/messaging";
 import { activateClusterChannel } from "../common/channels";
 import { requestClusterActivationInjectionToken } from "../common/request-token";
 
 const requestClusterActivationInjectable = getInjectable({
   id: "request-cluster-activation",
   instantiate: (di) => {
-    const requestFromChannel = di.inject(requestFromChannelInjectable);
+    const requestFromChannel = di.inject(requestFromChannelInjectionToken);
 
     return (req) => requestFromChannel(activateClusterChannel, req);
   },

packages/core/src/features/cluster/activation/renderer/request-deactivation.injectable.ts

@@ -3,14 +3,14 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { getInjectable } from "@ogre-tools/injectable";
-import requestFromChannelInjectable from "../../../../renderer/utils/channel/request-from-channel.injectable";
+import { requestFromChannelInjectionToken } from "@k8slens/messaging";
 import { deactivateClusterChannel } from "../common/channels";
 import { requestClusterDeactivationInjectionToken } from "../common/request-token";
 
 const requestClusterDeactivationInjectable = getInjectable({
   id: "request-cluster-deactivation",
   instantiate: (di) => {
-    const requestFromChannel = di.inject(requestFromChannelInjectable);
+    const requestFromChannel = di.inject(requestFromChannelInjectionToken);
 
     return (clusterId) => requestFromChannel(deactivateClusterChannel, clusterId);
   },

packages/core/src/features/cluster/delete-dialog/common/clear-as-deleting-channel.ts

@@ -3,10 +3,8 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import type { ClusterId } from "../../../../common/cluster-types";
-import type { RequestChannel } from "../../../../common/utils/channel/request-channel-listener-injection-token";
+import { getRequestChannel } from "@k8slens/messaging";
 
-export type ClearClusterAsDeletingChannel = RequestChannel<ClusterId, void>;
+export const clearClusterAsDeletingChannel = getRequestChannel<ClusterId, void>(
-
+  "clear-cluster-as-deleting",
-export const clearClusterAsDeletingChannel: ClearClusterAsDeletingChannel = {
+);
-  id: "clear-cluster-as-deleting",
-};

packages/core/src/features/cluster/delete-dialog/common/delete-channel.ts

@@ -3,10 +3,11 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import type { ClusterId } from "../../../../common/cluster-types";
-import type { RequestChannel } from "../../../../common/utils/channel/request-channel-listener-injection-token";
+import type { RequestChannel } from "@k8slens/messaging";
+import { getRequestChannel } from "@k8slens/messaging";
 
 export type DeleteClusterChannel = RequestChannel<ClusterId, void>;
 
-export const deleteClusterChannel: DeleteClusterChannel = {
+export const deleteClusterChannel = getRequestChannel<ClusterId, void>(
-  id: "delete-cluster",
+  "delete-cluster",
-};
+);

packages/core/src/features/cluster/delete-dialog/common/set-as-deleting-channel.ts

@@ -3,10 +3,8 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import type { ClusterId } from "../../../../common/cluster-types";
-import type { RequestChannel } from "../../../../common/utils/channel/request-channel-listener-injection-token";
+import { getRequestChannel } from "@k8slens/messaging";
 
-export type SetClusterAsDeletingChannel = RequestChannel<ClusterId, void>;
+export const setClusterAsDeletingChannel = getRequestChannel<ClusterId, void>(
-
+  "set-cluster-as-deleting",
-export const setClusterAsDeletingChannel: SetClusterAsDeletingChannel = {
+);
-  id: "set-cluster-as-deleting",
-};

packages/core/src/features/cluster/delete-dialog/main/clear-as-deleting-channel-listener.injectable.ts

@@ -3,12 +3,13 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import clustersThatAreBeingDeletedInjectable from "../../../../main/cluster/are-being-deleted.injectable";
-import { getRequestChannelListenerInjectable } from "../../../../main/utils/channel/channel-listeners/listener-tokens";
+import { getRequestChannelListenerInjectable } from "@k8slens/messaging";
 import { clearClusterAsDeletingChannel } from "../common/clear-as-deleting-channel";
 
 const clearClusterAsDeletingChannelListenerInjectable = getRequestChannelListenerInjectable({
+  id: "clear-cluster-as-deleting-channel-listener",
   channel: clearClusterAsDeletingChannel,
-  handler: (di) => {
+  getHandler: (di) => {
     const clustersThatAreBeingDeleted = di.inject(clustersThatAreBeingDeletedInjectable);
 
     return (clusterId) => {

packages/core/src/features/cluster/delete-dialog/main/delete-channel-listener.injectable.ts

@@ -10,12 +10,13 @@ import removePathInjectable from "../../../../common/fs/remove.injectable";
 import joinPathsInjectable from "../../../../common/path/join-paths.injectable";
 import clusterConnectionInjectable from "../../../../main/cluster/cluster-connection.injectable";
 import { noop } from "@k8slens/utilities";
-import { getRequestChannelListenerInjectable } from "../../../../main/utils/channel/channel-listeners/listener-tokens";
+import { getRequestChannelListenerInjectable } from "@k8slens/messaging";
 import { deleteClusterChannel } from "../common/delete-channel";
 
 const deleteClusterChannelListenerInjectable = getRequestChannelListenerInjectable({
+  id: "delete-cluster-channel-listener",
   channel: deleteClusterChannel,
-  handler: (di) => {
+  getHandler: (di) => {
     const emitAppEvent = di.inject(emitAppEventInjectable);
     const clusterStore = di.inject(clusterStoreInjectable);
     const clusterFrames = di.inject(clusterFramesInjectable);

packages/core/src/features/cluster/delete-dialog/main/set-as-deleteing-channel-listener.injectable.ts

@@ -3,12 +3,13 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import clustersThatAreBeingDeletedInjectable from "../../../../main/cluster/are-being-deleted.injectable";
-import { getRequestChannelListenerInjectable } from "../../../../main/utils/channel/channel-listeners/listener-tokens";
+import { getRequestChannelListenerInjectable } from "@k8slens/messaging";
 import { setClusterAsDeletingChannel } from "../common/set-as-deleting-channel";
 
 const setClusterAsDeletingChannelHandlerInjectable = getRequestChannelListenerInjectable({
+  id: "set-cluster-as-deleting-channel-handler",
   channel: setClusterAsDeletingChannel,
-  handler: (di) => {
+  getHandler: (di) => {
     const clustersThatAreBeingDeleted = di.inject(clustersThatAreBeingDeletedInjectable);
 
     return (clusterId) => {

packages/core/src/features/cluster/delete-dialog/renderer/request-clear-as-deleting.injectable.ts

@@ -4,7 +4,7 @@
  */
 import { getInjectable } from "@ogre-tools/injectable";
 import type { ClusterId } from "../../../../common/cluster-types";
-import requestFromChannelInjectable from "../../../../renderer/utils/channel/request-from-channel.injectable";
+import { requestFromChannelInjectionToken } from "@k8slens/messaging";
 import { clearClusterAsDeletingChannel } from "../common/clear-as-deleting-channel";
 
 export type RequestClearClusterAsDeleting = (clusterId: ClusterId) => Promise<void>;
@@ -12,7 +12,7 @@ export type RequestClearClusterAsDeleting = (clusterId: ClusterId) => Promise<vo
 const requestClearClusterAsDeletingInjectable = getInjectable({
   id: "request-clear-cluster-as-deleting",
   instantiate: (di): RequestClearClusterAsDeleting => {
-    const requestChannel = di.inject(requestFromChannelInjectable);
+    const requestChannel = di.inject(requestFromChannelInjectionToken);
 
     return (clusterId) => requestChannel(clearClusterAsDeletingChannel, clusterId);
   },

packages/core/src/features/cluster/delete-dialog/renderer/request-delete.injectable.ts

@@ -4,7 +4,7 @@
  */
 import { getInjectable } from "@ogre-tools/injectable";
 import type { ClusterId } from "../../../../common/cluster-types";
-import requestFromChannelInjectable from "../../../../renderer/utils/channel/request-from-channel.injectable";
+import { requestFromChannelInjectionToken } from "@k8slens/messaging";
 import { deleteClusterChannel } from "../common/delete-channel";
 
 export type RequestDeleteCluster = (clusterId: ClusterId) => Promise<void>;
@@ -12,7 +12,7 @@ export type RequestDeleteCluster = (clusterId: ClusterId) => Promise<void>;
 const requestDeleteClusterInjectable = getInjectable({
   id: "request-delete-cluster",
   instantiate: (di): RequestDeleteCluster => {
-    const requestChannel = di.inject(requestFromChannelInjectable);
+    const requestChannel = di.inject(requestFromChannelInjectionToken);
 
     return (clusterId) => requestChannel(deleteClusterChannel, clusterId);
   },

packages/core/src/features/cluster/delete-dialog/renderer/request-set-as-deleting.injectable.ts

@@ -4,7 +4,7 @@
  */
 import { getInjectable } from "@ogre-tools/injectable";
 import type { ClusterId } from "../../../../common/cluster-types";
-import requestFromChannelInjectable from "../../../../renderer/utils/channel/request-from-channel.injectable";
+import { requestFromChannelInjectionToken } from "@k8slens/messaging";
 import { setClusterAsDeletingChannel } from "../common/set-as-deleting-channel";
 
 export type RequestSetClusterAsDeleting = (clusterId: ClusterId) => Promise<void>;
@@ -12,7 +12,7 @@ export type RequestSetClusterAsDeleting = (clusterId: ClusterId) => Promise<void
 const requestSetClusterAsDeletingInjectable = getInjectable({
   id: "request-set-cluster-as-deleting",
   instantiate: (di): RequestSetClusterAsDeleting => {
-    const requestChannel = di.inject(requestFromChannelInjectable);
+    const requestChannel = di.inject(requestFromChannelInjectionToken);
 
     return (clusterId) => requestChannel(setClusterAsDeletingChannel, clusterId);
   },

packages/core/src/features/cluster/state-sync/common/channels.ts

@@ -4,8 +4,7 @@
  */
 
 import type { ClusterId, ClusterState } from "../../../../common/cluster-types";
-import type { MessageChannel } from "../../../../common/utils/channel/message-channel-listener-injection-token";
+import type { MessageChannel, RequestChannel } from "@k8slens/messaging";
-import type { RequestChannel } from "../../../../common/utils/channel/request-channel-listener-injection-token";
 
 export interface ClusterStateSync {
   clusterId: ClusterId;

packages/core/src/features/cluster/state-sync/main/emit-update.injectable.ts

@@ -3,18 +3,16 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { getInjectable } from "@ogre-tools/injectable";
-import type { MessageChannelHandler } from "../../../../common/utils/channel/message-channel-listener-injection-token";
+import { sendMessageToChannelInjectionToken } from "@k8slens/messaging";
-import { sendMessageToChannelInjectionToken } from "../../../../common/utils/channel/message-to-channel-injection-token";
+import type { ClusterStateSync } from "../common/channels";
 import { clusterStateSyncChannel } from "../common/channels";
 
-export type EmitClusterStateUpdate = MessageChannelHandler<typeof clusterStateSyncChannel>;
-
 const emitClusterStateUpdateInjectable = getInjectable({
   id: "emit-cluster-state-update",
-  instantiate: (di): EmitClusterStateUpdate => {
+  instantiate: (di) => {
     const sendMessageToChannel = di.inject(sendMessageToChannelInjectionToken);
 
-    return (message) => sendMessageToChannel(clusterStateSyncChannel, message);
+    return (message: ClusterStateSync) => sendMessageToChannel(clusterStateSyncChannel, message);
   },
 });
 

packages/core/src/features/cluster/state-sync/main/handle-initial.injectable.ts

@@ -3,12 +3,13 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import clusterStoreInjectable from "../../../../common/cluster-store/cluster-store.injectable";
-import { getRequestChannelListenerInjectable } from "../../../../main/utils/channel/channel-listeners/listener-tokens";
+import { getRequestChannelListenerInjectable } from "@k8slens/messaging";
 import { initialClusterStatesChannel } from "../common/channels";
 
 const handleInitialClusterStateSyncInjectable = getRequestChannelListenerInjectable({
+  id: "handle-initial-cluster-state-sync",
   channel: initialClusterStatesChannel,
-  handler: (di) => {
+  getHandler: (di) => {
     const clusterStore = di.inject(clusterStoreInjectable);
 
     return () => clusterStore.clustersList.map(cluster => ({

packages/core/src/features/cluster/state-sync/renderer/listener.injectable.ts

@@ -3,13 +3,13 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import getClusterByIdInjectable from "../../../../common/cluster-store/get-by-id.injectable";
-import { getMessageChannelListenerInjectable } from "../../../../common/utils/channel/message-channel-listener-injection-token";
+import { getMessageChannelListenerInjectable } from "@k8slens/messaging";
 import { clusterStateSyncChannel } from "../common/channels";
 
 const clusterStateListenerInjectable = getMessageChannelListenerInjectable({
   channel: clusterStateSyncChannel,
   id: "main",
-  handler: (di) => {
+  getHandler: (di) => {
     const getClusterById = di.inject(getClusterByIdInjectable);
 
     return ({ clusterId, state }) => getClusterById(clusterId)?.setState(state);

packages/core/src/features/cluster/state-sync/renderer/request-initial.injectable.ts

@@ -3,8 +3,8 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { getInjectable } from "@ogre-tools/injectable";
-import type { RequestChannelHandler } from "../../../../main/utils/channel/channel-listeners/listener-tokens";
+import type { RequestChannelHandler } from "@k8slens/messaging";
-import requestFromChannelInjectable from "../../../../renderer/utils/channel/request-from-channel.injectable";
+import { requestFromChannelInjectionToken } from "@k8slens/messaging";
 import { initialClusterStatesChannel } from "../common/channels";
 
 export type RequestInitialClusterStates = RequestChannelHandler<typeof initialClusterStatesChannel>;
@@ -12,7 +12,7 @@ export type RequestInitialClusterStates = RequestChannelHandler<typeof initialCl
 const requestInitialClusterStatesInjectable = getInjectable({
   id: "request-initial-cluster-states",
   instantiate: (di): RequestInitialClusterStates => {
-    const requestFromChannel = di.inject(requestFromChannelInjectable);
+    const requestFromChannel = di.inject(requestFromChannelInjectionToken);
 
     return () => requestFromChannel(initialClusterStatesChannel);
   },

packages/core/src/features/extensions/navigate/common/channel.ts

@@ -3,7 +3,7 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 
-import type { MessageChannel } from "../../../../common/utils/channel/message-channel-listener-injection-token";
+import type { MessageChannel } from "@k8slens/messaging";
 
 export interface NavigateForExtensionArgs {
   extId: string;

packages/core/src/features/extensions/navigate/renderer/listener.injectable.ts

@@ -2,15 +2,15 @@
  * Copyright (c) OpenLens Authors. All rights reserved.
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
-import { getMessageChannelListenerInjectable } from "../../../../common/utils/channel/message-channel-listener-injection-token";
+import { getMessageChannelListenerInjectable } from "@k8slens/messaging";
 import extensionLoaderInjectable from "../../../../extensions/extension-loader/extension-loader.injectable";
 import type { LensRendererExtension } from "../../../../extensions/lens-renderer-extension";
 import { navigateForExtensionChannel } from "../common/channel";
 
 const navigateForExtensionListenerInjectable = getMessageChannelListenerInjectable({
   channel: navigateForExtensionChannel,
-  id: "main",
+  id: "renderer",
-  handler: (di) => {
+  getHandler: (di) => {
     const extensionLoader = di.inject(extensionLoaderInjectable);
 
     return ({ extId, pageId, params }) => {

packages/core/src/features/helm-charts/child-features/preferences/renderer/active-helm-repositories.injectable.ts

@@ -5,7 +5,7 @@
 import { getInjectable } from "@ogre-tools/injectable";
 import { asyncComputed } from "@ogre-tools/injectable-react";
 import { getActiveHelmRepositoriesChannel } from "../../../../../common/helm/get-active-helm-repositories-channel";
-import { requestFromChannelInjectionToken } from "../../../../../common/utils/channel/request-from-channel-injection-token";
+import { requestFromChannelInjectionToken } from "@k8slens/messaging";
 import showErrorNotificationInjectable from "../../../../../renderer/components/notifications/show-error-notification.injectable";
 import helmRepositoriesErrorStateInjectable from "./helm-repositories-error-state.injectable";
 import { runInAction } from "mobx";

packages/core/src/features/helm-charts/child-features/preferences/renderer/adding-of-public-helm-repository/select-helm-repository/add-helm-repository.injectable.ts

@@ -4,7 +4,7 @@
  */
 import { getInjectable } from "@ogre-tools/injectable";
 import type { HelmRepo } from "../../../../../../../common/helm/helm-repo";
-import { requestFromChannelInjectionToken } from "../../../../../../../common/utils/channel/request-from-channel-injection-token";
+import { requestFromChannelInjectionToken } from "@k8slens/messaging";
 import activeHelmRepositoriesInjectable from "../../active-helm-repositories.injectable";
 import showErrorNotificationInjectable from "../../../../../../../renderer/components/notifications/show-error-notification.injectable";
 import showSuccessNotificationInjectable from "../../../../../../../renderer/components/notifications/show-success-notification.injectable";

packages/core/src/features/helm-charts/child-features/preferences/renderer/remove-helm-repository.injectable.ts

@@ -4,7 +4,7 @@
  */
 import { getInjectable } from "@ogre-tools/injectable";
 import type { HelmRepo } from "../../../../../common/helm/helm-repo";
-import { requestFromChannelInjectionToken } from "../../../../../common/utils/channel/request-from-channel-injection-token";
+import { requestFromChannelInjectionToken } from "@k8slens/messaging";
 import activeHelmRepositoriesInjectable from "./active-helm-repositories.injectable";
 import { removeHelmRepositoryChannel } from "../../../../../common/helm/remove-helm-repository-channel";
 

packages/core/src/features/navigation/reload-page/common/channel.ts

@@ -3,7 +3,7 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 
-import type { MessageChannel } from "../../../../common/utils/channel/message-channel-listener-injection-token";
+import type { MessageChannel } from "@k8slens/messaging";
 
 export type ReloadPageChannel = MessageChannel<void>;
 

packages/core/src/features/navigation/reload-page/renderer/register-listener.global-override-for-injectable.ts

@@ -8,6 +8,7 @@ import { reloadPageChannel } from "../common/channel";
 import reloadPageChannelListenerInjectable from "./register-listener.injectable";
 
 export default getGlobalOverride(reloadPageChannelListenerInjectable, () => ({
+  id: "reload-page-channel-listener",
   channel: reloadPageChannel,
   handler: () => {},
 }));

packages/core/src/features/navigation/reload-page/renderer/register-listener.injectable.ts

@@ -2,13 +2,13 @@
  * Copyright (c) OpenLens Authors. All rights reserved.
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
-import { getMessageChannelListenerInjectable } from "../../../../common/utils/channel/message-channel-listener-injection-token";
+import { getMessageChannelListenerInjectable } from "@k8slens/messaging";
 import { reloadPageChannel } from "../common/channel";
 
 const reloadPageChannelListenerInjectable = getMessageChannelListenerInjectable({
   id: "handler",
   channel: reloadPageChannel,
-  handler: () => () => location.reload(),
+  getHandler: () => () => location.reload(),
   causesSideEffects: true,
 });
 

packages/core/src/features/path-picking-dialog/common/channel.ts

@@ -4,7 +4,7 @@
  */
 
 import type { OpenDialogOptions } from "electron";
-import type { RequestChannel } from "../../../common/utils/channel/request-channel-listener-injection-token";
+import type { RequestChannel } from "@k8slens/messaging";
 
 export type PathPickingResponse = {
   canceled: true;

packages/core/src/features/path-picking-dialog/main/handle-pick-paths.injectable.ts

@@ -4,12 +4,13 @@
  */
 
 import askUserForFilePathsInjectable from "../../../main/ipc/ask-user-for-file-paths.injectable";
-import { getRequestChannelListenerInjectable } from "../../../main/utils/channel/channel-listeners/listener-tokens";
+import { getRequestChannelListenerInjectable } from "@k8slens/messaging";
 import { openPathPickingDialogChannel } from "../common/channel";
 
 const openPathPickingDialogListener = getRequestChannelListenerInjectable({
+  id: "open-path-picking-dialog",
   channel: openPathPickingDialogChannel,
-  handler: (di) => di.inject(askUserForFilePathsInjectable),
+  getHandler: (di) => di.inject(askUserForFilePathsInjectable),
 });
 
 export default openPathPickingDialogListener;

packages/core/src/features/path-picking-dialog/renderer/pick-paths.injectable.ts

@@ -4,7 +4,7 @@
  */
 import { getInjectable } from "@ogre-tools/injectable";
 import type { PathPickOpts } from "../../../renderer/components/path-picker";
-import requestFromChannelInjectable from "../../../renderer/utils/channel/request-from-channel.injectable";
+import { requestFromChannelInjectionToken } from "@k8slens/messaging";
 import { openPathPickingDialogChannel } from "../common/channel";
 
 export type OpenPathPickingDialog = (options: PathPickOpts) => Promise<void>;
@@ -12,7 +12,7 @@ export type OpenPathPickingDialog = (options: PathPickOpts) => Promise<void>;
 const openPathPickingDialogInjectable = getInjectable({
   id: "open-path-picking-dialog",
   instantiate: (di): OpenPathPickingDialog => {
-    const requestFromChannel = di.inject(requestFromChannelInjectable);
+    const requestFromChannel = di.inject(requestFromChannelInjectionToken);
 
     return async (options) => {
       const { onPick, onCancel, ...dialogOptions } = options;

packages/core/src/features/shell-sync/common/failure-channel.ts

@@ -3,7 +3,7 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 
-import type { MessageChannel } from "../../../common/utils/channel/message-channel-listener-injection-token";
+import type { MessageChannel } from "@k8slens/messaging";
 
 export const shellSyncFailedChannel: MessageChannel<string> = {
   id: "shell-sync-failed-channel",

packages/core/src/features/shell-sync/main/emit-failure.injectable.ts

@@ -3,16 +3,15 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { getInjectable } from "@ogre-tools/injectable";
-import type { MessageChannelSender } from "../../../common/utils/channel/message-to-channel-injection-token";
+import { sendMessageToChannelInjectionToken } from "@k8slens/messaging";
-import { sendMessageToChannelInjectionToken } from "../../../common/utils/channel/message-to-channel-injection-token";
 import { shellSyncFailedChannel } from "../common/failure-channel";
 
 const emitShellSyncFailedInjectable = getInjectable({
   id: "emit-shell-sync-failed",
-  instantiate: (di): MessageChannelSender<typeof shellSyncFailedChannel> => {
+  instantiate: (di) => {
     const sendMessageToChannel = di.inject(sendMessageToChannelInjectionToken);
 
-    return (error) => sendMessageToChannel(shellSyncFailedChannel, error);
+    return (error: string) => sendMessageToChannel(shellSyncFailedChannel, error);
   },
 });
 

packages/core/src/features/shell-sync/renderer/failure-listener.injectable.ts

@@ -2,14 +2,14 @@
  * Copyright (c) OpenLens Authors. All rights reserved.
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
-import { getMessageChannelListenerInjectable } from "../../../common/utils/channel/message-channel-listener-injection-token";
+import { getMessageChannelListenerInjectable } from "@k8slens/messaging";
 import showErrorNotificationInjectable from "../../../renderer/components/notifications/show-error-notification.injectable";
 import { shellSyncFailedChannel } from "../common/failure-channel";
 
 const shellSyncFailureListenerInjectable = getMessageChannelListenerInjectable({
   id: "notification",
   channel: shellSyncFailedChannel,
-  handler: (di) => {
+  getHandler: (di) => {
     const showErrorNotification = di.inject(showErrorNotificationInjectable);
 
     return (errorMessage) => showErrorNotification(`Failed to sync shell environment: ${errorMessage}`);

packages/core/src/features/theme/system-type/common/channels.ts

@@ -3,8 +3,7 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 
-import type { MessageChannel } from "../../../../common/utils/channel/message-channel-listener-injection-token";
+import type { MessageChannel, RequestChannel } from "@k8slens/messaging";
-import type { RequestChannel } from "../../../../common/utils/channel/request-channel-listener-injection-token";
 
 export type SystemThemeType = "dark" | "light";
 

packages/core/src/features/theme/system-type/main/emit-update.injectable.ts

@@ -3,18 +3,16 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { getInjectable } from "@ogre-tools/injectable";
-import type { MessageChannelHandler } from "../../../../common/utils/channel/message-channel-listener-injection-token";
+import { sendMessageToChannelInjectionToken } from "@k8slens/messaging";
-import { sendMessageToChannelInjectionToken } from "../../../../common/utils/channel/message-to-channel-injection-token";
+import type { SystemThemeType } from "../common/channels";
 import { systemThemeTypeUpdateChannel } from "../common/channels";
 
-export type EmitSystemThemeTypeUpdate = MessageChannelHandler<typeof systemThemeTypeUpdateChannel>;
-
 const emitSystemThemeTypeUpdateInjectable = getInjectable({
   id: "emit-system-theme-type-update",
-  instantiate: (di): EmitSystemThemeTypeUpdate => {
+  instantiate: (di) => {
     const sendMessageToChannel = di.inject(sendMessageToChannelInjectionToken);
 
-    return (type) => sendMessageToChannel(systemThemeTypeUpdateChannel, type);
+    return (type: SystemThemeType) => sendMessageToChannel(systemThemeTypeUpdateChannel, type);
   },
 });
 

packages/core/src/features/theme/system-type/main/handle-initial.injectable.ts

@@ -4,12 +4,13 @@
  */
 
 import operatingSystemThemeInjectable from "../../../../main/theme/operating-system-theme.injectable";
-import { getRequestChannelListenerInjectable } from "../../../../main/utils/channel/channel-listeners/listener-tokens";
+import { getRequestChannelListenerInjectable } from "@k8slens/messaging";
 import { initialSystemThemeTypeChannel } from "../common/channels";
 
 const initialSystemThemeTypeHandler = getRequestChannelListenerInjectable({
+  id: "initial-system-theme-type-listener",
   channel: initialSystemThemeTypeChannel,
-  handler: (di) => {
+  getHandler: (di) => {
     const operatingSystemTheme = di.inject(operatingSystemThemeInjectable);
 
     return () => operatingSystemTheme.get();

packages/core/src/features/theme/system-type/renderer/request-initial.injectable.ts

@@ -3,8 +3,8 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { getInjectable } from "@ogre-tools/injectable";
-import type { RequestChannelHandler } from "../../../../main/utils/channel/channel-listeners/listener-tokens";
+import type { RequestChannelHandler } from "@k8slens/messaging";
-import requestFromChannelInjectable from "../../../../renderer/utils/channel/request-from-channel.injectable";
+import { requestFromChannelInjectionToken } from "@k8slens/messaging";
 import { initialSystemThemeTypeChannel } from "../common/channels";
 
 export type RequestInitialSystemThemeType = RequestChannelHandler<typeof initialSystemThemeTypeChannel>;
@@ -12,7 +12,7 @@ export type RequestInitialSystemThemeType = RequestChannelHandler<typeof initial
 const requestInitialSystemThemeTypeInjectable = getInjectable({
   id: "request-initial-system-theme-type",
   instantiate: (di): RequestInitialSystemThemeType => {
-    const requestFromChannel = di.inject(requestFromChannelInjectable);
+    const requestFromChannel = di.inject(requestFromChannelInjectionToken);
 
     return () => requestFromChannel(initialSystemThemeTypeChannel);
   },

packages/core/src/features/theme/system-type/renderer/update-listener.injectable.ts

@@ -2,14 +2,14 @@
  * Copyright (c) OpenLens Authors. All rights reserved.
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
-import { getMessageChannelListenerInjectable } from "../../../../common/utils/channel/message-channel-listener-injection-token";
+import { getMessageChannelListenerInjectable } from "@k8slens/messaging";
 import systemThemeConfigurationInjectable from "../../../../renderer/themes/system-theme.injectable";
 import { systemThemeTypeUpdateChannel } from "../common/channels";
 
 const systemThemeTypeUpdateListenerInjectable = getMessageChannelListenerInjectable({
   channel: systemThemeTypeUpdateChannel,
   id: "main",
-  handler: (di) => {
+  getHandler: (di) => {
     const systemThemeConfiguration = di.inject(systemThemeConfigurationInjectable);
 
     return (type) => systemThemeConfiguration.set(type);

packages/core/src/jest-after-env.setup.ts

@@ -4,3 +4,8 @@
  */
 
 import "@testing-library/jest-dom";
+
+// Note: This is a kludge to prevent "Hooks cannot be defined inside tests" error
+// when importing a test util inside a test suite.
+import { render } from "@testing-library/react";
+void render;

packages/core/src/main/app-paths/app-paths-request-channel-listener.injectable.ts

@@ -4,11 +4,12 @@
  */
 import { appPathsChannel } from "../../common/app-paths/app-paths-channel";
 import appPathsInjectable from "../../common/app-paths/app-paths.injectable";
-import { getRequestChannelListenerInjectable } from "../utils/channel/channel-listeners/listener-tokens";
+import { getRequestChannelListenerInjectable } from "@k8slens/messaging";
 
 const appPathsRequestChannelListenerInjectable = getRequestChannelListenerInjectable({
+  id: "app-paths-request-channel-listener",
   channel: appPathsChannel,
-  handler: (di) => {
+  getHandler: (di) => {
     const appPaths = di.inject(appPathsInjectable);
 
     return () => appPaths;

packages/core/src/main/build-version/setup-channel.injectable.ts

@@ -3,12 +3,13 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { buildVersionChannel } from "../../common/vars/build-semantic-version.injectable";
-import { getRequestChannelListenerInjectable } from "../utils/channel/channel-listeners/listener-tokens";
+import { getRequestChannelListenerInjectable } from "@k8slens/messaging";
 import buildVersionInjectable from "../vars/build-version/build-version.injectable";
 
 const buildVersionChannelListenerInjectable = getRequestChannelListenerInjectable({
+  id: "build-version-channel-listener",
   channel: buildVersionChannel,
-  handler: (di) => {
+  getHandler: (di) => {
     const buildVersion = di.inject(buildVersionInjectable);
 
     return () => buildVersion.get();

packages/core/src/main/catalog-sync-to-renderer/catalog-sync-to-renderer.injectable.ts

@@ -7,7 +7,7 @@ import { reaction } from "mobx";
 import ipcMainInjectionToken from "../../common/ipc/ipc-main-injection-token";
 import { catalogInitChannel } from "../../common/ipc/catalog";
 import { disposer } from "@k8slens/utilities";
-import { getStartableStoppable } from "../../common/utils/get-startable-stoppable";
+import { getStartableStoppable } from "@k8slens/startable-stoppable";
 import catalogEntityRegistryInjectable from "../catalog/entity-registry.injectable";
 import catalogSyncBroadcasterInjectable from "./broadcaster.injectable";
 import { toJS } from "../../common/utils";

packages/core/src/main/cluster/visibility-handler.injectable.ts

@@ -3,13 +3,13 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { clusterVisibilityChannel } from "../../common/cluster/visibility-channel";
-import { getMessageChannelListenerInjectable } from "../../common/utils/channel/message-channel-listener-injection-token";
+import { getMessageChannelListenerInjectable } from "@k8slens/messaging";
 import visibleClusterInjectable from "./visible-cluster.injectable";
 
 const clusterVisibilityHandlerInjectable = getMessageChannelListenerInjectable({
   channel: clusterVisibilityChannel,
   id: "base",
-  handler: (di) => {
+  getHandler: (di) => {
     const visibleCluster = di.inject(visibleClusterInjectable);
 
     return (clusterId) => visibleCluster.set(clusterId);

packages/core/src/main/electron-app/features/sync-theme-from-operating-system.injectable.ts

@@ -3,7 +3,7 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { getInjectable } from "@ogre-tools/injectable";
-import { getStartableStoppable } from "../../../common/utils/get-startable-stoppable";
+import { getStartableStoppable } from "@k8slens/startable-stoppable";
 import operatingSystemThemeStateInjectable from "../../theme/operating-system-theme-state.injectable";
 import nativeThemeInjectable from "./native-theme.injectable";
 import getElectronThemeInjectable from "./get-electron-theme.injectable";

packages/core/src/main/getDiForUnitTesting.ts

@@ -29,6 +29,8 @@ import {
   setLegacyGlobalDiForExtensionApi,
 } from "../extensions/as-legacy-globals-for-extension-api/legacy-global-di-for-extension-api";
 import { registerMobX } from "@ogre-tools/injectable-extension-for-mobx";
+import { registerFeature } from "@k8slens/feature-core";
+import { messagingFeature, testUtils as messagingTestUtils } from "@k8slens/messaging";
 
 export function getDiForUnitTesting() {
   const di = createContainer("main");
@@ -36,6 +38,11 @@ export function getDiForUnitTesting() {
   registerMobX(di);
   setLegacyGlobalDiForExtensionApi(di, "main");
 
+  runInAction(() => {
+    registerFeature(di, messagingFeature, messagingTestUtils.messagingFeatureForUnitTesting);
+
+  });
+
   di.preventSideEffects();
 
   runInAction(() => {

packages/core/src/main/helm/repositories/add-helm-repository/add-helm-repository-channel-listener.injectable.ts

@@ -3,12 +3,14 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { addHelmRepositoryChannel } from "../../../../common/helm/add-helm-repository-channel";
-import { getRequestChannelListenerInjectable } from "../../../utils/channel/channel-listeners/listener-tokens";
+import { getRequestChannelListenerInjectable } from "@k8slens/messaging";
 import addHelmRepositoryInjectable from "./add-helm-repository.injectable";
 
-const addHelmRepositoryChannelListenerInjectable = getRequestChannelListenerInjectable({
+const addHelmRepositoryChannelListenerInjectable =
-  channel: addHelmRepositoryChannel,
+  getRequestChannelListenerInjectable({
-  handler: (di) => di.inject(addHelmRepositoryInjectable),
+    id: "add-helm-repository-channel-listener",
-});
+    channel: addHelmRepositoryChannel,
+    getHandler: (di) => di.inject(addHelmRepositoryInjectable),
+  });
 
 export default addHelmRepositoryChannelListenerInjectable;

packages/core/src/main/helm/repositories/add-helm-repository/add-helm-repository.injectable.ts

@@ -5,17 +5,16 @@
 import { getInjectable } from "@ogre-tools/injectable";
 import execHelmInjectable from "../../exec-helm/exec-helm.injectable";
 import loggerInjectable from "../../../../common/logger.injectable";
-import type { AddHelmRepositoryChannel } from "../../../../common/helm/add-helm-repository-channel";
+import type { HelmRepo } from "../../../../common/helm/helm-repo";
-import type { RequestChannelHandler } from "../../../utils/channel/channel-listeners/listener-tokens";
 
 const addHelmRepositoryInjectable = getInjectable({
   id: "add-helm-repository",
 
-  instantiate: (di): RequestChannelHandler<AddHelmRepositoryChannel> => {
+  instantiate: (di) => {
     const execHelm = di.inject(execHelmInjectable);
     const logger = di.inject(loggerInjectable);
 
-    return async (repo) => {
+    return async (repo: HelmRepo) => {
       const {
         name,
         url,
@@ -59,12 +58,12 @@ const addHelmRepositoryInjectable = getInjectable({
 
       if (result.callWasSuccessful) {
         return {
-          callWasSuccessful: true,
+          callWasSuccessful: true as const,
         };
       }
 
       return {
-        callWasSuccessful: false,
+        callWasSuccessful: false as const,
         error: result.error.stderr || result.error.message,
       };
     };

packages/core/src/main/helm/repositories/get-active-helm-repositories/get-active-helm-repositories-channel-listener.injectable.ts

@@ -3,12 +3,13 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { getActiveHelmRepositoriesChannel } from "../../../../common/helm/get-active-helm-repositories-channel";
-import { getRequestChannelListenerInjectable } from "../../../utils/channel/channel-listeners/listener-tokens";
+import { getRequestChannelListenerInjectable } from "@k8slens/messaging";
 import getActiveHelmRepositoriesInjectable from "./get-active-helm-repositories.injectable";
 
 const getActiveHelmRepositoriesChannelListenerInjectable = getRequestChannelListenerInjectable({
+  id: "get-active-helm-repositories-channel-listener",
   channel: getActiveHelmRepositoriesChannel,
-  handler: (di) => di.inject(getActiveHelmRepositoriesInjectable),
+  getHandler: (di) => di.inject(getActiveHelmRepositoriesInjectable),
 });
 
 export default getActiveHelmRepositoriesChannelListenerInjectable;

packages/core/src/main/helm/repositories/remove-helm-repository/remove-helm-repository-channel-listener.injectable.ts

@@ -4,11 +4,12 @@
  */
 import removeHelmRepositoryInjectable from "./remove-helm-repository.injectable";
 import { removeHelmRepositoryChannel } from "../../../../common/helm/remove-helm-repository-channel";
-import { getRequestChannelListenerInjectable } from "../../../utils/channel/channel-listeners/listener-tokens";
+import { getRequestChannelListenerInjectable } from "@k8slens/messaging";
 
 const removeHelmRepositoryChannelListenerInjectable = getRequestChannelListenerInjectable({
+  id: "remove-helm-repository-channel-listener",
   channel: removeHelmRepositoryChannel,
-  handler: (di) => di.inject(removeHelmRepositoryInjectable),
+  getHandler: (di) => di.inject(removeHelmRepositoryInjectable),
 });
 
 export default removeHelmRepositoryChannelListenerInjectable;

packages/core/src/main/ipc/ask-user-for-file-paths.injectable.ts

@@ -5,7 +5,7 @@
 
 import { getInjectable } from "@ogre-tools/injectable";
 import showApplicationWindowInjectable from "../start-main-application/lens-window/show-application-window.injectable";
-import type { RequestChannelHandler } from "../utils/channel/channel-listeners/listener-tokens";
+import type { RequestChannelHandler } from "@k8slens/messaging";
 import type { openPathPickingDialogChannel } from "../../features/path-picking-dialog/common/channel";
 import showOpenDialogInjectable from "../electron-app/features/show-open-dialog.injectable";
 

packages/core/src/main/kubectl/apply-all-handler.injectable.ts

@@ -6,11 +6,12 @@ import emitAppEventInjectable from "../../common/app-event-bus/emit-event.inject
 import getClusterByIdInjectable from "../../common/cluster-store/get-by-id.injectable";
 import { kubectlApplyAllChannel } from "../../common/kube-helpers/channels";
 import resourceApplierInjectable from "../resource-applier/create-resource-applier.injectable";
-import { getRequestChannelListenerInjectable } from "../utils/channel/channel-listeners/listener-tokens";
+import { getRequestChannelListenerInjectable } from "@k8slens/messaging";
 
 const kubectlApplyAllChannelHandlerInjectable = getRequestChannelListenerInjectable({
+  id: "kubectl-apply-all-channel-handler-listener",
   channel: kubectlApplyAllChannel,
-  handler: (di) => {
+  getHandler: (di) => {
     const getClusterById = di.inject(getClusterByIdInjectable);
     const emitAppEvent = di.inject(emitAppEventInjectable);
 

packages/core/src/main/kubectl/delete-all-handler.injectable.ts

@@ -6,11 +6,12 @@ import emitAppEventInjectable from "../../common/app-event-bus/emit-event.inject
 import getClusterByIdInjectable from "../../common/cluster-store/get-by-id.injectable";
 import { kubectlDeleteAllChannel } from "../../common/kube-helpers/channels";
 import resourceApplierInjectable from "../resource-applier/create-resource-applier.injectable";
-import { getRequestChannelListenerInjectable } from "../utils/channel/channel-listeners/listener-tokens";
+import { getRequestChannelListenerInjectable } from "@k8slens/messaging";
 
 const kubectlDeleteAllChannelHandlerInjectable = getRequestChannelListenerInjectable({
+  id: "kubectl-delete-all-channel-handler-listener",
   channel: kubectlDeleteAllChannel,
-  handler: (di) => {
+  getHandler: (di) => {
     const emitAppEvent = di.inject(emitAppEventInjectable);
     const getClusterById = di.inject(getClusterByIdInjectable);
 

packages/core/src/main/lens-proxy/lens-proxy-certificate-request-handler.injectable.ts

@@ -3,12 +3,13 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { lensProxyCertificateChannel } from "../../common/certificate/lens-proxy-certificate-channel";
-import { getRequestChannelListenerInjectable } from "../utils/channel/channel-listeners/listener-tokens";
+import { getRequestChannelListenerInjectable } from "@k8slens/messaging";
 import lensProxyCertificateInjectable from "../../common/certificate/lens-proxy-certificate.injectable";
 
 const lensProxyCertificateRequestHandlerInjectable = getRequestChannelListenerInjectable({
+  id: "lens-proxy-certificate-request-handler-listener",
   channel: lensProxyCertificateChannel,
-  handler: (di) => {
+  getHandler: (di) => {
     const lensProxyCertificate = di.inject(lensProxyCertificateInjectable).get();
 
     return () => ({

packages/core/src/main/start-main-application/lens-window/current-cluster-frame/listener.injectable.ts

@@ -3,17 +3,17 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { currentClusterMessageChannel } from "../../../../common/cluster/current-cluster-channel";
-import { getMessageChannelListenerInjectable } from "../../../../common/utils/channel/message-channel-listener-injection-token";
+import { getMessageChannelListenerInjectable } from "@k8slens/messaging";
 import currentClusterFrameClusterIdStateInjectable from "./current-cluster-frame-cluster-id-state.injectable";
 
-const currentVisibileClusterListenerInjectable = getMessageChannelListenerInjectable({
+const currentVisibleClusterListenerInjectable = getMessageChannelListenerInjectable({
-  id: "current-visibile-cluster",
+  id: "current-visible-cluster",
   channel: currentClusterMessageChannel,
-  handler: (di) => {
+  getHandler: (di) => {
     const currentClusterFrameState = di.inject(currentClusterFrameClusterIdStateInjectable);
 
     return clusterId => currentClusterFrameState.set(clusterId);
   },
 });
 
-export default currentVisibileClusterListenerInjectable;
+export default currentVisibleClusterListenerInjectable;

packages/core/src/main/start-main-application/runnables/root-frame-has-rendered/channel-listener.injectable.ts

@@ -2,7 +2,7 @@
  * Copyright (c) OpenLens Authors. All rights reserved.
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
-import { getMessageChannelListenerInjectable } from "../../../../common/utils/channel/message-channel-listener-injection-token";
+import { getMessageChannelListenerInjectable } from "@k8slens/messaging";
 import { rootFrameHasRenderedChannel } from "../../../../common/root-frame/root-frame-rendered-channel";
 import { runManyFor } from "@k8slens/run-many";
 import { afterRootFrameIsReadyInjectionToken } from "../../runnable-tokens/phases";
@@ -10,7 +10,7 @@ import { afterRootFrameIsReadyInjectionToken } from "../../runnable-tokens/phase
 const rootFrameRenderedChannelListenerInjectable = getMessageChannelListenerInjectable({
   id: "action",
   channel: rootFrameHasRenderedChannel,
-  handler: (di) => {
+  getHandler: (di) => {
     const runMany = runManyFor(di);
 
     return runMany(afterRootFrameIsReadyInjectionToken);