feat: IOListener with accept(), plus anonymous kernel objects and a run-queue cache fix

packages/kernel-node-runtime/CHANGELOG.md

@@ -13,6 +13,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Changed
 
+- **BREAKING:** `makeIOChannelFactory` is now `makeIOListenerFactory`, and `makeSocketIOChannel` is now `makeSocketIOListener`. The Unix-socket server hands each connection to `accept()` as its own `IOChannel`, whose receive buffer, decoder, line queue, and reader queue are local to that connection, so any number of peers can be served concurrently. Connections arriving before `accept()` is called are queued rather than dropped. Gone with the single-client design: the shared `currentSocket`, the session-boundary latch, the merged line queue, and the `socket.destroy()` that rejected every second connection ([#1007](https://github.com/MetaMask/ocap-kernel/pull/1007))
 - **BREAKING:** Drop `platformOptions.fetch` from `makeNodeJsVatSupervisor` ([#942](https://github.com/MetaMask/ocap-kernel/pull/942))
   - `fetch` is now a vat endowment; stub `globalThis.fetch` directly if needed
 

packages/kernel-node-runtime/src/index.ts

@@ -2,4 +2,4 @@ export { NodejsPlatformServices } from './kernel/PlatformServices.ts';
 export { makeKernel } from './kernel/make-kernel.ts';
 export type { MakeKernelResult } from './kernel/make-kernel.ts';
 export { makeNodeJsVatSupervisor } from './vat/make-supervisor.ts';
-export { makeIOChannelFactory, makeSocketIOChannel } from './io/index.ts';
+export { makeIOListenerFactory, makeSocketIOListener } from './io/index.ts';

packages/kernel-node-runtime/src/io/index.ts

@@ -1,23 +1,23 @@
-import type { IOChannelFactory, IOConfig } from '@metamask/ocap-kernel';
+import type { IOListenerFactory, IOConfig } from '@metamask/ocap-kernel';
 
-import { makeSocketIOChannel } from './socket-channel.ts';
+import { makeSocketIOListener } from './socket-listener.ts';
 
-export { makeSocketIOChannel } from './socket-channel.ts';
+export { makeSocketIOListener } from './socket-listener.ts';
 
 /**
- * Create an IOChannelFactory for the Node.js environment.
- * Dispatches on `config.type` to the appropriate channel implementation.
+ * Create an IOListenerFactory for the Node.js environment.
+ * Dispatches on `config.type` to the appropriate listener implementation.
  *
- * @returns An IOChannelFactory.
+ * @returns An IOListenerFactory.
  */
-export function makeIOChannelFactory(): IOChannelFactory {
+export function makeIOListenerFactory(): IOListenerFactory {
   return async (name: string, config: IOConfig) => {
     switch (config.type) {
       case 'socket':
-        return makeSocketIOChannel(name, config.path);
+        return makeSocketIOListener(name, config.path);
       default:
         throw new Error(
-          `Unsupported IO channel type "${config.type}" for channel "${name}"`,
+          `Unsupported IO listener type "${config.type}" for listener "${name}"`,
         );
     }
   };