artifacts/api-server/src/lib/capability/external-knowledge/user-uploads.adapter.ts

/**
 * user-uploads.adapter — 留接口。后续单独任务才实现。
 *
 * 真接通需要 ObjectStorage 配置(blueprint app_storage,本任务 OOS)。
 *
 * 临时 workaround:
 *  - 用户上传的文件目前走 chat 附件流(messages.attachments),
 *    capability 拿不到,需要 caller 显式把附件内容内嵌到 query.params
 *    里。
 */
import { NotImplementedAdapter } from "./errors.ts";
import { fingerprintParams, recordCall } from "./telemetry.ts";
import type {
  KnowledgeAdapter,
  KnowledgeQuery,
  KnowledgeResult,
} from "./types.ts";

export const userUploadsAdapter: KnowledgeAdapter = {
  kind: "user_uploads",
  status: "interface_only",
  async query(q: KnowledgeQuery): Promise<KnowledgeResult> {
    const fp = fingerprintParams(q.params ?? {});
    const err = new NotImplementedAdapter("user_uploads", "B-future (ObjectStorage blueprint)");
    void recordCall({
      adapter: "user_uploads",
      capabilityId: q.capabilityId,
      latencyMs: 0,
      hitCount: 0,
      cacheHit: null,
      error: err.message,
      paramsFingerprint: fp,
    });
    throw err;
  },
};