请求实现含用户及关注者内容的时间线API的聚合查询提示

嘿，我来帮你梳理下怎么搞定这个时间线API的需求！核心就是要把你自己发的帖子、关注的人发的帖子，还有关注的人转发的内容整合到一起，按时间排序返回。我给你拆解成具体步骤，附代码示例：

第一步：先拿到关键用户ID列表 #

首先得获取当前登录用户的_id，以及他们关注的所有用户ID——这个从Users集合的followedUsers字段就能拿到。别忘了把你自己的ID也加进去，因为要包含你自己发的帖子：

// 假设当前登录用户的ID是currentUserId
const currentUser = await Users.findById(currentUserId);
const followedUserIds = currentUser.followedUsers;
// 把自己的ID也加入目标列表，确保能拿到自己的帖子
const targetUserIds = [...followedUserIds, currentUserId];

第二步：构建聚合管道整合内容 #

接下来用MongoDB的聚合框架，把Posts和Reposts的数据合并、筛选、排序。这里要区分原生帖子和转发内容，最后输出统一格式的时间线：

完整聚合代码示例 #

const timelineFeed = await Posts.aggregate([
  // 1. 先筛选出当前用户+关注用户发的原生帖子
  {
    $match: {
      author: { $in: targetUserIds }
    }
  },
  // 2. 给原生帖子打个类型标记，方便后续区分
  {
    $addFields: {
      type: "post",
      originalPost: "$$ROOT" // 保存原帖的完整数据，转发时要用
    }
  },
  // 3. 关联Reposts集合，找出这些帖子被关注用户转发的记录
  {
    $lookup: {
      from: "reposts",
      let: { postId: "$_id" },
      pipeline: [
        // 子管道：只筛选关注用户发起的转发
        {
          $match: {
            $expr: { $eq: ["$post", "$$postId"] },
            author: { $in: followedUserIds }
          }
        },
        // 给转发内容打类型标记，记录谁转的
        {
          $addFields: {
            type: "repost",
            repostedBy: "$author"
          }
        }
      ],
      as: "reposts"
    }
  },
  // 4. 把转发记录拆成单独的文档，和原生帖子平级
  {
    $unwind: {
      path: "$reposts",
      preserveNullAndEmptyArrays: true // 没有被转发的帖子也要保留
    }
  },
  // 5. 统一原生帖子和转发内容的输出结构
  {
    $project: {
      _id: {
        $cond: {
          if: { $ne: ["$reposts", null] },
          then: "$reposts._id", // 转发内容用转发记录的ID
          else: "$_id"
        }
      },
      content: {
        $cond: {
          if: { $ne: ["$reposts", null] },
          then: "$originalPost.content", // 转发显示原帖内容
          else: "$content"
        }
      },
      author: {
        $cond: {
          if: { $ne: ["$reposts", null] },
          then: "$reposts.repostedBy", // 转发的作者是转发人
          else: "$author"
        }
      },
      type: {
        $cond: {
          if: { $ne: ["$reposts", null] },
          then: "$reposts.type",
          else: "$type"
        }
      },
      createdAt: {
        $cond: {
          if: { $ne: ["$reposts", null] },
          then: "$reposts.createdAt", // 转发按转发时间排序
          else: "$createdAt"
        }
      },
      originalPostId: {
        $cond: {
          if: { $ne: ["$reposts", null] },
          then: "$_id", // 转发记录关联原帖ID
          else: null
        }
      }
    }
  },
  // 6. 过滤掉可能的空文档（保险起见）
  {
    $match: {
      _id: { $ne: null }
    }
  },
  // 7. 按时间倒序排序，最新的内容排在最前面
  {
    $sort: { createdAt: -1 }
  },
  // 可选：分页处理，比如每次返回20条
  {
    $skip: 0,
    $limit: 20
  }
]);

几个关键细节要注意 #

• 筛选范围：原生帖子包含你自己和关注的人，转发内容只取关注的人发起的，完全符合你的需求。
• 排序逻辑：转发内容用转发的时间，原生帖子用发布时间，这样时间线的顺序是真实的，不会出现旧转发排在新帖子前面的情况。
• 性能优化：记得给Posts.author、Reposts.author、Reposts.post这几个字段建索引，聚合查询会快很多；如果关注的人特别多，$in查询可能有点压力，也可以把获取关注列表的逻辑整合到聚合管道里，不过分开查更直观。
• 前端友好：返回的type字段可以让前端轻松区分是原生帖还是转发，做不同的UI展示。

内容的提问来源于stack exchange，提问作者Abdulaziz.Musaileekh