Function startWatchdog

src/index.js:912–935

(directory, client, sessionID)

  const current = loopOwnedUserMessageGuards.get(sessionID) || { pending: 0, until: 0, messageIDs: new Map };
  current.pending += 1;
  current.until = Math.max(current.until || 0, now() + LOOP_OWNED_USER_MESSAGE_GUARD_MS);
  for (const [messageID, expiresAt] of current.messageIDs.entries())
    if (expiresAt < now())
      current.messageIDs.delete(messageID);
  loopOwnedUserMessageGuards.set(sessionID, current);
  for (const [key, entry] of loopOwnedUserMessageGuards.entries()) {
    for (const [messageID, expiresAt] of entry.messageIDs.entries())
      if (expiresAt < now())
        entry.messageIDs.delete(messageID);
    if ((entry.pending || 0) <= 0 && entry.messageIDs.size === 0 && (entry.until || 0) < now())
      loopOwnedUserMessageGuards.delete(key);
  }
}
function loopOwnedUserMessageGuardActive(sessionID, messageID) {
  const entry = loopOwnedUserMessageGuards.get(sessionID);
  if (!entry || typeof entry !== "object")
    return false;
  for (const [id2, expiresAt] of entry.messageIDs.entries())
    if (expiresAt < now())
      entry.messageIDs.delete(id2);
  const id = typeof messageID === "string" ? messageID : "";
  if (id && entry.messageIDs.has(id))
    return true;
  if ((entry.pending || 0) > 0 && (entry.until || 0) >= now()) {
    if (!id)
      return true;
    entry.pending -= 1;