import type { StreamIO } from "../data";
import type { BlobType, BooleanType, ConstFunction, DictType, EastFunction, EastType, IntegerType, PatchType, StringType } from "../east";
import type { Assertion } from "../task";
import type { ModulePath } from '../template';
/** @internal */
export type WriteableDefaultConfig = {
    default_type: "none";
} | {
    default_type: "file";
    path: string;
} | {
    default_type: "value";
    value: ConstFunction;
};
/** @internal */
export type WriteableSourceTaskDescription<T extends EastType = EastType> = {
    task_type: "source";
    source_type: "writeable";
    module: ModulePath;
    name: string;
    inputs: Record<string, StreamIO>;
    input_assertions: Assertion[];
    output_assertions: Assertion[];
    outputs: {
        output: StreamIO<T>;
    };
};
/** @internal */
export type PatchSourceTaskDescription<T extends EastType = EastType> = {
    task_type: "source";
    source_type: "patch";
    module: ModulePath;
    name: string;
    inputs: {
        base: StreamIO<T>;
        patch: StreamIO<PatchType<T>>;
    };
    outputs: {
        output: StreamIO<T>;
        conflicts: StreamIO<PatchType<T>>;
    };
};
/** @internal */
export type ClockSourceTaskDescription<T extends EastType = EastType> = {
    task_type: "source";
    source_type: "clock";
    module: ModulePath;
    name: string;
    cron: string;
    value: EastFunction<T>;
    inputs: Record<string, StreamIO>;
    input_assertions: Assertion[];
    output_assertions: Assertion[];
    outputs: {
        output: StreamIO<T>;
    };
};
/** @internal */
export type ElaraSourceTaskDescription<T extends EastType = EastType> = {
    task_type: "source";
    source_type: "elara";
    module: ModulePath;
    name: string;
    cron?: string | undefined;
    workspace: string;
    stream: string;
    type: T;
    inputs: Record<string, StreamIO>;
    outputs: {
        output: StreamIO<T>;
    };
};
/** @internal */
export type HttpMethod = "GET" | "POST" | "PUT" | "DELETE";
/** @internal */
export type ApiSourceTaskDescription = {
    task_type: "source";
    source_type: "api";
    module: ModulePath;
    name: string;
    cron?: string | undefined;
    request_url: EastFunction<StringType>;
    request_body?: EastFunction<EastType> | undefined;
    request_headers?: EastFunction<DictType<StringType, StringType>> | undefined;
    request_retry?: EastFunction<BooleanType> | undefined;
    request_next?: EastFunction<BooleanType> | undefined;
    request_delay?: EastFunction<IntegerType> | undefined;
    inputs: Record<string, StreamIO>;
    input_assertions: Assertion[];
    output_assertions: Assertion[];
    outputs: {
        output: StreamIO<BlobType>;
    };
};
/** @internal */
export type FtpSourceTaskDescription = {
    task_type: "source";
    source_type: "ftp";
    module: ModulePath;
    name: string;
    cron?: string | undefined;
    ftp_uri: EastFunction<StringType>;
    ftp_username?: EastFunction<StringType> | undefined;
    ftp_password?: EastFunction<StringType> | undefined;
    ftp_key?: EastFunction<StringType> | undefined;
    ftp_port?: EastFunction<IntegerType> | undefined;
    inputs: Record<string, StreamIO>;
    input_assertions: Assertion[];
    output_assertions: Assertion[];
    outputs: {
        output: StreamIO<BlobType>;
    };
};
/** @internal */
export type S3SourceTaskDescription = {
    task_type: "source";
    source_type: "s3";
    module: ModulePath;
    name: string;
    cron?: string | undefined;
    /** The aws region. */
    s3_region: EastFunction<StringType>;
    /** The bucket name containing the object. */
    s3_bucket: EastFunction<StringType>;
    /** Key of the object to get. */
    s3_key: EastFunction<StringType>;
    /** AWS access key ID */
    s3_access_key_id: EastFunction<StringType>;
    /** AWS secret access key */
    s3_secret_access_key: EastFunction<StringType>;
    inputs: Record<string, StreamIO>;
    input_assertions: Assertion[];
    output_assertions: Assertion[];
    outputs: {
        output: StreamIO<BlobType>;
    };
};
/** @internal */
export type SourceTaskDescription = WriteableSourceTaskDescription | PatchSourceTaskDescription | ClockSourceTaskDescription | ElaraSourceTaskDescription | ApiSourceTaskDescription | FtpSourceTaskDescription | S3SourceTaskDescription;