import {z} from 'zod' export type GetApiApiV21CalendarEconomicsArgs = {accept: 'application/json', page?: number | undefined, pagesize?: number | undefined, 'parameters[date]'?: unknown | undefined, 'parameters[date_from]'?: unknown | undefined, 'parameters[date_to]'?: unknown | undefined, 'parameters[importance]'?: (1 | 2 | 3) | undefined, 'parameters[updated]'?: number | undefined, country?: unknown | undefined, event_name?: unknown | undefined, event_category?: unknown | undefined}; export type GetApiApiV21CalendarEconomicsOptions = {baseUrl?: string | undefined, ApiKeyAuth?: string | undefined, fetch?: typeof fetch | undefined}; export const gitlabBenzingaIoBenzingaBzgoPkgModelsCalendarApiEconomic = z.object({actual: z.string().optional(), actual_t: z.string().optional(), confirmed: z.boolean().optional(), consensus: z.string().optional(), consensus_t: z.string().optional(), country: z.string().optional(), date: z.string().optional(), description: z.string().optional(), event_category: z.string().optional(), event_name: z.string().optional(), event_period: z.string().optional(), id: z.string().optional(), importance: z.number().int().optional(), notes: z.string().optional(), period_year: z.number().int().optional(), prior: z.string().optional(), prior_t: z.string().optional(), time: z.string().optional(), updated: z.number().int().optional()}); export const apiEconomicResponse = z.object({economics: z.array(gitlabBenzingaIoBenzingaBzgoPkgModelsCalendarApiEconomic).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 }; /** * Returns the economic calendar data * * GET /api/v2.1/calendar/economics */ export const getApiApiV21CalendarEconomics = async (args: GetApiApiV21CalendarEconomicsArgs, options?: GetApiApiV21CalendarEconomicsOptions) => { const {baseUrl = "https://api.benzinga.com", fetch: fetchFn = fetch, ApiKeyAuth} = options ?? {} const query = new URLSearchParams() const headers = new Headers() headers.set('accept', "application/json") if (args.accept != null) headers.set("accept", String(args.accept)) if (args.page != null) query.append("page", String(args.page)) if (args.pagesize != null) query.append("pagesize", String(args.pagesize)) if (args['parameters[date]'] != null) query.append("parameters[date]", String(args['parameters[date]'])) if (args['parameters[date_from]'] != null) query.append("parameters[date_from]", String(args['parameters[date_from]'])) if (args['parameters[date_to]'] != null) query.append("parameters[date_to]", String(args['parameters[date_to]'])) if (args['parameters[importance]'] != null) query.append("parameters[importance]", String(args['parameters[importance]'])) if (args['parameters[updated]'] != null) query.append("parameters[updated]", String(args['parameters[updated]'])) if (args.country != null) query.append("country", String(args.country)) if (args.event_name != null) query.append("event_name", String(args.event_name)) if (args.event_category != null) query.append("event_category", String(args.event_category)) if (ApiKeyAuth !== undefined) headers.set("Key", ApiKeyAuth) const url = `${baseUrl.replace(/\/+$/, '')}/api/v2.1/calendar/economics${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(apiEconomicResponse, await res.json()) };