|
|
@@ -375,18 +375,13 @@ export class Task extends EventEmitter<ClineEvents> {
|
|
|
await provider?.postMessageToWebview({ type: "messageUpdated", clineMessage: message })
|
|
|
this.emit("message", { action: "updated", message })
|
|
|
|
|
|
- // Only check for telemetry if the message is complete and CloudService is enabled
|
|
|
- if (message.partial !== true && CloudService.isEnabled()) {
|
|
|
- // Now check if this message was already captured
|
|
|
- const previousMessage = this.clineMessages.find((m) => m.ts === message.ts)
|
|
|
- const wasAlreadyCaptured = previousMessage && previousMessage.partial !== true
|
|
|
-
|
|
|
- if (!wasAlreadyCaptured) {
|
|
|
- CloudService.instance.captureEvent({
|
|
|
- event: TelemetryEventName.TASK_MESSAGE,
|
|
|
- properties: { taskId: this.taskId, message },
|
|
|
- })
|
|
|
- }
|
|
|
+ const shouldCaptureMessage = message.partial !== true && CloudService.isEnabled()
|
|
|
+
|
|
|
+ if (shouldCaptureMessage) {
|
|
|
+ CloudService.instance.captureEvent({
|
|
|
+ event: TelemetryEventName.TASK_MESSAGE,
|
|
|
+ properties: { taskId: this.taskId, message },
|
|
|
+ })
|
|
|
}
|
|
|
}
|
|
|
|