98 lines
4.6 KiB
TypeScript
98 lines
4.6 KiB
TypeScript
/**
|
|
* This file was generated by @pikku/cli@0.12.76
|
|
*/
|
|
/**
|
|
* Workflow type map with input/output types for each workflow
|
|
*/
|
|
|
|
import type { StubCall } from '.bun/@pikku+core@0.12.57/node_modules/@pikku/core/dist/services/stub-tracker'
|
|
|
|
export type AgentApproveCallerInput = { agentName: string; runId: string; approvals: { toolCallId: string; approved: boolean; }[]; }
|
|
export type AgentCallerInput = { agentName: string; message: string; threadId: string; resourceId: string; }
|
|
export type AgentResumeCallerInput = { agentName: string; runId: string; toolCallId: string; approved: boolean; }
|
|
export type AgentStreamCallerInput = { agentName: string; message: string; threadId: string; resourceId: string; context?: string | undefined; }
|
|
export type AuthHandlerOutput = Promise<void> | Promise<any>
|
|
export type DeleteAgentThreadInput = { threadId: string; resourceId?: string | undefined; }
|
|
export type DeleteAgentThreadOutput = { deleted: boolean; }
|
|
export type GetAgentThreadMessagesInput = { threadId: string; resourceId?: string | undefined; }
|
|
export type GetAgentThreadMessagesOutput = any[]
|
|
export type GetAgentThreadRunsInput = { threadId: string; resourceId?: string | undefined; }
|
|
export type GetAgentThreadRunsOutput = any[]
|
|
export type GetAgentThreadsInput = { agentName?: string | undefined; resourceId?: string | undefined; limit?: number | undefined; offset?: number | undefined; }
|
|
export type GetAgentThreadsOutput = any[]
|
|
export type GetSessionInput = {}
|
|
export type GetSessionOutput = {
|
|
userId: string;
|
|
email: string;
|
|
name: string | null;
|
|
}
|
|
export type GraphStarterInput = { workflowName: string; nodeId: string; data?: unknown; }
|
|
export type GraphStarterOutput = { runId: string; }
|
|
export type PikkuConsoleGetSecretInput = { secretId: string; }
|
|
export type PikkuConsoleGetSecretOutput = { exists: boolean; value: unknown; }
|
|
export type PikkuConsoleGetVariableInput = { variableId: string; }
|
|
export type PikkuConsoleGetVariableOutput = { exists: boolean; value: unknown; }
|
|
export type PikkuConsoleHasSecretInput = { secretId: string; }
|
|
export type PikkuConsoleHasSecretOutput = { exists: boolean; }
|
|
export type PikkuConsoleSetSecretInput = { secretId: string; value: unknown; }
|
|
export type PikkuConsoleSetSecretOutput = { success: boolean; }
|
|
export type PikkuConsoleSetVariableInput = { variableId: string; value: unknown; }
|
|
export type PikkuConsoleSetVariableOutput = { success: boolean; }
|
|
export type PikkuScenarioGetStubCallsInput = { service?: string | undefined; }
|
|
export type PikkuScenarioGetStubCallsOutput = StubCall[]
|
|
export type PikkuScenarioResetLiveCoverageOutput = { enabled: boolean; }
|
|
export type PikkuScenarioResetStubsOutput = { enabled: boolean; }
|
|
export type RealtimeEventStreamInput = { topic: string; }
|
|
export type RealtimeSubscribeInput = { topic: string; }
|
|
export type RealtimeUnsubscribeInput = { topic: string; }
|
|
export type RpcCallerInput = { rpcName: string; data?: unknown; }
|
|
export type SecretSchema_betterAuthSecret = string
|
|
export type SessionHealthScenarioOutput = { email: string; userId: string; }
|
|
export type WorkflowRunnerInput = { workflowName: string; data?: unknown; }
|
|
export type WorkflowStarterInput = { workflowName: string; data?: unknown; }
|
|
export type WorkflowStarterOutput = { runId: string; }
|
|
export type WorkflowStatusCheckerInput = { workflowName: string; runId: string; }
|
|
export type WorkflowStatusStreamFullInput = { workflowName: string; runId: string; }
|
|
export type WorkflowStatusStreamInput = { workflowName: string; runId: string; }
|
|
|
|
// Addon package Workflow maps
|
|
import type { WorkflowMap as ConsoleWorkflowMap } from '@pikku/addon-console/.pikku/workflow/pikku-workflow-map.gen.d.js'
|
|
|
|
|
|
interface WorkflowHandler<I, O> {
|
|
input: I;
|
|
output: O;
|
|
}
|
|
|
|
interface GraphNodeHandler<I> {
|
|
input: I;
|
|
}
|
|
|
|
export type WorkflowMap = {
|
|
readonly 'sessionHealthScenario': WorkflowHandler<void, SessionHealthScenarioOutput>,
|
|
};
|
|
|
|
export type GraphsMap = {
|
|
readonly 'sessionHealthScenario': {
|
|
readonly 'visitor signs in and reads their session': GraphNodeHandler<GetSessionInput>,
|
|
},
|
|
};
|
|
|
|
type PrefixWorkflowKeys<T, Prefix extends string> = unknown extends T ? {} : {
|
|
[K in keyof T as `${Prefix}:${string & K}`]: T[K]
|
|
}
|
|
|
|
export type FlattenedWorkflowMap =
|
|
WorkflowMap & PrefixWorkflowKeys<ConsoleWorkflowMap, 'console'>
|
|
|
|
|
|
export type WorkflowClient<Name extends keyof FlattenedWorkflowMap> = {
|
|
start: (input: FlattenedWorkflowMap[Name]['input']) => Promise<{ runId: string }>;
|
|
getRun: <output extends keyof FlattenedWorkflowMap[Name]>(runId: string) => Promise<FlattenedWorkflowMap[Name][output]>;
|
|
cancelRun: (runId: string) => Promise<boolean>;
|
|
}
|
|
|
|
export type TypedWorkflowClients = {
|
|
[Name in keyof FlattenedWorkflowMap]: WorkflowClient<Name>;
|
|
}
|