(conversationStart time.Time, markTurnStartReady func())
| 154 | } |
| 155 | |
| 156 | func (r *Runner) resetConversation(conversationStart time.Time, markTurnStartReady func()) { |
| 157 | if markTurnStartReady == nil { |
| 158 | markTurnStartReady = func() {} |
| 159 | } |
| 160 | |
| 161 | r.result = runnerResult{} |
| 162 | r.conversationStart = conversationStart |
| 163 | r.turnStartTime = conversationStart |
| 164 | r.currentPhase = phaseInitial |
| 165 | r.lastStreamError = "" |
| 166 | r.lastStatus = "" |
| 167 | r.sawTurnRunning = false |
| 168 | r.sawTurnFirstOutput = false |
| 169 | r.markTurnStartReady = markTurnStartReady |
| 170 | } |
| 171 | |
| 172 | func (r *Runner) runConversation(ctx context.Context, chatID uuid.UUID, logger slog.Logger, events <-chan codersdk.ChatStreamEvent) error { |
| 173 | r.chatID = chatID |
no outgoing calls