第 04 章：回车键之后

// Ink 中的事件处理，和 React 一样
function MyInput({ onSubmit }) {
  const [value, setValue] = React.useState('')

  const handleSubmit = () => {
    onSubmit(value)  // 把输入值传给父组件
    setValue('')     // 清空输入框
  }

  const handleChange = (newValue) => {
    setValue(newValue)
  }

  return <TextInput value={value} onChange={handleChange} onSubmit={handleSubmit} />
}

// → src/types/textInputTypes.ts 的 PromptInputMode 类型
export type PromptInputMode =
  | 'bash'                    // Bash 命令模式（! 开头）
  | 'prompt'                  // 普通提示模式（默认）
  | 'orphaned-permission'     // 孤立权限请求（工具权限弹窗）
  | 'task-notification'       // 任务通知（计划任务触发）

// → src/utils/handlePromptSubmit.ts 的 handlePromptSubmit() 函数（简化版）
export async function handlePromptSubmit(
  params: HandlePromptSubmitParams,
): Promise<void> {
  const input = params.input ?? ''
  const mode = params.mode ?? 'prompt'

  // 空输入直接返回
  if (input.trim() === '') return

  // 退出命令特殊处理
  if (['exit', 'quit', ':q', ':q!'].includes(input.trim())) {
    // 触发退出流程
  }

  // 图片引用检查：只保留文本中仍存在的 [Image #N] 对应的图片
  const referencedIds = new Set(parseReferences(input).map(r => r.id))
  const pastedContents = /* 过滤未引用的图片 */

  // 调用核心处理函数
  await processUserInput({
    input,
    mode,
    pastedContents,
    context,
    messages,
    // ...
  })
}

// → src/utils/processUserInput/processUserInput.ts 的 processUserInput() 函数（简化版）
export async function processUserInput({
  input, mode, context, pastedContents, messages, ...
}): Promise<ProcessUserInputBaseResult> {

  // 立即显示用户输入（不等处理完成）
  if (mode === 'prompt' && typeof input === 'string') {
    setUserInputOnProcessing?.(input)
  }

  // 核心处理逻辑委托给 processUserInputBase
  const result = await processUserInputBase(input, mode, ...)

  // 执行 UserPromptSubmit hooks（用户自定义钩子）
  for await (const hookResult of executeUserPromptSubmitHooks(input, ...)) {
    if (hookResult.blockingError) {
      return { messages: [createSystemMessage(blockingMessage)], shouldQuery: false }
    }
    if (hookResult.preventContinuation) {
      result.shouldQuery = false
      return result
    }
    if (hookResult.additionalContexts) {
      result.messages.push(createAttachmentMessage(...))
    }
  }

  return result
}

// → src/utils/processUserInput/processUserInput.ts 的 processUserInputBase() 函数（简化版）
async function processUserInputBase(input, mode, ...) {
  // 1. 图片处理（如果是多模态输入）
  //    - 调整图片大小（maybeResizeAndDownsampleImageBlock）
  //    - 存储到磁盘（storeImages）以便工具引用

  // 2. Bash 命令模式
  if (mode === 'bash') {
    return processBashCommand(inputString, ...)
  }

  // 3. 斜杠命令（以 / 开头）
  if (inputString.startsWith('/')) {
    return processSlashCommand(inputString, ...)
  }

  // 4. 普通文本提示（最常见路径）
  return processTextPrompt(input, imageContentBlocks, attachmentMessages, ...)
}

// → src/utils/processUserInput/processTextPrompt.ts 的 processTextPrompt() 函数（简化版）
export function processTextPrompt(
  input: string | ContentBlockParam[],
  imageContentBlocks: ContentBlockParam[],
  imagePasteIds: number[],
  attachmentMessages: AttachmentMessage[],
  uuid?: string,
  permissionMode?: PermissionMode,
  isMeta?: boolean,
): { messages: (UserMessage | AttachmentMessage)[], shouldQuery: boolean } {

  const promptId = randomUUID()
  setPromptId(promptId)

  if (imageContentBlocks.length > 0) {
    const userMessage = createUserMessage({
      content: [...textContent, ...imageContentBlocks],
      uuid,
      imagePasteIds,
    })
    return { messages: [userMessage, ...attachmentMessages], shouldQuery: true }
  }

  const userMessage = createUserMessage({
    content: input,
    uuid,
    permissionMode,
  })

  return { messages: [userMessage, ...attachmentMessages], shouldQuery: true }
}

// → src/utils/messages.ts 的 createUserMessage() 函数（简化版）
export function createUserMessage({
  content,
  isMeta,
  uuid,
  timestamp,
  imagePasteIds,
  permissionMode,
  origin,
}: {
  content: string | ContentBlockParam[]
  isMeta?: true                   // 对用户隐藏，对模型可见
  uuid?: UUID
  timestamp?: string
  imagePasteIds?: number[]
  permissionMode?: PermissionMode
  origin?: MessageOrigin           // 来源：人类 vs 系统生成
}): UserMessage {
  const m: UserMessage = {
    type: 'user',
    message: {
      role: 'user',
      content: content || NO_CONTENT_MESSAGE,
    },
    uuid: uuid || randomUUID(),
    timestamp: timestamp ?? new Date().toISOString(),
    isMeta,
    imagePasteIds,
    permissionMode,
    origin,
  }
  return m
}

// → src/types/message.js 的 UserMessage 类型
type UserMessage = {
  type: 'user'                    // 消息类型标识
  message: {
    role: 'user'                  // Anthropic API 角色
    content: string | ContentBlockParam[]  // 文本或多媒体内容
  }
  uuid: UUID                      // 唯一标识（用于回溯和调试）
  timestamp: string               // ISO 时间戳
  isMeta?: true                   // 元消息（系统生成，用户不可见）
  imagePasteIds?: number[]        // 粘贴图片的 ID 列表
  permissionMode?: PermissionMode // 发送时的权限模式
  origin?: MessageOrigin          // 消息来源
}

// → src/utils/processUserInput/processUserInput.ts 的附件提取逻辑
const shouldExtractAttachments =
  !skipAttachments &&
  inputString !== null &&
  (mode !== 'prompt' || !inputString.startsWith('/'))

const attachmentMessages = shouldExtractAttachments
  ? await toArray(getAttachmentMessages(inputString, context, ideSelection ?? null, [], messages, querySource))
  : []

// → image content block 的结构
{
  type: "image",
  source: {
    type: "base64",
    media_type: "image/png",  // 支持 image/jpeg, image/png, image/gif, image/webp
    data: "iVBORw0KGgo..."   // base64 编码的图片
  }
}

// → 最简图片压缩器
async function compressImage(
  data: Buffer,
  mediaType: string,
  maxWidth = 1024,
): Promise<Buffer> {
  // 用 sharp 库（如果可用）或 ImageMagick
  const sharp = await import("sharp")

  let pipeline = sharp(data)

  const metadata = await pipeline.metadata()
  if (metadata.width && metadata.width > maxWidth) {
    pipeline = pipeline.resize(maxWidth, undefined, {
      fit: "inside",
      withoutEnlargement: true,
    })
  }

  return pipeline
    .jpeg({ quality: 85 })
    .toBuffer()
}

console.log('[DEBUG] inputString:', inputString?.substring(0, 50), 'mode:', mode)

console.log('[DEBUG] UserMessage created:', JSON.stringify(userMessage, null, 2))