import {z} from 'zod' export type GetApiV1NamespacesNamespaceApplicationsAppnameArgs = {namespace: string, appname: string}; export type GetApiV1NamespacesNamespaceApplicationsAppnameOptions = {baseUrl: string, fetch?: typeof fetch | undefined}; export const v1alpha1InputItem = z.object({from: z.string(), parameterKey: z.string().optional()}); export const v1alpha1OutputItem = z.object({name: z.string(), valueFrom: z.string()}); export const commonApplicationTrait = z.object({properties: z.string().optional(), type: z.string()}); export const commonApplicationComponent = z.object({dependsOn: z.array(z.string()).optional(), externalRevision: z.string().optional(), inputs: z.array(v1alpha1InputItem).optional(), name: z.string(), outputs: z.array(v1alpha1OutputItem).optional(), properties: z.string().optional(), scopes: z.record(z.string(), z.string()).optional(), traits: z.array(commonApplicationTrait).optional(), type: z.string()}); export const v1beta1AppPolicy = z.object({name: z.string().optional(), properties: z.string().optional(), type: z.string()}); export const v1beta1ApplicationSourceStatusPolicy = z.object({exposeConsumedValues: z.boolean().optional(), maskPaths: z.array(z.string()).optional()}); export const v1beta1ApplicationSource = z.object({autoUpdate: z.boolean().optional(), name: z.string(), properties: z.string().optional(), statusPolicy: v1beta1ApplicationSourceStatusPolicy.optional(), type: z.string()}); export const v1alpha1WorkflowExecuteMode = z.object({steps: z.string().optional(), subSteps: z.string().optional()}); export const v1alpha1WorkflowStepMeta = z.object({alias: z.string().optional()}); export const v1alpha1WorkflowStepBase = z.object({dependsOn: z.array(z.string()).optional(), if: z.string().optional(), inputs: z.array(v1alpha1InputItem).optional(), meta: v1alpha1WorkflowStepMeta.optional(), name: z.string().optional(), outputs: z.array(v1alpha1OutputItem).optional(), properties: z.string().optional(), timeout: z.string().optional(), type: z.string()}); export const v1alpha1WorkflowStep = z.object({dependsOn: z.array(z.string()).optional(), if: z.string().optional(), inputs: z.array(v1alpha1InputItem).optional(), meta: v1alpha1WorkflowStepMeta.optional(), mode: z.string().optional(), name: z.string().optional(), outputs: z.array(v1alpha1OutputItem).optional(), properties: z.string().optional(), subSteps: z.array(v1alpha1WorkflowStepBase).optional(), timeout: z.string().optional(), type: z.string()}); export const v1beta1Workflow = z.object({mode: v1alpha1WorkflowExecuteMode.optional(), ref: z.string().optional(), steps: z.array(v1alpha1WorkflowStep).optional()}); export const v1beta1ApplicationSpec = z.object({components: z.array(commonApplicationComponent), policies: z.array(v1beta1AppPolicy).optional(), sources: z.array(v1beta1ApplicationSource).optional(), workflow: v1beta1Workflow.optional()}); export const commonAppliedApplicationPolicy = z.object({annotationsCount: z.number().int().optional(), applied: z.boolean(), definitionRevisionName: z.string().optional(), error: z.boolean().optional(), hasContext: z.boolean().optional(), labelsCount: z.number().int().optional(), message: z.string().optional(), name: z.string(), namespace: z.string(), revision: z.number().int().optional(), revisionHash: z.string().optional(), source: z.string().optional(), specModified: z.boolean().optional(), type: z.string().optional()}); export const commonClusterObjectReference = z.object({apiVersion: z.string().optional(), cluster: z.string().optional(), creator: z.string().optional(), fieldPath: z.string().optional(), kind: z.string().optional(), name: z.string().optional(), namespace: z.string().optional(), resourceVersion: z.string().optional(), uid: z.string().optional()}); export const v1ObjectReference = z.object({apiVersion: z.string().optional(), fieldPath: z.string().optional(), kind: z.string().optional(), name: z.string().optional(), namespace: z.string().optional(), resourceVersion: z.string().optional(), uid: z.string().optional()}); export const conditionCondition = z.object({lastTransitionTime: z.string(), message: z.string().optional(), reason: z.string(), status: z.string(), type: z.string()}); export const commonRevision = z.object({name: z.string(), revision: z.number().int(), revisionHash: z.string().optional()}); export const commonPolicyStatus = z.object({name: z.string(), status: z.string().optional(), type: z.string()}); export const commonApplicationTraitStatus = z.object({details: z.record(z.string(), z.string()).optional(), healthy: z.boolean(), message: z.string().optional(), pending: z.boolean().optional(), type: z.string()}); export const commonWorkloadGVK = z.object({apiVersion: z.string(), kind: z.string()}); export const commonApplicationComponentStatus = z.object({cluster: z.string().optional(), details: z.record(z.string(), z.string()).optional(), env: z.string().optional(), healthy: z.boolean(), message: z.string().optional(), name: z.string(), namespace: z.string().optional(), scopes: z.array(v1ObjectReference).optional(), traits: z.array(commonApplicationTraitStatus).optional(), workloadDefinition: commonWorkloadGVK.optional(), workloadHealthy: z.boolean().optional()}); export const commonSourceValue = z.object({property: z.string().optional(), sourceAttr: z.string(), value: z.string().optional()}); export const commonSourceConsumer = z.object({cluster: z.string().optional(), definitionKind: z.string(), name: z.string(), namespace: z.string().optional(), type: z.string().optional(), values: z.array(commonSourceValue).optional()}); export const commonSourceResolution = z.object({clusters: z.array(z.string()).optional(), expiresAt: z.string().optional(), message: z.string().optional(), phase: z.string().optional(), storageKey: z.string().optional()}); export const commonApplicationSourceStatus = z.object({autoUpdate: z.boolean().optional(), consumedBy: z.array(commonSourceConsumer).optional(), message: z.string().optional(), name: z.string(), phase: z.string().optional(), resolutions: z.array(commonSourceResolution).optional(), type: z.string().optional()}); export const v1alpha1StepStatus = z.object({firstExecuteTime: z.string().optional(), id: z.string(), lastExecuteTime: z.string().optional(), message: z.string().optional(), name: z.string().optional(), phase: z.string().optional(), reason: z.string().optional(), type: z.string().optional()}); export const v1alpha1WorkflowStepStatus = z.object({firstExecuteTime: z.string().optional(), id: z.string(), lastExecuteTime: z.string().optional(), message: z.string().optional(), name: z.string().optional(), phase: z.string().optional(), reason: z.string().optional(), subSteps: z.array(v1alpha1StepStatus).optional(), type: z.string().optional()}); export const commonWorkflowStatus = z.object({appRevision: z.string().optional(), contextBackend: v1ObjectReference.optional(), endTime: z.string().optional(), finished: z.boolean(), message: z.string().optional(), mode: z.string(), startTime: z.string().optional(), status: z.string().optional(), steps: z.array(v1alpha1WorkflowStepStatus).optional(), suspend: z.boolean(), suspendState: z.string().optional(), terminated: z.boolean()}); export const commonAppStatus = z.object({applicationPoliciesConfigMap: z.string().optional(), appliedApplicationPolicies: z.array(commonAppliedApplicationPolicy).optional(), appliedResources: z.array(commonClusterObjectReference).optional(), components: z.array(v1ObjectReference).optional(), conditions: z.array(conditionCondition).optional(), latestRevision: commonRevision.optional(), observedGeneration: z.number().int().optional(), policy: z.array(commonPolicyStatus).optional(), services: z.array(commonApplicationComponentStatus).optional(), sources: z.array(commonApplicationSourceStatus).optional(), status: z.string().optional(), workflow: commonWorkflowStatus.optional(), workflowRestartScheduledAt: z.string().optional()}); export const v1ApplicationResponse = z.object({apiVersion: z.string(), kind: z.string(), spec: v1beta1ApplicationSpec, status: commonAppStatus}); 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 the specified oam application in the specified namespace * * GET /v1/namespaces/{namespace}/applications/{appname} */ export const getApiV1NamespacesNamespaceApplicationsAppname = async (args: GetApiV1NamespacesNamespaceApplicationsAppnameArgs, options: GetApiV1NamespacesNamespaceApplicationsAppnameOptions) => { const {baseUrl, fetch: fetchFn = fetch} = options ?? {} const query = new URLSearchParams() const headers = new Headers() headers.set('accept', "application/json") const url = `${baseUrl.replace(/\/+$/, '')}/v1/namespaces/${encodeURIComponent(String(args.namespace))}/applications/${encodeURIComponent(String(args.appname))}${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(v1ApplicationResponse, await res.json()) };