create the backend for the chat app

build chat server with express, websocket, GET and POST messages endpoints

Author: Abubakar-Meigag

chat-app/server/.dockerignore

@@ -0,0 +1,2 @@
+
+/node_modules

chat-app/server/.gitignore

@@ -0,0 +1,24 @@
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+pnpm-debug.log*
+lerna-debug.log*
+
+/node_modules
+dist
+dist-ssr
+*.local
+
+# Editor directories and files
+.vscode/*
+!.vscode/extensions.json
+.idea
+.DS_Store
+*.suo
+*.ntvs*
+*.njsproj
+*.sln
+*.sw?

chat-app/server/Dockerfile

@@ -0,0 +1,13 @@
+FROM node:20-alpine
+
+WORKDIR /app
+
+COPY package*.json ./
+
+RUN npm install
+
+COPY . .
+
+EXPOSE 3000
+
+CMD ["node", "index.js"]

chat-app/server/data/messages.js

@@ -0,0 +1,2 @@
+const messages = [];
+module.exports = messages;

chat-app/server/endPoints/getMessage.js

@@ -0,0 +1,7 @@
+const messages = require("../data/messages");
+
+const getMessage = (req, res) => {
+  res.json(messages);
+};
+
+module.exports = getMessage;

chat-app/server/endPoints/postMessage.js

@@ -0,0 +1,32 @@
+const { v4: uuidv4 } = require("uuid");
+const messages = require("../data/messages");
+
+const postMessage = (req, res, wss) => {
+  const { name, text } = req.body;
+
+  if (!name || !text) {
+    return res.status(400).json({ error: "name and text are required" });
+  }
+
+  const newMessage = {
+    id: uuidv4(),
+    name,
+    text,
+    timestamp: new Date().toLocaleTimeString([], {
+      hour: "2-digit",
+      minute: "2-digit",
+    }),
+  };
+
+  messages.push(newMessage);
+
+  wss.clients.forEach((client) => {
+    if (client.readyState === 1) {
+      client.send(JSON.stringify(newMessage));
+    }
+  });
+
+  res.status(201).json(newMessage);
+};
+
+module.exports = postMessage;

chat-app/server/index.js

@@ -0,0 +1,37 @@
+const http                = require("http");
+const express             = require("express");
+const { WebSocketServer } = require("ws");
+const cors                = require("cors");
+const bodyParser          = require("body-parser");
+
+const app     = express();
+const server  = http.createServer(app);
+const wss     = new WebSocketServer({ server });
+
+const port    = process.env.PORT || 3000;
+
+app.use(bodyParser.json());
+app.use(bodyParser.urlencoded({ extended: true }));
+app.use(cors());
+
+wss.on("connection", (ws) => {
+  console.log("new client connected");
+
+  ws.on("close", () => {
+    console.log("client disconnected");
+  });
+});
+
+app.get("/", (req, res) => {
+  res.send(`Welcome to Beeko chat app server on port ${port}`);
+});
+
+const getMessage = require("./endPoints/getMessage");
+const postMessage = require("./endPoints/postMessage");
+
+app.get("/messages", getMessage);
+app.post("/messages", (req, res) => postMessage(req, res, wss));
+
+server.listen(port, () => {
+  console.log(`Server is running on Port: ${port}`);
+});