mirror of
https://github.com/multica-ai/multica.git
synced 2026-07-26 12:35:35 +02:00
Agents were writing runtime-local paths into deliverables as clickable links (`[screenshot](/Users/agent/work/shot.png)`). Two root causes, both fixed here. A. The brief never stated the delivery contract. Add an always-on delivery invariant (outside writeOutput's kind switch, so no task kind can inherit none) plus a per-surface file-delivery line for each of the five surfaces. Chat splits into two: `attachment upload` works only on web/mobile chat, never on an IM channel, so ChatChannelType is now threaded into TaskContextForEnv. The claim path only ever looked up Slack bindings, so a Feishu session reported as a web chat and got upload guidance for a channel that cannot carry attachments. Probe every channel type. The chat policy is two independent layers and stays that way: delivery keys off "is there a channel at all"; the `chat history` / `chat thread` commands stay Slack-only because both endpoints are hardwired to h.SlackHistory and there is no Feishu reader — ChatInThread only selects between those two commands, so it stays Slack-only too. Add a CLI hard-fail lint on `issue comment add` / `issue create` / `issue update` as the enforcement backstop. Scoped narrowly, since a false positive blocks a real deliverable: agent task context only (a human's PAT run is untouched), real CommonMark link/image/autolink destinations only via goldmark (a path in a code span or fence — how an agent quotes a path it is discussing — is structurally invisible), and three high-confidence signals only (`file://`, inside the workdir, or an existing local file). A bare `/foo` is a valid origin-relative URI and is deliberately allowed. `issue update` has no --attachment flag, so its hint redirects to `comment add` rather than naming an argument it rejects. B. Desktop presented the resulting router 404 as an unknown crash. 8 of 18 desktop_route_error reports were users clicking such a link and being told the app broke and to file a bug. Split the 404 into a first-class Not Found view: no crash framing, no Report error. Its recovery entry comes from the tab store's active workspace, never from the failed pathname — deriving a slug from `/Users/me/shot.png` yields "Users" and a button to `/Users/issues`, a second 404. Also add a will-navigate trusted-origin guard via the shared loadRenderer (main + issue windows). This is origin hardening only, NOT the mechanism for in-app links: client-side routing never fires will-navigate, so app paths never reach it. Issue windows need no 404 work — their router only accepts paths validated by parseIssueWindowPath and they do not listen for multica:navigate, so a bad path cannot reach them. Server-side completion observation is metric/log only and never blocks: it is lexical (`file://` + task work_dir prefix) because the server cannot stat the daemon's filesystem, and the metric label is a closed enum so no path or reply text reaches Prometheus. Verified: pnpm typecheck/lint/test (3582 tests), go vet, full Go suite including new claim-path integration tests. cmd/multica was verified outside the daemon workdir — inside one, 93 of its tests fail identically on origin/main because the suite walks up and finds the runtime's own task marker. Co-authored-by: Claude Opus 4.8 <noreply@anthropic.com> Co-authored-by: multica-agent <github@multica.ai>
463 lines
32 KiB
Go
463 lines
32 KiB
Go
package daemon
|
||
|
||
import (
|
||
"fmt"
|
||
"strings"
|
||
|
||
"github.com/multica-ai/multica/server/internal/daemon/execenv"
|
||
)
|
||
|
||
// BuildPrompt constructs the task prompt for an agent CLI.
|
||
// Keep this minimal — detailed instructions live in CLAUDE.md / AGENTS.md
|
||
// injected by execenv.InjectRuntimeConfig. The provider string is threaded
|
||
// through to comment-triggered tasks' per-turn reply template; that template
|
||
// is provider-agnostic AND host-agnostic now (every OS → write a UTF-8 file,
|
||
// post with `--content-file`) because the shell-layer corruption it guards
|
||
// against is not specific to any one provider or host (MUL-2904, #4182).
|
||
func BuildPrompt(task Task, provider string) string {
|
||
if task.ChatSessionID != "" {
|
||
return buildChatPrompt(task)
|
||
}
|
||
if task.TriggerCommentID != "" {
|
||
return buildCommentPrompt(task, provider)
|
||
}
|
||
if task.AutopilotRunID != "" {
|
||
return buildAutopilotPrompt(task)
|
||
}
|
||
if task.QuickCreatePrompt != "" {
|
||
return buildQuickCreatePrompt(task)
|
||
}
|
||
var b strings.Builder
|
||
b.WriteString("You are running as a local coding agent for a Multica workspace.\n\n")
|
||
fmt.Fprintf(&b, "Your assigned issue ID is: %s\n\n", task.IssueID)
|
||
// Assignment handoff (MUL-3375): a free-text instruction the person who
|
||
// assigned/promoted this issue left for you. Frame it as a handoff, not a
|
||
// comment to reply to — there is no comment thread to answer here.
|
||
if task.HandoffNote != "" {
|
||
b.WriteString("You were handed this issue with a handoff note. Treat it as the assigner's scoping instruction for this run; follow it before doing anything broader, and do not reply to it as if it were a comment:\n\n")
|
||
fmt.Fprintf(&b, "> %s\n\n", task.HandoffNote)
|
||
}
|
||
fmt.Fprintf(&b, "Start by running `multica issue get %s --output json` to understand your task, then complete it.\n", task.IssueID)
|
||
fmt.Fprintf(&b, "For comment history, follow the rule in your runtime workflow file (assignment-triggered tasks treat the read as mandatory). Start with `multica issue comment list %s --recent 10 --output json` to read the 10 most recently active threads, then page older threads via the stderr `Next thread cursor: ...` line and the matching `--before` / `--before-id` until you have enough history. Resolved threads come back folded — `--full` to expand. `--since <RFC3339>` is still available for incremental polling and may combine with `--recent`.\n", task.IssueID)
|
||
return b.String()
|
||
}
|
||
|
||
// buildQuickCreatePrompt constructs a prompt for quick-create tasks. The
|
||
// user typed a single natural-language sentence in the create-issue modal;
|
||
// the agent's job is to translate it into one `multica issue create` CLI
|
||
// invocation, using its judgment to decide whether fetching referenced URLs
|
||
// would produce a better issue. No issue exists yet, so the agent must NOT
|
||
// call `multica issue get` or attempt to comment — there's nothing to read
|
||
// or reply to.
|
||
func buildQuickCreatePrompt(task Task) string {
|
||
var b strings.Builder
|
||
b.WriteString("You are running as a quick-create assistant for a Multica workspace.\n\n")
|
||
b.WriteString("A user captured the following input via the quick-create modal. There is NO existing issue. Your job is to create a well-formed issue from this input with a single `multica issue create` command.\n\n")
|
||
fmt.Fprintf(&b, "User input:\n> %s\n\n", task.QuickCreatePrompt)
|
||
|
||
b.WriteString("Field rules:\n\n")
|
||
|
||
// title
|
||
b.WriteString("- **title**: required. A concise but semantically rich summary. If the input references external resources (PRs, issues, URLs), use your judgment on whether fetching the resource would produce a meaningfully better title — e.g. \"review PR #123\" → \"Review PR #123: Refactor auth module to OAuth2\". Strip filler words but preserve key semantic information.\n\n")
|
||
|
||
// description — the core optimization
|
||
b.WriteString("- **description**: The description is the executing agent's primary context. Aim for high fidelity — they should grasp the user's intent as if they had read the raw input themselves. Use a two-section structure:\n\n")
|
||
b.WriteString(" 1. **User request** — Faithfully restate what the user wants in their own words. Preserve specific names, identifiers, file paths, code snippets, and technical terms verbatim. Strip non-spec material before writing it (this is removal, not paraphrasing): verbal routing wrappers about creating the issue or routing it (e.g. \"create an issue\", \"分配给 X\", \"让 @X 处理\") and pure conversational fillers (e.g. \"对吧?\"). When in doubt, keep it.\n\n")
|
||
b.WriteString(" CC exception: `multica issue create` has no `--subscriber` flag, and the platform auto-subscribes members whose `[@Name](mention://member/<uuid>)` link appears in the description. When the user wrote \"cc @Y\", strip the verbal \"cc\" wrapper from the User request body and append a final `CC: <mention link(s)>` line to the description so the cc routing still fires.\n\n")
|
||
b.WriteString(" 2. **Context** — include ONLY when the input cited external resources AND you successfully fetched them AND they produced verifiable facts worth recording. Summarize facts only (e.g. \"PR #45 changes auth to JWT\"), not interpretation or unsolicited reference implementations. If you have nothing factual to add, omit the section entirely — never use it as an apology log for resources you could not fetch.\n\n")
|
||
b.WriteString(" Hard rules: never invent requirements, implementation details, or acceptance criteria the user did not express; never reduce multi-sentence input to a single vague sentence; never echo the title.\n\n")
|
||
b.WriteString(" Passing the description: a short, single-line body with no code, quotes, backticks, `$()`, or other special characters may go inline via `--description \"...\"`. Anything multi-line, or containing code snippets / file paths / quotes / backticks / `$()` / special characters, or otherwise long — which quick-create descriptions usually are — MUST be written to `./description.md` and passed with `--description-file ./description.md`; passing rich text inline lets the shell rewrite or truncate it (MUL-2904). That file MUST live inside your current working directory (e.g. `./description.md`) — never `/tmp` or any machine-shared path, where a different run may have left a stale file that would silently become this issue's description. If the file write fails for any reason, stop and fix it; never run `--description-file` against a file whose write did not succeed.\n\n")
|
||
|
||
// priority
|
||
if task.QuickCreatePriority != "" {
|
||
fmt.Fprintf(&b, "- **priority**: required for this run. Pass `--priority %s`; the quick-create selection is authoritative.\n\n", task.QuickCreatePriority)
|
||
} else {
|
||
b.WriteString("- **priority**: one of `urgent`, `high`, `medium`, `low`, or omit. Map P0/P1 → urgent/high; \"asap\" → urgent. If unspecified, omit.\n\n")
|
||
}
|
||
|
||
// assignee
|
||
b.WriteString("- **assignee**:\n")
|
||
b.WriteString(" - When the user names someone (\"assign to X\" / \"@X\"), call `multica workspace member list --output json`, `multica agent list --output json`, and `multica squad list --output json` and find the matching entity by display name. Squads are first-class assignees too — a squad name (e.g. \"Super Human\") routes work to the squad leader, who then delegates. On a clean unambiguous match, prefer `--assignee-id <uuid>` using the `user_id` (member) or `id` (agent or squad) from that JSON — UUID matching is exact and robust to name collisions in workspaces with overlapping names. `--assignee <name>` (fuzzy) is acceptable as a fallback when names are unambiguous. On no match or ambiguous match, do NOT pass either flag — instead append a final line to the description: `Unrecognized assignee: X`.\n")
|
||
b.WriteString(" - Treat bare @-routing as an assignee directive even when the user did not write the English word \"assign\". This includes Chinese imperatives like `让 @独立团 review 这个 PR`, `给 @X 处理`, or `交给 @X`; strip the leading `@`/`@` before matching display names. Do not keep that routing wrapper or `@Name` in the description unless it is a true CC-style notification rather than ownership. If the matched entity is a squad, pass the squad's `id` as `--assignee-id`, not the leader agent's id.\n")
|
||
agentID := ""
|
||
agentName := ""
|
||
if task.Agent != nil {
|
||
agentID = task.Agent.ID
|
||
agentName = task.Agent.Name
|
||
}
|
||
switch {
|
||
case task.SquadID != "":
|
||
// The user opened quick-create with a SQUAD selected. The task
|
||
// runs on the squad's leader agent, but the squad is the expected
|
||
// owner — assigning to the leader would mask the squad's
|
||
// delegation flow. Always point the default at the squad UUID.
|
||
if task.SquadName != "" {
|
||
fmt.Fprintf(&b, " - When the user did NOT name an assignee, default to the picker SQUAD %q: pass `--assignee-id %q` (the squad's UUID). The user opened quick-create with the squad selected; you (the leader agent) are running on the squad's behalf, so the squad — not you — is the expected owner. Never leave the issue unassigned, and do not assign it to your own agent UUID.\n\n", task.SquadName, task.SquadID)
|
||
} else {
|
||
fmt.Fprintf(&b, " - When the user did NOT name an assignee, default to the picker SQUAD: pass `--assignee-id %q` (the squad's UUID). The user opened quick-create with the squad selected; you (the leader agent) are running on the squad's behalf, so the squad — not you — is the expected owner. Never leave the issue unassigned, and do not assign it to your own agent UUID.\n\n", task.SquadID)
|
||
}
|
||
case agentID != "":
|
||
fmt.Fprintf(&b, " - When the user did NOT name an assignee, default to YOURSELF: pass `--assignee-id %q` (your agent UUID). The picker agent is the expected owner because the user opened quick-create with you selected — never leave the issue unassigned. Use the UUID flag, not `--assignee <name>`, so the assignment is unambiguous even when other agents share part of your name.\n\n", agentID)
|
||
case agentName != "":
|
||
fmt.Fprintf(&b, " - When the user did NOT name an assignee, default to YOURSELF: pass `--assignee %q`. The picker agent is the expected owner because the user opened quick-create with you selected — never leave the issue unassigned.\n\n", agentName)
|
||
default:
|
||
b.WriteString(" - When the user did NOT name an assignee, default to YOURSELF (the picker agent): pass `--assignee-id <your agent UUID>` (preferred) or `--assignee <your agent name>`. Never leave the issue unassigned.\n\n")
|
||
}
|
||
|
||
if task.QuickCreateDueDate != "" {
|
||
fmt.Fprintf(&b, "- **due-date**: required for this run. Pass `--due-date %s`; the quick-create selection is authoritative.\n\n", task.QuickCreateDueDate)
|
||
}
|
||
|
||
// project — pinned by the modal when the user picked one, otherwise
|
||
// omitted so the platform routes to the workspace default. Always pass
|
||
// the UUID (never a name) so the issue lands in the right project even
|
||
// when several share a title.
|
||
if task.ProjectID != "" {
|
||
if task.ProjectTitle != "" {
|
||
fmt.Fprintf(&b, "- **project**: required for this run. Pass `--project %q` so the new issue lands in project %q (the user picked it in the quick-create modal). Do not infer a different project from the prompt text — the modal selection is authoritative.\n", task.ProjectID, task.ProjectTitle)
|
||
} else {
|
||
fmt.Fprintf(&b, "- **project**: required for this run. Pass `--project %q` so the new issue lands in the project the user picked in the quick-create modal. Do not infer a different project from the prompt text — the modal selection is authoritative.\n", task.ProjectID)
|
||
}
|
||
} else {
|
||
b.WriteString("- **project**: omit. The platform will route the issue to the workspace default.\n")
|
||
}
|
||
// parent — pinned by the modal when the user opened it from "Add sub
|
||
// issue" on an existing issue. Pass the UUID (never the identifier) so
|
||
// the create lands the sub-issue under the right parent even when the
|
||
// workspace prefix changes; the identifier is included in the prose
|
||
// purely as human-readable context for the agent.
|
||
if task.ParentIssueID != "" {
|
||
if task.ParentIssueIdentifier != "" {
|
||
fmt.Fprintf(&b, "- **parent**: required for this run. Pass `--parent %q` so the new issue is filed as a sub-issue of %s (the user opened quick-create from that issue's \"Add sub issue\" entry). Do not infer a different parent from the prompt text — the modal entry point is authoritative.\n", task.ParentIssueID, task.ParentIssueIdentifier)
|
||
} else {
|
||
fmt.Fprintf(&b, "- **parent**: required for this run. Pass `--parent %q` so the new issue is filed as a sub-issue of the parent the user picked in the quick-create modal. Do not infer a different parent from the prompt text — the modal entry point is authoritative.\n", task.ParentIssueID)
|
||
}
|
||
}
|
||
b.WriteString("- **status**: omit (defaults to `todo`).\n")
|
||
b.WriteString("- **attachments**: do NOT pass `--attachment`. The flag only accepts LOCAL file paths. Any image URL in the user input is already markdown — keep it inline in `--description` instead.\n\n")
|
||
|
||
// output format
|
||
b.WriteString("Output format:\n")
|
||
b.WriteString("- Run exactly one `multica issue create --output json` invocation. Do not retry for any reason — even on non-zero exit. The issue may already exist; another attempt would create a duplicate.\n")
|
||
b.WriteString("- Parse the JSON response to read the created issue's `identifier` (preferred) or `id` (fallback). Do not scrape human output and do not assume any workspace issue prefix such as `MUL-`; workspaces can use custom prefixes.\n")
|
||
b.WriteString("- After success, print exactly one line: `Created <identifier-or-id>: <title>` and exit. No commentary, no follow-up tool calls.\n")
|
||
b.WriteString("- Do NOT call `multica issue get` or `multica issue comment add` — there is no issue to query or comment on.\n")
|
||
b.WriteString("- On CLI error or JSON parse error, exit with the error as the only output. The platform writes a failure notification automatically.\n")
|
||
return b.String()
|
||
}
|
||
|
||
// buildCommentPrompt constructs a prompt for comment-triggered tasks.
|
||
// The triggering comment content is embedded directly so the agent cannot
|
||
// miss it, even when stale output files exist in a reused workdir.
|
||
// The reply instructions (including the current TriggerCommentID as --parent)
|
||
// are re-emitted on every turn so resumed sessions cannot carry forward a
|
||
// previous turn's --parent UUID.
|
||
func buildCommentPrompt(task Task, provider string) string {
|
||
var b strings.Builder
|
||
b.WriteString("You are running as a local coding agent for a Multica workspace.\n\n")
|
||
fmt.Fprintf(&b, "Your assigned issue ID is: %s\n\n", task.IssueID)
|
||
if task.TriggerCommentContent != "" {
|
||
authorLabel := "A user"
|
||
if task.TriggerAuthorType == "agent" {
|
||
name := task.TriggerAuthorName
|
||
if name == "" {
|
||
name = "another agent"
|
||
}
|
||
authorLabel = fmt.Sprintf("Another agent (%s)", name)
|
||
}
|
||
fmt.Fprintf(&b, "[NEW COMMENT] %s just left a new comment. Focus on THIS comment — do not confuse it with previous ones:\n\n", authorLabel)
|
||
fmt.Fprintf(&b, "> %s\n\n", task.TriggerCommentContent)
|
||
// MUL-4195: comments that arrived before this run started were folded
|
||
// into it rather than dropped. The trigger above is the newest; the
|
||
// agent must ALSO address these earlier ones so no deliberate user
|
||
// instruction is silently lost. Prefer the embedded detail so the agent
|
||
// does not have to guess which thread each folded comment lives in
|
||
// (they may span multiple threads — review should-fix #3); fall back to
|
||
// a thread-agnostic issue-wide fetch hint for old servers that only send
|
||
// the ids.
|
||
if len(task.CoalescedComments) > 0 {
|
||
fmt.Fprintf(&b, "This run also covers %d earlier comment(s) posted before it started — you must read and address them too, not just the one above. They may be in different threads, so each is reproduced here with its own thread:\n\n", len(task.CoalescedComments))
|
||
for _, cc := range task.CoalescedComments {
|
||
authorLabel := "A user"
|
||
if cc.AuthorType == "agent" {
|
||
name := cc.AuthorName
|
||
if name == "" {
|
||
name = "another agent"
|
||
}
|
||
authorLabel = fmt.Sprintf("Another agent (%s)", name)
|
||
} else if cc.AuthorName != "" {
|
||
authorLabel = cc.AuthorName
|
||
}
|
||
fmt.Fprintf(&b, "- comment %s", cc.ID)
|
||
if cc.CreatedAt != "" {
|
||
fmt.Fprintf(&b, " (%s, %s)", authorLabel, cc.CreatedAt)
|
||
} else {
|
||
fmt.Fprintf(&b, " (%s)", authorLabel)
|
||
}
|
||
if cc.ThreadID != "" {
|
||
fmt.Fprintf(&b, " [thread %s]", cc.ThreadID)
|
||
}
|
||
b.WriteString(":\n")
|
||
fmt.Fprintf(&b, " > %s\n", strings.ReplaceAll(strings.TrimSpace(cc.Content), "\n", "\n > "))
|
||
}
|
||
fmt.Fprintf(&b, "\nIf you need the surrounding discussion for any of them, fetch its thread with `multica issue comment list %s --thread <thread-id> --tail 30 --output json` using the thread id shown above.\n\n", task.IssueID)
|
||
} else if len(task.CoalescedCommentIDs) > 0 {
|
||
fmt.Fprintf(&b, "This run also covers %d earlier comment(s) posted before it started — you must read and address them too, not just the one above: %s. These may be in DIFFERENT threads, so do not assume they share the triggering thread; fetch each by pulling the issue-wide discussion with `multica issue comment list %s --recent 30 --output json` (expand with `--full` if a thread is folded) and locate the ids above.\n\n",
|
||
len(task.CoalescedCommentIDs), strings.Join(task.CoalescedCommentIDs, ", "), task.IssueID)
|
||
}
|
||
if task.TriggerAuthorType == "agent" {
|
||
b.WriteString("⚠️ The triggering comment was posted by another agent. Decide whether a reply is warranted. If you produced actual work this turn (investigated, fixed something, answered a real question), post the result as a normal reply — that is NOT a noise comment, and the standard rule that final results must be delivered via comment still applies. If the triggering comment was a pure acknowledgment, thanks, or sign-off AND you produced no work this turn, do NOT reply — and do NOT post a comment saying 'No reply needed' or similar. Simply exit with no output. Silence is the preferred way to end agent-to-agent threads. If you do reply, do not @mention the other agent as a sign-off (that re-triggers them and starts a loop).\n\n")
|
||
}
|
||
if task.Agent != nil && strings.Contains(task.Agent.Instructions, "## Squad Operating Protocol") {
|
||
fmt.Fprintf(&b, "⚠️ **Squad leader no_action rule:** If you decide no action is needed, call `multica squad activity %s no_action --reason \"...\"` and EXIT. DO NOT post any comment — not even one that says \"no action needed\" or \"exiting silently\". The squad activity call records your decision; a comment is redundant noise.\n\n", task.IssueID)
|
||
}
|
||
}
|
||
fmt.Fprintf(&b, "Start by running `multica issue get %s --output json` to understand your task, then decide how to proceed.\n\n", task.IssueID)
|
||
// Comment-reading pointer. Warm path with new comments: issue-wide
|
||
// since-delta count, but steer the agent to read the triggering thread
|
||
// first. Warm resumed path with no new comments: the trigger is already
|
||
// injected, so don't force a duplicate thread read. Cold path: read the
|
||
// triggering thread, not the flat timeline. Final fallback (no trigger id,
|
||
// shouldn't happen here): plain read.
|
||
if hint := execenv.BuildNewCommentsHint(task.IssueID, task.TriggerCommentID, task.TriggerThreadID, task.NewCommentsSince, task.NewCommentCount); hint != "" {
|
||
b.WriteString(hint)
|
||
} else if task.PriorSessionID != "" {
|
||
b.WriteString(execenv.BuildResumedCommentsHint(task.IssueID, task.TriggerCommentID, task.TriggerThreadID))
|
||
} else if cold := execenv.BuildColdCommentsHint(task.IssueID, task.TriggerCommentID, task.TriggerThreadID); cold != "" {
|
||
b.WriteString(cold)
|
||
} else {
|
||
fmt.Fprintf(&b, "Read the discussion: `multica issue comment list %s --recent 10 --output json` (resolved threads come back folded — `--full` to expand).\n\n", task.IssueID)
|
||
}
|
||
// Reply routing. When this run coalesced comments spanning MORE THAN ONE
|
||
// root thread, answer each thread in its own thread instead of dumping one
|
||
// merged comment (MUL-4348). Same-thread follow-ups collapse to a single
|
||
// group upstream, so they keep the ordinary single-parent path below and can
|
||
// never be split into duplicate replies.
|
||
if targets := commentReplyThreads(task); len(targets) >= 2 {
|
||
b.WriteString(execenv.BuildMultiThreadCommentReplyInstructions(task.IssueID, targets))
|
||
} else {
|
||
b.WriteString(execenv.BuildCommentReplyInstructions(provider, task.IssueID, task.TriggerCommentID))
|
||
}
|
||
return b.String()
|
||
}
|
||
|
||
// commentReplyThreads groups this run's trigger + coalesced comments by their
|
||
// root thread, in first-seen order (coalesced comments oldest-first, the newest
|
||
// trigger last). A run that coalesced several @mentions from the SAME thread
|
||
// yields a single group, so same-thread follow-ups get exactly one consolidated
|
||
// reply and can never be split into duplicates; comments from different root
|
||
// threads yield one group each so the agent replies inside each thread instead
|
||
// of merging them into one blob (MUL-4348).
|
||
//
|
||
// The reply for each thread targets the NEWEST comment that triggered this run
|
||
// in that thread (coalesced comments arrive oldest-first and the trigger is the
|
||
// newest overall, so a simple last-write-wins yields the newest per thread).
|
||
// That nests the answer next to the most recent question in the thread rather
|
||
// than at the thread root, and makes the trigger's own thread (--parent =
|
||
// trigger comment) consistent with every other thread instead of a special
|
||
// case. Returns nil when there is no trigger or only a single distinct thread —
|
||
// the caller then keeps the existing single-parent reply path unchanged.
|
||
func commentReplyThreads(task Task) []execenv.ThreadReplyTarget {
|
||
if task.TriggerCommentID == "" {
|
||
return nil
|
||
}
|
||
// A comment with no explicit thread id is a root comment: it is its own
|
||
// thread, so fall back to the comment id itself as the thread key.
|
||
threadKey := func(threadID, commentID string) string {
|
||
if threadID != "" {
|
||
return threadID
|
||
}
|
||
return commentID
|
||
}
|
||
|
||
order := make([]string, 0, len(task.CoalescedComments)+1)
|
||
parentByThread := make(map[string]string, len(task.CoalescedComments)+1)
|
||
// note records first-seen order but lets the newest comment win the reply
|
||
// target: inputs are chronological (coalesced oldest-first, trigger last),
|
||
// so the last write for a thread is its newest triggering comment.
|
||
note := func(threadID, parentID string) {
|
||
if _, ok := parentByThread[threadID]; !ok {
|
||
order = append(order, threadID)
|
||
}
|
||
parentByThread[threadID] = parentID
|
||
}
|
||
|
||
// Coalesced (older) comments first: reply under the specific comment that
|
||
// mentioned the agent, not the thread root, so a mid-thread mention gets its
|
||
// answer next to the question.
|
||
for _, cc := range task.CoalescedComments {
|
||
note(threadKey(cc.ThreadID, cc.ID), cc.ID)
|
||
}
|
||
// The newest trigger last: it always wins its own thread's reply target,
|
||
// overriding any earlier coalesced comment that shared the trigger's thread.
|
||
note(threadKey(task.TriggerThreadID, task.TriggerCommentID), task.TriggerCommentID)
|
||
|
||
if len(order) <= 1 {
|
||
return nil
|
||
}
|
||
targets := make([]execenv.ThreadReplyTarget, 0, len(order))
|
||
for _, tid := range order {
|
||
targets = append(targets, execenv.ThreadReplyTarget{ThreadID: tid, ParentID: parentByThread[tid]})
|
||
}
|
||
return targets
|
||
}
|
||
|
||
// buildChatPrompt constructs a prompt for interactive chat tasks.
|
||
func buildChatPrompt(task Task) string {
|
||
// Proactive self-introduction: the agent was just created and is opening the
|
||
// conversation. There is no user message to reply to — the agent sends the
|
||
// first message so the thread reads as the agent messaging its creator, not
|
||
// the creator prompting the agent (MUL-4230).
|
||
if task.ChatIntro {
|
||
var b strings.Builder
|
||
b.WriteString("You are running as a chat assistant for a Multica workspace.\n")
|
||
b.WriteString("You were just created, and this is the very first message in a direct chat with the person who created you. They have not written anything yet — you are opening the conversation. Send a short, warm, first-person introduction: who you are, what you're good at, and how they can work with you. Do NOT phrase it as an answer to a question or repeat any prompt back; just introduce yourself as if you reached out first.\n")
|
||
return b.String()
|
||
}
|
||
|
||
var b strings.Builder
|
||
b.WriteString("You are running as a chat assistant for a Multica workspace.\n")
|
||
b.WriteString("A user is chatting with you directly. Respond to their message.\n\n")
|
||
// Channel awareness (MUL-3871). When the session is backed by an IM channel,
|
||
// the agent must KNOW it is operating inside that channel — otherwise an ask
|
||
// like "what did you just talk about" sends it to read Multica instead of the
|
||
// channel conversation. A web-only chat session gets no such block — its
|
||
// history is the Multica chat_session the agent already resumes.
|
||
//
|
||
// The history half is Slack-only, and that is a real server constraint, not a
|
||
// simplification: `multica chat history` / `multica chat thread` are served by
|
||
// handlers hardwired to h.SlackHistory (handler/chat_history.go), so on a
|
||
// Feishu session both commands return "no channel integration". Teaching them
|
||
// there would send the agent down a path that always fails. A Feishu run works
|
||
// from the context the inbound enricher already injected, so it gets the
|
||
// awareness statement without the commands, and ChatInThread — which only ever
|
||
// picks between those two commands — does not apply to it (MUL-4899).
|
||
if task.ChatChannelType != "" {
|
||
platform := channelDisplayName(task.ChatChannelType)
|
||
fmt.Fprintf(&b, "You are operating inside a %s conversation — not the Multica web app. This conversation and its history live in %s, NOT in Multica; never look in Multica issues or comments for it.\n", platform, platform)
|
||
if task.ChatChannelType == execenv.ChannelTypeSlack {
|
||
b.WriteString("The message below may be only what triggered you. Read the conversation with:\n")
|
||
b.WriteString("- `multica chat history --output json` — the channel overview: recent top-level messages, each thread tagged with a `thread_id` and `reply_count`. It does NOT expand thread contents.\n")
|
||
b.WriteString("- `multica chat thread [<thread_id>] --output json` — read one thread's messages; omit the id to read the thread you are in, or pass a `thread_id` from the overview to read a specific thread.\n")
|
||
if task.ChatInThread {
|
||
b.WriteString("You were @mentioned inside a thread: start with `multica chat thread` to read it; if you need the wider channel, run `multica chat history` and open a specific thread with `multica chat thread <thread_id>`.\n")
|
||
} else {
|
||
b.WriteString("You were @mentioned at the channel top level: start with `multica chat history` to see the channel, then read a specific thread's contents with `multica chat thread <thread_id>`.\n")
|
||
}
|
||
// These reads are the agent's private context-gathering; narrating them
|
||
// into a chat reply reads as noise (the user reported every reply being
|
||
// prefixed with "我先读取…"). Tell the agent to keep them out of its answer.
|
||
b.WriteString("Do these reads SILENTLY as an internal step — they are how you gather context, not part of your answer. Do NOT narrate them: your reply must not begin with what you are about to read or just read (no \"我先读取…\" / \"let me read the history / open the thread\"). Reply to the user with your answer only.\n")
|
||
} else {
|
||
fmt.Fprintf(&b, "Work from the context already provided to you below — Multica has no history reader for %s, so there is no command that can fetch more of this conversation. If you genuinely need earlier context that is not here, ask the user for it rather than guessing.\n", platform)
|
||
}
|
||
b.WriteString("\n")
|
||
}
|
||
if task.Agent != nil && len(task.Agent.Skills) > 0 {
|
||
refs := ExtractSlashSkills(task.ChatMessage)
|
||
if len(refs) > 0 {
|
||
agentSkills := make(map[string]string, len(task.Agent.Skills))
|
||
for _, s := range task.Agent.Skills {
|
||
agentSkills[s.ID] = s.Name
|
||
}
|
||
|
||
selected := make([]string, 0, len(refs))
|
||
seen := make(map[string]struct{}, len(refs))
|
||
for _, ref := range refs {
|
||
name, ok := agentSkills[ref.ID]
|
||
if !ok {
|
||
continue
|
||
}
|
||
if _, ok := seen[ref.ID]; ok {
|
||
continue
|
||
}
|
||
seen[ref.ID] = struct{}{}
|
||
selected = append(selected, name)
|
||
}
|
||
|
||
if len(selected) > 0 {
|
||
b.WriteString("Explicitly selected skills:\n")
|
||
for _, name := range selected {
|
||
fmt.Fprintf(&b, "- %s\n", name)
|
||
}
|
||
b.WriteString("\n")
|
||
}
|
||
}
|
||
}
|
||
fmt.Fprintf(&b, "User message:\n%s\n", task.ChatMessage)
|
||
// List attachments by id + filename so the agent can fetch them via
|
||
// the CLI. We deliberately do NOT inline the URL: chat attachments
|
||
// live behind a signed CDN with a short TTL, so by the time the agent
|
||
// has finished thinking the URL embedded in the markdown body may
|
||
// have expired. `multica attachment download <id>` re-signs at click
|
||
// time and is the only reliable path.
|
||
if len(task.ChatMessageAttachments) > 0 {
|
||
b.WriteString("\nAttachments on this message:\n")
|
||
for _, a := range task.ChatMessageAttachments {
|
||
if a.ContentType != "" {
|
||
fmt.Fprintf(&b, "- id=%s filename=%q content_type=%s\n", a.ID, a.Filename, a.ContentType)
|
||
} else {
|
||
fmt.Fprintf(&b, "- id=%s filename=%q\n", a.ID, a.Filename)
|
||
}
|
||
}
|
||
b.WriteString("Use `multica attachment download <id>` to fetch each file locally before referring to it.\n")
|
||
b.WriteString("When creating an issue that should preserve one of these attachments, pass `--attachment-id <id>` to `multica issue create` in addition to keeping the attachment markdown inline.\n")
|
||
}
|
||
// Outbound attachments: how the agent puts an image/file INTO its reply.
|
||
// Web/mobile chat only — for IM-channel chats the reply is delivered to
|
||
// that platform, not the Multica chat UI, so this binding does not apply.
|
||
// This is the DELIVERY layer of the channel policy and keys off "is there a
|
||
// channel at all", unlike the history block above which is Slack-only; the
|
||
// two layers must not be collapsed into one condition (MUL-4899). The brief's
|
||
// `## Output` section states the same policy for every surface.
|
||
if task.ChatChannelType == "" {
|
||
b.WriteString("\nTo include a file or image you produced in your reply, run `multica attachment upload <local-path>`. The file binds to your reply automatically and appears as an attachment card below it even if you paste nothing. The command also returns a `markdown` snippet you may paste on its own line to place the item where you want it (files render as a card, images inline).\n")
|
||
} else {
|
||
fmt.Fprintf(&b, "\nThis reply is delivered to %s as text. You cannot attach a file to it: `multica attachment upload` binds to a Multica chat reply, which this is not. If you produce a file, describe it in words — never write its local path as a link, and never upload it and then write as though it arrived.\n", channelDisplayName(task.ChatChannelType))
|
||
}
|
||
return b.String()
|
||
}
|
||
|
||
// channelDisplayName renders a chat_channel_type for prompt copy. The mapping
|
||
// itself lives in execenv so the per-turn prompt (here) and the runtime brief
|
||
// (execenv.writeOutput) cannot drift into naming the same platform differently.
|
||
func channelDisplayName(channelType string) string {
|
||
return execenv.ChannelDisplayName(channelType)
|
||
}
|
||
|
||
// buildAutopilotPrompt constructs a prompt for run_only autopilot tasks.
|
||
func buildAutopilotPrompt(task Task) string {
|
||
var b strings.Builder
|
||
b.WriteString("You are running as a local coding agent for a Multica workspace.\n\n")
|
||
b.WriteString("This task was triggered by an Autopilot in run-only mode. There is no assigned Multica issue for this run.\n\n")
|
||
fmt.Fprintf(&b, "Autopilot run ID: %s\n", task.AutopilotRunID)
|
||
if task.AutopilotID != "" {
|
||
fmt.Fprintf(&b, "Autopilot ID: %s\n", task.AutopilotID)
|
||
}
|
||
if task.AutopilotTitle != "" {
|
||
fmt.Fprintf(&b, "Autopilot title: %s\n", task.AutopilotTitle)
|
||
}
|
||
if task.AutopilotSource != "" {
|
||
fmt.Fprintf(&b, "Trigger source: %s\n", task.AutopilotSource)
|
||
}
|
||
if strings.TrimSpace(string(task.AutopilotTriggerPayload)) != "" {
|
||
fmt.Fprintf(&b, "Trigger payload:\n%s\n", strings.TrimSpace(string(task.AutopilotTriggerPayload)))
|
||
}
|
||
b.WriteString("\nAutopilot instructions:\n")
|
||
if strings.TrimSpace(task.AutopilotDescription) != "" {
|
||
b.WriteString(task.AutopilotDescription)
|
||
b.WriteString("\n\n")
|
||
} else if task.AutopilotTitle != "" {
|
||
fmt.Fprintf(&b, "%s\n\n", task.AutopilotTitle)
|
||
} else {
|
||
b.WriteString("No additional autopilot instructions were provided. Inspect the autopilot configuration before proceeding.\n\n")
|
||
}
|
||
if task.AutopilotID != "" {
|
||
fmt.Fprintf(&b, "Start by running `multica autopilot get %s --output json` if you need the full autopilot configuration, then complete the instructions above.\n", task.AutopilotID)
|
||
} else {
|
||
b.WriteString("Complete the instructions above.\n")
|
||
}
|
||
b.WriteString("Do not run `multica issue get`; this run does not have an issue ID.\n")
|
||
return b.String()
|
||
}
|