+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 | 1x +1x +1x +1x +1x +1x +1x +1x +17x +17x +17x +17x +17x +17x +1x +1x +1x + | import { getFeature } from "@k8slens/feature-core";
+import { autoRegister } from "@ogre-tools/injectable-extension-for-auto-registration";
+import { reactApplicationFeature } from "@k8slens/react-application";
+
+export const keyboardShortcutsFeature = getFeature({
+ id: "keyboard-shortcuts",
+
+ register: (di) => {
+ autoRegister({
+ di,
+ targetModule: module,
+ getRequireContexts: () => [require.context("./", true, /\.injectable\.(ts|tsx)$/)],
+ });
+ },
+
+ dependencies: [reactApplicationFeature],
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| feature.ts | +
+
+ |
+ 100% | +17/17 | +100% | +3/3 | +100% | +3/3 | +100% | +17/17 | +
| invoke-shortcut.injectable.ts | +
+
+ |
+ 100% | +94/94 | +100% | +22/22 | +100% | +6/6 | +100% | +94/94 | +
| keyboard-shortcut-injection-token.ts | +
+
+ |
+ 100% | +22/22 | +100% | +1/1 | +100% | +1/1 | +100% | +22/22 | +
| keyboard-shortcut-listener-react-application-hoc.injectable.tsx | +
+
+ |
+ 100% | +10/10 | +100% | +2/2 | +100% | +2/2 | +100% | +10/10 | +
| keyboard-shortcut-listener.tsx | +
+
+ |
+ 100% | +41/41 | +100% | +5/5 | +100% | +3/3 | +100% | +41/41 | +
| keyboard-shortcut-scope.tsx | +
+
+ |
+ 100% | +12/12 | +100% | +2/2 | +100% | +2/2 | +100% | +12/12 | +
| platform.injectable.ts | +
+
+ |
+ 100% | +11/11 | +100% | +1/1 | +100% | +1/1 | +100% | +11/11 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +18x +18x +18x +16x +16x +16x +16x +2x +2x +2x +2x +2x +2x +2x +2x +1x +1x +122x +94x +94x +94x +94x +94x +94x +94x +94x +28x +28x +28x +28x +28x +28x +28x +1x +1x +1x +1x +122x +122x +122x +122x +122x +122x +122x +122x +122x +122x +122x +122x +122x +122x +122x +22x +22x +21x +21x +122x +122x +1x +1x +1x +1x +1x +17x +17x +17x +17x +31x +31x +31x +31x +31x +31x +31x +12x +12x +31x +17x +1x +1x +1x + | import { pipeline } from "@ogre-tools/fp";
+import { filter, isString } from "lodash/fp";
+import { getInjectable } from "@ogre-tools/injectable";
+import {
+ Binding,
+ KeyboardShortcut,
+ keyboardShortcutInjectionToken,
+} from "./keyboard-shortcut-injection-token";
+import platformInjectable from "./platform.injectable";
+
+export type InvokeShortcut = (event: KeyboardEvent) => void;
+
+const toShortcutsWithMatchingScope = (shortcut: KeyboardShortcut) => {
+ const activeScopeElement = document.activeElement?.closest("[data-keyboard-shortcut-scope]");
+
+ if (!activeScopeElement) {
+ const shortcutIsRootLevel = !shortcut.scope;
+
+ return shortcutIsRootLevel;
+ }
+
+ const castedActiveScopeElementHtml = activeScopeElement as HTMLDivElement;
+
+ // eslint-disable-next-line xss/no-mixed-html
+ const activeScope = castedActiveScopeElementHtml.dataset.keyboardShortcutScope;
+
+ return shortcut.scope === activeScope;
+};
+
+const toBindingWithDefaults = (binding: Binding) =>
+ isString(binding)
+ ? {
+ code: binding,
+ shift: false,
+ ctrl: false,
+ altOrOption: false,
+ meta: false,
+ ctrlOrCommand: false,
+ }
+ : {
+ ctrl: false,
+ shift: false,
+ altOrOption: false,
+ meta: false,
+ ctrlOrCommand: false,
+ ...binding,
+ };
+
+const toShortcutsWithMatchingBinding =
+ (event: KeyboardEvent, platform: string) => (shortcut: KeyboardShortcut) => {
+ const binding = toBindingWithDefaults(shortcut.binding);
+
+ const shiftModifierMatches = binding.shift === event.shiftKey;
+ const altModifierMatches = binding.altOrOption === event.altKey;
+
+ const isMac = platform === "darwin";
+
+ const ctrlModifierMatches =
+ binding.ctrl === event.ctrlKey || (!isMac && binding.ctrlOrCommand === event.ctrlKey);
+
+ const metaModifierMatches =
+ binding.meta === event.metaKey || (isMac && binding.ctrlOrCommand === event.metaKey);
+
+ return (
+ event.code === binding.code &&
+ shiftModifierMatches &&
+ ctrlModifierMatches &&
+ altModifierMatches &&
+ metaModifierMatches
+ );
+ };
+
+const invokeShortcutInjectable = getInjectable({
+ id: "invoke-shortcut",
+
+ instantiate: (di): InvokeShortcut => {
+ const getShortcuts = () => di.injectMany(keyboardShortcutInjectionToken);
+ const platform = di.inject(platformInjectable);
+
+ return (event) => {
+ const shortcutsToInvoke = pipeline(
+ getShortcuts(),
+ filter(toShortcutsWithMatchingBinding(event, platform)),
+ filter(toShortcutsWithMatchingScope),
+ );
+
+ if (shortcutsToInvoke.length) {
+ shortcutsToInvoke.forEach((shortcut) => shortcut.invoke());
+ }
+ };
+ },
+});
+
+export default invokeShortcutInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import { getInjectionToken } from "@ogre-tools/injectable";
+
+export type Binding =
+ | string
+ | {
+ code: string;
+ shift?: boolean;
+ ctrl?: boolean;
+ altOrOption?: boolean;
+ meta?: boolean;
+ ctrlOrCommand?: boolean;
+ };
+
+export type KeyboardShortcut = {
+ binding: Binding;
+ invoke: () => void;
+ scope?: string;
+};
+
+export const keyboardShortcutInjectionToken = getInjectionToken<KeyboardShortcut>({
+ id: "keyboard-shortcut-injection-token",
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import { getInjectable } from "@ogre-tools/injectable";
+import { KeyboardShortcutListener } from "./keyboard-shortcut-listener";
+import { reactApplicationHigherOrderComponentInjectionToken } from "@k8slens/react-application";
+
+export const keyboardShortcutListenerReactApplicationHocInjectable = getInjectable({
+ id: "keyboard-shortcut-listener-react-application-hoc",
+ instantiate: () => KeyboardShortcutListener,
+
+ injectionToken: reactApplicationHigherOrderComponentInjectionToken,
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +17x +17x +17x +17x +17x +17x +17x +17x +17x +17x +17x +17x +17x +1x +1x +1x +1x +1x +1x +1x +1x +1x +17x +17x +17x +1x +1x + | import { withInjectables } from "@ogre-tools/injectable-react";
+import React, { useEffect } from "react";
+
+import invokeShortcutInjectable, { InvokeShortcut } from "./invoke-shortcut.injectable";
+
+export interface KeyboardShortcutListenerProps {
+ children: React.ReactNode;
+}
+
+interface Dependencies {
+ invokeShortcut: InvokeShortcut;
+}
+
+const NonInjectedKeyboardShortcutListener = ({
+ children,
+ invokeShortcut,
+}: KeyboardShortcutListenerProps & Dependencies) => {
+ useEffect(() => {
+ document.addEventListener("keydown", invokeShortcut);
+
+ return () => {
+ document.removeEventListener("keydown", invokeShortcut);
+ };
+ });
+
+ return <>{children}</>;
+};
+
+export const KeyboardShortcutListener = withInjectables<
+ Dependencies,
+ KeyboardShortcutListenerProps
+>(
+ NonInjectedKeyboardShortcutListener,
+
+ {
+ getProps: (di, props) => ({
+ invokeShortcut: di.inject(invokeShortcutInjectable),
+ ...props,
+ }),
+ },
+);
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 | 1x +1x +1x +1x +1x +1x +1x +1x +17x +17x +1x +1x + | import React from "react";
+
+export interface KeyboardShortcutScopeProps {
+ id: string;
+ children: React.ReactNode;
+}
+
+export const KeyboardShortcutScope = ({ id, children }: KeyboardShortcutScopeProps) => (
+ <div data-keyboard-shortcut-scope={id} data-keyboard-shortcut-scope-test={id} tabIndex={-1}>
+ {children}
+ </div>
+);
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import { getInjectable } from "@ogre-tools/injectable";
+
+export const allPlatforms = ["win32", "darwin", "linux"] as const;
+
+const platformInjectable = getInjectable({
+ id: "platform",
+ instantiate: () => process.platform as (typeof allPlatforms)[number],
+ causesSideEffects: true,
+});
+
+export default platformInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| src | +
+
+ |
+ 100% | +15/15 | +100% | +3/3 | +100% | +3/3 | +100% | +15/15 | +
| src/start-application | +
+
+ |
+ 100% | +46/46 | +100% | +5/5 | +100% | +1/1 | +100% | +46/46 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 | 1x +1x +1x +1x +1x +1x +1x +5x +5x +5x +5x +5x +5x +5x +1x + | import { getFeature } from "@k8slens/feature-core";
+import { autoRegister } from "@ogre-tools/injectable-extension-for-auto-registration";
+
+export const applicationFeature = getFeature({
+ id: "application",
+
+ register: (di) => {
+ autoRegister({
+ di,
+ targetModule: module,
+
+ getRequireContexts: () => [require.context("./", true, /\.injectable\.(ts|tsx)$/)],
+ });
+ },
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| feature.ts | +
+
+ |
+ 100% | +15/15 | +100% | +3/3 | +100% | +3/3 | +100% | +15/15 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| start-application.injectable.ts | +
+
+ |
+ 100% | +32/32 | +100% | +5/5 | +100% | +1/1 | +100% | +32/32 | +
| time-slots.ts | +
+
+ |
+ 100% | +14/14 | +100% | +0/0 | +100% | +0/0 | +100% | +14/14 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +5x +5x +5x +5x +5x +5x +5x +5x +5x +4x +3x +1x +5x +1x +1x +1x +1x +1x + | import { getInjectable, getInjectionToken } from "@ogre-tools/injectable";
+import { runManyFor } from "@k8slens/run-many";
+import * as timeSlots from "./time-slots";
+
+export type StartApplication = () => Promise<void>;
+
+export const startApplicationInjectionToken = getInjectionToken<StartApplication>({
+ id: "start-application-injection-token",
+});
+
+const startApplicationInjectable = getInjectable({
+ id: "start-application",
+
+ instantiate: (di): StartApplication => {
+ const runManyAsync = runManyFor(di);
+ const beforeApplicationIsLoading = runManyAsync(
+ timeSlots.beforeApplicationIsLoadingInjectionToken,
+ );
+ const onLoadOfApplication = runManyAsync(timeSlots.onLoadOfApplicationInjectionToken);
+ const afterApplicationIsLoaded = runManyAsync(timeSlots.afterApplicationIsLoadedInjectionToken);
+
+ return async () => {
+ await beforeApplicationIsLoading();
+ await onLoadOfApplication();
+ await afterApplicationIsLoaded();
+ };
+ },
+
+ injectionToken: startApplicationInjectionToken,
+});
+
+export default startApplicationInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import { getInjectionToken } from "@ogre-tools/injectable";
+import type { Runnable } from "@k8slens/run-many";
+
+export const beforeApplicationIsLoadingInjectionToken = getInjectionToken<Runnable>({
+ id: "before-application-is-loading-injection-token",
+});
+
+export const onLoadOfApplicationInjectionToken = getInjectionToken<Runnable>({
+ id: "on-load-of-application",
+});
+
+export const afterApplicationIsLoadedInjectionToken = getInjectionToken<Runnable>({
+ id: "after-application-is-loaded-injection-token",
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| src | +
+
+ |
+ 100% | +18/18 | +100% | +3/3 | +100% | +3/3 | +100% | +18/18 | +
| src/electron | +
+
+ |
+ 100% | +14/14 | +100% | +2/2 | +100% | +2/2 | +100% | +14/14 | +
| src/start-application | +
+
+ |
+ 100% | +75/75 | +100% | +9/9 | +100% | +5/5 | +100% | +75/75 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | /**
+ * 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 { app } from "electron";
+
+const electronAppInjectable = getInjectable({
+ id: "electron-app",
+ instantiate: () => app,
+ causesSideEffects: true,
+});
+
+export default electronAppInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| electron-app.injectable.ts | +
+
+ |
+ 100% | +14/14 | +100% | +2/2 | +100% | +2/2 | +100% | +14/14 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 | 1x +1x +1x +1x +1x +1x +1x +1x +8x +8x +8x +8x +8x +8x +8x +1x +1x +1x + | import { getFeature } from "@k8slens/feature-core";
+import { autoRegister } from "@ogre-tools/injectable-extension-for-auto-registration";
+import { applicationFeature } from "@k8slens/application";
+
+export const applicationFeatureForElectronMain = getFeature({
+ id: "application-for-electron-main",
+
+ register: (di) => {
+ autoRegister({
+ di,
+ targetModule: module,
+
+ getRequireContexts: () => [require.context("./", true, /\.injectable\.(ts|tsx)$/)],
+ });
+ },
+
+ dependencies: [applicationFeature],
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| feature.ts | +
+
+ |
+ 100% | +18/18 | +100% | +3/3 | +100% | +3/3 | +100% | +18/18 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| start-electron-application.injectable.ts | +
+
+ |
+ 100% | +49/49 | +100% | +6/6 | +100% | +3/3 | +100% | +49/49 | +
| time-slots.ts | +
+
+ |
+ 100% | +10/10 | +100% | +0/0 | +100% | +0/0 | +100% | +10/10 | +
| when-app-is-ready.injectable.ts | +
+
+ |
+ 100% | +16/16 | +100% | +3/3 | +100% | +2/2 | +100% | +16/16 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +5x +5x +5x +5x +5x +5x +5x +5x +5x +5x +5x +5x +1x +1x +1x +5x +5x +1x +1x +1x +1x +1x +8x +8x +8x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import {
+ DiContainer,
+ getInjectable,
+ instantiationDecoratorToken,
+ lifecycleEnum,
+} from "@ogre-tools/injectable";
+import { startApplicationInjectionToken } from "@k8slens/application";
+import whenAppIsReadyInjectable from "./when-app-is-ready.injectable";
+import { beforeAnythingInjectionToken, beforeElectronIsReadyInjectionToken } from "./time-slots";
+import { runManySyncFor } from "@k8slens/run-many";
+import { curry } from "lodash";
+
+type ToBeDecorated = (di: DiContainer, ...args: unknown[]) => (...args: unknown[]) => unknown;
+
+const decorator = (toBeDecorated: unknown, di: DiContainer, ...args: unknown[]) => {
+ const whenAppIsReady = di.inject(whenAppIsReadyInjectable);
+ const runManySync = runManySyncFor(di);
+ const beforeAnything = runManySync(beforeAnythingInjectionToken);
+ const beforeElectronIsReady = runManySync(beforeElectronIsReadyInjectionToken);
+ const startApplication = (toBeDecorated as ToBeDecorated)(di, ...args);
+
+ return (...startApplicationArgs: unknown[]) => {
+ beforeAnything();
+ beforeElectronIsReady();
+
+ return (async () => {
+ await whenAppIsReady();
+
+ return startApplication(...startApplicationArgs);
+ })();
+ };
+};
+
+const startElectronApplicationInjectable = getInjectable({
+ id: "start-electron-application",
+
+ instantiate: () => ({
+ decorate: curry(decorator),
+ target: startApplicationInjectionToken,
+ }),
+
+ decorable: false,
+
+ injectionToken: instantiationDecoratorToken,
+
+ lifecycle: lifecycleEnum.singleton,
+});
+
+export default startElectronApplicationInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import { getInjectionToken } from "@ogre-tools/injectable";
+import type { RunnableSync } from "@k8slens/run-many";
+
+export const beforeAnythingInjectionToken = getInjectionToken<RunnableSync>({
+ id: "before-anything",
+});
+
+export const beforeElectronIsReadyInjectionToken = getInjectionToken<RunnableSync>({
+ id: "before-electron-is-ready-injection-token",
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 | 1x +1x +1x +1x +1x +1x +1x +2x +2x +2x +2x +1x +1x +1x +1x +1x + | import { getInjectable } from "@ogre-tools/injectable";
+import electronAppInjectable from "../electron/electron-app.injectable";
+
+const whenAppIsReadyInjectable = getInjectable({
+ id: "when-app-is-ready",
+
+ instantiate: (di) => {
+ const electronApp = di.inject(electronAppInjectable);
+
+ return () => electronApp.whenReady();
+ },
+
+ decorable: false,
+});
+
+export default whenAppIsReadyInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 | 1x +1x +1x +1x +1x +40x +40x +40x +77x +77x +77x +30x +37x +30x +30x +47x +77x +77x +40x +40x +40x +1x +1x +42x +42x +42x +42x +42x +2x +2x +40x +40x +40x +40x +40x +40x +40x +42x +4x +4x +4x +4x +4x +4x +36x +42x +19x +19x +19x +19x +19x +19x +19x +14x +14x +19x +36x +41x +23x +23x +23x +23x +36x +42x +19x +19x +42x +1x +1x +19x +23x +23x +19x + | import type { DiContainer } from "@ogre-tools/injectable";
+import type { Feature } from "./feature";
+import { featureContextMapInjectable } from "./feature-context-map-injectable";
+
+const getDependingFeaturesFor = (
+ featureContextMap: Map<Feature, { dependedBy: Map<Feature, number> }>,
+) => {
+ const getDependingFeaturesForRecursion = (feature: Feature, atRoot = true): string[] => {
+ const context = featureContextMap.get(feature);
+
+ if (context?.dependedBy.size) {
+ return [...context?.dependedBy.entries()].flatMap(([dependant]) =>
+ getDependingFeaturesForRecursion(dependant, false),
+ );
+ }
+
+ return atRoot ? [] : [feature.id];
+ };
+
+ return getDependingFeaturesForRecursion;
+};
+
+const deregisterFeatureRecursed = (di: DiContainer, feature: Feature, dependedBy?: Feature) => {
+ const featureContextMap = di.inject(featureContextMapInjectable);
+
+ const featureContext = featureContextMap.get(feature);
+
+ if (!featureContext) {
+ throw new Error(`Tried to deregister feature "${feature.id}", but it was not registered.`);
+ }
+
+ featureContext.numberOfRegistrations--;
+
+ const getDependingFeatures = getDependingFeaturesFor(featureContextMap);
+
+ const dependingFeatures = getDependingFeatures(feature);
+
+ if (!dependedBy && dependingFeatures.length) {
+ throw new Error(
+ `Tried to deregister Feature "${
+ feature.id
+ }", but it is the dependency of Features "${dependingFeatures.join(", ")}"`,
+ );
+ }
+
+ if (dependedBy) {
+ // eslint-disable-next-line @typescript-eslint/no-non-null-assertion
+ const oldNumberOfDependents = featureContext.dependedBy.get(dependedBy)!;
+ const newNumberOfDependants = oldNumberOfDependents - 1;
+
+ featureContext.dependedBy.set(dependedBy, newNumberOfDependants);
+
+ if (newNumberOfDependants === 0) {
+ featureContext.dependedBy.delete(dependedBy);
+ }
+ }
+
+ if (featureContext.numberOfRegistrations === 0) {
+ featureContextMap.delete(feature);
+
+ featureContext.deregister();
+ }
+
+ feature.dependencies?.forEach((dependency) => {
+ deregisterFeatureRecursed(di, dependency, feature);
+ });
+};
+
+export const deregisterFeature = (di: DiContainer, ...features: Feature[]) => {
+ features.forEach((feature) => {
+ deregisterFeatureRecursed(di, feature);
+ });
+};
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import { getInjectable, getInjectionToken } from "@ogre-tools/injectable";
+import type { Feature } from "./feature";
+
+export type FeatureContextMap = Map<
+ Feature,
+ {
+ register: () => void;
+ deregister: () => void;
+ dependedBy: Map<Feature, number>;
+ numberOfRegistrations: number;
+ }
+>;
+
+export const featureContextMapInjectionToken = getInjectionToken<FeatureContextMap>({
+ id: "feature-context-map-injection-token",
+});
+
+const featureContextMapInjectable = getInjectable({
+ id: "feature-store",
+
+ instantiate: (): FeatureContextMap => new Map(),
+
+ injectionToken: featureContextMapInjectionToken,
+});
+
+export { featureContextMapInjectable };
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import type { DiContainerForInjection } from "@ogre-tools/injectable";
+
+export interface Feature {
+ id: string;
+ register: (di: DiContainerForInjection) => void;
+ dependencies?: Feature[];
+}
+
+export interface GetFeatureArgs extends Feature {}
+
+export const getFeature = (getFeatureArgs: GetFeatureArgs): Feature => getFeatureArgs;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| deregister-feature.ts | +
+
+ |
+ 100% | +73/73 | +100% | +26/26 | +100% | +5/5 | +100% | +73/73 | +
| feature-context-map-injectable.ts | +
+
+ |
+ 100% | +26/26 | +100% | +1/1 | +100% | +1/1 | +100% | +26/26 | +
| feature.ts | +
+
+ |
+ 100% | +11/11 | +100% | +2/2 | +100% | +2/2 | +100% | +11/11 | +
| register-feature.ts | +
+
+ |
+ 100% | +80/80 | +100% | +20/20 | +100% | +7/7 | +100% | +80/80 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +58x +58x +58x +58x +58x +58x +58x +58x +58x +23x +23x +58x +58x +58x +58x +58x +58x +58x +58x +58x +58x +58x +58x +58x +58x +58x +58x +58x +58x +1x +1x +79x +79x +79x +21x +21x +79x +79x +79x +79x +79x +79x +1x +1x +78x +78x +79x +79x +79x +79x +34x +34x +34x +34x +34x +34x +78x +78x +58x +58x +78x +79x +34x +34x +79x +1x +1x +31x +45x +45x +31x + | import type { DiContainer } from "@ogre-tools/injectable";
+import { getInjectable } from "@ogre-tools/injectable";
+import type { Feature } from "./feature";
+import {
+ featureContextMapInjectable,
+ featureContextMapInjectionToken,
+} from "./feature-context-map-injectable";
+
+const createFeatureContext = (feature: Feature, di: DiContainer) => {
+ const featureContextInjectable = getInjectable({
+ id: feature.id,
+
+ instantiate: (diForContextOfFeature) => ({
+ register: () => {
+ feature.register(diForContextOfFeature);
+ },
+
+ deregister: () => {
+ diForContextOfFeature.deregister(featureContextInjectable);
+ },
+
+ dependedBy: new Map<Feature, number>(),
+
+ numberOfRegistrations: 0,
+ }),
+
+ scope: true,
+ });
+
+ di.register(featureContextInjectable);
+
+ const featureContextMap = di.inject(featureContextMapInjectable);
+ const featureContext = di.inject(featureContextInjectable);
+
+ featureContextMap.set(feature, featureContext);
+
+ return featureContext;
+};
+
+const registerFeatureRecursed = (di: DiContainer, feature: Feature, dependedBy?: Feature) => {
+ const featureContextMaps = di.injectMany(featureContextMapInjectionToken);
+
+ if (featureContextMaps.length === 0) {
+ di.register(featureContextMapInjectable);
+ }
+
+ const featureContextMap = di.inject(featureContextMapInjectable);
+
+ const existingFeatureContext = featureContextMap.get(feature);
+
+ if (!dependedBy && existingFeatureContext && existingFeatureContext.dependedBy.size === 0) {
+ throw new Error(`Tried to register feature "${feature.id}", but it was already registered.`);
+ }
+
+ const featureContext = existingFeatureContext || createFeatureContext(feature, di);
+
+ featureContext.numberOfRegistrations++;
+
+ if (dependedBy) {
+ const oldNumberOfDependents = featureContext.dependedBy.get(dependedBy) || 0;
+
+ const newNumberOfDependants = oldNumberOfDependents + 1;
+
+ featureContext.dependedBy.set(dependedBy, newNumberOfDependants);
+ }
+
+ if (!existingFeatureContext) {
+ featureContext.register();
+ }
+
+ feature.dependencies?.forEach((dependency) => {
+ registerFeatureRecursed(di, dependency, feature);
+ });
+};
+
+export const registerFeature = (di: DiContainer, ...features: Feature[]) => {
+ features.forEach((feature) => {
+ registerFeatureRecursed(di, feature);
+ });
+};
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +13x +13x +13x +13x +13x +13x +13x +1x + | import { autoRegister } from "@ogre-tools/injectable-extension-for-auto-registration";
+import { applicationFeature } from "@k8slens/application";
+import { getFeature } from "@k8slens/feature-core";
+
+export const messagingFeature = getFeature({
+ id: "messaging",
+
+ dependencies: [applicationFeature],
+
+ register: (di) => {
+ autoRegister({
+ di,
+ targetModule: module,
+
+ getRequireContexts: () => [require.context("./", true, /\.injectable\.(ts|tsx)$/)],
+ });
+ },
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| feature.ts | +
+
+ |
+ 100% | +18/18 | +100% | +3/3 | +100% | +3/3 | +100% | +18/18 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| listening-of-channels.injectable.ts | +
+
+ |
+ 100% | +113/113 | +100% | +18/18 | +100% | +4/4 | +100% | +113/113 | +
| start-listening-of-channels.injectable.ts | +
+
+ |
+ 100% | +21/21 | +100% | +3/3 | +100% | +3/3 | +100% | +21/21 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 +99 +100 +101 +102 +103 +104 +105 +106 +107 +108 +109 +110 +111 +112 +113 +114 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +26x +26x +26x +26x +26x +26x +26x +26x +26x +26x +26x +45x +45x +45x +45x +45x +45x +45x +45x +45x +24x +24x +24x +1x +1x +1x +1x +23x +23x +23x +23x +23x +45x +45x +8x +8x +8x +8x +8x +8x +45x +26x +26x +26x +26x +26x +8x +8x +8x +26x +1x +1x +1x +1x +1x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +4x +4x +4x +13x +13x +1x +1x +1x +1x +1x + | import { getInjectable, getInjectionToken } from "@ogre-tools/injectable";
+import { enlistMessageChannelListenerInjectionToken } from "../message/enlist-message-channel-listener-injection-token";
+
+import { getStartableStoppable, StartableStoppable } from "@k8slens/startable-stoppable";
+
+import { computedInjectManyInjectable } from "@ogre-tools/injectable-extension-for-mobx";
+import { IComputedValue, reaction } from "mobx";
+
+import {
+ MessageChannel,
+ messageChannelListenerInjectionToken,
+} from "../message/message-channel-listener-injection-token";
+import {
+ RequestChannel,
+ requestChannelListenerInjectionToken,
+} from "../request/request-channel-listener-injection-token";
+import { enlistRequestChannelListenerInjectionToken } from "../request/enlist-request-channel-listener-injection-token";
+
+export type ListeningOfChannels = StartableStoppable;
+export const listeningOfChannelsInjectionToken = getInjectionToken<ListeningOfChannels>({
+ id: "listening-of-channels-injection-token",
+});
+
+const listening = <
+ T extends { id: string; channel: MessageChannel<any> | RequestChannel<any, any> },
+>(
+ channelListeners: IComputedValue<T[]>,
+ enlistChannelListener: (listener: T) => () => void,
+ getId: (listener: T) => string,
+) => {
+ const listenerDisposers = new Map<string, () => void>();
+
+ const reactionDisposer = reaction(
+ () => channelListeners.get(),
+ (newValues, oldValues = []) => {
+ const addedListeners = newValues.filter(
+ (newValue) => !oldValues.some((oldValue) => oldValue.id === newValue.id),
+ );
+
+ const removedListeners = oldValues.filter(
+ (oldValue) => !newValues.some((newValue) => newValue.id === oldValue.id),
+ );
+
+ addedListeners.forEach((listener) => {
+ const id = getId(listener);
+
+ if (listenerDisposers.has(id)) {
+ throw new Error(
+ `Tried to add listener for channel "${listener.channel.id}" but listener already exists.`,
+ );
+ }
+
+ const disposer = enlistChannelListener(listener);
+
+ listenerDisposers.set(id, disposer);
+ });
+
+ removedListeners.forEach((listener) => {
+ const dispose = listenerDisposers.get(getId(listener));
+
+ dispose?.();
+
+ listenerDisposers.delete(getId(listener));
+ });
+ },
+
+ { fireImmediately: true },
+ );
+
+ return () => {
+ reactionDisposer();
+ listenerDisposers.forEach((dispose) => dispose());
+ };
+};
+
+const listeningOfChannelsInjectable = getInjectable({
+ id: "listening-of-channels",
+
+ instantiate: (di) => {
+ const enlistMessageChannelListener = di.inject(enlistMessageChannelListenerInjectionToken);
+
+ const enlistRequestChannelListener = di.inject(enlistRequestChannelListenerInjectionToken);
+
+ const computedInjectMany = di.inject(computedInjectManyInjectable);
+
+ const messageChannelListeners = computedInjectMany(messageChannelListenerInjectionToken);
+
+ const requestChannelListeners = computedInjectMany(requestChannelListenerInjectionToken);
+
+ return getStartableStoppable("listening-of-channels", () => {
+ const stopListeningOfMessageChannels = listening(
+ messageChannelListeners,
+ enlistMessageChannelListener,
+ (x) => x.id,
+ );
+
+ const stopListeningOfRequestChannels = listening(
+ requestChannelListeners,
+ enlistRequestChannelListener,
+ (x) => x.channel.id,
+ );
+
+ return () => {
+ stopListeningOfMessageChannels();
+ stopListeningOfRequestChannels();
+ };
+ });
+ },
+
+ injectionToken: listeningOfChannelsInjectionToken,
+});
+
+export default listeningOfChannelsInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 | 1x +1x +1x +1x +1x +1x +1x +1x +13x +13x +13x +13x +13x +13x +13x +13x +1x +1x +1x +1x +1x + | import { getInjectable } from "@ogre-tools/injectable";
+import { onLoadOfApplicationInjectionToken } from "@k8slens/application";
+import { listeningOfChannelsInjectionToken } from "./listening-of-channels.injectable";
+
+const startListeningOfChannelsInjectable = getInjectable({
+ id: "start-listening-of-channels",
+
+ instantiate: (di) => {
+ const listeningOfChannels = di.inject(listeningOfChannelsInjectionToken);
+
+ return {
+ run: async () => {
+ await listeningOfChannels.start();
+ },
+ };
+ },
+
+ injectionToken: onLoadOfApplicationInjectionToken,
+});
+
+export default startListeningOfChannelsInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import type { Disposer } from "@k8slens/utilities";
+import { getInjectionToken } from "@ogre-tools/injectable";
+
+import type {
+ MessageChannel,
+ MessageChannelListener,
+} from "./message-channel-listener-injection-token";
+
+export type EnlistMessageChannelListener = <T>(
+ listener: MessageChannelListener<MessageChannel<T>>,
+) => Disposer;
+
+export const enlistMessageChannelListenerInjectionToken =
+ getInjectionToken<EnlistMessageChannelListener>({
+ id: "listening-to-a-message-channel",
+ });
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 | 1x +1x +1x +6x +6x + | import type { MessageChannel } from "./message-channel-listener-injection-token";
+
+export const getMessageChannel = <Request>(id: string): MessageChannel<Request> => ({
+ id,
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| enlist-message-channel-listener-injection-token.ts | +
+
+ |
+ 100% | +16/16 | +100% | +1/1 | +100% | +1/1 | +100% | +16/16 | +
| get-message-channel.ts | +
+
+ |
+ 100% | +5/5 | +100% | +2/2 | +100% | +2/2 | +100% | +5/5 | +
| message-channel-listener-injection-token.ts | +
+
+ |
+ 100% | +51/51 | +100% | +2/2 | +100% | +2/2 | +100% | +51/51 | +
| message-to-channel-injection-token.ts | +
+
+ |
+ 100% | +11/11 | +100% | +1/1 | +100% | +1/1 | +100% | +11/11 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +11x +11x +11x +11x +11x +11x +11x +11x +11x +11x +11x +11x +11x +11x +11x +11x +11x + | import type { DiContainerForInjection } from "@ogre-tools/injectable";
+import { getInjectable, getInjectionToken } from "@ogre-tools/injectable";
+
+export interface MessageChannel<Message> {
+ id: string;
+ _messageSignature?: Message;
+}
+
+export type ExtraData = { processId: number; frameId: number };
+
+export type MessageChannelHandler<Channel> = Channel extends MessageChannel<infer Message>
+ ? (message: Message, data?: ExtraData) => void
+ : never;
+
+export interface MessageChannelListener<Channel> {
+ id: string;
+ 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;
+ getHandler: (di: DiContainerForInjection) => MessageChannelHandler<Channel>;
+ causesSideEffects?: boolean;
+}
+
+export const getMessageChannelListenerInjectable = <
+ Channel extends MessageChannel<Message>,
+ Message,
+>(
+ info: GetMessageChannelListenerInfo<Channel, Message>,
+) =>
+ getInjectable({
+ id: `${info.channel.id}-message-listener-${info.id}`,
+
+ instantiate: (di): MessageChannelListener<Channel> => ({
+ id: `${info.channel.id}-message-listener-${info.id}`,
+ channel: info.channel,
+ handler: info.getHandler(di),
+ }),
+
+ injectionToken: messageChannelListenerInjectionToken,
+ causesSideEffects: info.causesSideEffects,
+ });
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import { getInjectionToken } from "@ogre-tools/injectable";
+import type { MessageChannel } from "./message-channel-listener-injection-token";
+
+export interface SendMessageToChannel {
+ (channel: MessageChannel<void>): void;
+ <Message>(channel: MessageChannel<Message>, message: Message): void;
+}
+
+export const sendMessageToChannelInjectionToken = getInjectionToken<SendMessageToChannel>({
+ id: "send-message-to-message-channel",
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import type { Disposer } from "@k8slens/utilities/index";
+import { getInjectionToken } from "@ogre-tools/injectable";
+
+import type {
+ RequestChannel,
+ RequestChannelListener,
+} from "./request-channel-listener-injection-token";
+
+export type EnlistRequestChannelListener = <Request, Response>(
+ listener: RequestChannelListener<RequestChannel<Request, Response>>,
+) => Disposer;
+
+export const enlistRequestChannelListenerInjectionToken =
+ getInjectionToken<EnlistRequestChannelListener>({
+ id: "listening-to-a-request-channel",
+ });
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 | 1x +1x +1x +14x +14x +14x +14x + | import type { RequestChannel } from "./request-channel-listener-injection-token";
+
+export const getRequestChannel = <Request, Response>(
+ id: string,
+): RequestChannel<Request, Response> => ({
+ id,
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| enlist-request-channel-listener-injection-token.ts | +
+
+ |
+ 100% | +16/16 | +100% | +1/1 | +100% | +1/1 | +100% | +16/16 | +
| get-request-channel.ts | +
+
+ |
+ 100% | +7/7 | +100% | +2/2 | +100% | +2/2 | +100% | +7/7 | +
| request-channel-listener-injection-token.ts | +
+
+ |
+ 100% | +56/56 | +100% | +2/2 | +100% | +2/2 | +100% | +56/56 | +
| request-from-channel-injection-token.ts | +
+
+ |
+ 100% | +21/21 | +100% | +1/1 | +100% | +1/1 | +100% | +21/21 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x +13x + | import type { DiContainerForInjection } from "@ogre-tools/injectable";
+import { getInjectable, getInjectionToken } from "@ogre-tools/injectable";
+
+export interface RequestChannel<Request, Response> {
+ id: string;
+ _requestSignature?: Request;
+ _responseSignature?: Response;
+}
+
+export type RequestChannelHandler<Channel> = Channel extends RequestChannel<
+ infer Request,
+ infer Response
+>
+ ? (req: Request) => Promise<Response> | Response
+ : never;
+
+export interface RequestChannelListener<Channel> {
+ id: string;
+ channel: Channel;
+ handler: RequestChannelHandler<Channel>;
+}
+
+export const requestChannelListenerInjectionToken = getInjectionToken<
+ RequestChannelListener<RequestChannel<unknown, unknown>>
+>({
+ id: "request-channel-listener",
+});
+
+export interface GetRequestChannelListenerInjectableInfo<
+ Channel extends RequestChannel<Request, Response>,
+ Request,
+ Response,
+> {
+ id: string;
+ channel: Channel;
+ getHandler: (di: DiContainerForInjection) => RequestChannelHandler<Channel>;
+}
+
+export const getRequestChannelListenerInjectable = <
+ Channel extends RequestChannel<Request, Response>,
+ Request,
+ Response,
+>(
+ info: GetRequestChannelListenerInjectableInfo<Channel, Request, Response>,
+) =>
+ getInjectable({
+ id: `${info.channel.id}-request-listener-${info.id}`,
+
+ instantiate: (di) => ({
+ id: `${info.channel.id}-request-listener-${info.id}`,
+ channel: info.channel,
+ handler: info.getHandler(di),
+ }),
+
+ injectionToken: requestChannelListenerInjectionToken,
+ });
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import { getInjectionToken } from "@ogre-tools/injectable";
+import type { RequestChannel } from "./request-channel-listener-injection-token";
+
+export interface RequestFromChannel {
+ <Request, Response>(
+ channel: RequestChannel<Request, Response>,
+ request: Request,
+ ): Promise<Response>;
+ <Response>(channel: RequestChannel<void, Response>): Promise<Response>;
+}
+
+export type ChannelRequester<Channel> = Channel extends RequestChannel<
+ infer Request,
+ infer Response
+>
+ ? (req: Request) => Promise<Awaited<Response>>
+ : never;
+
+export const requestFromChannelInjectionToken = getInjectionToken<RequestFromChannel>({
+ id: "request-from-request-channel",
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| actual | +
+
+ |
+ 100% | +18/18 | +100% | +3/3 | +100% | +3/3 | +100% | +18/18 | +
| actual/listening-of-channels | +
+
+ |
+ 100% | +134/134 | +100% | +21/21 | +100% | +7/7 | +100% | +134/134 | +
| actual/message | +
+
+ |
+ 100% | +83/83 | +100% | +6/6 | +100% | +6/6 | +100% | +83/83 | +
| actual/request | +
+
+ |
+ 100% | +100/100 | +100% | +6/6 | +100% | +6/6 | +100% | +100/100 | +
| unit-testing | +
+
+ |
+ 100% | +49/49 | +100% | +5/5 | +100% | +7/7 | +100% | +49/49 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +13x +13x +13x +13x +13x +13x +13x +1x + | import { autoRegister } from "@ogre-tools/injectable-extension-for-auto-registration";
+import { getFeature } from "@k8slens/feature-core";
+import { messagingFeature } from "../actual/feature";
+
+export const messagingFeatureForUnitTesting = getFeature({
+ id: "messaging-for-unit-testing",
+
+ dependencies: [messagingFeature],
+
+ register: (di) => {
+ autoRegister({
+ di,
+ targetModule: module,
+
+ getRequireContexts: () => [require.context("./", true, /\.injectable\.(ts|tsx)$/)],
+ });
+ },
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| feature.ts | +
+
+ |
+ 100% | +18/18 | +100% | +3/3 | +100% | +3/3 | +100% | +18/18 | +
| test-doubles.injectable.ts | +
+
+ |
+ 100% | +31/31 | +100% | +2/2 | +100% | +4/4 | +100% | +31/31 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import { sendMessageToChannelInjectionToken } from "../actual/message/message-to-channel-injection-token";
+import { enlistMessageChannelListenerInjectionToken } from "../actual/message/enlist-message-channel-listener-injection-token";
+import { requestFromChannelInjectionToken } from "../actual/request/request-from-channel-injection-token";
+import { enlistRequestChannelListenerInjectionToken } from "../actual/request/enlist-request-channel-listener-injection-token";
+import { getInjectable } from "@ogre-tools/injectable";
+
+export const sendMessageToChannelStubInjectable = getInjectable({
+ id: "send-message-to-channel-stub",
+ /* c8 ignore next */
+ instantiate: () => () => {},
+ injectionToken: sendMessageToChannelInjectionToken,
+});
+
+export const enlistMessageChannelListenerStubInjectable = getInjectable({
+ id: "enlist-message-channel-listener-stub",
+ instantiate: () => () => () => {},
+ injectionToken: enlistMessageChannelListenerInjectionToken,
+});
+
+export const requestFromChannelStubInjectable = getInjectable({
+ id: "request-from-channel-stub",
+ /* c8 ignore next */
+ instantiate: () => () => Promise.resolve(),
+ injectionToken: requestFromChannelInjectionToken,
+});
+
+export const enlistRequestChannelListenerStubInjectable = getInjectable({
+ id: "enlist-request-channel-listener-stub",
+ instantiate: () => () => () => {},
+ injectionToken: enlistRequestChannelListenerInjectionToken,
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| src | +
+
+ |
+ 100% | +18/18 | +100% | +3/3 | +100% | +3/3 | +100% | +18/18 | +
| src/computed-channel | +
+
+ |
+ 100% | +190/190 | +100% | +28/28 | +100% | +8/8 | +100% | +190/190 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +90x +90x +90x +90x +90x +65x +48x +48x +48x +48x +48x +1x +1x +47x +47x +47x +47x +53x +53x +53x +53x +53x +53x +47x +47x +47x +47x +47x +47x +47x +65x +17x +17x +17x +17x +65x +90x +1x + | import { reaction } from "mobx";
+import { getMessageChannelListenerInjectable } from "@k8slens/messaging";
+import { sendMessageToChannelInjectionToken } from "@k8slens/messaging";
+import { computedChannelObserverInjectionToken } from "./computed-channel.injectable";
+import { getMessageChannel } from "@k8slens/messaging";
+
+export type ComputedChannelAdminMessage = {
+ channelId: string;
+ status: "became-observed" | "became-unobserved";
+};
+
+export const computedChannelAdministrationChannel = getMessageChannel<ComputedChannelAdminMessage>(
+ "computed-channel-administration-channel",
+);
+
+export const computedChannelAdministrationListenerInjectable = getMessageChannelListenerInjectable({
+ id: "computed-channel-administration",
+ channel: computedChannelAdministrationChannel,
+
+ getHandler: (di) => {
+ const sendMessageToChannel = di.inject(sendMessageToChannelInjectionToken);
+
+ const disposersByChannelId = new Map<string, () => void>();
+
+ return (message) => {
+ if (message.status === "became-observed") {
+ const result = di
+ .injectMany(computedChannelObserverInjectionToken)
+ .find((channelObserver) => channelObserver.channel.id === message.channelId);
+
+ if (result === undefined) {
+ return;
+ }
+
+ const disposer = reaction(
+ () => result.observer.get(),
+ (observed) =>
+ sendMessageToChannel(
+ {
+ id: message.channelId,
+ },
+
+ observed,
+ ),
+ {
+ fireImmediately: true,
+ },
+ );
+
+ disposersByChannelId.set(message.channelId, disposer);
+ } else {
+ const disposer = disposersByChannelId.get(message.channelId);
+
+ disposer?.();
+ }
+ };
+ },
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +45x +45x +45x +47x +47x +47x +47x +47x +47x +47x +47x +47x +50x +50x +50x +50x +47x +47x +47x +47x +47x +47x +47x +51x +51x +51x +51x +51x +51x +51x +51x +51x +47x +47x +18x +18x +18x +18x +18x +18x +18x +18x +18x +47x +47x +47x +45x +1x +1x +1x +1x +1x + | import { getInjectable, getInjectionToken } from "@ogre-tools/injectable";
+
+import {
+ computed,
+ IComputedValue,
+ observable,
+ onBecomeObserved,
+ onBecomeUnobserved,
+ runInAction,
+} from "mobx";
+
+import type { MessageChannel } from "@k8slens/messaging";
+import { getMessageChannelListenerInjectable } from "@k8slens/messaging";
+import { sendMessageToChannelInjectionToken } from "@k8slens/messaging";
+import { computedChannelAdministrationChannel } from "./computed-channel-administration-channel.injectable";
+
+export type ComputedChannelFactory = <T>(
+ channel: MessageChannel<T>,
+ pendingValue: T,
+) => IComputedValue<T>;
+
+export const computedChannelInjectionToken = getInjectionToken<ComputedChannelFactory>({
+ id: "computed-channel-injection-token",
+});
+
+export type ChannelObserver<T> = {
+ channel: MessageChannel<T>;
+ observer: IComputedValue<T>;
+};
+
+export const computedChannelObserverInjectionToken = getInjectionToken<ChannelObserver<unknown>>({
+ id: "computed-channel-observer",
+});
+
+const computedChannelInjectable = getInjectable({
+ id: "computed-channel",
+
+ instantiate: (di) => {
+ const sendMessageToChannel = di.inject(sendMessageToChannelInjectionToken);
+
+ return ((channel, pendingValue) => {
+ const observableValue = observable.box(pendingValue);
+
+ const computedValue = computed(() => observableValue.get());
+
+ const valueReceiverInjectable = getMessageChannelListenerInjectable({
+ id: `computed-channel-value-receiver-for-${channel.id}`,
+ channel,
+
+ getHandler: () => (message) => {
+ runInAction(() => {
+ observableValue.set(message);
+ });
+ },
+ });
+
+ runInAction(() => {
+ di.register(valueReceiverInjectable);
+ });
+
+ onBecomeObserved(computedValue, () => {
+ runInAction(() => {
+ observableValue.set(pendingValue);
+ });
+
+ sendMessageToChannel(computedChannelAdministrationChannel, {
+ channelId: channel.id,
+ status: "became-observed",
+ });
+ });
+
+ onBecomeUnobserved(computedValue, () => {
+ runInAction(() => {
+ observableValue.set(pendingValue);
+ });
+
+ sendMessageToChannel(computedChannelAdministrationChannel, {
+ channelId: channel.id,
+ status: "became-unobserved",
+ });
+ });
+
+ return computedValue;
+ }) as ComputedChannelFactory;
+ },
+
+ injectionToken: computedChannelInjectionToken,
+});
+
+export default computedChannelInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +90x +90x +90x +90x +90x +90x +90x +47x +47x +47x +47x +47x +47x +47x +47x +47x +2x +2x +2x +2x +2x +2x +47x +90x +90x +90x +90x +1x +1x +1x + | import { onLoadOfApplicationInjectionToken } from "@k8slens/application";
+import { pipeline } from "@ogre-tools/fp";
+import { getInjectable } from "@ogre-tools/injectable";
+import { computedInjectManyInjectable } from "@ogre-tools/injectable-extension-for-mobx";
+import { filter, groupBy, nth, map, toPairs } from "lodash/fp";
+import { reaction } from "mobx";
+import { computedChannelObserverInjectionToken } from "./computed-channel.injectable";
+
+export const duplicateChannelObserverGuardInjectable = getInjectable({
+ id: "duplicate-channel-observer-guard",
+
+ instantiate: (di) => {
+ const computedInjectMany = di.inject(computedInjectManyInjectable);
+
+ return {
+ run: () => {
+ reaction(
+ () => computedInjectMany(computedChannelObserverInjectionToken).get(),
+ (observers) => {
+ const duplicateObserverChannelIds = pipeline(
+ observers,
+ groupBy((observer) => observer.channel.id),
+ toPairs,
+ filter(([, channelObservers]) => channelObservers.length > 1),
+ map(nth(0)),
+ );
+
+ if (duplicateObserverChannelIds.length) {
+ throw new Error(
+ `Tried to register duplicate channel observer for channels "${duplicateObserverChannelIds.join(
+ '", "',
+ )}"`,
+ );
+ }
+ },
+ );
+ },
+ };
+ },
+
+ injectionToken: onLoadOfApplicationInjectionToken,
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| computed-channel-administration-channel.injectable.ts | +
+
+ |
+ 100% | +58/58 | +100% | +9/9 | +100% | +3/3 | +100% | +58/58 | +
| computed-channel.injectable.ts | +
+
+ |
+ 100% | +90/90 | +100% | +11/11 | +100% | +2/2 | +100% | +90/90 | +
| duplicate-channel-observer-guard.injectable.ts | +
+
+ |
+ 100% | +42/42 | +100% | +8/8 | +100% | +3/3 | +100% | +42/42 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +90x +90x +90x +90x +90x +90x +90x +1x + | import { autoRegister } from "@ogre-tools/injectable-extension-for-auto-registration";
+import { getFeature } from "@k8slens/feature-core";
+import { messagingFeature } from "@k8slens/messaging";
+
+export const computedChannelFeature = getFeature({
+ id: "computed-channel",
+
+ dependencies: [messagingFeature],
+
+ register: (di) => {
+ autoRegister({
+ di,
+ targetModule: module,
+
+ getRequireContexts: () => [require.context("./", true, /\.injectable\.(ts|tsx)$/)],
+ });
+ },
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| feature.ts | +
+
+ |
+ 100% | +18/18 | +100% | +3/3 | +100% | +3/3 | +100% | +18/18 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| src | +
+
+ |
+ 100% | +18/18 | +100% | +3/3 | +100% | +3/3 | +100% | +18/18 | +
| src/channel-listeners | +
+
+ |
+ 100% | +59/59 | +100% | +10/10 | +100% | +6/6 | +100% | +59/59 | +
| src/ipc-main | +
+
+ |
+ 100% | +10/10 | +100% | +2/2 | +100% | +2/2 | +100% | +10/10 | +
| src/request-from-channel | +
+
+ |
+ 100% | +23/23 | +100% | +1/1 | +100% | +2/2 | +100% | +23/23 | +
| src/send-message-to-channel | +
+
+ |
+ 100% | +89/89 | +100% | +18/18 | +100% | +12/12 | +100% | +89/89 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +8x +8x +8x +8x +5x +5x +8x +8x +8x +8x +1x +1x +8x +8x +1x +1x +1x +1x +1x + | import { getInjectable } from "@ogre-tools/injectable";
+import type { IpcMainEvent } from "electron";
+import ipcMainInjectable from "../ipc-main/ipc-main.injectable";
+import { enlistMessageChannelListenerInjectionToken } from "@k8slens/messaging";
+
+const enlistMessageChannelListenerInjectable = getInjectable({
+ id: "enlist-message-channel-listener",
+
+ instantiate: (di) => {
+ const ipcMain = di.inject(ipcMainInjectable);
+
+ return ({ channel, handler }) => {
+ const nativeOnCallback = (nativeEvent: IpcMainEvent, message: any) => {
+ handler(message, { frameId: nativeEvent.frameId, processId: nativeEvent.processId });
+ };
+
+ ipcMain.on(channel.id, nativeOnCallback);
+
+ return () => {
+ ipcMain.off(channel.id, nativeOnCallback);
+ };
+ };
+ },
+
+ injectionToken: enlistMessageChannelListenerInjectionToken,
+});
+
+export default enlistMessageChannelListenerInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +13x +13x +13x +13x +13x +13x +13x +13x +1x +1x +13x +13x +1x +1x +1x +1x +1x + | import { getInjectable } from "@ogre-tools/injectable";
+import type { IpcMainInvokeEvent } from "electron";
+import ipcMainInjectable from "../ipc-main/ipc-main.injectable";
+import type { RequestChannel, RequestChannelListener } from "@k8slens/messaging";
+import { enlistRequestChannelListenerInjectionToken } from "@k8slens/messaging";
+
+export type EnlistRequestChannelListener = <TChannel extends RequestChannel<unknown, unknown>>(
+ listener: RequestChannelListener<TChannel>,
+) => () => void;
+
+const enlistRequestChannelListenerInjectable = getInjectable({
+ id: "enlist-request-channel-listener-for-main",
+
+ instantiate: (di): EnlistRequestChannelListener => {
+ const ipcMain = di.inject(ipcMainInjectable);
+
+ return ({ channel, handler }) => {
+ const nativeHandleCallback = (_: IpcMainInvokeEvent, request: unknown) => handler(request);
+
+ ipcMain.handle(channel.id, nativeHandleCallback);
+
+ return () => {
+ ipcMain.off(channel.id, nativeHandleCallback);
+ };
+ };
+ },
+
+ injectionToken: enlistRequestChannelListenerInjectionToken,
+});
+
+export default enlistRequestChannelListenerInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| enlist-message-channel-listener.injectable.ts | +
+
+ |
+ 100% | +28/28 | +100% | +5/5 | +100% | +3/3 | +100% | +28/28 | +
| enlist-request-channel-listener.injectable.ts | +
+
+ |
+ 100% | +31/31 | +100% | +5/5 | +100% | +3/3 | +100% | +31/31 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 | 1x +1x +1x +1x +1x +1x +1x +1x +27x +27x +27x +27x +27x +27x +27x +1x +1x +1x + | import { autoRegister } from "@ogre-tools/injectable-extension-for-auto-registration";
+import { getFeature } from "@k8slens/feature-core";
+import { messagingFeature } from "@k8slens/messaging";
+
+export const messagingFeatureForMain = getFeature({
+ id: "messaging-for-main",
+
+ register: (di) => {
+ autoRegister({
+ di,
+ targetModule: module,
+
+ getRequireContexts: () => [require.context("./", true, /\.injectable\.(ts|tsx)$/)],
+ });
+ },
+
+ dependencies: [messagingFeature],
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| feature.ts | +
+
+ |
+ 100% | +18/18 | +100% | +3/3 | +100% | +3/3 | +100% | +18/18 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| ipc-main.injectable.ts | +
+
+ |
+ 100% | +10/10 | +100% | +2/2 | +100% | +2/2 | +100% | +10/10 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import { getInjectable } from "@ogre-tools/injectable";
+import { ipcMain } from "electron";
+
+const ipcMainInjectable = getInjectable({
+ id: "ipc-main",
+ instantiate: () => ipcMain,
+ causesSideEffects: true,
+});
+
+export default ipcMainInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| request-from-channel.injectable.ts | +
+
+ |
+ 100% | +23/23 | +100% | +1/1 | +100% | +2/2 | +100% | +23/23 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | /* c8 ignore start */
+import { getInjectable } from "@ogre-tools/injectable";
+import {
+ RequestChannel,
+ RequestFromChannel,
+ requestFromChannelInjectionToken,
+} from "@k8slens/messaging";
+
+const requestFromChannelInjectable = getInjectable({
+ id: "request-from-channel",
+
+ instantiate: () =>
+ ((channel: RequestChannel<any, any>) => {
+ throw new Error(
+ `Tried to request from channel "${channel.id}" but requesting in "main" it's not supported yet`,
+ );
+ }) as unknown as RequestFromChannel,
+
+ injectionToken: requestFromChannelInjectionToken,
+});
+
+export default requestFromChannelInjectable;
+/* c8 ignore stop */
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +2x +2x +2x +4x +4x +2x +1x +1x +1x + | import { getMessageChannel, getMessageChannelListenerInjectable } from "@k8slens/messaging";
+import frameIdsInjectable from "./frameIds.injectable";
+
+const frameCommunicationAdminChannel = getMessageChannel<undefined>(
+ "frame-communication-admin-channel",
+);
+
+const allowCommunicationListenerInjectable = getMessageChannelListenerInjectable({
+ id: "allow-communication",
+ channel: frameCommunicationAdminChannel,
+
+ getHandler: (di) => {
+ const frameIds = di.inject(frameIdsInjectable);
+
+ return (_, { frameId, processId }) => {
+ frameIds.add({ frameId, processId });
+ };
+ },
+});
+
+export default allowCommunicationListenerInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 | 1x +1x +1x +1x +1x +1x +1x +1x + | import { getInjectable } from "@ogre-tools/injectable";
+
+const frameIdsInjectable = getInjectable({
+ id: "frame-ids",
+ instantiate: () => new Set<{ frameId: number; processId: number }>(),
+});
+
+export default frameIdsInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | /* c8 ignore start */
+import { getInjectable } from "@ogre-tools/injectable";
+import { webContents } from "electron";
+
+const getWebContentsInjectable = getInjectable({
+ id: "web-contents",
+ instantiate: () => () => webContents.getAllWebContents(),
+ causesSideEffects: true,
+});
+
+export default getWebContentsInjectable;
+/* c8 ignore stop */
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| allow-communication-listener.injectable.ts | +
+
+ |
+ 100% | +21/21 | +100% | +3/3 | +100% | +2/2 | +100% | +21/21 | +
| frameIds.injectable.ts | +
+
+ |
+ 100% | +8/8 | +100% | +2/2 | +100% | +2/2 | +100% | +8/8 | +
| get-web-contents.injectable.ts | +
+
+ |
+ 100% | +12/12 | +100% | +1/1 | +100% | +2/2 | +100% | +12/12 | +
| send-message-to-channel.injectable.ts | +
+
+ |
+ 100% | +48/48 | +100% | +12/12 | +100% | +6/6 | +100% | +48/48 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +5x +5x +1x +1x +1x +1x +1x +5x +5x +5x +5x +5x +5x +5x +5x +5x +5x +6x +6x +6x +8x +8x +6x +5x +5x +14x +14x +5x +5x +5x +1x +1x +1x +1x +1x + | import { getInjectable } from "@ogre-tools/injectable";
+import { pipeline } from "@ogre-tools/fp";
+import { SendMessageToChannel, sendMessageToChannelInjectionToken } from "@k8slens/messaging";
+import getWebContentsInjectable from "./get-web-contents.injectable";
+import { flatMap, reject } from "lodash/fp";
+import type { WebContents } from "electron";
+import frameIdsInjectable from "./frameIds.injectable";
+
+const isDestroyed = (webContent: WebContents) => webContent.isDestroyed();
+const isCrashed = (webContent: WebContents) => webContent.isCrashed();
+
+const forEach =
+ <T>(predicate: (item: T) => void) =>
+ (items: T[]) =>
+ items.forEach(predicate);
+
+const sendMessageToChannelInjectable = getInjectable({
+ id: "send-message-to-channel",
+
+ instantiate: (di) => {
+ const getWebContents = di.inject(getWebContentsInjectable);
+ const frameIds = di.inject(frameIdsInjectable);
+
+ return ((channel, message) => {
+ pipeline(
+ getWebContents(),
+ reject(isDestroyed),
+ reject(isCrashed),
+
+ flatMap((webContent) => [
+ (channelId: string, ...args: any[]) => webContent.send(channelId, ...args),
+
+ ...[...frameIds].map(({ frameId, processId }) => (channelId: string, ...args: any[]) => {
+ webContent.sendToFrame([frameId, processId], channelId, ...args);
+ }),
+ ]),
+
+ forEach((send) => {
+ send(channel.id, message);
+ }),
+ );
+ }) as SendMessageToChannel;
+ },
+
+ injectionToken: sendMessageToChannelInjectionToken,
+});
+
+export default sendMessageToChannelInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| src | +
+
+ |
+ 100% | +43/43 | +100% | +5/5 | +100% | +5/5 | +100% | +43/43 | +
| src/ipc | +
+
+ |
+ 100% | +10/10 | +100% | +2/2 | +100% | +2/2 | +100% | +10/10 | +
| src/listening-of-messages | +
+
+ |
+ 100% | +28/28 | +100% | +5/5 | +100% | +3/3 | +100% | +28/28 | +
| src/listening-of-requests | +
+
+ |
+ 100% | +18/18 | +100% | +2/2 | +100% | +2/2 | +100% | +18/18 | +
| src/requesting-of-requests | +
+
+ |
+ 100% | +28/28 | +100% | +5/5 | +100% | +4/4 | +100% | +28/28 | +
| src/sending-of-messages | +
+
+ |
+ 100% | +29/29 | +100% | +5/5 | +100% | +4/4 | +100% | +29/29 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import { getInjectable } from "@ogre-tools/injectable";
+import { onLoadOfApplicationInjectionToken } from "@k8slens/application";
+import { getMessageChannel, sendMessageToChannelInjectionToken } from "@k8slens/messaging";
+
+export const frameCommunicationAdminChannel = getMessageChannel<undefined>(
+ "frame-communication-admin-channel",
+);
+
+const allowCommunicationToIframeInjectable = getInjectable({
+ id: "allow-communication-to-iframe-injectable",
+
+ instantiate: (di) => {
+ const sendMessageToChannel = di.inject(sendMessageToChannelInjectionToken);
+
+ return {
+ run: () => {
+ sendMessageToChannel(frameCommunicationAdminChannel);
+ },
+ };
+ },
+
+ injectionToken: onLoadOfApplicationInjectionToken,
+});
+
+export default allowCommunicationToIframeInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 | 1x +1x +1x +1x +1x +1x +1x +1x +16x +16x +16x +16x +16x +16x +16x +1x +1x +1x + | import { autoRegister } from "@ogre-tools/injectable-extension-for-auto-registration";
+import { getFeature } from "@k8slens/feature-core";
+import { messagingFeature } from "@k8slens/messaging";
+
+export const messagingFeatureForRenderer = getFeature({
+ id: "messaging-for-renderer",
+
+ register: (di) => {
+ autoRegister({
+ di,
+ targetModule: module,
+
+ getRequireContexts: () => [require.context("./", true, /\.injectable\.(ts|tsx)$/)],
+ });
+ },
+
+ dependencies: [messagingFeature],
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| allow-communication-to-iframe.injectable.ts | +
+
+ |
+ 100% | +25/25 | +100% | +2/2 | +100% | +2/2 | +100% | +25/25 | +
| feature.ts | +
+
+ |
+ 100% | +18/18 | +100% | +3/3 | +100% | +3/3 | +100% | +18/18 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| ipc-renderer.injectable.ts | +
+
+ |
+ 100% | +10/10 | +100% | +2/2 | +100% | +2/2 | +100% | +10/10 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import { getInjectable } from "@ogre-tools/injectable";
+import { ipcRenderer } from "electron";
+
+const ipcRendererInjectable = getInjectable({
+ id: "ipc-renderer",
+ instantiate: () => ipcRenderer,
+ causesSideEffects: true,
+});
+
+export default ipcRendererInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +9x +9x +9x +8x +5x +5x +8x +8x +8x +8x +1x +1x +8x +9x +1x +1x +1x +1x +1x + | import ipcRendererInjectable from "../ipc/ipc-renderer.injectable";
+import { getInjectable } from "@ogre-tools/injectable";
+import type { IpcRendererEvent } from "electron";
+import { enlistMessageChannelListenerInjectionToken } from "@k8slens/messaging";
+
+const enlistMessageChannelListenerInjectable = getInjectable({
+ id: "enlist-message-channel-listener-for-renderer",
+
+ instantiate: (di) => {
+ const ipcRenderer = di.inject(ipcRendererInjectable);
+
+ return ({ channel, handler }) => {
+ const nativeCallback = (_: IpcRendererEvent, message: any) => {
+ handler(message);
+ };
+
+ ipcRenderer.on(channel.id, nativeCallback);
+
+ return () => {
+ ipcRenderer.off(channel.id, nativeCallback);
+ };
+ };
+ },
+
+ injectionToken: enlistMessageChannelListenerInjectionToken,
+});
+
+export default enlistMessageChannelListenerInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| enlist-message-channel-listener.injectable.ts | +
+
+ |
+ 100% | +28/28 | +100% | +5/5 | +100% | +3/3 | +100% | +28/28 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | /* c8 ignore start */
+import { getInjectable } from "@ogre-tools/injectable";
+import { enlistRequestChannelListenerInjectionToken } from "@k8slens/messaging";
+
+const enlistRequestChannelListenerInjectable = getInjectable({
+ id: "enlist-request-channel-listener-for-renderer",
+
+ instantiate: () => (listener) => {
+ throw new Error(
+ `Tried to enlist request channel "${listener.channel.id}" in "renderer", but requesting it's not supported yet.`,
+ );
+ },
+
+ injectionToken: enlistRequestChannelListenerInjectionToken,
+});
+
+export default enlistRequestChannelListenerInjectable;
+/* c8 ignore end */
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| enlist-request-channel-listener.injectable.ts | +
+
+ |
+ 100% | +18/18 | +100% | +2/2 | +100% | +2/2 | +100% | +18/18 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| invoke-ipc.injectable.ts | +
+
+ |
+ 100% | +10/10 | +100% | +2/2 | +100% | +2/2 | +100% | +10/10 | +
| request-from-channel.injectable.ts | +
+
+ |
+ 100% | +18/18 | +100% | +3/3 | +100% | +2/2 | +100% | +18/18 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import { getInjectable } from "@ogre-tools/injectable";
+import ipcRendererInjectable from "../ipc/ipc-renderer.injectable";
+
+const invokeIpcInjectable = getInjectable({
+ id: "invoke-ipc",
+
+ instantiate: (di) => di.inject(ipcRendererInjectable).invoke,
+});
+
+export default invokeIpcInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +2x +2x +2x +2x +1x +1x +1x +1x +1x + | import { getInjectable } from "@ogre-tools/injectable";
+import type { RequestFromChannel } from "@k8slens/messaging";
+import { requestFromChannelInjectionToken } from "@k8slens/messaging";
+import invokeIpcInjectable from "./invoke-ipc.injectable";
+
+const requestFromChannelInjectable = getInjectable({
+ id: "request-from-channel",
+
+ instantiate: (di) => {
+ const invokeIpc = di.inject(invokeIpcInjectable);
+
+ return ((channel, request) => invokeIpc(channel.id, request)) as RequestFromChannel;
+ },
+
+ injectionToken: requestFromChannelInjectionToken,
+});
+
+export default requestFromChannelInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| message-to-channel.injectable.ts | +
+
+ |
+ 100% | +19/19 | +100% | +3/3 | +100% | +2/2 | +100% | +19/19 | +
| send-to-ipc.injectable.ts | +
+
+ |
+ 100% | +10/10 | +100% | +2/2 | +100% | +2/2 | +100% | +10/10 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import { getInjectable } from "@ogre-tools/injectable";
+import sendToIpcInjectable from "./send-to-ipc.injectable";
+import { SendMessageToChannel, sendMessageToChannelInjectionToken } from "@k8slens/messaging";
+
+const messageToChannelInjectable = getInjectable({
+ id: "message-to-channel",
+
+ instantiate: (di) => {
+ const sendToIpc = di.inject(sendToIpcInjectable);
+
+ return ((channel, message) => {
+ sendToIpc(channel.id, message);
+ }) as SendMessageToChannel;
+ },
+
+ injectionToken: sendMessageToChannelInjectionToken,
+});
+
+export default messageToChannelInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import { getInjectable } from "@ogre-tools/injectable";
+import ipcRendererInjectable from "../ipc/ipc-renderer.injectable";
+
+const sendToIpcInjectable = getInjectable({
+ id: "send-to-ipc",
+
+ instantiate: (di) => di.inject(ipcRendererInjectable).send,
+});
+
+export default sendToIpcInjectable;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 +99 +100 +101 +102 +103 +104 +105 +106 +107 +108 +109 +110 +111 +112 +113 +114 +115 +116 +117 +118 +119 +120 +121 +122 +123 +124 +125 +126 +127 +128 +129 +130 +131 +132 +133 +134 +135 +136 +137 +138 +139 +140 +141 +142 +143 +144 +145 +146 +147 +148 +149 +150 +151 +152 +153 +154 +155 +156 +157 +158 +159 +160 +161 +162 +163 +164 +165 +166 +167 +168 +169 +170 +171 +172 +173 +174 +175 +176 +177 +178 +179 +180 +181 +182 +183 +184 +185 +186 +187 +188 +189 +190 +191 +192 +193 +194 +195 +196 +197 +198 +199 +200 +201 +202 +203 +204 | 1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +84x +84x +84x +84x +84x +84x +84x +84x +84x +84x +84x +84x +84x +84x +84x +84x +84x +84x +21x +21x +21x +42x +42x +42x +42x +42x +23x +23x +19x +42x +12x +12x +12x +9x +9x +12x +12x +42x +7x +7x +42x +21x +84x +84x +84x +84x +84x +47x +28x +28x +47x +47x +47x +47x +47x +47x +2x +2x +47x +84x +84x +1x +1x +1x +1x +84x +84x +84x +84x +84x +84x +84x +84x +84x +84x +84x +84x +84x +84x +12x +12x +12x +12x +12x +12x +12x +12x +2x +2x +2x +2x +10x +12x +2x +2x +2x +2x +8x +8x +8x +8x +8x +8x +8x +8x +12x +12x +84x +84x +84x +84x +30x +30x +30x +30x +30x +30x +30x +30x +30x +2x +2x +30x +84x +1x +1x +28x +28x +28x +28x +28x +28x +9x +9x +9x +9x +9x +28x +28x +3x +3x +3x +6x +6x +3x +28x +28x +28x +28x +28x +28x +28x +84x +84x +84x +84x +84x +84x +84x +84x +84x +28x +28x +28x +28x +28x +28x +28x +16x +16x +28x +28x + | import type { DiContainer } from "@ogre-tools/injectable";
+import type {
+ MessageChannel,
+ MessageChannelHandler,
+ MessageChannelListener,
+ RequestChannel,
+ RequestChannelHandler,
+} from "@k8slens/messaging";
+
+import {
+ enlistMessageChannelListenerInjectionToken,
+ enlistRequestChannelListenerInjectionToken,
+ RequestFromChannel,
+ requestFromChannelInjectionToken,
+ sendMessageToChannelInjectionToken,
+} from "@k8slens/messaging";
+
+import { pipeline } from "@ogre-tools/fp";
+import { filter, map } from "lodash/fp";
+import asyncFn, { AsyncFnMock } from "@async-fn/jest";
+
+export type MessageBridgeFake = {
+ involve: (...dis: DiContainer[]) => void;
+ messagePropagation: () => Promise<void>;
+ messagePropagationRecursive: (callback: any) => any;
+ setAsync: (value: boolean) => void;
+};
+
+type MessageHandlers = Set<MessageChannelHandler<MessageChannel<any>>>;
+
+const overrideMessaging = ({
+ di,
+ messageListenersByDi,
+ messagePropagationBuffer,
+ getAsyncModeStatus,
+}: {
+ di: DiContainer;
+
+ messageListenersByDi: Map<DiContainer, Map<string, MessageHandlers>>;
+
+ messagePropagationBuffer: Set<{ resolve: () => Promise<void> }>;
+
+ getAsyncModeStatus: () => boolean;
+}) => {
+ const messageHandlersByChannel = new Map<string, MessageHandlers>();
+
+ messageListenersByDi.set(di, messageHandlersByChannel);
+
+ di.override(sendMessageToChannelInjectionToken, () => (channel, message) => {
+ const allOtherDis = [...messageListenersByDi.keys()].filter((x) => x !== di);
+
+ allOtherDis.forEach((otherDi) => {
+ const listeners = messageListenersByDi.get(otherDi);
+
+ const handlersForChannel = listeners?.get(channel.id);
+
+ if (!handlersForChannel) {
+ return;
+ }
+
+ if (getAsyncModeStatus()) {
+ const resolvableHandlePromise = asyncFn();
+
+ resolvableHandlePromise().then(() => {
+ handlersForChannel.forEach((handler) => handler(message, { frameId: 42, processId: 42 }));
+ });
+
+ messagePropagationBuffer.add(resolvableHandlePromise);
+ } else {
+ handlersForChannel.forEach((handler) => handler(message, { frameId: 42, processId: 42 }));
+ }
+ });
+ });
+
+ di.override(
+ enlistMessageChannelListenerInjectionToken,
+ () =>
+ <T>(listener: MessageChannelListener<MessageChannel<T>>) => {
+ if (!messageHandlersByChannel.has(listener.channel.id)) {
+ messageHandlersByChannel.set(listener.channel.id, new Set());
+ }
+
+ const handlerSet = messageHandlersByChannel.get(listener.channel.id);
+
+ handlerSet?.add(listener.handler);
+
+ return () => {
+ handlerSet?.delete(listener.handler);
+ };
+ },
+ );
+};
+
+type RequestHandlers = Set<RequestChannelHandler<RequestChannel<any, any>>>;
+
+const overrideRequesting = ({
+ di,
+ requestListenersByDi,
+}: {
+ di: DiContainer;
+
+ requestListenersByDi: Map<DiContainer, Map<string, RequestHandlers>>;
+}) => {
+ const requestHandlersByChannel = new Map<string, RequestHandlers>();
+
+ requestListenersByDi.set(di, requestHandlersByChannel);
+
+ di.override(
+ requestFromChannelInjectionToken,
+ () =>
+ (async (channel, request) =>
+ pipeline(
+ [...requestListenersByDi.values()],
+ map((listenersByChannel) => listenersByChannel?.get(channel.id)),
+ filter((x) => !!x),
+
+ (channelSpecificListeners) => {
+ if (channelSpecificListeners.length === 0) {
+ throw new Error(
+ `Tried to make a request but no listeners for channel "${channel.id}" was discovered in any DIs`,
+ );
+ }
+
+ if (channelSpecificListeners.length > 1) {
+ throw new Error(
+ `Tried to make a request but multiple listeners were discovered for channel "${channel.id}" in multiple DIs.`,
+ );
+ }
+
+ const listeners = channelSpecificListeners[0];
+
+ // eslint-disable-next-line @typescript-eslint/no-non-null-assertion
+ const [handler] = listeners!;
+
+ return handler;
+ },
+
+ async (handler) => handler(request),
+ )) as RequestFromChannel,
+ );
+
+ di.override(enlistRequestChannelListenerInjectionToken, () => (listener) => {
+ if (!requestHandlersByChannel.has(listener.channel.id)) {
+ requestHandlersByChannel.set(listener.channel.id, new Set());
+ }
+
+ const handlerSet = requestHandlersByChannel.get(listener.channel.id);
+
+ handlerSet?.add(listener.handler);
+
+ return () => {
+ handlerSet?.delete(listener.handler);
+ };
+ });
+};
+
+export const getMessageBridgeFake = (): MessageBridgeFake => {
+ const messageListenersByDi = new Map<DiContainer, Map<string, MessageHandlers>>();
+ const requestListenersByDi = new Map<DiContainer, Map<string, RequestHandlers>>();
+
+ const messagePropagationBuffer = new Set<AsyncFnMock<() => void>>();
+
+ const messagePropagation = async (wrapper: (callback: any) => any = (callback) => callback()) => {
+ const oldMessages = [...messagePropagationBuffer.values()];
+
+ messagePropagationBuffer.clear();
+ await Promise.all(oldMessages.map((x) => wrapper(x.resolve)));
+ };
+
+ const messagePropagationRecursive = async (
+ wrapper: (callback: any) => any = (callback) => callback(),
+ ) => {
+ while (messagePropagationBuffer.size) {
+ await messagePropagation(wrapper);
+ }
+ };
+
+ let asyncModeStatus = false;
+ const getAsyncModeStatus = () => asyncModeStatus;
+
+ return {
+ involve: (...dis: DiContainer[]) => {
+ dis.forEach((di) => {
+ overrideRequesting({ di, requestListenersByDi });
+
+ overrideMessaging({
+ di,
+ messageListenersByDi,
+ messagePropagationBuffer,
+ getAsyncModeStatus,
+ });
+ });
+ },
+
+ messagePropagation,
+
+ messagePropagationRecursive,
+
+ setAsync: (value) => {
+ asyncModeStatus = value;
+ },
+ };
+};
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| get-message-bridge-fake.ts | +
+
+ |
+ 100% | +203/203 | +100% | +42/42 | +100% | +11/11 | +100% | +203/203 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| src | +
+
+ |
+ 100% | +17/17 | +100% | +3/3 | +100% | +3/3 | +100% | +17/17 | +
| src/react-application | +
+
+ |
+ 100% | +90/90 | +100% | +14/14 | +100% | +6/6 | +100% | +90/90 | +
| src/render-application | +
+
+ |
+ 100% | +43/43 | +100% | +3/3 | +100% | +4/4 | +100% | +43/43 | +