import {z} from 'zod' export type UserPreferences = {theme?: ('light' | 'dark' | null) | undefined}; export type UserCreate = {username: string, firstname: string, lastname: string, email: string, billing_name?: (string | null) | undefined, billing_address?: (Record | null) | undefined, credit_balance_warning?: (number | null) | undefined, organization_uuid?: (string | null) | undefined, organization_role_id?: (number | null) | undefined, pinned_workflows?: (Array | null) | undefined, preferences?: (UserPreferences | null) | undefined, max_concurrency?: (number | null) | undefined, max_credit_overage?: (number | null) | undefined, password?: (string | null) | undefined, signup_data?: Record | undefined}; export type CreateApiUserArgs = {body: UserCreate}; export type CreateApiUserOptions = {baseUrl: string, fetch?: typeof fetch | undefined}; export const userPreferences = z.object({theme: z.enum(["light", "dark"]).nullable().optional()}); export const organizationRole = z.object({id: z.number().int(), name: z.string(), permissions: z.array(z.string())}); export const subscriptionPlan = z.object({name: z.string(), is_free: z.boolean(), max_concurrency: z.number().int(), default_organization_weekly_credits: z.number().int().nullable().optional(), display_name: z.string().nullable().optional(), billed_monthly: z.boolean().optional(), max_max_concurrency: z.number().int()}); export const subscription = z.object({subscription_plan: subscriptionPlan, num_seats: z.number().int().nullable().optional()}); export const organization = z.object({uuid: z.string(), name: z.string(), subscription: subscription.nullable(), credits: z.number(), weekly_credits: z.number(), weekly_credit_override: z.number().nullable().optional(), use_ip_whitelist: z.boolean().optional(), overage_credits: z.number().nullable().optional(), max_credit_overage: z.number().nullable().optional(), allow_credit_overage: z.boolean().optional(), allow_storage_overage: z.boolean().optional()}); export const user = z.object({username: z.string().min(3).max(128), firstname: z.string().max(128), lastname: z.string().max(128), email: z.string(), billing_name: z.string().nullable().optional(), billing_address: z.object({}).nullable().optional(), credit_balance_warning: z.number().int().nullable().optional(), organization_uuid: z.string().nullable().optional(), organization_role_id: z.number().int().nullable().optional(), pinned_workflows: z.array(z.string()).nullable().optional(), preferences: userPreferences.nullable().optional(), max_concurrency: z.number().int().nullable().optional(), max_credit_overage: z.number().int().nullable().optional(), uuid: z.string(), credits: z.number(), weekly_credits_used: z.number().nullable().optional(), weekly_credit_limit: z.number().nullable().optional(), email_verified: z.boolean(), cost_per_credit: z.number().gt(0), organization_role: organizationRole.nullable().optional(), organization: organization.nullable().optional(), individual_subscription: subscription.nullable().optional(), active: z.boolean().nullable().optional(), feature_list: z.array(z.string()).nullable().optional(), enabled_workflows: z.array(z.string()).nullable().optional(), two_fa_enabled: z.boolean().nullable().optional(), is_academic: z.boolean().optional(), overage_credits: z.number().nullable().optional(), allow_credit_overage: z.boolean().optional(), allow_storage_overage: z.boolean().optional()}); 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 }; /** * Create User * * POST /user */ export const createApiUser = async (args: CreateApiUserArgs, options: CreateApiUserOptions) => { const {baseUrl, fetch: fetchFn = fetch} = options ?? {} const query = new URLSearchParams() const headers = new Headers() headers.set('content-type', "application/json") headers.set('accept', "application/json") const url = `${baseUrl.replace(/\/+$/, '')}/user${query.size > 0 ? `?${query}` : ''}` const res = await fetchFn(url, {method: "POST", headers, body: JSON.stringify(args.body)}) if (!res.ok) throw new Error(`Request failed with status ${res.status}`, {cause: {status: res.status, body: await res.text()}}) return validateResponse(user, await res.json()) };