import {z} from 'zod' export type GetApiAdmissionOptionsArgs = {'X-Auth-Token': string}; export type GetApiAdmissionOptionsOptions = {baseUrl: string, fetch?: typeof fetch | undefined}; export const rESTAdmissionState = z.object({enable: z.boolean().optional(), mode: z.string().optional(), default_action: z.string().optional(), adm_client_mode: z.string().optional(), adm_svc_type: z.string().optional(), adm_client_mode_options: z.object({service: z.string().optional(), url: z.string().optional()}).optional(), ctrl_states: z.object({validate: z.string().optional(), states: z.boolean().optional()}).optional()}); export const rESTAdmissionRuleOption: z.ZodType = z.object({name: z.string(), ops: z.array(z.string()), values: z.array(z.string()).optional(), match_src: z.string().optional(), sub_options: z.object({rule: z.string().optional(), options: z.lazy(() => rESTAdmissionRuleOption.optional())}).optional()}); export const rESTAdmRuleOptions = z.object({rule_options: z.object({rule: z.string().optional(), options: rESTAdmissionRuleOption.optional()})}); export const rESTAdmCatOptions = z.object({k8s_options: rESTAdmRuleOptions.optional()}); export const rESTAdmRuleCriterion: z.ZodType = z.object({name: z.string(), op: z.string(), value: z.string(), sub_criteria: z.array(z.lazy(() => rESTAdmRuleCriterion)).optional()}); export const rESTAdmRuleTypeOptions = z.object({deny_options: rESTAdmCatOptions, exception_options: rESTAdmCatOptions, psp_collection: z.array(rESTAdmRuleCriterion).optional()}); export const rESTAdmissionConfigData = z.object({state: rESTAdmissionState.optional(), admission_options: rESTAdmRuleTypeOptions.optional(), k8s_env: z.boolean()}); 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 a list of admission options * * GET /admission/options */ export const getApiAdmissionOptions = async (args: GetApiAdmissionOptionsArgs, options: GetApiAdmissionOptionsOptions) => { const {baseUrl, fetch: fetchFn = fetch} = options ?? {} const query = new URLSearchParams() const headers = new Headers() headers.set('accept', "application/json") if (args['X-Auth-Token'] != null) headers.set("X-Auth-Token", String(args['X-Auth-Token'])) const url = `${baseUrl.replace(/\/+$/, '')}/admission/options${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(rESTAdmissionConfigData, await res.json()) };