Dev

.gitignore

@@ -11,3 +11,5 @@ env
 
 # IDEA
 .idea
+
+src/

app.js

@@ -4,7 +4,6 @@ const cookieParser = require('cookie-parser');
 const logger = require('morgan');
 const cors = require("cors");
 const { corsOptions } = require('./config/cors');
-
 const app = express();
 
 app.use(cors(corsOptions))
@@ -17,6 +16,7 @@ if (process.env.NODE_ENV === "production") {
 app.use(express.json());
 app.use(express.urlencoded({ extended: false }));
 app.use(cookieParser());
+app.use(express.static('src'));
 
 require('./components/user/userRoute')(app);
 require('./components/farm/farmRoute')(app);

bin/www

@@ -18,17 +18,31 @@ app.set('port', port);
 /**
  * Create HTTP server.
  */
-
 const server = http.createServer(app);
+const io = require('socket.io')(server);
 
 /**
  * Listen on provided port, on all network interfaces.
  */
-
+//httpsServer.listen(httpsPort)
 server.listen(port);
+
+io.on('connection', (socket)=>{
+  require('../components/chat/chatRoute')(io,socket);
+  console.log('user connected');
+  socket.on('error', (err)=>{
+    console.log("Socket error: ", err);
+  })
+})
+io.on('error', (err) => {
+  console.log("testtest");
+  console.error("Socket.IO 서버 오류:", err);
+});
+
 server.on('error', onError);
 server.on('listening', onListening);
 
+
 /**
  * Normalize a port into a number, string, or false.
  */

components/chat/chatRoute.js

@@ -0,0 +1,72 @@
+const Chat = require('./chatModel');
+const docClient = require('../../config/dynamo')
+const {PutItemCommand, QueryCommand } = require("@aws-sdk/client-dynamodb");
+const moment = require('moment-timezone');
+
+module.exports = function (io,socket) {
+    socket.on('send', async(data)=>{
+        data.name = socket.sender
+
+        const koreanTime = moment().tz('Asia/Seoul');
+        const currentDate = koreanTime.toISOString();
+
+        const params = {
+            TableName: 'Chats',
+            Item: {
+              ChatId: {S: socket.id},
+              sendDate : {S: currentDate},
+              Sender: {S: socket.sender},
+              Receiver: {S: socket.receiver},
+              Message: {S: data.message},
+            },
+        };
+        try{
+            const command = new PutItemCommand(params);
+            await docClient.send(command);
+            console.log("저장완료!!!");
+            io.sockets.emit('update', data)
+        }catch(err){
+          console.error("채팅 메시지 저장 오류", err);
+        }
+    })
+    socket.on('newUser', async(chatInfo)=>{
+        socket.id = chatInfo.farmer  + '_' + chatInfo.user;
+        if (chatInfo.farmer == chatInfo.email){
+            socket.sender = chatInfo.farmer
+            socket.receiver = chatInfo.user
+        }
+        else{
+            socket.sender = chatInfo.user
+            socket.receiver = chatInfo.farmer
+        }
+
+        try{
+            const params = {
+                TableName: 'Chats',
+                KeyConditionExpression: "ChatId = :ChatId",
+                ExpressionAttributeValues: {
+                    ":ChatId": {S : socket.id}
+                }
+            };
+            const command = new QueryCommand(params)
+            const result = await docClient.send(command)
+
+            const chatLog = result.Items
+            io.sockets.emit('update', {
+                name : 'SERVER',
+                chatLog : chatLog
+            });
+            console.log(chatLog);
+
+        }catch (err) {
+            console.error(err);
+        }
+
+
+    });
+    socket.on('disconnect', ()=>{
+        console.log("채팅종료");
+    })
+
+}
+