refactor(plugin): add renderer-plugin-loader

This commit is contained in:
Su-Yong
2023-11-12 00:21:34 +09:00
parent bc916f3a6e
commit ef71abfff1
4 changed files with 119 additions and 78 deletions

View File

@ -29,7 +29,7 @@ import { pluginBuilders } from 'virtual:PluginBuilders';
import youtubeMusicCSS from './youtube-music.css?inline'; import youtubeMusicCSS from './youtube-music.css?inline';
import { getLoadedAllPlugins, loadAllPlugins, registerMainPlugin } from './loader/main'; import { getAllLoadedMainPlugins, loadAllMainPlugins, registerMainPlugin } from './loader/main';
import { MainPluginFactory, PluginBaseConfig, PluginBuilder } from './plugins/utils/builder'; import { MainPluginFactory, PluginBaseConfig, PluginBuilder } from './plugins/utils/builder';
// Catch errors and log them // Catch errors and log them
@ -104,7 +104,7 @@ const initHook = (win: BrowserWindow) => {
if (!isEqual) { if (!isEqual) {
const config = deepmerge(pluginBuilders[id as keyof PluginBuilderList].config, newPluginConfig); const config = deepmerge(pluginBuilders[id as keyof PluginBuilderList].config, newPluginConfig);
const mainPlugin = getLoadedAllPlugins()[id]; const mainPlugin = getAllLoadedMainPlugins()[id];
if (mainPlugin) mainPlugin.onConfigChange?.(config as PluginBaseConfig); if (mainPlugin) mainPlugin.onConfigChange?.(config as PluginBaseConfig);
win.webContents.send('config-changed', id, config); win.webContents.send('config-changed', id, config);
@ -125,7 +125,7 @@ function initTheme(win: BrowserWindow) {
injectCSSAsFile(win.webContents, cssFile); injectCSSAsFile(win.webContents, cssFile);
}, },
() => { () => {
console.warn(`CSS file "${cssFile}" does not exist, ignoring`); console.warn('[YTMusic]', `CSS file "${cssFile}" does not exist, ignoring`);
}, },
); );
} }
@ -186,7 +186,7 @@ async function createMainWindow() {
registerMainPlugin(id, typedBuilder, plugin); registerMainPlugin(id, typedBuilder, plugin);
}); });
await loadAllPlugins(win); await loadAllMainPlugins(win);
if (windowPosition) { if (windowPosition) {
const { x: windowX, y: windowY } = windowPosition; const { x: windowX, y: windowY } = windowPosition;

View File

@ -37,7 +37,7 @@ const createContext = <
}, },
}); });
const forceUnloadPlugin = (id: keyof PluginBuilderList, win: BrowserWindow) => { const forceUnloadMainPlugin = (id: keyof PluginBuilderList, win: BrowserWindow) => {
unregisterStyleMap[id]?.forEach((unregister) => unregister()); unregisterStyleMap[id]?.forEach((unregister) => unregister());
delete unregisterStyleMap[id]; delete unregisterStyleMap[id];
@ -47,7 +47,7 @@ const forceUnloadPlugin = (id: keyof PluginBuilderList, win: BrowserWindow) => {
console.log('[YTMusic]', `"${id}" plugin is unloaded`); console.log('[YTMusic]', `"${id}" plugin is unloaded`);
}; };
export const forceLoadPlugin = async (id: keyof PluginBuilderList, win: BrowserWindow) => { export const forceLoadMainPlugin = async (id: keyof PluginBuilderList, win: BrowserWindow) => {
const builder = allPluginBuilders[id]; const builder = allPluginBuilders[id];
Promise.allSettled( Promise.allSettled(
@ -88,7 +88,7 @@ export const forceLoadPlugin = async (id: keyof PluginBuilderList, win: BrowserW
} }
}; };
export const loadAllPlugins = async (win: BrowserWindow) => { export const loadAllMainPlugins = async (win: BrowserWindow) => {
const pluginConfigs = config.plugins.getPlugins(); const pluginConfigs = config.plugins.getPlugins();
for (const [pluginId, builder] of Object.entries(allPluginBuilders)) { for (const [pluginId, builder] of Object.entries(allPluginBuilders)) {
@ -97,25 +97,25 @@ export const loadAllPlugins = async (win: BrowserWindow) => {
const config = deepmerge(typedBuilder.config, pluginConfigs[pluginId as keyof PluginBuilderList] ?? {}); const config = deepmerge(typedBuilder.config, pluginConfigs[pluginId as keyof PluginBuilderList] ?? {});
if (config.enabled) { if (config.enabled) {
await forceLoadPlugin(pluginId as keyof PluginBuilderList, win); await forceLoadMainPlugin(pluginId as keyof PluginBuilderList, win);
} else { } else {
if (loadedPluginMap[pluginId as keyof PluginBuilderList]) { if (loadedPluginMap[pluginId as keyof PluginBuilderList]) {
forceUnloadPlugin(pluginId as keyof PluginBuilderList, win); forceUnloadMainPlugin(pluginId as keyof PluginBuilderList, win);
} }
} }
} }
}; };
export const unloadAllPlugins = (win: BrowserWindow) => { export const unloadAllMainPlugins = (win: BrowserWindow) => {
for (const id of Object.keys(loadedPluginMap)) { for (const id of Object.keys(loadedPluginMap)) {
forceUnloadPlugin(id as keyof PluginBuilderList, win); forceUnloadMainPlugin(id as keyof PluginBuilderList, win);
} }
}; };
export const getLoadedPlugin = <Key extends keyof PluginBuilderList>(id: Key): MainPlugin<PluginBuilderList[Key]['config']> | undefined => { export const getLoadedMainPlugin = <Key extends keyof PluginBuilderList>(id: Key): MainPlugin<PluginBuilderList[Key]['config']> | undefined => {
return loadedPluginMap[id]; return loadedPluginMap[id];
}; };
export const getLoadedAllPlugins = () => { export const getAllLoadedMainPlugins = () => {
return loadedPluginMap; return loadedPluginMap;
}; };
export const registerMainPlugin = ( export const registerMainPlugin = (

97
src/loader/renderer.ts Normal file
View File

@ -0,0 +1,97 @@
import { deepmerge } from 'deepmerge-ts';
import {
PluginBaseConfig, PluginBuilder,
RendererPlugin,
RendererPluginContext,
RendererPluginFactory
} from '../plugins/utils/builder';
const allPluginFactoryList: Record<string, RendererPluginFactory<PluginBaseConfig>> = {};
const allPluginBuilders: Record<string, PluginBuilder<string, PluginBaseConfig>> = {};
const unregisterStyleMap: Record<string, (() => void)[]> = {};
const loadedPluginMap: Record<string, RendererPlugin<PluginBaseConfig>> = {};
const createContext = <
Key extends keyof PluginBuilderList,
Config extends PluginBaseConfig = PluginBuilderList[Key]['config'],
>(id: Key): RendererPluginContext<Config> => ({
getConfig: async () => {
return await window.ipcRenderer.invoke('get-config', id) as Config;
},
setConfig: async (newConfig) => {
await window.ipcRenderer.invoke('set-config', id, newConfig);
},
invoke: async <Return>(event: string, ...args: unknown[]): Promise<Return> => {
return await window.ipcRenderer.invoke(event, ...args) as Return;
},
on: (event: string, listener) => {
window.ipcRenderer.on(event, async (_, ...args) => listener(...args as never));
},
});
const forceUnloadRendererPlugin = (id: keyof PluginBuilderList) => {
unregisterStyleMap[id]?.forEach((unregister) => unregister());
delete unregisterStyleMap[id];
loadedPluginMap[id]?.onUnload?.();
delete loadedPluginMap[id];
console.log('[YTMusic]', `"${id}" plugin is unloaded`);
};
export const forceLoadRendererPlugin = async (id: keyof PluginBuilderList) => {
try {
const factory = allPluginFactoryList[id];
if (!factory) return;
const context = createContext(id);
const plugin = await factory(context);
loadedPluginMap[id] = plugin;
plugin.onLoad?.();
console.log('[YTMusic]', `"${id}" plugin is loaded`);
} catch (err) {
console.log('[YTMusic]', `Cannot initialize "${id}" plugin: ${String(err)}`);
}
};
export const loadAllRendererPlugins = async () => {
const pluginConfigs = window.mainConfig.plugins.getPlugins();
for (const [pluginId, builder] of Object.entries(allPluginBuilders)) {
const typedBuilder = builder as PluginBuilderList[keyof PluginBuilderList];
const config = deepmerge(typedBuilder.config, pluginConfigs[pluginId as keyof PluginBuilderList] ?? {});
if (config.enabled) {
await forceLoadRendererPlugin(pluginId as keyof PluginBuilderList);
} else {
if (loadedPluginMap[pluginId as keyof PluginBuilderList]) {
forceUnloadRendererPlugin(pluginId as keyof PluginBuilderList);
}
}
}
};
export const unloadAllRendererPlugins = () => {
for (const id of Object.keys(loadedPluginMap)) {
forceUnloadRendererPlugin(id as keyof PluginBuilderList);
}
};
export const getLoadedRendererPlugin = <Key extends keyof PluginBuilderList>(id: Key): RendererPlugin<PluginBuilderList[Key]['config']> | undefined => {
return loadedPluginMap[id];
};
export const getAllLoadedRendererPlugins = () => {
return loadedPluginMap;
};
export const registerRendererPlugin = (
id: string,
builder: PluginBuilder<string, PluginBaseConfig>,
factory?: RendererPluginFactory<PluginBaseConfig>,
) => {
if (factory) allPluginFactoryList[id] = factory;
allPluginBuilders[id] = builder;
};

View File

@ -1,16 +1,14 @@
// eslint-disable-next-line import/order // eslint-disable-next-line import/order
import { rendererPlugins } from 'virtual:RendererPlugins'; import { rendererPlugins } from 'virtual:RendererPlugins';
import { pluginBuilders } from 'virtual:PluginBuilders'; import { pluginBuilders } from 'virtual:PluginBuilders';
import { deepmerge } from 'deepmerge-ts'; import { PluginBaseConfig, PluginBuilder, RendererPluginFactory } from './plugins/utils/builder';
import { PluginBaseConfig, RendererPluginContext, RendererPluginFactory } from './plugins/utils/builder';
import { startingPages } from './providers/extracted-data'; import { startingPages } from './providers/extracted-data';
import { setupSongControls } from './providers/song-controls-front'; import { setupSongControls } from './providers/song-controls-front';
import setupSongInfo from './providers/song-info-front'; import setupSongInfo from './providers/song-info-front';
import { getAllLoadedRendererPlugins, loadAllRendererPlugins, registerRendererPlugin } from './loader/renderer';
let api: Element | null = null; let api: Element | null = null;
@ -96,73 +94,19 @@ function onApiLoaded() {
} }
} }
const createContext = <
Key extends keyof PluginBuilderList,
Config extends PluginBaseConfig = PluginBuilderList[Key]['config'],
>(name: Key): RendererPluginContext<Config> => ({
getConfig: async () => {
const result = await window.ipcRenderer.invoke('get-config', name) as Config;
return result;
},
setConfig: async (newConfig) => {
await window.ipcRenderer.invoke('set-config', name, newConfig);
},
invoke: async <Return>(event: string, ...args: unknown[]): Promise<Return> => {
return await window.ipcRenderer.invoke(event, ...args) as Return;
},
on: (event: string, listener) => {
window.ipcRenderer.on(event, async (_, ...args) => listener(...args as never));
},
});
(async () => { (async () => {
const pluginConfig = window.mainConfig.plugins.getPlugins(); Object.entries(pluginBuilders).forEach(([id, builder]) => {
const typedBuilder = builder as PluginBuilder<string, PluginBaseConfig>;
const plugin = rendererPlugins[id] as RendererPluginFactory<PluginBaseConfig> | undefined;
const rendererPluginList = Object.entries(rendererPlugins); registerRendererPlugin(id, typedBuilder, plugin);
const rendererPluginResult = await Promise.allSettled(
rendererPluginList
.filter(([id]) => {
const typedId = id as keyof PluginBuilderList;
const config = deepmerge(pluginBuilders[typedId].config, pluginConfig[typedId] ?? {});
return config.enabled;
})
.map(async ([id, builder]) => {
const context = createContext(id as keyof PluginBuilderList);
return [id, await (builder as RendererPluginFactory<PluginBaseConfig>)(context)] as const;
}),
);
rendererPluginResult.forEach((it, index) => {
if (it.status === 'rejected') {
const id = rendererPluginList[index][0];
console.error('[YTMusic]', `Cannot load plugin "${id}"`);
console.trace(it.reason);
}
});
const loadedRendererPluginList = rendererPluginResult
.map((it) => it.status === 'fulfilled' ? it.value : null)
.filter(Boolean);
loadedRendererPluginList.forEach(([id, plugin]) => {
try {
plugin.onLoad?.();
console.log('[YTMusic]', `"${id}" plugin is loaded`);
} catch (error) {
console.error('[YTMusic]', `Cannot load plugin "${id}"`);
console.trace(error);
}
}); });
await loadAllRendererPlugins();
window.ipcRenderer.on('config-changed', (_event, id: string, newConfig: PluginBaseConfig) => { window.ipcRenderer.on('config-changed', (_event, id: string, newConfig: PluginBaseConfig) => {
const plugin = loadedRendererPluginList.find(([pluginId]) => pluginId === id); const plugin = getAllLoadedRendererPlugins()[id];
if (plugin) { if (plugin) plugin.onConfigChange?.(newConfig);
plugin[1].onConfigChange?.(newConfig);
}
}); });
// Inject song-info provider // Inject song-info provider