Function dueJobs

src/index.js:979–990

(state, force = false)

function commandEventKey(sessionID, messageID) {
  return `${sessionID || "no-session"}:event:${messageID || "no-message"}`;
}
function markHandled(sessionID, name, args) {
  const key = commandKey(sessionID, name, args);
  const previous = handledCommands.get(key);
  const pending = previous && now() - previous.time < COMMAND_DEDUPE_MS ? previous.pending + 1 : 1;
  handledCommands.set(key, { time: now(), pending });
  for (const [entryKey, entry] of handledCommands.entries())
    if (now() - entry.time > COMMAND_DEDUPE_MS)
      handledCommands.delete(entryKey);
  for (const [entryKey, time] of handledCommandEvents.entries())
    if (now() - time > COMMAND_DEDUPE_MS)
      handledCommandEvents.delete(entryKey);
}
function consumeHandled(sessionID, name, args) {
  const key = commandKey(sessionID, name, args);