Function makeMockRpc

frontend/preview/mock/mockwaveenv.ts:208–366

(
    overrides: RpcOverrides,
    streamOverrides: RpcStreamOverrides,
    wos: MockWosFns
)

};

export function makeMockRpc(
    overrides: RpcOverrides,
    streamOverrides: RpcStreamOverrides,
    wos: MockWosFns
): {
    rpc: RpcApiType;
    setRpcHandler: (command: string, fn: RpcHandlerType) => void;
    setRpcStreamHandler: (command: string, fn: RpcStreamHandlerType) => void;
} {
    const callDispatchMap = new Map<string, (...args: any[]) => Promise<any>>();
    const streamDispatchMap = new Map<string, (...args: any[]) => AsyncGenerator<any, void, boolean>>();
    const secrets = new Map<string, string>();
    const setCallHandler = (command: string, fn: (...args: any[]) => Promise<any>) => {
        callDispatchMap.set(command, fn);
    };
    const setStreamHandler = (command: string, fn: (...args: any[]) => AsyncGenerator<any, void, boolean>) => {
        streamDispatchMap.set(command, fn);
    };
    setCallHandler("eventpublish", async (_client, data: WaveEvent) => {
        console.log("[mock eventpublish]", data);
        handleWaveEvent(data);
        return null;
    });
    setCallHandler("getmeta", async (_client, data: CommandGetMetaData) => {
        const objAtom = wos.getWaveObjectAtom(data.oref);
        const current = globalStore.get(objAtom) as WaveObj & { meta?: MetaType };
        return current?.meta ?? {};
    });
    setCallHandler("setmeta", async (_client, data: CommandSetMetaData) => {
        const objAtom = wos.getWaveObjectAtom(data.oref);
        const current = globalStore.get(objAtom) as WaveObj & { meta?: MetaType };
        const updatedMeta = { ...(current?.meta ?? {}) };
        for (const [key, value] of Object.entries(data.meta)) {
            if (value === null) {
                delete updatedMeta[key];
            } else {
                (updatedMeta as any)[key] = value;
            }
        }
        const updated = { ...current, meta: updatedMeta };
        wos.mockSetWaveObj(data.oref, updated);
        return null;
    });
    setCallHandler("updatetabname", async (_client, data: { args: [string, string] }) => {
        const [tabId, newName] = data.args;
        const tabORef = "tab:" + tabId;
        const objAtom = wos.getWaveObjectAtom(tabORef);
        const current = globalStore.get(objAtom) as Tab;
        const updated = { ...current, name: newName };
        wos.mockSetWaveObj(tabORef, updated);
        return null;
    });
    setCallHandler("setconfig", async (_client, data: SettingsType) => {
        const current = globalStore.get(wos.fullConfigAtom);
        const updatedSettings = { ...(current?.settings ?? {}) };
        for (const [key, value] of Object.entries(data)) {
            if (value === null) {
                delete (updatedSettings as any)[key];