tricu

io-profile.js (3165B)

---

 // This table is the implemented browser provider, not the native catalogue.
 import { canonicalNat, decodeAction, ProtocolError } from './io-protocol.js';
 export const coreNames = ['pure', 'bind', 'fail', 'scope', 'current-scope', 'spawn', 'join', 'discard', 'cancel', 'cancelled'];
 const groups = Object.freeze({
     runtime: ['capabilities', 'inspect'], standard: ['input', 'output', 'error'],
     stream: ['read', 'write'], resource: ['close'], utf8: ['encode', 'decode'],
 });
 export function available(group, revision, operation) {
     return revision === 1 && Object.hasOwn(groups, group) && groups[group].includes(operation);
 }
 export function capabilities(wire, backend) {
     const { tree } = wire, text = (s) => tree.text(s), number = (n) => tree.natural(BigInt(n));
     const strings = (xs) => wire.list(xs.map(text)), row = (name, value) => wire.list([text(name), value]);
     return wire.list([
         row('schema', number(1)), row('io-version', number(2)), row('backend', text(backend)), row('authority', text('browser-terminal')),
         row('core', strings(coreNames)), row('groups', wire.list(Object.entries(groups).map(([name, ops]) => wire.list([text(name), number(1), strings(ops)])))),
         row('limits', wire.list(Object.entries({ 'io-actions': 65536, 'chunk-bytes': 4096, 'transfer-handles': 256, 'utf8-encode-scalars': 1024, 'input-line-scalars': 256, 'output-attempted-bytes': 16384 }).map(([key, value]) => row(key, number(value))))),
         row('restrictions', strings(['action-boundary-cancellation', 'no-hard-deadlines', 'borrowed-standard-streams', 'standard-stream-leases-per-run', 'utf8-strict-scalars', 'text-line-input', 'byte-preserving-output', 'no-filesystem', 'no-network', 'no-processes'])),
     ]);
 }
 export function inspect(wire, value) {
     const action = decodeAction(wire.tree, value), t = wire.tree;
     return action.kind === 'core' ? wire.list([t.text('core'), t.text(coreNames[action.code])]) :
         wire.list([t.text('facility'), t.text(action.group), t.natural(BigInt(action.revision)), t.text(action.operation), t.text(available(action.group, action.revision, action.operation) ? 'available' : 'unsupported')]);
 }
 // Authenticate framing before selecting an interpreter. No action is observed.
 export function envelope(tree, value) {
     const root = tree.observe(value).node;
     if (root.kind !== 'fork')
         throw new ProtocolError('invalid IO envelope');
     let rest = root.left;
     for (const char of 'tricuIO') {
         const node = tree.observe(rest).node;
         if (node.kind !== 'fork' || canonicalNat(tree, node.left, 7) !== BigInt(char.charCodeAt(0)))
             throw new ProtocolError('Missing tricuIO sentinel');
         rest = node.right;
     }
     if (tree.observe(rest).node.kind !== 'leaf')
         throw new ProtocolError('Missing tricuIO sentinel');
     const body = tree.observe(root.right).node;
     if (body.kind !== 'fork')
         throw new ProtocolError('invalid IO envelope');
     const version = canonicalNat(tree, body.left, 2);
     if (version !== 2n)
         throw new ProtocolError('Unsupported tricuIO version');
     return { version: 2, action: body.right };
 }