fmode-app/cloud/functions/fmodeagent-chatthreads.js

// FmodeAgent 会话目录云函数（2026-10-31 建，2026-11-06 v0.1.6 补群会话字段）
//
// 目的：会话目录（标题/归档/排序）此前只存在客户端 localStorage，
//       换浏览器或清站点数据就全部丢失。这里把它落到服务端，成为**唯一真相源**。
//
// 调用：POST https://server.fmode.cn/api/functions
//       头：X-Parse-Application-Id / X-Parse-Session-Token
//       body：{ id: "<本函数 objectId>", params: {...} }
//
// params.op:
//   list   { agentId }                                  → { code:200, threads:[...] }
//   upsert { items:[{agentId,roomId,threadRoot,title,messageCount,lastMessageAt,lastPreview,revive}] }
//                                                       → { code:200, created, updated }
//   patch  { threadRoot, title?, archived? }            → { code:200, thread }
//   remove { threadRoot }                               → { code:200, removed }
//
// 平台约定（与 fmodeagent-matrix-provision 一致，实测）：
//   · 入口 async function handler(request, response)；入参在**全局 params**；
//   · 身份：优先 request.user（平台按 sessionToken 注入），否则按 token 查 _Session；
//   · 🔴 输出必须 response.status(200).json(...) **显式写出**；直接 return 对象平台不回包（请求挂起）。
//
// 安全约定：
//   1. 归属一律取服务端解析出的 user，忽略客户端传入的任何 user / company 参数；
//   2. 会话只归用户本人（不写 company），不会进公司共享视角；
//   3. 删除是软删（isDeleted=true），与平台「删除用软删」铁律一致；
//   4. 标题一旦被用户手动改过（titleLocked=true），upsert 不再覆盖。
//
// 表：FmodeChatThread（首次写入自动建表）
//   user Pointer<_User> / agentId String / roomId String / threadRoot String
//   title String / titleLocked Boolean / messageCount Number / lastMessageAt Date
//   archived Boolean / isDeleted Boolean / lastPreview String
//   workspaceId String（归属工作区；'' = 日常对话）— v0.1.4 新增
//   kind String（'dm' | 'group'；缺省 = dm）— v0.1.6 新增
//   memberIds Array<String>（群成员容器 id；单聊空）— v0.1.6 新增
//   deliverableUrls Array<String>（本会话的成果链接）— v0.1.9 新增（2026-11-09）
//   唯一语义：(user, threadRoot) —— upsert 前查重保证

var CLASS_NAME = 'FmodeChatThread';
var MAX_ITEMS = 200;
var TITLE_MAX = 60;
var PREVIEW_MAX = 120;

function _ok(data) {
  response.status(200).json(Object.assign({ code: 200 }, data || {}));
  return true;
}
function _fail(code, mess) {
  response.status(200).json({ code: code, mess: mess });
  return false;
}

function _str(v, max) {
  var s = v == null ? '' : String(v);
  return max && s.length > max ? s.slice(0, max) : s;
}

/**
 * 字符串数组清洗（v0.1.6）。
 *
 * 去空、去重、限长；非数组一律返回空数组 —— 调用方据此判断「没有成员」。
 * 成员 id 上限 120 与 agentId 字段一致。
 */
function _strArr(v) {
  if (!Array.isArray(v)) return [];
  var out = [];
  for (var i = 0; i < v.length && out.length < 50; i++) {
    /*
     * 🔴 上限 500 而不是 120（2026-11-09）：成果链接是完整 URL，
     *    典型长度 s3.fmode.cn/deliverables/<agentId>/<YYYYMM>/<id>/<hash>-<name>
     *    常常超过 120 字符，按 120 截断会得到打不开的地址。
     */
    var s = _str(v[i], 500);
    if (s && out.indexOf(s) < 0) out.push(s);
  }
  return out;
}

function _date(v) {
  if (!v) return new Date();
  var d = v instanceof Date ? v : new Date(v);
  return isNaN(d.getTime()) ? new Date() : d;
}

/**
 * token → _User（唯一权威解析）。
 *
 * 🔴 加固（2026-11-01，**不是**重复记录的根因，属正确性改进）：
 *    上一版先判 `request.user && request.user.id` 就直接 `return request.user`。
 *    平台注入的 `request.user` 实测不一定带出 `objectId`，拿它当
 *    `equalTo('user', ...)` 的条件会匹配不到记录。
 *    现在以 token 查 `_Session` 得到的真实 `_User` 为准，
 *    `request.user` 只在**确实带出 objectId** 时作为兜底。
 *
 * ⚠️ 重复记录的真根因在 `_findAllByRoot`（查重键含 roomId），见其注释。
 */
async function _getUser(t) {
  if (!t) return null;
  try {
    var q = new Parse.Query(Parse.Session);
    q.equalTo('sessionToken', t);
    q.include('user');
    var s = await q.first({ useMasterKey: true });
    if (s) {
      var u = s.get('user');
      if (u) return u;
    }
  } catch (e) {
    /* 落到 request.user 兜底 */
  }
  // 兜底：平台注入了**完整**用户对象时使用（残缺 Pointer 一律不用）
  if (request && request.user && request.user.id) return request.user;
  return null;
}

/** 取当前会话 token（与平台其他函数同一约定） */
/**
 * 取当前会话 token。
 *
 * 🔴 实测（2026-10-31，加 __debug 探测得出）：
 *    · 平台把 X-Parse-Session-Token 请求头**原样保留**在 request.headers；
 *    · request.body 只剩 {id, params}，body 里的 token 被平台剥离；
 *    · request.user **没有**被注入。
 *    ⇒ 身份的唯一可靠来源是 x-parse-session-token 请求头（兜底 params.sessionToken）。
 */
function _sessionToken() {
  var h = request && request.headers ? request.headers : {};
  if (h['x-parse-session-token']) return h['x-parse-session-token'];
  if (request && request.body && request.body.token) return request.body.token;
  if (params && params.sessionToken) return params.sessionToken;
  return null;
}

/**
 * 查某用户**所有房间**下同一线程根的全部记录（2026-11-01）。
 *
 * 为什么按 `threadRoot` 而不是 `(roomId, threadRoot)` 查：
 *   · `threadRoot` 是客户端生成的全局唯一 ID，一个会话只可能属于一个线程；
 *   · 房间可能变（agent 重建、换绑定），同一会话被写进新房间后，
 *     旧房间那条会变成孤儿 —— 必须收敛掉，不能各留一条。
 */
function _findAllByRoot(userPtr, threadRoot) {
  var q = new Parse.Query(CLASS_NAME);
  q.equalTo('user', userPtr);
  q.equalTo('threadRoot', threadRoot);
  q.limit(50);
  return q.find({ useMasterKey: true });
}

async function opList(userPtr, p) {
  var q = new Parse.Query(CLASS_NAME);
  q.equalTo('user', userPtr);
  /*
   * includeDeleted:1 → 只返回已软删的记录（客户端据此建立「不允许重建」黑名单）。
   * 跨设备有效：换浏览器/重新登录后仍能挡住「删了又被扫描建回来」。
   */
  if (p.includeDeleted) q.equalTo('isDeleted', true);
  else q.notEqualTo('isDeleted', true);
  if (p.agentId) q.equalTo('agentId', String(p.agentId));
  if (p.roomId) q.equalTo('roomId', String(p.roomId));
  q.descending('lastMessageAt');
  q.limit(500);
  var rows = await q.find({ useMasterKey: true });
  return _ok({
    threads: rows.map(function (r) {
      return {
        objectId: r.id,
        agentId: r.get('agentId') || '',
        roomId: r.get('roomId') || '',
        threadRoot: r.get('threadRoot') || '',
        title: r.get('title') || '',
        titleLocked: !!r.get('titleLocked'),
        messageCount: r.get('messageCount') || 0,
        lastMessageAt: (r.get('lastMessageAt') || r.updatedAt || r.createdAt).getTime(),
        archived: !!r.get('archived'),
        lastPreview: r.get('lastPreview') || '',
        // v0.1.4：工作区归属随列表返回，客户端据此还原层级
        workspaceId: r.get('workspaceId') || '',
        // v0.1.6：群会话标识随列表返回 —— 缺了它客户端无法把群会话
        // 归到「群聊」分组，会以首成员身份混进单聊列表
        kind: r.get('kind') === 'group' ? 'group' : 'dm',
        memberIds: _strArr(r.get('memberIds')),
        /*
         * v0.1.7：本会话的成果链接（2026-11-09）。
         * 客户端据此只显示「属于这条对话」的成果，不再显示整个容器的。
         */
        deliverableUrls: _strArr(r.get('deliverableUrls')),
      };
    }),
  });
}

async function opUpsert(userPtr, p) {
  var items = Array.isArray(p.items) ? p.items.slice(0, MAX_ITEMS) : [];
  if (items.length === 0) return _fail(400, 'items 不能为空');
  var ptr = { __type: 'Pointer', className: '_User', objectId: userPtr.id };
  var created = 0;
  var updated = 0;
  var collapsed = 0;
  for (var i = 0; i < items.length; i++) {
    var it = items[i] || {};
    var roomId = _str(it.roomId, 200);
    var threadRoot = _str(it.threadRoot, 200);
    if (!roomId || !threadRoot) continue;
    /*
     * 🔴 按 threadRoot 查全部记录（不只是当前房间）。
     *    房间可能变化；同时兜住历史脏数据里「同一线程根在多条记录」的情况 ——
     *    取最新一条作为主记录，其余物理删除（索引重复没有任何保留价值）。
     */
    var rows = await _findAllByRoot(ptr, threadRoot);
    var rec = null;
    for (var j = 0; j < rows.length; j++) {
      if (!rec || rows[j].updatedAt >= rec.updatedAt) rec = rows[j];
    }
    for (var k = 0; k < rows.length; k++) {
      if (rec && rows[k].id !== rec.id) {
        try {
          await rows[k].destroy({ useMasterKey: true });
          collapsed++;
        } catch (e) {
          /* 单条失败不影响其余 */
        }
      }
    }
    if (!rec) {
      rec = new Parse.Object(CLASS_NAME);
      rec.set('user', ptr);
      rec.set('roomId', roomId);
      rec.set('threadRoot', threadRoot);
      rec.set('messageCount', 0);
      rec.set('archived', false);
      rec.set('isDeleted', false);
      rec.set('titleLocked', false);
      created++;
    } else {
      updated++;
    }
    // 标题：用户手改过就不覆盖；否则仅在为空时写入（避免把容器标题降级成首句）
    var incomingTitle = _str(it.title, TITLE_MAX);
    if (incomingTitle && !rec.get('titleLocked') && !rec.get('title')) {
      rec.set('title', incomingTitle);
    }
    // 房间以本次上报为准（会话跟着房间走）
    rec.set('roomId', roomId);
    if (it.agentId) rec.set('agentId', _str(it.agentId, 120));
    if (typeof it.messageCount === 'number' && it.messageCount >= 0) {
      rec.set('messageCount', it.messageCount);
    }
    if (it.lastMessageAt) rec.set('lastMessageAt', _date(it.lastMessageAt));
    if (it.lastPreview) rec.set('lastPreview', _str(it.lastPreview, PREVIEW_MAX));
    /*
     * v0.1.4：工作区归属。
     * 🔴 用 `!= null` 判定而不是真值判断 —— '' 是合法值（代表「移回日常对话」），
     *    用 if (it.workspaceId) 会把「移回日常」当成「没传」，归属永远清不掉。
     */
    if (it.workspaceId !== undefined && it.workspaceId !== null) {
      rec.set('workspaceId', _str(it.workspaceId, 120));
    }
    /*
     * v0.1.6：群会话标识。
     * 🔴 只在明确传入时写 —— 单聊的后续 upsert 不带这两个字段，
     *    若无条件写空值，会把已有的群会话降级成单聊。
     */
    if (it.kind === 'dm' || it.kind === 'group') {
      rec.set('kind', it.kind);
    }
    if (Array.isArray(it.memberIds) && it.memberIds.length > 0) {
      rec.set('memberIds', _strArr(it.memberIds));
    }
    /*
     * v0.1.7：本会话的成果链接（2026-11-09 用户裁决）。
     *
     * 🔴 只在明确传入时写 —— 与 kind/memberIds 同理，
     *    后续 upsert 不带这个字段时不能把已有链接清空。
     * 🔴 用 `[]` 显式传空数组才表示「清空」（用户删光了成果）。
     */
    if (Array.isArray(it.deliverableUrls)) {
      rec.set('deliverableUrls', _strArr(it.deliverableUrls));
    }
    // 🔴 upsert 表示「这条会话现在存在」→ 永远解除墓碑。
    //    上一版只有传 revive:true 才解除，客户端漏传就会出现
    //    「本地有、云端是墓碑」→ 下次拉取被当已删除跳过 → 会话消失（实测）。
    rec.set('isDeleted', false);
    await rec.save(null, { useMasterKey: true });
  }
  return _ok({ created: created, updated: updated, collapsed: collapsed });
}

async function opPatch(userPtr, p) {
  var threadRoot = _str(p.threadRoot, 200);
  if (!threadRoot) return _fail(400, 'threadRoot 不能为空');
  var q = new Parse.Query(CLASS_NAME);
  q.equalTo('user', userPtr);
  q.equalTo('threadRoot', threadRoot);
  q.notEqualTo('isDeleted', true);
  q.descending('updatedAt');
  var rec = await q.first({ useMasterKey: true });
  if (!rec) return _fail(404, '会话不存在');
  if (p.title != null) {
    var t = _str(p.title, TITLE_MAX);
    if (!t) return _fail(400, '标题不能为空');
    rec.set('title', t);
    rec.set('titleLocked', true);
  }
  if (p.archived != null) rec.set('archived', !!p.archived);
  /* v0.1.4：移动工作区单独走 patch，'' = 移回日常对话 */
  if (p.workspaceId !== undefined && p.workspaceId !== null) {
    rec.set('workspaceId', _str(p.workspaceId, 120));
  }
  await rec.save(null, { useMasterKey: true });
  return _ok({ thread: { objectId: rec.id, threadRoot: threadRoot } });
}

/**
 * remove：**物理删除**云端索引（2026-11-01 用户裁决）。
 *
 * 语义：删除后不可恢复 —— 云端记录直接 `destroy()`，列表查询不会再返回。
 * Matrix 房间里的消息**不动**（会话正文仍在服务器，只是不再作为会话展示）。
 * 同时写入一条墓碑记录（isDeleted=true 的极简行），用于跨设备阻止扫描重建。
 */
async function opRemove(userPtr, p) {
  var threadRoot = _str(p.threadRoot, 200);
  if (!threadRoot) return _fail(400, 'threadRoot 不能为空');

  /*
   * 🔴 用 objectId 构造标准 Pointer 再查（2026-11-01）：
   *    平台注入的 userPtr 有时是不可枚举的代理对象，直接 equalTo('user', userPtr)
   *    匹配不到已有记录（实测：记录明明存在，find() 返回 0 条）。
   *    用 Pointer 显式指定 className + objectId 最稳。
   */
  var ptr = { __type: 'Pointer', className: '_User', objectId: userPtr.id };

  /* ① 查全部同线程记录（含已软删） */
  var q = new Parse.Query(CLASS_NAME);
  q.equalTo('user', ptr);
  q.equalTo('threadRoot', threadRoot);
  q.limit(100);
  var rows = await q.find({ useMasterKey: true });
  console.warn('[REMOVE] found=' + rows.length + ' ids=' + rows.map(function (r) { return r.id; }).join(','));

  /* ② 保留/创建一条墓碑（isDeleted=true），其余物理删除 */
  var tomb = null;
  for (var i = 0; i < rows.length; i++) {
    if (rows[i].get('isDeleted') === true && !tomb) {
      tomb = rows[i];
      continue;
    }
    try {
      await rows[i].destroy({ useMasterKey: true });
    } catch (e) {
      /* 单条删除失败不影响其余 */
    }
  }
  if (!tomb) {
    tomb = new Parse.Object(CLASS_NAME);
    tomb.set('user', ptr);
    tomb.set('threadRoot', threadRoot);
    tomb.set('roomId', _str(p.roomId, 200) || '');
    tomb.set('agentId', _str(p.agentId, 120) || '');
    tomb.set('title', '');
    tomb.set('messageCount', 0);
    tomb.set('isDeleted', true);
    await tomb.save(null, { useMasterKey: true });
  }
  return _ok({ removed: rows.length - (tomb ? 1 : 0), tomb: true });
}

/**
 * ===== 工作区（2026-11-01 新增）=====
 *
 * 表：FmodeWorkspace
 *   user Pointer<_User> / name String / createdAtMs Number / isDeleted Boolean
 *
 * 为什么独立建表而不塞进 FmodeChatThread：
 *   工作区是「文件夹」，一条会话只属于一个文件夹，但**文件夹本身也要有列表**
 *   （空工作区、改名、排序都得有地方放）。塞进会话表就只能靠某条会话顺带记录，
 *   会出现「删掉文件夹里最后一条会话，文件夹也跟着消失」这类问题。
 *
 * 为什么不用 FmodeWorkGroup：那是**群聊**表（roomId/members/goal），语义完全不同。
 */
var WS_CLASS = 'FmodeWorkspace';

async function opWsList(userPtr) {
  var ptr = { __type: 'Pointer', className: '_User', objectId: userPtr.id };
  var q = new Parse.Query(WS_CLASS);
  q.equalTo('user', ptr);
  q.notEqualTo('isDeleted', true);
  q.ascending('createdAtMs');
  q.limit(500);
  var rows = await q.find({ useMasterKey: true });
  return _ok({
    workspaces: rows.map(function (r) {
      return {
        objectId: r.id,
        id: r.get('wsId') || r.id,
        name: r.get('name') || '',
        createdAt: r.get('createdAtMs') || r.createdAt.getTime(),
      };
    }),
  });
}

async function opWsUpsert(userPtr, p) {
  var items = Array.isArray(p.items) ? p.items.slice(0, 200) : [];
  if (items.length === 0) return _fail(400, 'items 不能为空');
  var ptr = { __type: 'Pointer', className: '_User', objectId: userPtr.id };
  var created = 0;
  var updated = 0;
  for (var i = 0; i < items.length; i++) {
    var it = items[i] || {};
    var wsId = _str(it.id, 120);
    var name = _str(it.name, 120);
    if (!wsId || !name) continue;
    var q = new Parse.Query(WS_CLASS);
    q.equalTo('user', ptr);
    q.equalTo('wsId', wsId);
    q.limit(1);
    var rec = await q.first({ useMasterKey: true });
    if (!rec) {
      rec = new Parse.Object(WS_CLASS);
      rec.set('user', ptr);
      rec.set('wsId', wsId);
      rec.set('isDeleted', false);
      created++;
    } else {
      updated++;
    }
    rec.set('name', name);
    if (typeof it.createdAt === 'number') rec.set('createdAtMs', it.createdAt);
    rec.set('isDeleted', false);
    await rec.save(null, { useMasterKey: true });
  }
  return _ok({ created: created, updated: updated });
}

async function opWsRemove(userPtr, p) {
  var wsId = _str(p.id, 120);
  if (!wsId) return _fail(400, 'id 不能为空');
  var ptr = { __type: 'Pointer', className: '_User', objectId: userPtr.id };
  var q = new Parse.Query(WS_CLASS);
  q.equalTo('user', ptr);
  q.equalTo('wsId', wsId);
  q.limit(10);
  var rows = await q.find({ useMasterKey: true });
  /* 软删：保留记录便于排查，列表查询已过滤 */
  for (var i = 0; i < rows.length; i++) {
    rows[i].set('isDeleted', true);
    await rows[i].save(null, { useMasterKey: true });
  }
  return _ok({ removed: rows.length });
}

async function handler(request, response) {
  try {
    /*
     * 🔴 body 里的 token 由平台放在 **request.body.token**，不会合并进全局 params
     *    （实测：只管 params.sessionToken 会一直 401，而 token 本身是有效的）。
     *    业务参数在全局 params；用户身份两种来源都兼容。
     */
    params = (params && typeof params === 'object') ? params : (request && request.body && request.body.params) || {};
    var user = await _getUser(_sessionToken());
    if (!user) return _fail(401, 'sessionToken 无效或已过期，请重新登录 App');

    switch (params.op) {
      case 'list':
        return await opList(user, params);
      case 'upsert':
        return await opUpsert(user, params);
      case 'patch':
        return await opPatch(user, params);
      case 'remove':
        return await opRemove(user, params);
      /* ---- v0.1.5：工作区 ---- */
      case 'wsList':
        return await opWsList(user);
      case 'wsUpsert':
        return await opWsUpsert(user, params);
      case 'wsRemove':
        return await opWsRemove(user, params);
      default:
        return _fail(400, '未知 op: ' + params.op);
    }
  } catch (e) {
    return _fail(500, '会话目录服务异常: ' + ((e && e.message) || String(e)));
  }
}