Function createPendingThread

lib/shared/thread-utils.js:470–523

(args: CreatePendingThreadArgs)

};

function createPendingThread(args: CreatePendingThreadArgs): ThreadInfo {
  const { viewerID, threadType, members, sourceMessageID } = args;
  const now = Date.now();
  if (!members.some(member => member.id === viewerID)) {
    throw new Error(
      'createPendingThread should be called with the viewer as a member',
    );
  }

  const memberIDs = members.map(member => member.id);
  const threadID = getPendingThreadID(
    threadType,
    memberIDs,
    sourceMessageID,
    threadSpecs[threadType].protocol().protocolName,
  );

  const permissions: ThreadRolePermissionsBlob = {
    [threadPermissions.KNOW_OF]: true,
    [threadPermissions.VISIBLE]: true,
    [threadPermissions.VOICED]: true,
  };

  const membershipPermissions = getAllThreadPermissions(
    makePermissionsBlob(permissions, null, threadID, threadType),
    threadID,
  );
  const role: RoleInfo = {
    ...minimallyEncodeRoleInfo({
      id: `${threadID}/role`,
      name: 'Members',
      permissions,
      isDefault: true,
    }),
    specialRole: specialRoles.DEFAULT_ROLE,
  };

  const rawThreadInfo = threadSpecs[threadType].protocol().createPendingThread({
    createPendingThreadArgs: args,
    creationTime: now,
    membershipPermissions,
    role,
    threadID,
    memberIDs,
  });

  const userInfos: { [string]: UserInfo } = {};
  for (const member of members) {
    const { id, username } = member;
    userInfos[id] = { id, username };
  }

  return threadInfoFromRawThreadInfo(rawThreadInfo, viewerID, userInfos);
}

type PendingPersonalThread = {
  +threadInfo: ThreadInfo,