Skip to content

Commit 65c3d07

Browse files
committed
Fix task completion events
1 parent f773bc3 commit 65c3d07

File tree

3 files changed

+12
-10
lines changed

3 files changed

+12
-10
lines changed

package-lock.json

Lines changed: 1 addition & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

src/core/Cline.ts

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -3202,6 +3202,9 @@ export class Cline extends EventEmitter<ClineEvents> {
32023202
false,
32033203
)
32043204

3205+
telemetryService.captureTaskCompleted(this.taskId)
3206+
this.emit("taskCompleted", this.taskId, this.getTokenUsage())
3207+
32053208
await this.ask(
32063209
"command",
32073210
removeClosingTag("command", command),
@@ -3233,9 +3236,10 @@ export class Cline extends EventEmitter<ClineEvents> {
32333236

32343237
if (command) {
32353238
if (lastMessage && lastMessage.ask !== "command") {
3236-
// Haven't sent a command message yet so
3237-
// first send completion_result then command.
3239+
// Haven't sent a command message yet so first send completion_result then command.
32383240
await this.say("completion_result", result, undefined, false)
3241+
telemetryService.captureTaskCompleted(this.taskId)
3242+
this.emit("taskCompleted", this.taskId, this.getTokenUsage())
32393243
}
32403244

32413245
// Complete command message.
@@ -3257,11 +3261,10 @@ export class Cline extends EventEmitter<ClineEvents> {
32573261
commandResult = execCommandResult
32583262
} else {
32593263
await this.say("completion_result", result, undefined, false)
3264+
telemetryService.captureTaskCompleted(this.taskId)
3265+
this.emit("taskCompleted", this.taskId, this.getTokenUsage())
32603266
}
32613267

3262-
telemetryService.captureTaskCompleted(this.taskId)
3263-
this.emit("taskCompleted", this.taskId, this.getTokenUsage())
3264-
32653268
if (this.parentTask) {
32663269
const didApprove = await askFinishSubTaskApproval()
32673270

src/exports/api.ts

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -27,15 +27,13 @@ export class API extends EventEmitter<RooCodeEvents> implements RooCodeAPI {
2727
cline.on("taskUnpaused", () => this.emit("taskUnpaused", cline.taskId))
2828
cline.on("taskAskResponded", () => this.emit("taskAskResponded", cline.taskId))
2929
cline.on("taskAborted", () => this.emit("taskAborted", cline.taskId))
30-
cline.on("taskSpawned", (taskId) => this.emit("taskSpawned", cline.taskId, taskId))
30+
cline.on("taskSpawned", (childTaskId) => this.emit("taskSpawned", cline.taskId, childTaskId))
31+
cline.on("taskCompleted", (_, usage) => this.emit("taskCompleted", cline.taskId, usage))
32+
cline.on("taskTokenUsageUpdated", (_, usage) => this.emit("taskTokenUsageUpdated", cline.taskId, usage))
3133
this.emit("taskCreated", cline.taskId)
3234
})
3335

3436
this.on("message", ({ taskId, action, message }) => {
35-
// if (message.type === "say") {
36-
// console.log("message", { taskId, action, message })
37-
// }
38-
3937
if (action === "created") {
4038
this.history.add(taskId, message)
4139
} else if (action === "updated") {

0 commit comments

Comments
 (0)