Task bridge

Author: cte

pnpm-lock.yaml

@@ -52,6 +52,7 @@ import { BrowserSession } from "../../services/browser/BrowserSession"
 import { McpHub } from "../../services/mcp/McpHub"
 import { McpServerManager } from "../../services/mcp/McpServerManager"
 import { RepoPerTaskCheckpointService } from "../../services/checkpoints"
+import { TaskBridgeService } from "../../services/task-bridge/TaskBridgeService"
 
 // integrations
 import { DiffViewProvider } from "../../integrations/editor/DiffViewProvider"
@@ -247,6 +248,9 @@ export class Task extends EventEmitter<TaskEvents> {
 	checkpointService?: RepoPerTaskCheckpointService
 	checkpointServiceInitializing = false
 
+	// Task Bridge
+	taskBridgeService?: TaskBridgeService
+
 	// Streaming
 	isWaitingForFirstChunk = false
 	isStreaming = false
@@ -351,6 +355,12 @@ export class Task extends EventEmitter<TaskEvents> {
 
 		this.toolRepetitionDetector = new ToolRepetitionDetector(this.consecutiveMistakeLimit)
 
+		// TODO: Figure out when to enable task bridge.
+		// eslint-disable-next-line no-constant-condition
+		if (true) {
+			this.taskBridgeService = TaskBridgeService.getInstance()
+		}
+
 		onCreated?.(this)
 
 		if (startTask) {
@@ -1210,6 +1220,13 @@ export class Task extends EventEmitter<TaskEvents> {
 			this.pauseInterval = undefined
 		}
 
+		// Unsubscribe from TaskBridge service.
+		if (this.taskBridgeService) {
+			this.taskBridgeService
+				.unsubscribeFromTask(this.taskId)
+				.catch((error) => console.error("Error unsubscribing from task bridge:", error))
+		}
+
 		// Release any terminals associated with this task.
 		try {
 			// Release any terminals associated with this task.
@@ -1304,6 +1321,11 @@ export class Task extends EventEmitter<TaskEvents> {
 		// Kicks off the checkpoints initialization process in the background.
 		getCheckpointService(this)
 
+		if (this.taskBridgeService) {
+			await this.taskBridgeService.initialize()
+			await this.taskBridgeService.subscribeToTask(this)
+		}
+
 		let nextUserContent = userContent
 		let includeFileDetails = true
 

src/core/task/Task.ts

@@ -445,6 +445,7 @@
 		"gray-matter": "^4.0.3",
 		"i18next": "^25.0.0",
 		"ignore": "^7.0.3",
+		"ioredis": "^5.3.2",
 		"isbinaryfile": "^5.0.2",
 		"lodash.debounce": "^4.0.8",
 		"mammoth": "^1.9.1",
@@ -492,6 +493,7 @@
 		"@types/diff": "^5.2.1",
 		"@types/diff-match-patch": "^1.0.36",
 		"@types/glob": "^8.1.0",
+		"@types/ioredis-mock": "^8.2.6",
 		"@types/mocha": "^10.0.10",
 		"@types/node": "20.x",
 		"@types/node-cache": "^4.1.3",
@@ -508,6 +510,7 @@
 		"esbuild": "^0.25.0",
 		"execa": "^9.5.2",
 		"glob": "^11.0.1",
+		"ioredis-mock": "^8.9.0",
 		"mkdirp": "^3.0.1",
 		"nock": "^14.0.4",
 		"npm-run-all2": "^8.0.1",