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