File size: 3,930 Bytes
23d991d | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 | import type { CustomApiConfig } from '../../types'
import type {
StudioAssistantMessage,
StudioEventBus,
StudioMessageStore,
StudioPartStore,
StudioPermissionDecision,
StudioPermissionRequest,
StudioRun,
StudioRunStore,
StudioRuntimeTurnPlan,
StudioSession,
StudioSessionEventStore,
StudioSessionStore,
StudioTaskStore,
StudioToolChoice,
StudioWorkResultStore,
StudioWorkStore
} from '../domain/types'
import type { StudioPermissionService } from '../permissions/permission-service'
import { StudioToolRegistry } from '../tools/registry'
import { StudioSessionRunner, type StudioBackgroundRunHandle } from './session-runner'
import type { StudioTurnPlanResolver } from './turn-plan-resolver'
import type {
StudioResolvedSkill,
StudioSubagentRunRequest,
StudioSubagentRunResult
} from './tool-runtime-context'
interface StudioBuilderRuntimeOptions {
registry: StudioToolRegistry
messageStore: StudioMessageStore
partStore: StudioPartStore
runStore?: StudioRunStore
sessionStore?: StudioSessionStore
sessionEventStore?: StudioSessionEventStore
permissionService?: StudioPermissionService
askForConfirmation?: (request: StudioPermissionRequest) => Promise<StudioPermissionDecision>
taskStore?: StudioTaskStore
workStore?: StudioWorkStore
workResultStore?: StudioWorkResultStore
eventBus?: StudioEventBus
resolveTurnPlan: StudioTurnPlanResolver
resolveSkill?: (name: string, session: StudioSession) => Promise<StudioResolvedSkill>
}
export class StudioBuilderRuntime {
private readonly runner: StudioSessionRunner
constructor(options: StudioBuilderRuntimeOptions) {
this.runner = new StudioSessionRunner({
registry: options.registry,
messageStore: options.messageStore,
partStore: options.partStore,
runStore: options.runStore,
sessionStore: options.sessionStore,
sessionEventStore: options.sessionEventStore,
permissionService: options.permissionService,
askForConfirmation: options.askForConfirmation,
taskStore: options.taskStore,
workStore: options.workStore,
workResultStore: options.workResultStore,
eventBus: options.eventBus,
resolveTurnPlan: options.resolveTurnPlan,
resolveSkill: options.resolveSkill
})
}
async createAssistantMessage(session: StudioSession): Promise<StudioAssistantMessage> {
return this.runner.createAssistantMessage(session)
}
createRun(session: StudioSession, inputText: string, metadata?: Record<string, unknown>): StudioRun {
return this.runner.createRun(session, inputText, metadata)
}
async executePlan(input: {
projectId: string
session: StudioSession
run: StudioRun
assistantMessage: StudioAssistantMessage
plan: StudioRuntimeTurnPlan
customApiConfig?: CustomApiConfig
toolChoice?: StudioToolChoice
}): Promise<void> {
await this.runner.runWithPlan({
projectId: input.projectId,
session: input.session,
inputText: input.run.inputText,
plan: input.plan,
customApiConfig: input.customApiConfig,
toolChoice: input.toolChoice
})
}
async run(input: {
projectId: string
session: StudioSession
inputText: string
customApiConfig?: CustomApiConfig
toolChoice?: StudioToolChoice
runMetadata?: Record<string, unknown>
}): Promise<StudioSubagentRunResult & { run: StudioRun; assistantMessage: StudioAssistantMessage }> {
return this.runner.run(input)
}
async startBackgroundRun(input: {
projectId: string
session: StudioSession
inputText: string
customApiConfig?: CustomApiConfig
toolChoice?: StudioToolChoice
runMetadata?: Record<string, unknown>
}): Promise<StudioBackgroundRunHandle> {
return this.runner.startBackgroundRun(input)
}
async runSubagent(input: StudioSubagentRunRequest): Promise<StudioSubagentRunResult> {
return this.runner.runSubagent(input)
}
}
|