cyrusagents
diff --git a/‎CHANGELOG.internal.md‎
Lines changed: 1 addition & 0 deletions b/‎CHANGELOG.internal.md‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎packages/edge-worker/src/ActivityPoster.ts‎
Lines changed: 277 additions & 0 deletions b/‎packages/edge-worker/src/ActivityPoster.ts‎
Lines changed: 277 additions & 0 deletions
@@ -5,6 +5,7 @@ This changelog documents internal development changes, refactors, tooling update
 ## [Unreleased]
 
 ### Changed
+- Refactored `EdgeWorker.ts` by extracting 5 service modules: `ActivityPoster` (Linear activity posting), `AttachmentService` (attachment download/manifests), `ConfigManager` (config file watching/reload/change detection), `PromptBuilder` (prompt assembly/system prompts/issue context), and `RunnerSelectionService` (runner/model selection/tool configuration). Reduced EdgeWorker from 7,687 to 5,466 lines (29% reduction) while maintaining full test coverage (522 tests). ([CYPACK-822](https://linear.app/ceedar/issue/CYPACK-822), [#874](https://github.com/ceedaragents/cyrus/pull/874))
 - Merged `main` into `cypack-807` branch, resolving 7 merge conflicts and fixing auto-merge issues across AgentSessionManager, EdgeWorker, GitService, ProcedureAnalyzer, gemini-runner, and changelogs. Updated 2 test files from `IIssueTrackerService` to `IActivitySink` interface. ([CYPACK-821](https://linear.app/ceedar/issue/CYPACK-821), [#873](https://github.com/ceedaragents/cyrus/pull/873))
 - Decoupled Slack webhook handler from `RepositoryConfig`: introduced `NoopActivitySink` for non-repository sessions, dedicated `slackSessionManager` on `EdgeWorker`, and `slackThreadSessions` map for thread-based session reuse. `createSlackWorkspace` now creates plain directories under `~/.cyrus/slack-workspaces/` instead of git worktrees. Runner config is built inline (bypassing `buildAgentRunnerConfig` which requires a repository). Added `SlackReactionService` to `cyrus-slack-event-transport` package. ([CYPACK-815](https://linear.app/ceedar/issue/CYPACK-815), [#868](https://github.com/ceedaragents/cyrus/pull/868))
 - Refactored logging across all packages to use a dedicated `ILogger` interface and `Logger` implementation in `packages/core/src/logging/`. Replaced direct `console.log`/`console.error` calls in EdgeWorker, AgentSessionManager, ClaudeRunner, GitService, RepositoryRouter, SharedApplicationServer, SharedWebhookServer, WorktreeIncludeService, ProcedureAnalyzer, AskUserQuestionHandler, LinearEventTransport, and LinearIssueTrackerService with structured logger calls. Log level is configurable via the `CYRUS_LOG_LEVEL` environment variable (DEBUG, INFO, WARN, ERROR, SILENT).
 
@@ -0,0 +1,277 @@
+import type {
+	AgentActivityCreateInput,
+	IIssueTrackerService,
+	ILogger,
+	RepositoryConfig,
+} from "cyrus-core";
+
+export class ActivityPoster {
+	private issueTrackers: Map<string, IIssueTrackerService>;
+	private repositories: Map<string, RepositoryConfig>;
+	private logger: ILogger;
+
+	constructor(
+		issueTrackers: Map<string, IIssueTrackerService>,
+		repositories: Map<string, RepositoryConfig>,
+		logger: ILogger,
+	) {
+		this.issueTrackers = issueTrackers;
+		this.repositories = repositories;
+		this.logger = logger;
+	}
+
+	async postActivityDirect(
+		issueTracker: IIssueTrackerService,
+		input: AgentActivityCreateInput,
+		label: string,
+	): Promise<string | null> {
+		try {
+			const result = await issueTracker.createAgentActivity(input);
+			if (result.success) {
+				if (result.agentActivity) {
+					const activity = await result.agentActivity;
+					this.logger.debug(`Created ${label} activity ${activity.id}`);
+					return activity.id;
+				}
+				this.logger.debug(`Created ${label}`);
+				return null;
+			}
+			this.logger.error(`Failed to create ${label}:`, result);
+			return null;
+		} catch (error) {
+			this.logger.error(`Error creating ${label}:`, error);
+			return null;
+		}
+	}
+
+	async postInstantAcknowledgment(
+		sessionId: string,
+		repositoryId: string,
+	): Promise<void> {
+		const issueTracker = this.issueTrackers.get(repositoryId);
+		if (!issueTracker) {
+			this.logger.warn(`No issue tracker found for repository ${repositoryId}`);
+			return;
+		}
+
+		await this.postActivityDirect(
+			issueTracker,
+			{
+				agentSessionId: sessionId,
+				content: {
+					type: "thought",
+					body: "I've received your request and I'm starting to work on it. Let me analyze the issue and prepare my approach.",
+				},
+			},
+			"instant acknowledgment",
+		);
+	}
+
+	async postParentResumeAcknowledgment(
+		sessionId: string,
+		repositoryId: string,
+	): Promise<void> {
+		const issueTracker = this.issueTrackers.get(repositoryId);
+		if (!issueTracker) {
+			this.logger.warn(`No issue tracker found for repository ${repositoryId}`);
+			return;
+		}
+
+		await this.postActivityDirect(
+			issueTracker,
+			{
+				agentSessionId: sessionId,
+				content: { type: "thought", body: "Resuming from child session" },
+			},
+			"parent resume acknowledgment",
+		);
+	}
+
+	async postRepositorySelectionActivity(
+		sessionId: string,
+		repositoryId: string,
+		repositoryName: string,
+		selectionMethod:
+			| "description-tag"
+			| "label-based"
+			| "project-based"
+			| "team-based"
+			| "team-prefix"
+			| "catch-all"
+			| "workspace-fallback"
+			| "user-selected",
+	): Promise<void> {
+		const issueTracker = this.issueTrackers.get(repositoryId);
+		if (!issueTracker) {
+			this.logger.warn(`No issue tracker found for repository ${repositoryId}`);
+			return;
+		}
+
+		let methodDisplay: string;
+		if (selectionMethod === "user-selected") {
+			methodDisplay = "selected by user";
+		} else if (selectionMethod === "description-tag") {
+			methodDisplay = "matched via [repo=...] tag in issue description";
+		} else if (selectionMethod === "label-based") {
+			methodDisplay = "matched via label-based routing";
+		} else if (selectionMethod === "project-based") {
+			methodDisplay = "matched via project-based routing";
+		} else if (selectionMethod === "team-based") {
+			methodDisplay = "matched via team-based routing";
+		} else if (selectionMethod === "team-prefix") {
+			methodDisplay = "matched via team prefix routing";
+		} else if (selectionMethod === "catch-all") {
+			methodDisplay = "matched via catch-all routing";
+		} else {
+			methodDisplay = "matched via workspace fallback";
+		}
+
+		await this.postActivityDirect(
+			issueTracker,
+			{
+				agentSessionId: sessionId,
+				content: {
+					type: "thought",
+					body: `Repository "${repositoryName}" has been ${methodDisplay}.`,
+				},
+			},
+			"repository selection",
+		);
+	}
+
+	async postSystemPromptSelectionThought(
+		sessionId: string,
+		labels: string[],
+		repositoryId: string,
+	): Promise<void> {
+		const issueTracker = this.issueTrackers.get(repositoryId);
+		if (!issueTracker) {
+			this.logger.warn(`No issue tracker found for repository ${repositoryId}`);
+			return;
+		}
+
+		// Determine which prompt type was selected and which label triggered it
+		let selectedPromptType: string | null = null;
+		let triggerLabel: string | null = null;
+		const repository = Array.from(this.repositories.values()).find(
+			(r) => r.id === repositoryId,
+		);
+
+		if (repository?.labelPrompts) {
+			// Check debugger labels
+			const debuggerConfig = repository.labelPrompts.debugger;
+			const debuggerLabels = Array.isArray(debuggerConfig)
+				? debuggerConfig
+				: debuggerConfig?.labels;
+			const debuggerLabel = debuggerLabels?.find((label) =>
+				labels.includes(label),
+			);
+			if (debuggerLabel) {
+				selectedPromptType = "debugger";
+				triggerLabel = debuggerLabel;
+			} else {
+				// Check builder labels
+				const builderConfig = repository.labelPrompts.builder;
+				const builderLabels = Array.isArray(builderConfig)
+					? builderConfig
+					: builderConfig?.labels;
+				const builderLabel = builderLabels?.find((label) =>
+					labels.includes(label),
+				);
+				if (builderLabel) {
+					selectedPromptType = "builder";
+					triggerLabel = builderLabel;
+				} else {
+					// Check scoper labels
+					const scoperConfig = repository.labelPrompts.scoper;
+					const scoperLabels = Array.isArray(scoperConfig)
+						? scoperConfig
+						: scoperConfig?.labels;
+					const scoperLabel = scoperLabels?.find((label) =>
+						labels.includes(label),
+					);
+					if (scoperLabel) {
+						selectedPromptType = "scoper";
+						triggerLabel = scoperLabel;
+					} else {
+						// Check orchestrator labels
+						const orchestratorConfig = repository.labelPrompts.orchestrator;
+						const orchestratorLabels = Array.isArray(orchestratorConfig)
+							? orchestratorConfig
+							: (orchestratorConfig?.labels ?? ["orchestrator"]);
+						const orchestratorLabel = orchestratorLabels?.find((label) =>
+							labels.includes(label),
+						);
+						if (orchestratorLabel) {
+							selectedPromptType = "orchestrator";
+							triggerLabel = orchestratorLabel;
+						}
+					}
+				}
+			}
+		}
+
+		// Only post if a role was actually triggered
+		if (!selectedPromptType || !triggerLabel) {
+			return;
+		}
+
+		await this.postActivityDirect(
+			issueTracker,
+			{
+				agentSessionId: sessionId,
+				content: {
+					type: "thought",
+					body: `Entering '${selectedPromptType}' mode because of the '${triggerLabel}' label. I'll follow the ${selectedPromptType} process...`,
+				},
+			},
+			"system prompt selection",
+		);
+	}
+
+	async postInstantPromptedAcknowledgment(
+		sessionId: string,
+		repositoryId: string,
+		isStreaming: boolean,
+	): Promise<void> {
+		const issueTracker = this.issueTrackers.get(repositoryId);
+		if (!issueTracker) {
+			this.logger.warn(`No issue tracker found for repository ${repositoryId}`);
+			return;
+		}
+
+		const message = isStreaming
+			? "I've queued up your message as guidance"
+			: "Getting started on that...";
+
+		await this.postActivityDirect(
+			issueTracker,
+			{
+				agentSessionId: sessionId,
+				content: { type: "thought", body: message },
+			},
+			"prompted acknowledgment",
+		);
+	}
+
+	async postComment(
+		issueId: string,
+		body: string,
+		repositoryId: string,
+		parentId?: string,
+	): Promise<void> {
+		// Get the issue tracker for this repository
+		const issueTracker = this.issueTrackers.get(repositoryId);
+		if (!issueTracker) {
+			throw new Error(`No issue tracker found for repository ${repositoryId}`);
+		}
+		const commentInput: { body: string; parentId?: string } = {
+			body,
+		};
+		// Add parent ID if provided (for reply)
+		if (parentId) {
+			commentInput.parentId = parentId;
+		}
+		await issueTracker.createComment(issueId, commentInput);
+	}
+}