suimeng
/
socketio-zustand
mirror of https://github.com/qiangziakbar/socketio-zustand.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

chore: add console to observe Socket.io connection

main
Justin Xiao 2023-07-17 22:23:30 +08:00
parent 01a69e2b6b
commit c2ebf20a2a
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
frontend/src/pages/api/socket/socketio.ts
View File

@ -11,7 +11,7 @@ export const config = {
const socketio = async (req: NextApiRequest, res: NextApiResponseServerIO) => { const socketio = async (req: NextApiRequest, res: NextApiResponseServerIO) => {
if (!res.socket.server.io) { if (!res.socket.server.io) {
console.log("First connect on socket.io"); console.log("MOCK SERVER: First connect on socket.io");
// adapt Next's net Server to http Server // adapt Next's net Server to http Server
const httpServer: NetServer = res.socket.server as any; const httpServer: NetServer = res.socket.server as any;
const io = new ServerIO(httpServer, { const io = new ServerIO(httpServer, {
@ -19,14 +19,14 @@ const socketio = async (req: NextApiRequest, res: NextApiResponseServerIO) => {
addTrailingSlash: false, addTrailingSlash: false,
}); });
io.on("connect", (socket) => { io.on("connect", (socket) => {
console.log("SOCKET CONNECTED!", socket.id); console.log("MOCK SERVER: SOCKET CONNECTED!", socket.id);
}).on("disconnect", () => { }).on("disconnect", () => {
console.log("SOCKET DISCONNECTED!"); console.log("MOCK SERVER: SOCKET DISCONNECTED!");
}); });
// append SocketIO server to Next.js socket server response // append SocketIO server to Next.js socket server response
res.socket.server.io = io; res.socket.server.io = io;
} else { } else {
console.log("Socket.io already running"); console.log("MOCK SERVER: Socket.io already running");
} }
res.end(); res.end();
}; };

1
server/index.js
View File

@ -21,6 +21,7 @@ io.on("connection", (socket) => {
}); });
socket.on("message", (message, callback) => { socket.on("message", (message, callback) => {
console.log("PRODUCTION SERVER: ", message);
const { from: sourceSocketId, to: targetSocketId } = message; const { from: sourceSocketId, to: targetSocketId } = message;
io.to(targetSocketId).emit("message", message); io.to(targetSocketId).emit("message", message);
io.to(sourceSocketId).emit("message", message); io.to(sourceSocketId).emit("message", message);