node-mongo-demo

lucky7-bets.js

(1890B)

 import Joi from 'joi';
 import * as betEvents from '../events/lucky7-bets.js';
 import Lucky7Session from '../models/lucky7-session.js';
 import Lucky7Bet from '../models/lucky7-bet.js';
 import EventStream from '../utils/event-stream.js';
 
 const schema = Joi.object({
     lucky: Joi.boolean().required(),
 });
 
 const errors = {
     'SESSION_EXPIRED': { code: 'SESSION_EXPIRED', error: 'Session has expired' },
     'SESSION_TIMER': { code: 'SESSION_TIMER', error: '5 seconds or less remaining' },
     'SESSION_EXPIRING': { code: 'SESSION_EXPIRING', error: 'Session has no more games' },
 };
 
 export let changeStream;
 export const subscribeEvents = () => {
     changeStream = Lucky7Bet.watch().on('change', betEvents.onChange);
 };
 
 export const getEvents = async (req, res) => {
     const { userId } = req;
     const stream = new EventStream(req, res);
     betEvents.subscribe(userId, stream);
 };
 
 export const create = async (req, res) => {
     const { userId } = req;
     const { value, error } = schema.validate(req.body);
 
     if (error) {
         return res.status(400).json({ error })
     }
 
     try {
         const session = await Lucky7Session.findByUserId(userId);
         const rollAt = session?.nextIntervalAt();
 
         if (!session) return res.status(409).json(errors['SESSION_EXPIRED']);
         if (!session.nextIntervalAt()) return res.status(409).json(errors['SESSION_EXPIRING']);
         if (!session.isPlayable()) return res.status(409).json(errors['SESSION_TIMER']);
 
         const bet = await Lucky7Bet.findOne({ userId, rollAt }) || new Lucky7Bet({ userId, rollAt });
         bet.lucky = value.lucky;
 
         if (!bet.played()) {
             bet.play();
         }
 
         await bet.save();
         res.status(201).json(bet.toRedactedObject());
     } catch (error) {
         console.error(error);
         res.status(500).json({ message: 'Something went wrong' });
     }
 };