Function processMessage

packages/parser/src/formats/weflow.ts:481–540

(msg: WeFlowMessage)

    const pipeline = chain([readStream, parser(), pick({ filter: /^messages\.\d+$/ }), streamValues()])

    const processMessage = (msg: WeFlowMessage): ParsedMessage | null => {
      // 验证必要字段
      if (!msg.senderUsername || msg.createTime === undefined) {
        return null
      }

      const platformId = msg.senderUsername

      // 跳过群"成员"（群ID以 @chatroom 结尾的消息）
      // 这些通常是系统消息，发送者是群本身，不是真正的成员
      if (platformId.endsWith('@chatroom')) {
        return null
      }

      const accountName = msg.senderDisplayName || platformId

      // 获取头像（通过 senderAvatarKey 从 avatarsMap 查找）
      const avatarKey = msg.senderAvatarKey || msg.senderUsername
      const avatar = avatarsMap.get(avatarKey)

      // 更新成员信息
      if (!memberMap.has(platformId)) {
        memberMap.set(platformId, {
          platformId,
          accountName,
          avatar,
        })
      } else {
        // 更新为最新的显示名
        const existing = memberMap.get(platformId)!
        existing.accountName = accountName
        // 头像使用最新的（覆盖更新）
        if (avatar) {
          existing.avatar = avatar
        }
      }

      // 转换消息类型
      const type = convertMessageType(msg.type)

      // 确保 content 是字符串类型（防止某些消息类型的 content 是对象）
      // 同时去除开头和结尾的空白字符
      let content: string | null = null
      if (msg.content != null) {
        const rawContent = typeof msg.content === 'string' ? msg.content : JSON.stringify(msg.content)
        content = rawContent.trim() || null
      }

      return {
        platformMessageId: String(msg.localId), // 消息的平台原始 ID（用于回复关联查询）
        senderPlatformId: platformId,
        senderAccountName: accountName,
        // WeFlow 格式没有单独的群昵称字段
        senderGroupNickname: undefined,
        timestamp: msg.createTime,
        type,
        content,
        // 注意：WeFlow 导出格式不包含被引用消息的 ID，所以 replyToMessageId 为空