import { AgentPieceTool, AppConnectionType, AppConnectionValue, ExecutionType, FlowRunId, PopulatedFlow, ProjectId, RespondResponse, ResumePayload, SeekPage, TriggerPayload, TriggerStrategy } from '@activepieces/shared';
import { LanguageModel, Tool } from 'ai';
import { BasicAuthProperty, CustomAuthProperty, InputPropertyMap, OAuth2Property, SecretTextProperty, StaticPropsValue } from '../property';
import { PieceAuthProperty } from '../property/authentication';
import { DelayPauseMetadata, PauseMetadata, WebhookPauseMetadata } from '@activepieces/shared';
export type BaseContext<PieceAuth extends PieceAuthProperty | PieceAuthProperty[] | undefined, Props extends InputPropertyMap> = {
    flows: FlowsContext;
    step: StepContext;
    auth: AppConnectionValueForAuthProperty<PieceAuth>;
    propsValue: StaticPropsValue<Props>;
    store: Store;
    project: {
        id: ProjectId;
        externalId: () => Promise<string | undefined>;
    };
    connections: ConnectionsManager;
};
type ExtractCustomAuthProps<T> = T extends CustomAuthProperty<infer Props> ? Props : never;
type ExtractOAuth2Props<T> = T extends OAuth2Property<infer Props> ? Props : never;
export type AppConnectionValueForAuthProperty<T extends PieceAuthProperty | PieceAuthProperty[] | undefined> = T extends PieceAuthProperty[] ? AppConnectionValueForSingleAuthProperty<T[number]> : T extends PieceAuthProperty ? AppConnectionValueForSingleAuthProperty<T> : T extends undefined ? undefined : never;
type AppConnectionValueForSingleAuthProperty<T extends PieceAuthProperty | undefined> = T extends SecretTextProperty<boolean> ? AppConnectionValue<AppConnectionType.SECRET_TEXT> : T extends BasicAuthProperty ? AppConnectionValue<AppConnectionType.BASIC_AUTH> : T extends CustomAuthProperty<any> ? AppConnectionValue<AppConnectionType.CUSTOM_AUTH, StaticPropsValue<ExtractCustomAuthProps<T>>> : T extends OAuth2Property<any> ? AppConnectionValue<AppConnectionType.OAUTH2, StaticPropsValue<ExtractOAuth2Props<T>>> : T extends undefined ? undefined : never;
type AppWebhookTriggerHookContext<PieceAuth extends PieceAuthProperty | PieceAuthProperty[] | undefined, TriggerProps extends InputPropertyMap> = BaseContext<PieceAuth, TriggerProps> & {
    webhookUrl: string;
    payload: TriggerPayload;
    app: {
        createListeners({ events, identifierValue, }: {
            events: string[];
            identifierValue: string;
        }): void;
    };
};
type PollingTriggerHookContext<PieceAuth extends PieceAuthProperty | PieceAuthProperty[] | undefined, TriggerProps extends InputPropertyMap> = BaseContext<PieceAuth, TriggerProps> & {
    setSchedule(schedule: {
        cronExpression: string;
        timezone?: string;
    }): void;
};
type WebhookTriggerHookContext<PieceAuth extends PieceAuthProperty | PieceAuthProperty[] | undefined, TriggerProps extends InputPropertyMap> = BaseContext<PieceAuth, TriggerProps> & {
    webhookUrl: string;
    payload: TriggerPayload;
    server: ServerContext;
};
export type TriggerHookContext<PieceAuth extends PieceAuthProperty | PieceAuthProperty[] | undefined, TriggerProps extends InputPropertyMap, S extends TriggerStrategy> = S extends TriggerStrategy.APP_WEBHOOK ? AppWebhookTriggerHookContext<PieceAuth, TriggerProps> : S extends TriggerStrategy.POLLING ? PollingTriggerHookContext<PieceAuth, TriggerProps> : S extends TriggerStrategy.WEBHOOK ? WebhookTriggerHookContext<PieceAuth, TriggerProps> & {
    server: ServerContext;
} : never;
export type TestOrRunHookContext<PieceAuth extends PieceAuthProperty | PieceAuthProperty[] | undefined, TriggerProps extends InputPropertyMap, S extends TriggerStrategy> = TriggerHookContext<PieceAuth, TriggerProps, S> & {
    files: FilesService;
};
export type StopHookParams = {
    response: RespondResponse;
};
export type RespondHookParams = {
    response: RespondResponse;
};
export type StopHook = (params?: StopHookParams) => void;
export type RespondHook = (params?: RespondHookParams) => void;
/** @deprecated Since 2026-04-12. Use {@link CreateWaitpointHook} and {@link WaitForWaitpointHook} instead. */
export type PauseHookParams = {
    pauseMetadata: PauseMetadata;
};
/** @deprecated Since 2026-04-12. Use {@link CreateWaitpointHook} and {@link WaitForWaitpointHook} instead. */
export type PauseHook = (params: {
    pauseMetadata: Omit<DelayPauseMetadata, 'requestIdToReply'> | Omit<WebhookPauseMetadata, 'requestId' | 'requestIdToReply'>;
}) => void;
export type FlowsContext = {
    list(params?: ListFlowsContextParams): Promise<SeekPage<PopulatedFlow>>;
    current: {
        id: string;
        version: {
            id: string;
        };
    };
};
export type StepContext = {
    name: string;
};
export type ListFlowsContextParams = {
    externalIds?: string[];
};
export type PropertyContext = {
    server: ServerContext;
    project: {
        id: ProjectId;
        externalId: () => Promise<string | undefined>;
    };
    searchValue?: string;
    flows: FlowsContext;
    connections: ConnectionsManager;
};
export type ServerContext = {
    apiUrl: string;
    publicUrl: string;
    token: string;
};
export type CreateWaitpointParams = {
    type: 'DELAY' | 'WEBHOOK';
    version?: 'V0' | 'V1';
    resumeDateTime?: string;
    responseToSend?: RespondResponse;
};
export type CreateWaitpointResult = {
    id: string;
    resumeUrl: string;
    buildResumeUrl: (params: {
        queryParams: Record<string, string>;
        sync?: boolean;
    }) => string;
};
export type CreateWaitpointHook = (params: CreateWaitpointParams) => Promise<CreateWaitpointResult>;
export type WaitForWaitpointHook = (waitpointId: string) => void;
export type RunContext = {
    id: FlowRunId;
    stop: StopHook;
    /** @deprecated Use createWaitpoint + waitForWaitpoint instead */
    pause?: PauseHook;
    respond: RespondHook;
    createWaitpoint: CreateWaitpointHook;
    waitForWaitpoint: WaitForWaitpointHook;
};
export type OnStartContext<PieceAuth extends PieceAuthProperty | PieceAuthProperty[] | undefined, TriggerProps extends InputPropertyMap> = Omit<BaseContext<PieceAuth, TriggerProps>, 'flows'> & {
    run: Pick<RunContext, 'id'>;
    payload: unknown;
};
export type OutputContext = {
    update: (params: {
        data: {
            [key: string]: unknown;
        };
    }) => Promise<void>;
};
type BaseActionContext<ET extends ExecutionType, PieceAuth extends PieceAuthProperty | PieceAuthProperty[] | undefined, ActionProps extends InputPropertyMap> = BaseContext<PieceAuth, ActionProps> & {
    executionType: ET;
    tags: TagsManager;
    server: ServerContext;
    files: FilesService;
    output: OutputContext;
    agent: AgentContext;
    run: RunContext;
    /** @deprecated Use waitpoint.buildResumeUrl() from createWaitpoint result instead */
    generateResumeUrl?: (params: {
        queryParams: Record<string, string>;
        sync?: boolean;
    }) => string;
};
type BeginExecutionActionContext<PieceAuth extends PieceAuthProperty | PieceAuthProperty[] | undefined = undefined, ActionProps extends InputPropertyMap = InputPropertyMap> = BaseActionContext<ExecutionType.BEGIN, PieceAuth, ActionProps>;
type ResumeExecutionActionContext<PieceAuth extends PieceAuthProperty | PieceAuthProperty[] | undefined = undefined, ActionProps extends InputPropertyMap = InputPropertyMap> = BaseActionContext<ExecutionType.RESUME, PieceAuth, ActionProps> & {
    resumePayload: ResumePayload;
};
export type ActionContext<PieceAuth extends PieceAuthProperty | PieceAuthProperty[] | undefined = undefined, ActionProps extends InputPropertyMap = InputPropertyMap> = BeginExecutionActionContext<PieceAuth, ActionProps> | ResumeExecutionActionContext<PieceAuth, ActionProps>;
export type ConstructToolParams = {
    tools: AgentPieceTool[];
    model: LanguageModel;
};
export interface AgentContext {
    tools: (params: ConstructToolParams) => Promise<Record<string, Tool>>;
}
export interface FilesService {
    write({ fileName, data, }: {
        fileName: string;
        data: Buffer;
    }): Promise<string>;
}
export interface ConnectionsManager {
    get(key: string): Promise<AppConnectionValue | Record<string, unknown> | string | null>;
}
export interface TagsManager {
    add(params: {
        name: string;
    }): Promise<void>;
}
export interface Store {
    put<T>(key: string, value: T, scope?: StoreScope): Promise<T>;
    get<T>(key: string, scope?: StoreScope): Promise<T | null>;
    delete(key: string, scope?: StoreScope): Promise<void>;
}
export declare enum StoreScope {
    PROJECT = "COLLECTION",
    FLOW = "FLOW"
}
export {};
//# sourceMappingURL=index.d.ts.map