116 lines
3.8 KiB
TypeScript
116 lines
3.8 KiB
TypeScript
/**
|
|
* This file was generated by @pikku/cli@0.12.48
|
|
*/
|
|
/**
|
|
* This provides the structure needed for typescript to be aware of Queue workers and their input/output types
|
|
*/
|
|
|
|
|
|
|
|
|
|
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; }
|
|
export type AuthHandlerOutput = Promise<any> | Promise<void>
|
|
export type DeleteAgentThreadInput = { threadId: string; resourceId?: string; }
|
|
export type DeleteAgentThreadOutput = { deleted: boolean; }
|
|
export type EdgeEchoInput = {
|
|
message: string;
|
|
}
|
|
export type EdgeEchoOutput = {
|
|
echoed: string;
|
|
serverless: boolean;
|
|
}
|
|
export type GetAgentThreadMessagesInput = { threadId: string; resourceId?: string; }
|
|
export type GetAgentThreadMessagesOutput = any[]
|
|
export type GetAgentThreadRunsInput = { threadId: string; resourceId?: string; }
|
|
export type GetAgentThreadRunsOutput = any[]
|
|
export type GetAgentThreadsInput = { agentName?: string; resourceId?: string; limit?: number; offset?: number; }
|
|
export type GetAgentThreadsOutput = any[]
|
|
export type GetMessageInput = {}
|
|
export type GetMessageOutput = {
|
|
message: string;
|
|
updatedAt: string;
|
|
updatedBy: {
|
|
email: string;
|
|
name: string | null;
|
|
} | null;
|
|
}
|
|
export type GetSessionInput = {}
|
|
export type GetSessionOutput = {
|
|
userId: string;
|
|
email: string;
|
|
name: string | null;
|
|
}
|
|
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 RemoteRPCHandlerInput = { rpcName: string; data?: unknown; }
|
|
export type RpcCallerInput = { rpcName: string; data?: unknown; }
|
|
export type SecretSchema_betterAuthSecret = string
|
|
export type ServerCounterInput = {}
|
|
export type ServerCounterOutput = {
|
|
count: number;
|
|
pid: number;
|
|
}
|
|
export type ServerUptimeInput = {}
|
|
export type ServerUptimeOutput = {
|
|
uptimeSeconds: number;
|
|
nodeVersion: string;
|
|
rssMb: number;
|
|
}
|
|
export type UpdateMessageInput = {
|
|
message: string;
|
|
}
|
|
export type UpdateMessageOutput = {
|
|
message: string;
|
|
updatedAt: string;
|
|
updatedBy: {
|
|
email: string;
|
|
name: string | null;
|
|
} | null;
|
|
}
|
|
|
|
import type { QueueJob } from '@pikku/core/queue'
|
|
|
|
interface QueueHandler<I, O> {
|
|
input: I;
|
|
output: O;
|
|
}
|
|
|
|
export type QueueMap = {
|
|
readonly 'pikku-remote-internal-rpc': QueueHandler<RemoteRPCHandlerInput, null>,
|
|
};
|
|
|
|
|
|
type QueueAdd = <Name extends keyof QueueMap>(
|
|
name: Name,
|
|
data: QueueMap[Name]['input'],
|
|
options?: {
|
|
priority?: number
|
|
delay?: number
|
|
attempts?: number
|
|
removeOnComplete?: number
|
|
removeOnFail?: number
|
|
jobId?: string
|
|
}
|
|
) => Promise<string>
|
|
|
|
type QueueGetJob = <Name extends keyof QueueMap>(
|
|
name: Name,
|
|
jobId: string
|
|
) => Promise<QueueJob<QueueMap[Name]['input'], QueueMap[Name]['output']> | null>
|
|
|
|
export type TypedPikkuQueue = {
|
|
add: QueueAdd;
|
|
getJob: QueueGetJob;
|
|
}
|
|
|