Add injected isomorphic environment

environment/types.ts

@@ -0,0 +1,4 @@
+export interface IsomorphicEnvironment {
+  log: (...args: unknown[]) => void;
+  error: (...args: unknown[]) => void;
+}

index.ts

@@ -45,3 +45,5 @@ export {
   waitForSocketReady,
   createWebSocketClient,
 } from './transport/util';
+
+export type { IsomorphicEnvironment } from './environment/types';

router/builder.ts

@@ -1,6 +1,7 @@
 import { TObject, Static, Type } from '@sinclair/typebox';
 import type { Pushable } from 'it-pushable';
 import { TransportMessage } from '../transport/message';
+import { IsomorphicEnvironment } from '../environment/types';
 
 export type ValidProcType = 'stream' | 'rpc';
 export type ProcListing = Record<
@@ -58,6 +59,11 @@ export type ProcType<
   ProcName extends keyof S['procedures'],
 > = S['procedures'][ProcName]['type'];
 
+export interface ProcedureContext<State extends object | unknown> {
+  environment: IsomorphicEnvironment;
+  state: State;
+}
+
 export type Procedure<
   State extends object | unknown,
   Ty extends ValidProcType,
@@ -68,7 +74,7 @@ export type Procedure<
       input: I;
       output: O;
       handler: (
-        state: State,
+        context: ProcedureContext<State>,
         input: TransportMessage<Static<I>>,
       ) => Promise<TransportMessage<Static<O>>>;
       type: Ty;
@@ -77,7 +83,7 @@ export type Procedure<
       input: I;
       output: O;
       handler: (
-        state: State,
+        context: ProcedureContext<State>,
         input: AsyncIterable<TransportMessage<Static<I>>>,
         output: Pushable<TransportMessage<Static<O>>>,
       ) => Promise<void>;

router/server.ts

@@ -1,10 +1,16 @@
 import { TObject } from '@sinclair/typebox';
 import { Transport } from '../transport/types';
-import { AnyService, Procedure, ValidProcType } from './builder';
+import {
+  AnyService,
+  Procedure,
+  ProcedureContext,
+  ValidProcType,
+} from './builder';
 import { Value } from '@sinclair/typebox/value';
 import { pushable } from 'it-pushable';
 import type { Pushable } from 'it-pushable';
 import { OpaqueTransportMessage, TransportMessage } from '../transport/message';
+import { IsomorphicEnvironment } from '../environment/types';
 
 export interface Server<Services> {
   services: Services;
@@ -18,12 +24,18 @@ interface ProcStream {
 }
 
 export async function createServer<Services extends Record<string, AnyService>>(
+  environment: IsomorphicEnvironment,
   transport: Transport,
   services: Services,
 ): Promise<Server<Services>> {
   // create streams for every stream procedure
   const streamMap: Map<string, ProcStream> = new Map();
   for (const [serviceName, service] of Object.entries(services)) {
+    const context: ProcedureContext<object> = {
+      environment,
+      state: service.state,
+    };
+
     for (const [procedureName, proc] of Object.entries(service.procedures)) {
       const procedure = proc as Procedure<
         object,
@@ -39,7 +51,7 @@ export async function createServer<Services extends Record<string, AnyService>>(
           outgoing,
           doneCtx: Promise.all([
             // processing the actual procedure
-            procedure.handler(service.state, incoming, outgoing),
+            procedure.handler(context, incoming, outgoing),
             // sending outgoing messages back to client
             (async () => {
               for await (const response of outgoing) {
@@ -78,7 +90,11 @@ export async function createServer<Services extends Record<string, AnyService>>(
           Value.Check(procedure.input, inputMessage.payload)
         ) {
           // synchronous rpc
-          const response = await procedure.handler(service.state, inputMessage);
+          const context: ProcedureContext<object> = {
+            environment,
+            state: service.state,
+          };
+          const response = await procedure.handler(context, inputMessage);
           transport.send(response);
           return;
         } else if (