hendrik/lens
1
0
Fork 0
mirror of https://github.com/lensapp/lens.git synced 2025-05-20 05:10:56 +00:00
Code Issues Projects Releases Wiki Activity

fix ipc broadcast to frames from renderer

Browse Source 
Signed-off-by: Jari Kolehmainen <jari.kolehmainen@gmail.com>
This commit is contained in:
Jari Kolehmainen 2021-01-22 15:04:06 +02:00
parent f38b307d9e
commit 3f158f4a4b
1 changed files with 19 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/common/ipc.ts
View File

@ -3,6 +3,7 @@
// https://www.electronjs.org/docs/api/ipc-renderer
import { ipcMain, ipcRenderer, webContents, remote } from "electron";
import { toJS } from "mobx";
import logger from "../main/logger";
import { ClusterFrameInfo, clusterFrameMap } from "./cluster-frames";
@ -24,8 +25,15 @@ async function getSubFrames(): Promise<ClusterFrameInfo[]> {
return subFrames;
}
export function broadcastMessage(channel: string, ...args: any[]) {
const views = (webContents || remote?.webContents)?.getAllWebContents();
export async function broadcastMessage(channel: string, ...args: any[]) {
let subFrames: ClusterFrameInfo[];
if (ipcRenderer) {
subFrames = await requestMain("ipc:get-sub-frames");
} else {
subFrames = await getSubFrames();
}
const views = (webContents || remote.webContents)?.getAllWebContents();
if (!views) return;
@ -34,11 +42,9 @@ export function broadcastMessage(channel: string, ...args: any[]) {
logger.silly(`[IPC]: broadcasting "${channel}" to ${type}=${webContent.id}`, { args });
webContent.send(channel, ...args);
getSubFrames().then((frames) => {
frames.map((frameInfo) => {
webContent.sendToFrame([frameInfo.processId, frameInfo.frameId], channel, ...args);
});
}).catch((e) => e);
subFrames.map((frameInfo) => {
webContent.sendToFrame([frameInfo.processId, frameInfo.frameId], channel, ...args);
});
});
if (ipcRenderer) {
@ -73,3 +79,9 @@ export function unsubscribeAllFromBroadcast(channel: string) {
ipcMain.removeAllListeners(channel);
}
}
export function bindBroadcastHandlers() {
handleRequest("ipc:get-sub-frames", async () => {
return toJS(await getSubFrames(), { recurseEverything: true });
});
}