node-mongo-demo

lucky7-bets.js

(1722B)

 import Lucky7Bet from '../models/lucky7-bet.js';
 
 const users = new Map();
 const bets = new Map();
 
 export const subscribe = (userId, stream) => {
     users.set(userId, { stream });
 
     stream.onClose(() => {
         const user = users.get(userId)
         if (user?.nextBetTimeoutId) {
             clearTimeout(user.nextBetTimeoutId);
         }
         users.delete(userId);
     });
 };
 
 const handleInsert = data => {
     const bet = new Lucky7Bet(data.fullDocument);
     const user = users.get(bet.userId.toString());
 
     if (user) {
         const id = bet.id.toString();
         bets.set(id, bet);
 
         user.stream.writeJson({
             operationType: 'insert',
             bet: bet.toRedactedObject(),
         });
 
         user.nextBetTimeoutId = setTimeout(() => {
             user.stream.writeJson({
                 operationType: 'update',
                 bet: bet.toRedactedObject(),
             });
 
             bets.delete(id);
             delete user['nextBetTimeoutId'];
         }, bet.rollAt - Date.now());
     }
 };
 
 const handleUpdate = data => {
     const id = data.documentKey._id.toString();
     const bet = bets.get(id);
     const userId = bet?.userId.toString();
     const user = userId ? users.get(userId) : undefined;
 
     if (bet && user) {
         const { lucky } = data.updateDescription.updatedFields;
         user.stream.writeJson({
             operationType: 'update',
             bet: {
                 id,
                 lucky,
                 state: 'pending',
             },
         });
     }
 };
 
 export const onChange = data => {
     const { operationType } = data;
 
     if (operationType === 'insert') handleInsert(data);
     if (operationType === 'update') handleUpdate(data);
 };