import {z} from 'zod'

export type GetApiV1OrgOrgIdScenarioScenarioIdAuditLogArgs = {orgId: string, scenarioId: string, limit?: number | undefined, from?: string | undefined, format?: string | undefined};

export type GetApiV1OrgOrgIdScenarioScenarioIdAuditLogOptions = {baseUrl?: string | undefined, fetch?: typeof fetch | undefined};

export const event = z.object({id: z.string(), userId: z.string(), orgId: z.string().optional(), type: z.enum(["APP", "APPROVE", "CANCEL", "COMBINE", "CREATE", "DELETE", "DONE", "ERROR", "EXPORT", "EXPORT_CSV", "EXPORT_ORG_CHART", "GENERATE", "GEOIP", "INCOMING", "INSTALL", "INVITE", "INBOUND", "LOGIN", "MERGE", "MESSAGE", "OUTBOUND", "PREVIEW_AS", "READ", "READ_EXTERNAL", "READ_SENSITIVE", "READ_ATS", "READ_ATS_WEBHOOK", "READ_FULL_NAME", "READ_FUTURE_DATE", "READ_METADATA", "READ_COMP", "READ_BILLING", "READ_PENDING", "READ_PAYROLL", "READ_SENSITIVE_FILTERS", "WRITE_EXTERNAL", "REASSIGN", "REJECT", "RELEASE", "REMIND", "REMOVE_PASSWORD", "REQUEST", "RESTORE", "RESUME", "REVOKE", "RUN", "RUN_ATS", "SECURITY", "SHARE", "SHOW_DASHBOARD_DAYS_AHEAD", "SHOW_OPEN_JOBS", "STEP", "SUBMIT", "SYNC", "TEST", "TOKEN", "UNINSTALL", "UPDATE", "UPDATE_PASSWORD", "UPLOAD_CSV", "WRITE", "VIEW_AS"]), entityType: z.enum(["ACTION", "AGREEMENT", "AI_AGENT", "AI_AGENT_MEMORY", "AI_CHAT", "AI_CONFIG", "AI_CREDIT_LIMIT", "AI_CREDIT_LIMIT_CONFIG", "AI_CREDIT_USAGE", "AI_HINT", "AI_PROMPT", "APP", "APP_CONFIG", "APPROVAL_CHAIN", "APPROVAL_CHAIN_STAGE", "APPROVAL_DELEGATE", "APPROVAL_REQUEST", "ASSESSMENT", "BUDGET", "BUDGET_POOL", "BUNDLE", "CALENDAR", "CALENDAR_ENTRY", "CATEGORY", "CATEGORY_SORT", "CHANGE", "COMMENT", "COMP_BAND", "COMP_REVIEW", "CONTENT", "CUSTOMER", "DATA_VIEW", "EXCHANGE_RATE", "EMAIL_TEMPLATE", "EVENT", "FIELD", "FILE", "FORM", "FORM_DRAFT", "FORM_RESPONSE", "GEOCODE", "GROUP", "GROUP_ALLOCATION", "GROUP_TYPE", "GOAL", "GOAL_PROGRESS", "GOAL_TARGET", "GOAL_TYPE", "GUIDELINE", "JOB", "JOB_CODE", "JOB_LEVEL", "MEDIA", "MESSAGE", "MULTIPLIER", "ORG", "ORG_CONFIG", "PERSON", "PROFILE_TAB", "POLICY", "PROCESS", "PRODUCT", "QUERY_TOKEN", "QUESTION", "REPORT", "REPORT_CHART", "ROLE", "SCENARIO", "SIGNATURE", "SIGNATURE_REQUEST", "STOCK_GRANT", "STOCK_PRICE", "TABLE", "TABLE_ROW", "TASK_CONFIG", "TEMPLATE", "TASK", "TOKEN", "TIMEOFF", "TIMEOFF_BALANCE_ADJUSTMENT", "TIMEOFF_LEDGER_ENTRY", "TIMEOFF_POLICY", "TRANSCRIPT", "USER"]), entityId: z.string(), behalfUserId: z.string().optional(), agentUserId: z.string().optional(), aiChatId: z.string().optional(), aiToolUseId: z.string().optional(), jobId: z.string().optional(), personId: z.string().optional(), tableId: z.string().optional(), subtype: z.string().optional(), payload: z.record(z.string(), z.object({})).optional(), at: z.string(), processId: z.string().optional(), date: z.string().optional(), scenarioId: z.string().optional(), parentEntityId: z.string().optional(), fields: z.array(z.string()).optional(), code: z.string().optional()});

export const accessAction = z.object({action: z.string(), fields: z.array(z.string()).optional(), types: z.array(z.string()).optional()});

export const resultsAccess = z.object({ids: z.array(z.string()).optional(), allowed: z.array(accessAction)});

export const resultsEvent = z.object({data: z.array(event), next: z.string().optional(), access: z.array(resultsAccess).optional()});

export const validateResponse = async <Output>(
  schema: {
    readonly '~standard': {
      readonly validate: (value: unknown) => ({ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray<PropertyKey | { readonly key: PropertyKey }> | undefined }> }) | Promise<{ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray<PropertyKey | { readonly key: PropertyKey }> | undefined }> }>
    }
  },
  value: unknown
): Promise<Output> => {
  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
};

/**
 * Return past audit log events for a scenario, paginated
 * 
 * GET /v1/org/{orgId}/scenario/{scenarioId}/audit-log
 */
export const getApiV1OrgOrgIdScenarioScenarioIdAuditLog = async (args: GetApiV1OrgOrgIdScenarioScenarioIdAuditLogArgs, options?: GetApiV1OrgOrgIdScenarioScenarioIdAuditLogOptions) => {
const {baseUrl = "https://localhost", fetch: fetchFn = fetch} = options ?? {}

const query = new URLSearchParams()
const headers = new Headers()
headers.set('accept', "application/json")

if (args.limit != null) query.append("limit", String(args.limit))
if (args.from != null) query.append("from", String(args.from))
if (args.format != null) query.append("format", String(args.format))

const url = `${baseUrl.replace(/\/+$/, '')}/v1/org/${encodeURIComponent(String(args.orgId))}/scenario/${encodeURIComponent(String(args.scenarioId))}/audit-log${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(resultsEvent, await res.json())
};