From 1cad0b0b0ddc85212bea4a36b61a9f064eeb7f5b Mon Sep 17 00:00:00 2001 From: ing9990 Date: Wed, 3 Jul 2024 15:46:43 +0900 Subject: [PATCH] feat: Increase min temperature by 2 degrees to support polar bear habitat --- server.js | 57 ++++++++++++++++++++++++++++--------------------------- 1 file changed, 29 insertions(+), 28 deletions(-) diff --git a/server.js b/server.js index 1eafae4..3065d37 100644 --- a/server.js +++ b/server.js @@ -1,30 +1,29 @@ const fastify = require("fastify"); const path = require('path') -const { RateLimiterMemory } = require('rate-limiter-flexible'); +const {RateLimiterMemory} = require('rate-limiter-flexible'); const rateLimiter = new RateLimiterMemory( - { - points: 15, // 초당 x회 limit - duration: 1, - } + { + points: 15, // 초당 x회 limit + duration: 1, + } ); - +const temperatures = { + min: 20, + now: 20, + max: 30 +} const app = fastify(); -app.register(require("fastify-socket.io"), { - -}); +app.register(require("fastify-socket.io"), {}); app.register(require('@fastify/static'), { root: path.join(__dirname, 'public'), // prefix: '/public/', }) -app.listen({ port: 8080 }); - - -var temp = 18; +app.listen({port: 8080}); app.get("/", (req, reply) => { return reply.sendFile('index.html') @@ -34,25 +33,27 @@ app.get("/", (req, reply) => { // return reply.send(temp) // }); - app.ready((err) => { - if (err) throw err; + if (err) { + throw err; + } console.log('http://localhost:8080') - app.io.on("connect", (socket) =>{ + app.io.on("connect", (socket) => { // console.log('connected', socket.id) - socket.emit("init", temp); + socket.emit("init", temperatures.min); - socket.on('disconnect', function(){ + socket.on('disconnect', function () { }); - + socket.on("plus", async (arg) => { try { - await rateLimiter.consume(socket.handshake.headers['x-real-ip']); - if (temp < 30) { - temp++; + await rateLimiter.consume(socket.handshake.headers['x-real-ip']); + if (temperatures.now < temperatures.max) { + temperatures.now++; } - app.io.emit('tempChange', {temp : temp, username : arg.substring(0, 9)}) + app.io.emit('tempChange', + {temp: temperatures.now, username: arg.substring(0, 9)}) } catch (err) { socket.emit('blocked', '너무 잦은 요청'); } @@ -60,15 +61,15 @@ app.ready((err) => { socket.on("minus", async (arg) => { try { - await rateLimiter.consume(socket.handshake.address); - if (temp > 18) { - temp--; + await rateLimiter.consume(socket.handshake.address); + if (temperatures.now > temperatures.min) { + temperatures.now--; } - app.io.emit('tempChange', {temp : temp, username : arg.substring(0, 9)}) + app.io.emit('tempChange', + {temp: temperatures.now, username: arg.substring(0, 9)}) } catch (err) { socket.emit('blocked', '너무 잦은 요청'); } }) - }); });