source: pages/api/roulette/index.js@ d0ef259

main
Last change on this file since d0ef259 was d0ef259, checked in by anastasovv <simon@…>, 23 months ago

Roulette rethought with 1 second update calls
  • Property mode set to 100644
File size: 9.4 KB
Line 
1import axios from 'axios';
2
3require('dotenv').config();
4
5let samplePlayer = {
6 session_id: '',
7 name: '',
8 whichBets: [],
9 coinPlaced: {
10 x: -1,
11 y: -1,
12 },
13 credits: -1,
14 betAmount: 0,
15 wonAmount: 0,
16 status: '_1_',
17 outcome: 'none',
18 gotResults: false,
19}
20
21function getWinningBets(magicNumber) {
22 let winningBets = [];
23 winningBets.push(magicNumber);
24
25 if (magicNumber != 0) {
26 if ((magicNumber <= 9 && magicNumber % 2 == 1) || (magicNumber > 10 && magicNumber <= 18 && magicNumber % 2 == 0) ||
27 (magicNumber > 19 && magicNumber <= 27 && magicNumber % 2 == 1) || (magicNumber > 27 && magicNumber % 2 == 0)) {
28
29 winningBets.push('Red');
30 }
31 else {
32 winningBets.push('Black');
33 }
34
35 if (magicNumber % 2 === 0) winningBets.push('Even');
36 else winningBets.push('Odd');
37
38 if (magicNumber <= 12) winningBets.push('1-12');
39 else if (magicNumber <= 24) winningBets.push('13-24');
40 else winningBets.push('25-36');
41
42 if (magicNumber <= 18) winningBets.push('1-18');
43 else winningBets.push('19-36');
44
45 if (magicNumber % 3 === 0) winningBets.push('Remainder3');
46 else if (magicNumber % 3 === 2) winningBets.push('Remainder2');
47 else winningBets.push('Remainder1');
48 }
49
50 return winningBets;
51}
52
53function updateGameWithWinners() {
54 for (let i = 0; i < game.players.length; i++) {
55 const player = game.players[i];
56
57 let playerWon = false;
58 player.whichBets.forEach(bet => {
59 if (game.winningBets.indexOf(bet) !== -1) {
60 playerWon = true;
61 }
62 })
63
64 if (playerWon) {
65 player.outcome = 'won';
66 }
67 else {
68 player.outcome = 'lost';
69 }
70
71 player.wonAmount = calculateWinnings(player);
72
73 axios.get(`${process.env.HOME_URL}/api/postgre/?action=add_credits&session_id=${player.session_id}&credits=${player.wonAmount}&game=roulette&outcome=${player.outcome}`).then(postgreRes => {
74 if (postgreRes.data?.success) {
75 player.credits = postgreRes.data?.credits;
76 }
77 });
78 }
79}
80
81function resetGame() {
82 game.magicNumber = -1;
83 game.winningBets = [];
84 game.status = '_1_ongoing_timer';
85
86 game.players.forEach(player => {
87 player.whichBets = [];
88 player.betAmount = 0;
89 player.wonAmount = 0;
90 player.coinPlaced = {
91 x: -1,
92 y: -1,
93 },
94 player.outcome = 'none';
95 player.status = '_1_no_placed_bet';
96 player.gotResults = false;
97 })
98}
99
100function calculateWinnings(player) {
101 if (player.outcome === 'lost') return 0;
102
103 let bets = player.whichBets;
104 let bet = player.betAmount;
105
106 if (bets[0] === 'Even' || bets[0] === 'Odd') return 2 * bet;
107 else if (bets[0] === 'Red' || bets[0] === 'Black') return 2 * bet;
108 else if (bets[0].includes('Remainder')) return 3 * bet;
109 else if (bets[0] === '1-12' || bets[0] === '13-24' || bets[0] === '25-36') return 3 * bet;
110 else if (bets[0] === '1-18' || bets[0] === '19-36') return 2 * bet;
111 else if (bets.length === 4) return 9 * bet;
112 else if (bets.length === 2) return 18 * bet;
113 else if (bets.length === 1) return 36 * bet;
114
115 return 0;
116}
117
118(function() {
119 setInterval(() => {
120 game.timeToStart--;
121
122 // WAIT_BEFORE seconds is the time allocated for spinning the wheel and seeing the results.
123 if (game.timeToStart == 0) {
124 game.timeToStart = game.COUNTDOWN_FROM + game.WAIT_BEFORE;
125
126 game.magicNumber = Math.floor(Math.random() * 37);
127 game.winningBets = getWinningBets(game.magicNumber);
128
129 setTimeout(() => {
130 updateGameWithWinners();
131 }, 6000)
132 }
133 else if (game.timeToStart == 10) {
134 game.status = '_2_spinning';
135 }
136 else if (game.timeToStart == game.COUNTDOWN_FROM) {
137 resetGame();
138 }
139
140 }, 1000);
141})();
142
143let game = {
144 status: '_1_ongoing_timer', // statuses: _1_ongoing_timer, _2_spinning,
145 timeToStart: 30, // in seconds
146 COUNTDOWN_FROM: 30,
147 WAIT_BEFORE: 20,
148 magicNumber: -1,
149 winningBets: [],
150 players: [],
151}
152
153function addPlayer(session_id, name) {
154 if (game.players.map(e=>e.session_id).indexOf(session_id) === -1) {
155 game.players.push({
156 session_id: session_id,
157 name: name,
158 whichBets: [],
159 coinPlaced: {
160 x: -1,
161 y: -1,
162 },
163 credits: -1,
164 betAmount: 0,
165 wonAmount: 0,
166 status: '_1_no_placed_bet',
167 outcome: 'none',
168 gotResults: false,
169 })
170 }
171}
172
173export function getPlayer(session_id) {
174 const playerIdx = game.players.map(e=>e.session_id).indexOf(session_id);
175
176 if (playerIdx !== -1) {
177 return {
178 success: true,
179 player: game.players[playerIdx],
180 }
181 }
182
183 return {
184 success: false,
185 player: {...samplePlayer},
186 };
187}
188
189export function restrictGameInfo() {
190 const restrictedPlayers = game.players.map(player=>({...player, session_id: ""}))
191
192 return {
193 ...game,
194 players: restrictedPlayers,
195 }
196}
197
198/**
199 * ********************* BEGIN OF REQUEST HANDLER *********************
200 */
201export default async function handler(req, res) {
202 /**
203 * GET method
204 */
205 if (req.method === 'GET') {
206 /**
207 * /---------------------- GET ----------------------/
208 * Place a bet.
209 * @action place_bet
210 * @param session_id
211 * @param betAmount
212 * @param whichBets
213 * @param coinPlacedX
214 * @param coinPlacedY
215 */
216 if (req.query.action === 'place_bet' && req.query?.session_id && req.query?.betAmount && req.query?.whichBets && req.query?.coinPlacedX && req.query?.coinPlacedY) {
217 const session_id = req.query.session_id;
218
219 const { success, player } = getPlayer(session_id);
220
221 if (success && game.status.includes('_1_') && player.status.includes('_1_')) {
222 axios.get(`${process.env.HOME_URL}/api/postgre?action=take_credits&session_id=${session_id}&credits=${req.query.betAmount}`).then(postgreRes => {
223 if (postgreRes.data?.success) {
224 player.betAmount = parseInt(req.query.betAmount);
225 player.whichBets = req.query.whichBets.split(',');
226 player.status = '_2_placed_bet';
227 player.coinPlaced = {
228 x: req.query.coinPlacedX,
229 y: req.query.coinPlacedY,
230 },
231 player.credits = postgreRes.data?.credits;
232 }
233 });
234 }
235
236 res.end();
237 }
238
239 /**
240 * /---------------------- GET ----------------------/
241 * Updates the state periodically
242 * @action update_state
243 * @param session_id
244 */
245 if (req.query.action === 'update_state' && req.query?.session_id) {
246 const session_id = req.query.session_id;
247
248 const { success, player } = getPlayer(session_id);
249
250 let extraAction = "";
251 let magicNumber = -1;
252 let winningBets = [];
253
254 if (success) {
255 if (game.timeToStart > game.COUNTDOWN_FROM && !player.gotResults) {
256 extraAction = "spin_wheel";
257 magicNumber = game.magicNumber;
258 winningBets = game.winningBets;
259
260 player.gotResults = true;
261 }
262 }
263
264 res.json({
265 success: true,
266 rouletteGame: {
267 game: restrictGameInfo(),
268 player: player,
269 },
270 extraAction: extraAction,
271 magicNumber: magicNumber,
272 winningBets: winningBets,
273 })
274 }
275
276 /**
277 * /---------------------- GET ----------------------/
278 * If the player is not in an existing room, create a room for them.
279 * If they are reconnecting, get the room they were in.
280 * @action get_player_info_on_enter
281 * @param session_id
282 */
283 if (req.query.action === 'get_player_info_on_enter' && req.query?.session_id) {
284 const session_id = req.query.session_id;
285
286 axios.get(`${process.env.HOME_URL}/api/postgre?action=check_if_logged_in&session_id=${session_id}`).then(postgreRes => {
287 if (postgreRes.data?.success) {
288 addPlayer(session_id, postgreRes.data?.displayName);
289
290 res.json({
291 success: true,
292 game: game,
293 displayName: postgreRes.data?.displayName,
294 session_id: postgreRes.data?.session_id,
295 credits: postgreRes.data?.credits,
296 })
297 }
298 else {
299 res.json({
300 success: false,
301 })
302 }
303 });
304 }
305 }
306}
307/**
308 * ********************* END OF REQUEST HANDLER *********************
309 */
Note: See TracBrowser for help on using the repository browser.