@webpieces/ipc-bridge
v0.4.843
Published
Portable typed duplex IPC client and server factories for browser, React Native and Node
Readme
Portable IPC bridge
@webpieces/ipc-bridge exports both IpcClientFactory and IpcServerFactory for browser, React Native and Node. Install one package on each side of a trusted JSON transport connection. Either side can create client proxies and register server implementations.
import { IpcClientFactory, IpcServerFactory } from '@webpieces/ipc-bridge';Declare a shared abstract API with class-level @WpInternal(apiId) and one method-level @WpIpcEndpoint(methodId) per operation. The IDs are stable wire identities and survive minification. Methods accept exactly one non-null DTO and return a Promise. Add { kind: 'notification' } when the operation is a notification; notifications still acknowledge failures rather than silently swallowing them. IPC intentionally passes parsed JSON shapes through without consumer-authored runtime schemas or DTO reconstruction.
import { MaskLog, WpInternal, WpIpcEndpoint } from '@webpieces/core-util/ipc';
@WpInternal('playback.v1')
abstract class PlaybackApi {
@MaskLog({ token: 'full' })
@WpIpcEndpoint('play.v1')
abstract play(request: PlayRequest): Promise<void>;
}
const clients = new IpcClientFactory(connection, logging);
const playback = clients.createClient(PlaybackApi);
await playback.play(new PlayRequest('track-id'));The DTO, IDs and metadata live in the shared API package. The names of the abstract class and controller are never sent on the wire. Proxy inspection, symbols and then do not send requests. Added JSON fields are naturally ignored by typed consumers; missing fields may fail in application logic.
Construct IpcConnection with an IpcTransport adapter and IpcConnectionOptions: a positive timeout, a connection-wide unique ID generator, a scheduler returning timer cancellation functions, and an error owner. The adapter sends strings and subscribes once to incoming strings, transport errors and close events. Its send Promise must reject on send failure; parse/message-error callbacks go to the failure subscriber. A vendor bus adapter must not expose vendor Node declarations through its public contract. Do not install a second vendor handler for every API.
IpcLogging.context(call) is required and supplies an active per-call ApiCallContext carrying the transaction/call/parent IDs in the host logger. Both factories invoke framework LogApiCallImpl; receiver logging happens before encoding failures and sender completion logging happens after decoding. ApiEndUserError is rethrown but remains a successful monitoring outcome. Configure the normal framework logging backend at bootstrap. Masking affects logs, never wire DTOs.
Use clients.withContext(inboundContext) when making nested calls; this copies the transaction and makes the inbound call the parent. No ambient mutable state is held across awaits. createScoped on the server supports constructing a controller with a scoped client factory.
Timeout rejects with the existing ApiCallTimeoutError. Send/close/disposal rejects with local IpcTransportError, preserving the original failure as standard cause. This extends Error, not semantic ApiError, and is never a remote wire category. A receiver throwing ApiUnavailableError still arrives as that canonical semantic error, so callers can distinguish a failed local bridge from an unavailable remote implementation. A timeout does not cancel remote side effects, and the framework never replays requests. dispose() rejects pending requests and closes the adapter. Late replies are reported and ignored. Malformed envelopes and correlation mismatches fail the connection, including its pending calls. Observe all OS-callback send Promises or route rejections to the application's explicit error owner.
Host responsibilities: validate WebView origins/navigation/session identity and expose only authorized APIs. Suspension/resume, coalescing native state, durable usage journals and installed shell protocol minimums are application policies. Generic IPC cannot make suspended website JavaScript execute. Android/iOS lifecycle and locked-screen tests remain downstream integration work.
The required compatibility build checks published declarations without Node/DOM ambient types, scans transitive runtime dependencies, bundles Android/iOS with Metro and compiles Hermes bytecode. Hermes/device execution is a separate verification claim and must only be made when actually run.
Receiver registration
IpcServerFactory registers explicit shared contracts and already-constructed implementations. It does not create a bus or import an HTTP server, DI container, React Native runtime or Node request context.
const server = new IpcServerFactory(logging);
server.create(PlaybackApi, new NativePlaybackController(player));
server.create(NavigationApi, new NavigationController(router));
connection.setHandler(server.handle); // exactly once, before sending any callsOne connection has one dispatcher containing multiple APIs. Duplicate registrations fail. Unknown API/method IDs return canonical ApiEndpointNotFoundError, distinct from a missing domain entity. Successful void is encoded explicitly as null. Receiver exceptions are logged then encoded with the same ApiErrorCodec used by the sender to reconstruct canonical errors.
createScoped(Api, scope) accepts an IpcControllerScope<T> whose create(context) supplies the implementation for that invocation. Inject a clients.withContext(context) proxy into this controller when it calls back or invokes another API. Concurrent calls have separate context objects and do not overwrite a global async context.
A host may register receivers and create client proxies on both ends of the same connection. IpcConnection owns transport parse/send failures and disposal; see the connection and logging contracts above for the transport and logging contracts, error ownership, security responsibilities and downstream native lifecycle tests.
