mirror of
https://github.com/lensapp/lens.git
synced 2025-05-20 05:10:56 +00:00
Move extension updater to renderer
Signed-off-by: Alex Andreev <alex.andreev.email@gmail.com>
This commit is contained in:
parent
3ba60a47b0
commit
b33b5f89c3
@ -2,5 +2,4 @@
|
|||||||
* Copyright (c) OpenLens Authors. All rights reserved.
|
* Copyright (c) OpenLens Authors. All rights reserved.
|
||||||
* Licensed under MIT License. See LICENSE in root directory for more information.
|
* Licensed under MIT License. See LICENSE in root directory for more information.
|
||||||
*/
|
*/
|
||||||
export const BundledExtensionsLoaded = "extension-loader:bundled-extensions-loaded";
|
|
||||||
export const BundledExtensionsUpdated = "extension-loader:bundled-extensions-updated";
|
export const BundledExtensionsUpdated = "extension-loader:bundled-extensions-updated";
|
||||||
|
|||||||
@ -4,9 +4,9 @@
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
import { getInjectable, lifecycleEnum } from "@ogre-tools/injectable";
|
import { getInjectable, lifecycleEnum } from "@ogre-tools/injectable";
|
||||||
import ipcRendererInjectable from "../../renderer/app-paths/get-value-from-registered-channel/ipc-renderer/ipc-renderer.injectable";
|
import extensionLoaderInjectable from "../../../../extensions/extension-loader/extension-loader.injectable";
|
||||||
import installFromInputInjectable from "../../renderer/components/+extensions/install-from-input/install-from-input.injectable";
|
import ipcRendererInjectable from "../../../app-paths/get-value-from-registered-channel/ipc-renderer/ipc-renderer.injectable";
|
||||||
import extensionLoaderInjectable from "../extension-loader/extension-loader.injectable";
|
import installFromInputInjectable from "../install-from-input/install-from-input.injectable";
|
||||||
import { BundledExtensionsUpdater } from "./bundled-extensions-updater";
|
import { BundledExtensionsUpdater } from "./bundled-extensions-updater";
|
||||||
|
|
||||||
const bundledExtensionsUpdaterInjectable = getInjectable({
|
const bundledExtensionsUpdaterInjectable = getInjectable({
|
||||||
@ -3,9 +3,9 @@
|
|||||||
* Licensed under MIT License. See LICENSE in root directory for more information.
|
* Licensed under MIT License. See LICENSE in root directory for more information.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
import { BundledExtensionsLoaded, BundledExtensionsUpdated, ipcRendererOn } from "../../common/ipc"
|
import { BundledExtensionsUpdated } from "../../../../common/ipc";
|
||||||
import { logger } from "../common-api";
|
import { logger } from "../../../../extensions/common-api";
|
||||||
import type { InstalledExtension } from "../extension-discovery/extension-discovery";
|
import type { InstalledExtension } from "../../../../extensions/extension-discovery/extension-discovery";
|
||||||
import { ExtensionUpdater, UpdaterDependencies } from "./extension-updater";
|
import { ExtensionUpdater, UpdaterDependencies } from "./extension-updater";
|
||||||
|
|
||||||
interface Dependencies extends UpdaterDependencies {
|
interface Dependencies extends UpdaterDependencies {
|
||||||
@ -18,13 +18,7 @@ export class BundledExtensionsUpdater extends ExtensionUpdater {
|
|||||||
super(dependencies);
|
super(dependencies);
|
||||||
}
|
}
|
||||||
|
|
||||||
init() {
|
async updateAll() {
|
||||||
ipcRendererOn(BundledExtensionsLoaded, (event) => {
|
|
||||||
this.updateAll();
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
private async updateAll() {
|
|
||||||
logger.info("[EXTENSIONS-UPDATER]: Bundled extensions update started.");
|
logger.info("[EXTENSIONS-UPDATER]: Bundled extensions update started.");
|
||||||
|
|
||||||
const updates = this.dependencies.extensions.map(this.update);
|
const updates = this.dependencies.extensions.map(this.update);
|
||||||
@ -3,7 +3,7 @@
|
|||||||
* Licensed under MIT License. See LICENSE in root directory for more information.
|
* Licensed under MIT License. See LICENSE in root directory for more information.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
import type { InstalledExtension } from "../extension-discovery/extension-discovery"
|
import type { InstalledExtension } from "../../../../extensions/extension-discovery/extension-discovery"
|
||||||
|
|
||||||
export interface UpdaterDependencies {
|
export interface UpdaterDependencies {
|
||||||
installFromInput: (input: string) => Promise<void>;
|
installFromInput: (input: string) => Promise<void>;
|
||||||
@ -14,7 +14,7 @@ export class ExtensionUpdater {
|
|||||||
}
|
}
|
||||||
|
|
||||||
async update({ availableUpdate, manifest }: InstalledExtension): Promise<void> {
|
async update({ availableUpdate, manifest }: InstalledExtension): Promise<void> {
|
||||||
return new Promise(resolve => {
|
return new Promise((resolve, reject) => {
|
||||||
if (availableUpdate) {
|
if (availableUpdate) {
|
||||||
console.info(`[EXTENSIONS-UPDATER]: Trying to update ${manifest.name} extension`);
|
console.info(`[EXTENSIONS-UPDATER]: Trying to update ${manifest.name} extension`);
|
||||||
|
|
||||||
@ -22,6 +22,7 @@ export class ExtensionUpdater {
|
|||||||
// TODO: actual install
|
// TODO: actual install
|
||||||
// this.dependencies.installFromInput(availableUpdate.input);
|
// this.dependencies.installFromInput(availableUpdate.input);
|
||||||
}
|
}
|
||||||
|
reject();
|
||||||
});
|
});
|
||||||
|
|
||||||
}
|
}
|
||||||
@ -5,11 +5,10 @@
|
|||||||
import { getInjectable, lifecycleEnum } from "@ogre-tools/injectable";
|
import { getInjectable, lifecycleEnum } from "@ogre-tools/injectable";
|
||||||
import { initRootFrame } from "./init-root-frame";
|
import { initRootFrame } from "./init-root-frame";
|
||||||
import extensionLoaderInjectable from "../../../../extensions/extension-loader/extension-loader.injectable";
|
import extensionLoaderInjectable from "../../../../extensions/extension-loader/extension-loader.injectable";
|
||||||
import ipcRendererInjectable from "../../../app-paths/get-value-from-registered-channel/ipc-renderer/ipc-renderer.injectable";
|
|
||||||
import bindProtocolAddRouteHandlersInjectable from "../../../protocol-handler/bind-protocol-add-route-handlers/bind-protocol-add-route-handlers.injectable";
|
import bindProtocolAddRouteHandlersInjectable from "../../../protocol-handler/bind-protocol-add-route-handlers/bind-protocol-add-route-handlers.injectable";
|
||||||
import lensProtocolRouterRendererInjectable from "../../../protocol-handler/lens-protocol-router-renderer/lens-protocol-router-renderer.injectable";
|
import lensProtocolRouterRendererInjectable from "../../../protocol-handler/lens-protocol-router-renderer/lens-protocol-router-renderer.injectable";
|
||||||
import catalogEntityRegistryInjectable from "../../../api/catalog-entity-registry/catalog-entity-registry.injectable";
|
import catalogEntityRegistryInjectable from "../../../api/catalog-entity-registry/catalog-entity-registry.injectable";
|
||||||
import bundledExtensionsUpdaterInjectable from "../../../../extensions/extension-updater/bundled-extensions-updater.injectable";
|
import bundledExtensionsUpdaterInjectable from "../../../components/+extensions/extension-updater/bundled-extensions-updater.injectable";
|
||||||
|
|
||||||
const initRootFrameInjectable = getInjectable({
|
const initRootFrameInjectable = getInjectable({
|
||||||
instantiate: (di) => {
|
instantiate: (di) => {
|
||||||
@ -18,8 +17,6 @@ const initRootFrameInjectable = getInjectable({
|
|||||||
return initRootFrame({
|
return initRootFrame({
|
||||||
loadExtensions: extensionLoader.loadOnClusterManagerRenderer,
|
loadExtensions: extensionLoader.loadOnClusterManagerRenderer,
|
||||||
|
|
||||||
ipcRenderer: di.inject(ipcRendererInjectable),
|
|
||||||
|
|
||||||
bindProtocolAddRouteHandlers: di.inject(
|
bindProtocolAddRouteHandlers: di.inject(
|
||||||
bindProtocolAddRouteHandlersInjectable,
|
bindProtocolAddRouteHandlersInjectable,
|
||||||
),
|
),
|
||||||
|
|||||||
@ -3,20 +3,17 @@
|
|||||||
* Licensed under MIT License. See LICENSE in root directory for more information.
|
* Licensed under MIT License. See LICENSE in root directory for more information.
|
||||||
*/
|
*/
|
||||||
import { delay } from "../../../../common/utils";
|
import { delay } from "../../../../common/utils";
|
||||||
import { broadcastMessage, BundledExtensionsLoaded } from "../../../../common/ipc";
|
import { broadcastMessage } from "../../../../common/ipc";
|
||||||
import { registerIpcListeners } from "../../../ipc";
|
import { registerIpcListeners } from "../../../ipc";
|
||||||
import logger from "../../../../common/logger";
|
import logger from "../../../../common/logger";
|
||||||
import { unmountComponentAtNode } from "react-dom";
|
import { unmountComponentAtNode } from "react-dom";
|
||||||
import type { ExtensionLoading } from "../../../../extensions/extension-loader";
|
import type { ExtensionLoading } from "../../../../extensions/extension-loader";
|
||||||
import type { CatalogEntityRegistry } from "../../../api/catalog-entity-registry";
|
import type { CatalogEntityRegistry } from "../../../api/catalog-entity-registry";
|
||||||
import type { BundledExtensionsUpdater } from "../../../../extensions/extension-updater/bundled-extensions-updater";
|
import type { BundledExtensionsUpdater } from "../../../components/+extensions/extension-updater/bundled-extensions-updater";
|
||||||
|
|
||||||
interface Dependencies {
|
interface Dependencies {
|
||||||
loadExtensions: () => Promise<ExtensionLoading[]>;
|
loadExtensions: () => Promise<ExtensionLoading[]>;
|
||||||
|
|
||||||
// TODO: Move usages of third party library behind abstraction
|
|
||||||
ipcRenderer: { send: (name: string) => void };
|
|
||||||
|
|
||||||
// TODO: Remove dependencies being here only for correct timing of initialization
|
// TODO: Remove dependencies being here only for correct timing of initialization
|
||||||
bindProtocolAddRouteHandlers: () => void;
|
bindProtocolAddRouteHandlers: () => void;
|
||||||
lensProtocolRouterRenderer: { init: () => void };
|
lensProtocolRouterRenderer: { init: () => void };
|
||||||
@ -32,13 +29,11 @@ export const initRootFrame =
|
|||||||
loadExtensions,
|
loadExtensions,
|
||||||
bindProtocolAddRouteHandlers,
|
bindProtocolAddRouteHandlers,
|
||||||
lensProtocolRouterRenderer,
|
lensProtocolRouterRenderer,
|
||||||
ipcRenderer,
|
|
||||||
catalogEntityRegistry,
|
catalogEntityRegistry,
|
||||||
bundledExtensionsUpdater,
|
bundledExtensionsUpdater,
|
||||||
}: Dependencies) =>
|
}: Dependencies) =>
|
||||||
async (rootElem: HTMLElement) => {
|
async (rootElem: HTMLElement) => {
|
||||||
catalogEntityRegistry.init();
|
catalogEntityRegistry.init();
|
||||||
bundledExtensionsUpdater.init();
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
// maximum time to let bundled extensions finish loading
|
// maximum time to let bundled extensions finish loading
|
||||||
@ -54,7 +49,7 @@ export const initRootFrame =
|
|||||||
|
|
||||||
await Promise.race([bundledExtensionsFinished, timeout]);
|
await Promise.race([bundledExtensionsFinished, timeout]);
|
||||||
} finally {
|
} finally {
|
||||||
ipcRenderer.send(BundledExtensionsLoaded);
|
bundledExtensionsUpdater.updateAll();
|
||||||
}
|
}
|
||||||
|
|
||||||
lensProtocolRouterRenderer.init();
|
lensProtocolRouterRenderer.init();
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user