Direct-to-Landlord Chat with Archiving (#39)

Author: mijinummi

src/controllers/chat.controller.js

@@ -0,0 +1,27 @@
+const chatService = require('../services/chat.service');
+
+class ChatController {
+  async sendMessage(req, res) {
+    try {
+      const { receiverId, content } = req.body;
+      const senderId = req.user.id;
+      const message = await chatService.sendMessage(senderId, receiverId, content);
+      res.status(201).json(message);
+    } catch (err) {
+      res.status(500).json({ error: err.message });
+    }
+  }
+
+  async listMessages(req, res) {
+    try {
+      const otherPartyId = req.params.id;
+      const userId = req.user.id;
+      const messages = await chatService.listMessages(userId, otherPartyId);
+      res.json(messages);
+    } catch (err) {
+      res.status(500).json({ error: err.message });
+    }
+  }
+}
+
+module.exports = new ChatController();

src/routes/chat.routes.js

@@ -0,0 +1,9 @@
+const express = require('express');
+const router = express.Router();
+const chatController = require('../controllers/chat.controller');
+const { authMiddleware } = require('../services/auth.service');
+
+router.post('/chat/message', authMiddleware, (req, res) => chatController.sendMessage(req, res));
+router.get('/chat/messages/:id', authMiddleware, (req, res) => chatController.listMessages(req, res));
+
+module.exports = router;

src/services/chat.service.js

@@ -0,0 +1,31 @@
+const db = require('../db');
+const crypto = require('crypto');
+
+class ChatService {
+  async sendMessage(senderId, receiverId, content) {
+    const hash = crypto.createHash('sha256').update(content + Date.now()).digest('hex');
+
+    const [message] = await db('chat_messages')
+      .insert({
+        senderId,
+        receiverId,
+        content,
+        hash,
+        createdAt: new Date()
+      })
+      .returning('*');
+
+    return message;
+  }
+
+  async listMessages(userId, otherPartyId) {
+    return db('chat_messages')
+      .where(function () {
+        this.where({ senderId: userId, receiverId: otherPartyId })
+            .orWhere({ senderId: otherPartyId, receiverId: userId });
+      })
+      .orderBy('createdAt', 'asc');
+  }
+}
+
+module.exports = new ChatService();

src/websockets/chat.gateway.js

@@ -0,0 +1,18 @@
+const { Server } = require('socket.io');
+const chatService = require('../services/chat.service');
+
+let io;
+
+function initChatGateway(server) {
+  io = new Server(server, { path: '/ws/chat' });
+
+  io.on('connection', (socket) => {
+    socket.on('send_message', async ({ senderId, receiverId, content }) => {
+      const message = await chatService.sendMessage(senderId, receiverId, content);
+      io.to(receiverId).emit('new_message', message);
+      io.to(senderId).emit('message_sent', message);
+    });
+  });
+}
+
+module.exports = { initChatGateway };

tests/chat.e2e-spec.js

@@ -0,0 +1,21 @@
+const request = require('supertest');
+const app = require('../index');
+
+describe('Direct-to-Landlord Chat API', () => {
+  it('POST /chat/message archives and hashes message', async () => {
+    const res = await request(app)
+      .post('/chat/message')
+      .set('Authorization', 'Bearer tenantToken')
+      .send({ receiverId: 'landlord-123', content: 'Hello landlord' });
+    expect(res.status).toBe(201);
+    expect(res.body).toHaveProperty('hash');
+  });
+
+  it('GET /chat/messages/:id returns full conversation', async () => {
+    const res = await request(app)
+      .get('/chat/messages/landlord-123')
+      .set('Authorization', 'Bearer tenantToken');
+    expect(res.status).toBe(200);
+    expect(Array.isArray(res.body)).toBe(true);
+  });
+});