Function decodeQueryResult

packages/runtime-host/src/protocol/skill-catalog.ts:482–532

(value: unknown)

}

function decodeQueryResult(value: unknown): SkillCatalogQueryResult {
  const record = requireRecord(value, 'skill catalog query result');
  if (record.kind === 'revision_changed') {
    const changed = requireExactRecord(record, 'skill catalog revision changed result', [
      'kind',
      'expectedRevision',
      'actualRevision',
      'resolvedWorkspace',
    ]);
    return {
      ...revisionChanged({
        kind: changed.kind,
        expectedRevision: changed.expectedRevision,
        actualRevision: changed.actualRevision,
      }),
      resolvedWorkspace: decodeWorkspaceProjection(changed.resolvedWorkspace),
    };
  }
  const page = requireExactRecord(record, 'skill catalog page result', [
    'kind',
    'view',
    'revision',
    'items',
    'nextCursor',
    'resolvedWorkspace',
  ]);
  if (page.kind !== 'page' || !Array.isArray(page.items)) {
    throw invalidProtocolFrame('Invalid skill catalog page result');
  }
  if (page.items.length > SKILL_CATALOG_PAGE_MAX_ITEMS) {
    throw invalidProtocolFrame('Skill catalog page exceeds item limit');
  }
  const view = catalogView(page.view);
  const decoded: SkillCatalogQueryResult = {
    kind: 'page',
    view,
    revision: sha256(page.revision, 'skill catalog revision'),
    items: page.items.map((item) => pageItem(item, view)),
    nextCursor:
      page.nextCursor === null
        ? null
        : utf8String(page.nextCursor, 'skill catalog next cursor', CURSOR_MAX_BYTES),
    resolvedWorkspace: decodeWorkspaceProjection(page.resolvedWorkspace),
  };
  assertJsonByteLimit(
    decoded,
    SKILL_CATALOG_PAGE_MAX_BYTES + resolvedWorkspaceByteOverhead(decoded.resolvedWorkspace),
    'Skill catalog page',
  );
  return decoded;
}

function pageItem(value: unknown, view: SkillCatalogView): SkillCatalogPageItem {
  if (view === 'governance') return governanceItem(value);