import {z} from 'zod' export type GetApiLibraryPathHandleArgs = {handle: string}; export type GetApiLibraryPathHandleOptions = {baseUrl: string, ApiKeyAuth?: string | undefined, fetch?: typeof fetch | undefined}; export const metadataCurrencyInfo = z.object({code: z.string().optional()}); export const metadataFormulaInfo = z.object({literal: z.string().optional(), resolved: z.string().optional()}); export const metadataColumnInfo = z.object({currency: metadataCurrencyInfo.optional(), formula: metadataFormulaInfo.optional()}); export const metadataColumnInfoMap = z.record(z.string(), metadataColumnInfo); export const typesJSONText = z.object({}); export const metadataFileDeletingState = z.union([z.literal(0), z.literal(1), z.literal(2), z.literal(8), z.literal(16), z.literal(32)]); export const metadataFileStatus = z.enum(["uploading", "loading", "processing", "processed", "error"]); export const metadataMetaData = z.object({ClickhouseNode: z.number().int().optional(), ColumnInfo: metadataColumnInfoMap.optional(), Comments: typesJSONText.optional(), CreatedAt: z.string().optional(), DeletedAt: z.string().optional(), Deleting: metadataFileDeletingState.optional(), DetailedStatus: z.string().optional(), Details: typesJSONText.optional(), ExampleAnalyses: z.array(z.string()).optional(), FieldsTypes: z.array(z.string()).optional(), FileName: z.string().optional(), FileRows: z.number().int().optional(), FileSize: z.string().optional(), FileUuid: z.string().optional(), HeaderToColumnMapping: typesJSONText.optional(), Headers: z.array(z.string()).optional(), IsDirectory: z.boolean().optional(), LastAccessed: z.string().optional(), LastUpdated: z.string().optional(), Note: z.string().optional(), OperationStatus: typesJSONText.optional(), Owner: z.string().optional(), ParentDirectory: z.string().optional(), ParserUsed: z.string().optional(), Source: z.string().optional(), Status: metadataFileStatus.optional(), StatusDetails: typesJSONText.optional(), ThreatDetectionStatus: typesJSONText.optional(), Type: z.number().int().optional()}); export const filesRestrictedEntry = z.object({permissions: z.array(z.number().int()).optional(), user_id: z.string().optional()}); export const filesShared = z.object({organization: z.array(z.number().int()).optional(), public: z.array(z.number().int()).optional(), restricted: z.array(filesRestrictedEntry).optional()}); export const filesLibraryEntry = z.object({metadata: metadataMetaData.optional(), permissions: z.array(z.number().int()).optional(), shared: filesShared.optional(), within_quota: z.boolean().optional()}); export const getApiLibraryPathHandleResponse = z.array(filesLibraryEntry); export const validateResponse = async ( schema: { readonly '~standard': { readonly validate: (value: unknown) => ({ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray | undefined }> }) | Promise<{ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray | undefined }> }> } }, value: unknown ): Promise => { const result = await schema['~standard'].validate(value) if (result.issues !== undefined) { const detail = result.issues .map(({ message, path }) => path?.length ? `${path.map((segment) => String(typeof segment === 'object' ? segment.key : segment)).join('.')}: ${message}` : message ) .join('; ') throw new Error(`Response does not match the schema: ${detail}`, { cause: { issues: result.issues } }) } return result.value }; /** * Get path * * GET /library/path/{handle} */ export const getApiLibraryPathHandle = async (args: GetApiLibraryPathHandleArgs, options: GetApiLibraryPathHandleOptions) => { const {baseUrl, fetch: fetchFn = fetch, ApiKeyAuth} = options ?? {} const query = new URLSearchParams() const headers = new Headers() headers.set('accept', "application/json") if (ApiKeyAuth !== undefined) headers.set("X-GIGASHEET-TOKEN", ApiKeyAuth) const url = `${baseUrl.replace(/\/+$/, '')}/library/path/${encodeURIComponent(String(args.handle))}${query.size > 0 ? `?${query}` : ''}` const res = await fetchFn(url, {method: "GET", headers}) if (!res.ok) throw new Error(`Request failed with status ${res.status}`, {cause: {status: res.status, body: await res.text()}}) return validateResponse(getApiLibraryPathHandleResponse, await res.json()) };