(sessionID)
| 935 | if ((entry.pending || 0) > 0 && (entry.until || 0) >= now()) { |
| 936 | if (!id) |
| 937 | return true; |
| 938 | entry.pending -= 1; |
| 939 | entry.messageIDs.set(id, now() + LOOP_OWNED_USER_MESSAGE_RETENTION_MS); |
| 940 | loopOwnedUserMessageGuards.set(sessionID, entry); |
| 941 | return true; |
| 942 | } |
| 943 | if ((entry.pending || 0) <= 0 && entry.messageIDs.size === 0) |
| 944 | loopOwnedUserMessageGuards.delete(sessionID); |