Add files using upload-large-folder tool

4e23b01 verified about 1 month ago

1.56 kB

/**
 * `fileService` — process-global upload store. Mirrors
 * `agent-core-v2/app/file/fileService.ts`.
 *
 * The wire cannot carry the engine's streams (every value JSON round-trips),
 * so bytes cross base64-encoded: `save`'s `Readable` source becomes a base64
 * string as the first argument, and `get`'s result stream is buffered
 * server-side and returned as `{ meta, data }` with `data` base64-encoded.
 * The dispatcher performs the stream ⇄ base64 adaptation; the facade encodes
 * and decodes the caller's `Uint8Array`s.
 */

import { z } from 'zod';

import { noResult } from '../helpers.js';
import type { ServiceContract } from '../types.js';

export const fileMetaSchema = z.object({
  id: z.string().min(1),
  name: z.string().min(1),
  media_type: z.string().min(1),
  size: z.number().int().nonnegative(),
  created_at: z.string(),
  expires_at: z.string().optional(),
});

export const fileSaveOptionsSchema = z.object({
  name: z.string().optional(),
  mimeType: z.string().optional(),
  expiresInSec: z.number().optional(),
});

/** Wire result of `get` — the engine's `GetResult.stream` buffered to base64. */
export const fileGetResultSchema = z.object({
  meta: fileMetaSchema,
  data: z.string(),
});

export const filesContract = {
  save: {
    input: z.tuple([z.string(), z.string().min(1), fileSaveOptionsSchema]),
    output: fileMetaSchema,
  },
  get: { input: z.tuple([z.string().min(1)]), output: fileGetResultSchema },
  delete: { input: z.tuple([z.string().min(1)]), output: noResult },
} satisfies ServiceContract;

	/**
	* `fileService` — process-global upload store. Mirrors
	* `agent-core-v2/app/file/fileService.ts`.
	*
	* The wire cannot carry the engine's streams (every value JSON round-trips),
	* so bytes cross base64-encoded: `save`'s `Readable` source becomes a base64
	* string as the first argument, and `get`'s result stream is buffered
	* server-side and returned as `{ meta, data }` with `data` base64-encoded.
	* The dispatcher performs the stream ⇄ base64 adaptation; the facade encodes
	* and decodes the caller's `Uint8Array`s.
	*/

	import { z } from 'zod';

	import { noResult } from '../helpers.js';
	import type { ServiceContract } from '../types.js';

	export const fileMetaSchema = z.object({
	id: z.string().min(1),
	name: z.string().min(1),
	media_type: z.string().min(1),
	size: z.number().int().nonnegative(),
	created_at: z.string(),
	expires_at: z.string().optional(),
	});

	export const fileSaveOptionsSchema = z.object({
	name: z.string().optional(),
	mimeType: z.string().optional(),
	expiresInSec: z.number().optional(),
	});

	/** Wire result of `get` — the engine's `GetResult.stream` buffered to base64. */
	export const fileGetResultSchema = z.object({
	meta: fileMetaSchema,
	data: z.string(),
	});

	export const filesContract = {
	save: {
	input: z.tuple([z.string(), z.string().min(1), fileSaveOptionsSchema]),
	output: fileMetaSchema,
	},
	get: { input: z.tuple([z.string().min(1)]), output: fileGetResultSchema },
	delete: { input: z.tuple([z.string().min(1)]), output: noResult },
	} satisfies ServiceContract;