T5 — Synthetic system reminder cho mid-turn messages

{`
// Chỉ áp dụng từ step 2 trở đi
if (step > 1 && lastFinished) {
  for (const m of msgs) {
    // Điều kiện 1: phải là user message
    if (m.info.role !== "user") continue

    // Điều kiện 2: phải là message MỚI (sau lần loop cuối hoàn thành)
    if (m.info.id <= lastFinished.id) continue

    for (const p of m.parts) {
      // Điều kiện 3: chỉ wrap text, không wrap media/synthetic/ignored
      if (p.type !== "text" || p.ignored || p.synthetic) continue
      if (!p.text.trim()) continue

      // Wrap trong system-reminder XML block
      p.text = [
        "<system-reminder>",
        "The user sent the following message:",
        p.text,
        "",
        "Please address this message and continue with your tasks.",
        "</system-reminder>",
      ].join("\n")
    }
  }
}
`}

{`
// Được update mỗi lần kết thúc một step:
lastFinished = lastAssistant  // assistant response cuối cùng

// Mỗi iteration: user messages mới (id > lastFinished.id)
// là những message đến trong khi loop đang chạy
const newUserMsgs = msgs.filter(
  m => m.role === "user" && m.id > lastFinished.id
)
`}

{`
// Các loại part có thể có trong một user message:
// - type: "text"      → ← CHỈ WRAP type này
// - type: "image"     → skip (không wrap media)
// - type: "file"      → skip
// - synthetic: true   → skip (harness-injected, vd compaction)
// - ignored: true     → skip (user đã mark là irrelevant)
`}

{`
// Step 3, history:
// [user: "viết service X"]
// [assistant: "OK tôi sẽ..."]
// [tool: read_file result]
// [tool: write_file result]
// [user: "hãy dùng TypeScript strict mode"] ← message mới!
// [assistant: ...] ← model có thể không address vì nó "buried"

// Với reminder:
// [user: "<system-reminder>The user sent:\nhãy dùng TypeScript strict mode\nPlease address...</system-reminder>"]
// Model NOW sees it as priority instruction
`}

{`
// WRONG: không check step > 1
for (const m of msgs) {
  if (m.role === "user") wrapWithReminder(m)
}
// Initial user message cũng bị wrap:
// "<system-reminder>The user sent:\nViết hàm sort\nPlease address...</system-reminder>"
// → unneccesary và verbose

// CORRECT:
if (step > 1 && lastFinished) {  // chỉ step > 1
  // ...
}
`}

{`
// WRONG: wrap tất cả parts
for (const p of m.parts) {
  p.text = wrapReminder(p.text || p.toString())
  // Image part: p.text = undefined → "undefined" được wrap
}

// CORRECT: chỉ text parts không phải synthetic/ignored
if (p.type !== "text" || p.ignored || p.synthetic) continue
`}

{`
interface Message {
  id: string
  role: "user" | "assistant" | "tool"
  parts: MessagePart[]
}

interface MessagePart {
  type: "text" | "image" | "file"
  text?: string
  ignored?: boolean
  synthetic?: boolean
}

function injectSystemReminders(
  messages: Message[],
  lastFinishedId: string | null,
  step: number
): Message[] {
  // Chỉ áp dụng từ step 2 trở đi
  if (step <= 1 || lastFinishedId === null) {
    return messages
  }

  return messages.map((msg) => {
    // Chỉ xử lý user messages
    if (msg.role !== "user") return msg

    // Chỉ xử lý messages MỚI (sau lastFinished)
    if (msg.id <= lastFinishedId) return msg

    // Transform text parts
    const newParts = msg.parts.map((part) => {
      // Bỏ qua non-text, synthetic, ignored, empty
      if (
        part.type !== "text" ||
        part.ignored ||
        part.synthetic ||
        !part.text?.trim()
      ) {
        return part
      }

      // Wrap trong system-reminder
      return {
        ...part,
        text: [
          "<system-reminder>",
          "The user sent the following message:",
          part.text,
          "",
          "Please address this message and continue with your tasks.",
          "</system-reminder>",
        ].join("\n"),
      }
    })

    return { ...msg, parts: newParts }
  })
}

// Usage trong agent loop:
// const processedMessages = injectSystemReminders(
//   rawMessages,
//   lastAssistantMessage?.id ?? null,
//   currentStep
// )
// // Gửi processedMessages cho LLM
`}