Function decodeQueryInput

packages/runtime-host/src/protocol/skill-catalog.ts:449–480

(value: unknown)

}

function decodeQueryInput(value: unknown): SkillCatalogQueryInput {
  const record = requireRecord(value, 'skill catalog query input');
  if (record.kind === 'start') {
    const start = requireExactRecord(record, 'skill catalog start query', [
      'kind',
      'context',
      'view',
    ]);
    return {
      kind: 'start',
      context: localContext(start.context),
      view: catalogView(start.view),
    };
  }
  if (record.kind === 'continue') {
    const continuation = requireExactRecord(record, 'skill catalog continuation query', [
      'kind',
      'context',
      'view',
      'revision',
      'cursor',
    ]);
    return {
      kind: 'continue',
      context: localContext(continuation.context),
      view: catalogView(continuation.view),
      revision: sha256(continuation.revision, 'skill catalog revision'),
      cursor: utf8String(continuation.cursor, 'skill catalog cursor', CURSOR_MAX_BYTES),
    };
  }
  throw invalidProtocolFrame('Invalid skill catalog query kind');
}

function decodeQueryResult(value: unknown): SkillCatalogQueryResult {
  const record = requireRecord(value, 'skill catalog query result');