fix(slack): Ignore message edits

packages/junior-dashboard/src/client/conversations/eventTranscript.ts

@@ -80,7 +80,9 @@ export function pendingTranscriptMessage(
     // Keep pending rows after history without colliding with real event seqs.
     sourceSeq: Number.MAX_SAFE_INTEGER - 1_000_000 + index,
     timestamp: Date.parse(message.createdAt),
-    ...(message.actorIdentity ? { actorIdentity: message.actorIdentity } : undefined),
+    ...(message.actorIdentity
+      ? { actorIdentity: message.actorIdentity }
+      : undefined),
   };
 }
 
@@ -197,7 +199,9 @@ export function transcriptMessagesFromEvents(
             : { type: "text", text: data.text! },
         ]),
         messageId: data.messageId,
-        ...(data.actorIdentity ? { actorIdentity: data.actorIdentity } : undefined),
+        ...(data.actorIdentity
+          ? { actorIdentity: data.actorIdentity }
+          : undefined),
         ...(data.eventType ? { eventType: data.eventType } : undefined),
         ...(data.trustedSummary
           ? { trustedSummary: data.trustedSummary }

packages/junior-evals/evals/integration/event-automations/management.eval.ts

@@ -161,7 +161,7 @@ describeEval("Event automation management", slackEvals, (it) => {
         ],
         fail: [
           "Do not create separate tasks for closed and reopened.",
-          "Do not claim a polling schedule, recurring timer, or watch was created.",
+          "Do not claim that `watchEvents`, a polling schedule, or a recurring timer was created instead of the event automation.",
         ],
       }),
     });
@@ -208,7 +208,7 @@ describeEval("Event automation management", slackEvals, (it) => {
         fail: [
           "Do not narrow the task to one issue number.",
           "Do not create separate tasks for closed and reopened issues.",
-          "Do not claim a polling schedule or watch was created.",
+          "Do not claim that `watchEvents` or a polling schedule was created instead of the event automation.",
         ],
       }),
     });

packages/junior-evals/src/behavior-harness.ts

@@ -1143,8 +1143,7 @@ function toEvalAssistantPost(value: unknown): EvalAssistantPost {
  * Build a Chat SDK Message for Slack ingress from a harness event.
  *
  * Synthetic Slack ingress keeps an empty formatted AST so plain text remains
- * the source of truth, matching mailbox restore and edited-message
- * construction elsewhere in Junior.
+ * the source of truth, matching mailbox restore elsewhere in Junior.
  */
 function toSlackMessage(
   event: MentionEvent | SubscribedMessageEvent,

packages/junior/src/chat/ingress/slack-webhook.ts

@@ -34,10 +34,6 @@ import {
 import { coerceThreadConversationState } from "@/chat/state/conversation";
 import { parseContent } from "@/chat/slack/message/content";
 import { stopSlackThread } from "@/chat/slack/thread-stop";
-import {
-  extractMessageChangedMention,
-  isMessageChangedEnvelope,
-} from "@/chat/ingress/message-changed";
 import {
   normalizeIncomingSlackThreadId,
   withNormalizedThreadId,
@@ -102,6 +98,8 @@ function slackEventLogContext(
 }
 
 const IGNORED_MESSAGE_SUBTYPES = new Set([
+  // Conversation Messages are immutable once accepted. An edit must not
+  // rewrite input or start another Turn. Send a new Slack Message instead.
   "message_changed",
   "message_deleted",
   "message_replied",
@@ -454,50 +452,6 @@ async function routeParsedMessage(args: {
   });
 }
 
-async function handleMessageChanged(args: {
-  adapter: SlackAdapter;
-  body: unknown;
-  installation: SlackInstallationContext;
-  queue: ConversationWorkQueue;
-  conversationStore?: ConversationStore;
-  receivedAtMs: number;
-  state: StateAdapter;
-}): Promise<boolean> {
-  if (!isMessageChangedEnvelope(args.body)) {
-    return false;
-  }
-  const botUserId = args.adapter.botUserId;
-  if (!botUserId) {
-    // Entry classification requires resolved bot identity; degrading into
-    // silently dropped edited-mention events would hide the outage. Throwing
-    // makes the webhook return a retryable non-2xx so Slack redelivers.
-    throw new Error(
-      "Slack bot identity is unresolved; cannot classify message_changed event",
-    );
-  }
-
-  const result = extractMessageChangedMention(
-    args.body,
-    botUserId,
-    args.adapter,
-  );
-  if (!result || shouldIgnoreMessage(result.message)) {
-    return true;
-  }
-
-  await persistSlackMessage({
-    adapter: args.adapter,
-    installation: args.installation,
-    message: result.message,
-    conversationStore: args.conversationStore,
-    queue: args.queue,
-    receivedAtMs: args.receivedAtMs,
-    route: "mention",
-    state: args.state,
-  });
-  return true;
-}
-
 async function handleSlackEvent(args: {
   body: SlackEventEnvelope;
   services: SlackWebhookServices;
@@ -533,20 +487,6 @@ async function handleSlackEvent(args: {
       installation,
       state,
       task: async () => {
-        if (
-          await handleMessageChanged({
-            adapter,
-            body: args.body,
-            installation,
-            conversationStore: args.services.conversationStore,
-            queue: args.services.queue,
-            receivedAtMs,
-            state,
-          })
-        ) {
-          return;
-        }
-
         if (event.type === "assistant_thread_started") {
           const assistantThread = (event as Record<string, unknown>)
             .assistant_thread as