import { LogLevel } from '../common.js'
import { Job } from '../common.js'

export type EnricherTriggerRequest<
  TParams = Record<string, any>,
  TOptions = {
    parallelism?: number
    slots?: number
  },
> = {
  enricher: string
  params?: TParams
  options?: TOptions
  jobId?: string
  idempotencyKey?: string
  logLevel?: LogLevel
}

export type EnricherQueueRequest<
  TRecord = Record<string, any>,
  TParams = Record<string, any>,
> = {
  enricher: string
  record: TRecord
  params?: TParams
  jobId?: string
  logLevel?: LogLevel
}

export const enrichers = {
  triggerWithParams: async <
    TParams = Record<string, any>,
    TOptions = { parallelism?: number; slots?: number },
  >(
    request: EnricherTriggerRequest<TParams, TOptions>,
  ): Promise<Job> => {
    request
    throw new Error(
      'enrichers.triggerWithParams() is a native function implemented by the platform runtime',
    )
  },
  queueRecord: async <
    TRecord = Record<string, any>,
    TParams = Record<string, any>,
  >(
    request: EnricherQueueRequest<TRecord, TParams>,
  ): Promise<void> => {
    request
    throw new Error(
      'enrichers.queue() is a native function implemented by the platform runtime',
    )
  },
}