import {z} from 'zod' export type CreateApiCurpReverseQueryArgs = {body: {state?: ('AS' | 'BC' | 'BS' | 'CC' | 'CL' | 'CM' | 'CS' | 'CH' | 'DF' | 'DG' | 'GT' | 'GR' | 'HG' | 'JC' | 'MC' | 'MN' | 'MS' | 'NT' | 'NL' | 'OC' | 'PL' | 'QT' | 'QR' | 'SP' | 'SL' | 'SR' | 'TC' | 'TS' | 'TL' | 'VZ' | 'YN' | 'ZS' | 'NE') | undefined, birthdate?: unknown | undefined, name?: string | undefined, first_surname?: string | undefined, last_surname?: string | undefined, gender?: ('M' | 'F') | undefined}}; export type CreateApiCurpReverseQueryOptions = {baseUrl: string, APIKeyAuth?: string | undefined, fetch?: typeof fetch | undefined}; export const cURPResponse = z.object({data: z.object({document_data: z.object({}).optional(), personal_data: z.object({}).optional()}).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 }; /** * Consulta por datos personales * * POST /curp/reverse-query */ export const createApiCurpReverseQuery = async (args: CreateApiCurpReverseQueryArgs, options: CreateApiCurpReverseQueryOptions) => { const {baseUrl, fetch: fetchFn = fetch, APIKeyAuth} = options ?? {} const query = new URLSearchParams() const headers = new Headers() headers.set('content-type', "application/x-www-form-urlencoded") headers.set('accept', "application/json") if (APIKeyAuth !== undefined) headers.set("X-API-Key", APIKeyAuth) const url = `${baseUrl.replace(/\/+$/, '')}/curp/reverse-query${query.size > 0 ? `?${query}` : ''}` const res = await fetchFn(url, {method: "POST", headers, body: new URLSearchParams(Object.entries(args.body).flatMap(([key, value]) => (value == null ? [] : [[key, String(value)]])))}) if (!res.ok) throw new Error(`Request failed with status ${res.status}`, {cause: {status: res.status, body: await res.text()}}) return validateResponse(cURPResponse, await res.json()) };