subscription working

package.json

@@ -63,6 +63,8 @@
     "redux-persist": "^6.0.0",
     "redux-thunk": "^3.1.0",
     "reverse-mirage": "^1.0.3",
+    "socket.io": "^4.7.4",
+    "socket.io-client": "^4.7.4",
     "tailwind-merge": "^2.1.0",
     "truncate-eth-address": "^1.0.2",
     "viem": "^2.5.0",

sendPushNotification.js

@@ -3,8 +3,8 @@ const webPush = require('web-push');
 
 const sendPushNotification = async () => {
   const publicKey =
-    'BKygzgxdX4Y-kic62cOFL6SYlEjIXryAyd6i1lqvp2N9F8UQ9-eSCUpyoQxryU-Q-E1Xn0AxdFOZFvFxdVksKdI';
-  const privateKey = 'AWDM9R15IL7prFSo3EmNjIyoz3w8f1d5-bbp01emJHo';
+    'BK9FZUL3u5bgvs8NlurUeFesIq5dm3qEUwOlh3hL7wGPbNec2SELGLwjKU2jWv9P9GULDvlWlC04Lric-w8yEf8';
+  const privateKey = 'EctJtRAxWnq18ayGbnjcHQ';
 
   webPush.setVapidDetails(
     'mailto:[email protected]',

src/app/notification/route.ts

@@ -13,7 +13,7 @@ export const POST = async (req: NextRequest) => {
     subscription: webPush.PushSubscription;
     message: string;
   };
-  console.log(message);
+  console.log(subscription);
   try {
     webPush.setVapidDetails(
       `mailto:${process.env.NEXT_PUBLIC_WEB_PUSH_EMAIL}`,

src/app/server/index.js

@@ -0,0 +1,28 @@
+const Server = require('socket.io');
+
+// Create a socket.io server
+const ioHandler = (req, res) => {
+  if (!res.socket.server.io) {
+    console.log('*First use, starting Socket.IO');
+    const io = new Server(res.socket.server);
+
+    // Listen for connection events
+    io.on('connection', (socket) => {
+      console.log(`Socket ${socket.id} connected.`);
+
+      // Listen for incoming messages and broadcast to all clients
+      socket.on('message', (message) => {
+        io.emit('message', message);
+      });
+
+      // Clean up the socket on disconnect
+      socket.on('disconnect', () => {
+        console.log(`Socket ${socket.id} disconnected.`);
+      });
+    });
+    res.socket.server.io = io;
+  }
+  res.end();
+};
+
+module.exports = ioHandler;