Function blobsRoute

apps/vis/server/src/routes/blobs.ts:9–45

(home: string = KIMI_CODE_HOME)

import { isSafeBlobHash } from '../lib/blob-resolver';

export function blobsRoute(home: string = KIMI_CODE_HOME): Hono {
  const r = new Hono();
  r.get('/:id/blobs/:hash', async (c) => {
    const id = c.req.param('id');
    const agentId = c.req.query('agent') ?? 'main';
    const hash = c.req.param('hash');
    if (!isSafeAgentId(agentId)) {
      return c.json({ error: 'invalid agent id', code: 'BAD_REQUEST' }, 400);
    }
    if (!isSafeBlobHash(hash)) {
      return c.json({ error: 'invalid blob hash', code: 'BAD_REQUEST' }, 400);
    }
    const detail = await readSessionDetail(home, id);
    if (!detail) {
      return c.json({ error: 'session not found', code: 'NOT_FOUND' }, 404);
    }
    const agent = detail.agents.find((a) => a.agentId === agentId);
    if (!agent) {
      return c.json(
        { error: `agent "${agentId}" not found`, code: 'NOT_FOUND' },
        404,
      );
    }
    const blobPath = join(agent.homedir, 'blobs', hash);
    let content: Buffer;
    try {
      content = await readFile(blobPath);
    } catch {
      return c.json({ error: 'blob not found', code: 'NOT_FOUND' }, 404);
    }
    const mimeType = c.req.query('mime') ?? 'application/octet-stream';
    return new Response(content, {
      headers: { 'content-type': mimeType },
    });
  });
  return r;
}