import { type FarmIntegrationLogger } from "@farm.js/core";
import type { FarmIntegrationAPIOperation } from "@farm.js/core/client";
export type JobsRuntimeKind = "trigger" | "inngest";
export type JobsRunStatus = "queued" | "delayed" | "running" | "waiting" | "completed" | "failed" | "canceled" | "expired" | "unknown";
export interface JobsRuntimeCapabilities {
    readonly delay: boolean;
    readonly schedule: boolean;
    readonly debounce: boolean;
    readonly tags: boolean;
    readonly cancel: boolean;
    readonly batchTrigger: boolean;
    readonly queue: boolean;
    readonly retry: boolean;
    readonly ttl: boolean;
    readonly concurrencyKey: boolean;
    readonly idempotencyKey: boolean;
}
export interface JobsTaskQueueDefinition {
    name: string;
    concurrencyLimit?: number;
}
export interface JobsTaskRetryDefinition {
    attempts?: number;
}
export interface JobsTaskScheduleDefinition {
    cron: string;
    timezone?: string;
}
export type JobsTaskSchedule = string | JobsTaskScheduleDefinition;
export interface JobsTaskContext {
    runtime: JobsRuntimeKind;
    task: {
        key: string;
        id: string;
    };
    logger: Pick<Console, "debug" | "info" | "warn" | "error">;
}
export interface JobsTaskDefaults<TInput> {
    queue?: string | JobsTaskQueueDefinition;
    retry?: false | JobsTaskRetryDefinition;
    ttl?: string | number;
    concurrencyKey?: string | ((input: TInput) => string);
    idempotencyKey?: string | ((input: TInput) => string);
    tags?: readonly string[];
}
export interface JobsTaskInput<TInput, TOutput> {
    id?: string;
    description?: string;
    schedule?: JobsTaskSchedule;
    defaults?: JobsTaskDefaults<TInput>;
    run(input: TInput, context: JobsTaskContext): Promise<TOutput> | TOutput;
}
export interface JobsTaskDefinition<TInput, TOutput> extends JobsTaskInput<TInput, TOutput> {
    readonly kind: "farm-jobs-task";
}
export type JobsTaskMap = Record<string, JobsTaskDefinition<any, any>>;
export type InferJobsTaskInput<TTask> = TTask extends JobsTaskDefinition<infer TInput, any> ? TInput : never;
export type InferJobsTaskOutput<TTask> = TTask extends JobsTaskDefinition<any, infer TOutput> ? TOutput : never;
export type JobsTriggerBody<TInput> = [TInput] extends [void] ? {
    $options?: JobsTriggerOptions;
} : (TInput extends object ? TInput & {
    $options?: JobsTriggerOptions;
} : {
    value: TInput;
    $options?: JobsTriggerOptions;
}) | JobsLegacyTriggerBody<TInput>;
export type JobsBatchTriggerItem<TInput> = [TInput] extends [void] ? {
    $options?: JobsTriggerOptions;
} : JobsTriggerBody<TInput>;
export interface JobsBatchTriggerBody<TInput> {
    items: JobsBatchTriggerItem<TInput>[];
}
export interface JobsScheduleOptions {
    debounce?: JobsDebounceOptions;
    idempotencyKey?: string;
    tags?: readonly string[];
}
export interface JobsScheduleConfig extends JobsScheduleOptions {
    at?: string | Date;
    after?: string | number;
}
export type JobsScheduleBody<TInput> = [TInput] extends [void] ? {
    $schedule: JobsScheduleConfig;
} : (TInput extends object ? TInput & {
    $schedule: JobsScheduleConfig;
} : {
    value: TInput;
    $schedule: JobsScheduleConfig;
}) | JobsLegacyScheduleBody<TInput>;
export type JobsLegacyTriggerBody<TInput> = [TInput] extends [void] ? {
    input?: undefined;
    options?: JobsTriggerOptions;
} : {
    input: TInput;
    options?: JobsTriggerOptions;
};
export type JobsLegacyScheduleBody<TInput> = [TInput] extends [void] ? {
    input?: undefined;
    at?: string | Date;
    after?: string | number;
    options?: JobsScheduleOptions;
} : {
    input: TInput;
    at?: string | Date;
    after?: string | number;
    options?: JobsScheduleOptions;
};
export interface JobsDebounceOptions {
    key: string;
    delay: string | number | Date;
}
export interface JobsTriggerOptions {
    delay?: string | number | Date;
    debounce?: JobsDebounceOptions;
    idempotencyKey?: string;
    tags?: readonly string[];
}
export interface JobsTriggerResult {
    handleId: string;
    task: string;
    runtime: JobsRuntimeKind;
    queuedAt: string;
    providerTaskId: string;
}
export interface JobsScheduleResult extends JobsTriggerResult {
    scheduledFor: string | number;
}
export interface JobsBatchTriggerRunResult {
    index: number;
    handleId: string;
    queuedAt: string;
}
export interface JobsBatchTriggerResult {
    batchId: string | null;
    task: string;
    runtime: JobsRuntimeKind;
    providerTaskId: string;
    runs: JobsBatchTriggerRunResult[];
}
export interface JobsStatusQuery {
    handleId: string;
}
export interface JobsCancelBody {
    handleId: string;
}
export interface JobsRunStatusResult<TOutput = unknown> {
    handleId: string;
    providerRunId: string | null;
    task: string;
    runtime: JobsRuntimeKind;
    status: JobsRunStatus;
    providerStatus: string | null;
    queuedAt: string | null;
    startedAt: string | null;
    finishedAt: string | null;
    output: TOutput | null;
    error: unknown;
    tags: string[];
    raw: unknown;
}
export interface JobsCancelResult {
    handleId: string;
    task: string;
    runtime: JobsRuntimeKind;
    canceled: true;
}
export interface JobsTaskMetadata {
    key: string;
    id: string;
    remoteId: string;
    description: string | null;
    schedule: JobsTaskSchedule | null;
    runtime: JobsRuntimeKind;
    configured: boolean;
    capabilities: JobsRuntimeCapabilities;
    paths: {
        trigger: string;
        schedule: string;
        batchTrigger: string;
        status: string;
        cancel: string;
    };
    defaults: {
        queue: JobsTaskQueueDefinition | null;
        retryAttempts: number | null;
        ttl: string | number | null;
        tags: string[];
        hasConcurrencyKey: boolean;
        hasIdempotencyKey: boolean;
    };
}
export interface TriggerJobsRuntimeConfig {
    projectRef?: string;
    apiKey?: string;
    webhookSecret?: string;
    apiBaseUrl?: string;
}
export interface InngestJobsRuntimeConfig {
    appId?: string;
    eventKey?: string;
    signingKey?: string;
    eventBaseUrl?: string;
    apiBaseUrl?: string;
    eventNamePrefix?: string;
}
export interface TriggerJobsRuntimeDefinition {
    kind: "trigger";
    config: TriggerJobsRuntimeConfig;
}
export interface InngestJobsRuntimeDefinition {
    kind: "inngest";
    config: InngestJobsRuntimeConfig;
}
export type JobsRuntimeDefinition = TriggerJobsRuntimeDefinition | InngestJobsRuntimeDefinition;
interface ResolvedTriggerJobsConfig {
    kind: "trigger";
    projectRef: string;
    apiKey: string;
    webhookSecret: string;
    apiBaseUrl: string;
}
interface ResolvedInngestJobsConfig {
    kind: "inngest";
    appId: string;
    eventKey: string;
    signingKey: string;
    eventBaseUrl: string;
    apiBaseUrl: string;
    eventNamePrefix: string;
}
export interface JobsIntegrationInputBase<TTasks extends JobsTaskMap> {
    basePath?: string;
    tasks: TTasks;
    log?: FarmIntegrationLogger;
}
type JobsIntegrationRuntimeInput<TTasks extends JobsTaskMap> = JobsIntegrationInputBase<TTasks> & {
    runtime: JobsRuntimeDefinition;
    trigger?: never;
    inngest?: never;
};
type JobsIntegrationLegacyInput<TTasks extends JobsTaskMap> = (JobsIntegrationInputBase<TTasks> & {
    trigger: TriggerJobsRuntimeConfig;
    inngest?: never;
    runtime?: never;
}) | (JobsIntegrationInputBase<TTasks> & {
    inngest: InngestJobsRuntimeConfig;
    trigger?: never;
    runtime?: never;
});
export type JobsIntegrationInput<TTasks extends JobsTaskMap> = JobsIntegrationRuntimeInput<TTasks> | JobsIntegrationLegacyInput<TTasks>;
type JobsAPI<TTasks extends JobsTaskMap> = {
    [TKey in keyof TTasks & string]: {
        trigger: FarmIntegrationAPIOperation<JobsTriggerBody<InferJobsTaskInput<TTasks[TKey]>>, never, JobsTriggerResult, false, "POST">;
        schedule: FarmIntegrationAPIOperation<JobsScheduleBody<InferJobsTaskInput<TTasks[TKey]>>, never, JobsScheduleResult, false, "POST">;
        batchTrigger: FarmIntegrationAPIOperation<JobsBatchTriggerBody<InferJobsTaskInput<TTasks[TKey]>>, never, JobsBatchTriggerResult, false, "POST">;
        status: FarmIntegrationAPIOperation<never, JobsStatusQuery, JobsRunStatusResult<InferJobsTaskOutput<TTasks[TKey]>>, false, "GET">;
        cancel: FarmIntegrationAPIOperation<JobsCancelBody, never, JobsCancelResult, false, "POST">;
    };
} & {
    tasks: {
        list: FarmIntegrationAPIOperation<never, never, JobsTaskMetadata[], false, "GET">;
    };
};
export declare function task<TInput, TOutput>(input: JobsTaskInput<TInput, TOutput>): JobsTaskDefinition<TInput, TOutput>;
export declare function defineTasks<const TTasks extends JobsTaskMap>(tasks: TTasks): TTasks;
export declare function trigger(config: TriggerJobsRuntimeConfig): TriggerJobsRuntimeDefinition;
export declare function inngest(config: InngestJobsRuntimeConfig): InngestJobsRuntimeDefinition;
export declare function jobs<const TTasks extends JobsTaskMap>(input: JobsIntegrationInput<TTasks>): import("@farm.js/core").DefinedIntegration<{
    category: "automation";
    type: string;
    instance: {
        runtime: JobsRuntimeKind;
        configured: boolean;
        tasks: JobsTaskMetadata[];
    };
    config: import("@farm.js/core").FarmIntegrationConfigDefinition<ResolvedTriggerJobsConfig, import("@farm.js/core").FarmIntegrationSchema | undefined> | import("@farm.js/core").FarmIntegrationConfigDefinition<ResolvedInngestJobsConfig, import("@farm.js/core").FarmIntegrationSchema | undefined>;
    api: JobsAPI<TTasks>;
    log: FarmIntegrationLogger | undefined;
    routes: (import("@farm.js/core").FarmTypedIntegrationRoute<string, never, never, JobsTaskMetadata[], false, "GET", import("@farm.js/core").FarmIntegrationSchema | undefined> | import("@farm.js/core").FarmTypedIntegrationRoute<string, JobsTriggerBody<InferJobsTaskInput<TTasks[string & keyof TTasks]>>, never, JobsTriggerResult, false, "POST", import("@farm.js/core").FarmIntegrationSchema | undefined> | import("@farm.js/core").FarmTypedIntegrationRoute<string, JobsBatchTriggerBody<InferJobsTaskInput<TTasks[string & keyof TTasks]>>, never, JobsBatchTriggerResult, false, "POST", import("@farm.js/core").FarmIntegrationSchema | undefined> | import("@farm.js/core").FarmTypedIntegrationRoute<string, JobsScheduleBody<InferJobsTaskInput<TTasks[string & keyof TTasks]>>, never, JobsScheduleResult, false, "POST", import("@farm.js/core").FarmIntegrationSchema | undefined> | import("@farm.js/core").FarmTypedIntegrationRoute<string, never, JobsStatusQuery, JobsRunStatusResult<InferJobsTaskOutput<TTasks[string & keyof TTasks]>>, false, "GET", import("@farm.js/core").FarmIntegrationSchema | undefined> | import("@farm.js/core").FarmTypedIntegrationRoute<string, JobsCancelBody, never, JobsCancelResult, false, "POST", import("@farm.js/core").FarmIntegrationSchema | undefined>)[];
}>;
export {};
//# sourceMappingURL=index.d.ts.map