Your one stop for message bus apollo links
Complex GraphQL based applications may use a separate process to run schema execuation.
This library provides a set of tools which can used to create an ApolloLink and a Schema Executor which can communicate across any JS based message bus.
This library provides pre-written receipes for electron and webworker's
- API to integrate with any Bus
- Subscriptions, Queries, and Mutations
- Built in support for Electron and WebWorker buses
Electron 
Main
import {
createBusLinkBackend,
createSchemaExecutor,
} from "apollo-bus-link/core";
import { electronBus } from "apollo-bus-link/electron";
import { ipcMain } from "electron";
// Args come from the link through `.initialiseBackend`
// You can pass whatever object you want
export type Args = {
mockedMode: boolean;
};
const backend = createBusLinkBackend<Args>({
registerBus: electronBus(mockIpc.ipcMain),
createExecutor: (args) =>
createSchemaExecutor({
// Same API as apollo-server etc
schema,
context,
}),
});
// If you want to preiniitalise the backend, this can be done
// by calling initialise
// backend.initialise(...)
backend.listen();Renderer
import { createElectronBusLink, electronBus } from "apollo-bus-link/electron";
import { ipcRenderer } from "electron";
import { ApolloClient } from "@apollo/client/core";
const link = createElectronBusLink<Args>(ipcRenderer);
await link.initialiseBackend({ mockedMode: false });
const client = new ApolloClient({
link,
...
});WebWorker 🧑🏭
Worker
import {
createBusLinkBackend,
createSchemaExecutor,
} from "apollo-bus-link/core";
import { webWorkerBus } from "apollo-bus-link/electron";
// Args come from the link through `.initialiseBackend`
// You can pass whatever object you want
export type Args = {
mockedMode: boolean;
};
const backend = createBusLinkBackend<Args>({
registerBus: webWorkerBus(self),
createExecutor: (args) =>
createSchemaExecutor({
schema,
context,
}),
});
// If you want to preiniitalise the backend, this can be done
// by calling initialise
// backend.initialise(...)
backend.listen();Window
import { createWebWorkerBusLink } from "apollo-bus-link/webworker";
import { ApolloClient } from "@apollo/client/core";
const worker = new Worker(
new URL("./Worker.ts", import.meta.url)
);
const link = createWebWorkerBusLink<Args>(worker);
await link.initialiseBackend({ mockedMode: false });
const client = new ApolloClient({
link,
...
});Custom
Backend
import {
createBusLinkBackend,
createSchemaExecutor,
} from "apollo-bus-link/core";
const backend = createBusLinkBackend<Args>({
registerBus: (request) => {
myMessageBus.onMessage((message) =>
// It may be that you need the context of the initial message
// to be able to response, hence this being callback hell
request(message, (response) => {
myMessageBus.send(response);
})
);
},
createExecutor: (args) =>
createSchemaExecutor({
// Same API as apollo-server etc
schema,
context,
}),
});Link
import { BusLink } from "apollo-bus-link/core";
import { ApolloClient } from "@apollo/client/core";
const link = new BusLink({
requestHandler: (request) => {
myMessageBus.send(request);
},
registerResponseHandler: (handler) => {
myMessageBus.onMessage((response) => handler(response));
},
});
await link.initialiseBackend({ mockedMode: false });
const client = new ApolloClient({
link,
...
});- fresh-configurator - Used as both in webworker and electron formats depending on where the app is loaded
MIT