feat: add typing indicator for better UI experience issue #8

backend/.env.example

@@ -1,21 +1,15 @@
-# Backend Environment Variables
-# Copy this to .env and fill in your actual values
-
-# Supabase Configuration (get from https://app.supabase.com → Project Settings → API)
+# Supabase Configuration
 SUPABASE_URL=https://your-project-id.supabase.co
-SUPABASE_ANON_KEY=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9...
-SUPABASE_SERVICE_ROLE_KEY=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9...
+SUPABASE_ANON_KEY=your-anon-key
+SUPABASE_SERVICE_ROLE_KEY=your-service-role-key
 
-# HuggingFace API Token (optional - get from https://huggingface.co/settings/tokens)
-# If not provided, crisis detection will use keyword-based fallback
+# HuggingFace API Token (Optional)
 HUGGINGFACE_API_TOKEN=hf_YourTokenHere
 
-# Frontend URL (for CORS whitelist)
-FRONTEND_URL=http://localhost:3000
-
 # Server Configuration
 PORT=3001
+FRONTEND_URL=http://localhost:3000
 
-# Rate Limiting (optional - defaults shown)
+# Rate Limiting
 RATE_LIMIT_WINDOW_MS=900000
 RATE_LIMIT_MAX_REQUESTS=100

backend/package.json

@@ -9,7 +9,12 @@
     "start": "node dist/index.js",
     "setup-db": "ts-node src/scripts/setupDatabase.ts"
   },
-  "keywords": ["mental-health", "websocket", "express", "crisis-detection"],
+  "keywords": [
+    "mental-health",
+    "websocket",
+    "express",
+    "crisis-detection"
+  ],
   "author": "OpenMindWell Contributors",
   "license": "MIT",
   "dependencies": {
@@ -19,7 +24,8 @@
     "express": "^4.18.2",
     "express-rate-limit": "^7.1.5",
     "helmet": "^7.1.0",
-    "ws": "^8.16.0"
+    "ws": "^8.16.0",
+    "zod": "^4.3.6"
   },
   "devDependencies": {
     "@types/cors": "^2.8.17",

backend/src/config/env.ts

@@ -0,0 +1,32 @@
+import { z } from 'zod';
+import dotenv from 'dotenv';
+
+dotenv.config();
+
+const envSchema = z.object({
+  // Supabase Configuration
+  SUPABASE_URL: z.string().url(),
+  SUPABASE_ANON_KEY: z.string().min(1),
+  SUPABASE_SERVICE_ROLE_KEY: z.string().min(1),
+
+  // HuggingFace API Token (Optional)
+  HUGGINGFACE_API_TOKEN: z.string().optional(),
+
+  // Server Configuration
+  FRONTEND_URL: z.string().url().default('http://localhost:3000'),
+  PORT: z.coerce.number().default(3001),
+
+  // Rate Limiting
+  RATE_LIMIT_WINDOW_MS: z.coerce.number().default(900000),
+  RATE_LIMIT_MAX_REQUESTS: z.coerce.number().default(100),
+});
+
+const _env = envSchema.safeParse(process.env);
+
+if (!_env.success) {
+  console.error('Invalid environment variables:');
+  console.error(JSON.stringify(_env.error.format(), null, 4));
+  process.exit(1);
+}
+
+export const env = _env.data;

backend/src/config/index.ts

@@ -1,60 +1,22 @@
-import dotenv from 'dotenv';
+import { env } from './env';
 
-dotenv.config();
-
-interface Config {
+const config = {
   supabase: {
-    url: string;
-    anonKey: string;
-    serviceRoleKey: string;
-  };
-  huggingface: {
-    apiToken?: string;
-  };
-  server: {
-    port: number;
-    frontendUrl: string;
-  };
-  rateLimit: {
-    windowMs: number;
-    maxRequests: number;
-  };
-}
-
-const config: Config = {
-  supabase: {
-    url: process.env.SUPABASE_URL || '',
-    anonKey: process.env.SUPABASE_ANON_KEY || '',
-    serviceRoleKey: process.env.SUPABASE_SERVICE_ROLE_KEY || '',
+    url: env.SUPABASE_URL,
+    anonKey: env.SUPABASE_ANON_KEY,
+    serviceRoleKey: env.SUPABASE_SERVICE_ROLE_KEY,
   },
   huggingface: {
-    apiToken: process.env.HUGGINGFACE_API_TOKEN,
+    apiToken: env.HUGGINGFACE_API_TOKEN,
   },
   server: {
-    port: parseInt(process.env.PORT || '3001', 10),
-    frontendUrl: process.env.FRONTEND_URL || 'http://localhost:3000',
+    port: env.PORT,
+    frontendUrl: env.FRONTEND_URL,
   },
   rateLimit: {
-    windowMs: parseInt(process.env.RATE_LIMIT_WINDOW_MS || '900000', 10),
-    maxRequests: parseInt(process.env.RATE_LIMIT_MAX_REQUESTS || '100', 10),
+    windowMs: env.RATE_LIMIT_WINDOW_MS,
+    maxRequests: env.RATE_LIMIT_MAX_REQUESTS,
   },
 };
 
-// Validation
-const requiredEnvVars = [
-  'SUPABASE_URL',
-  'SUPABASE_ANON_KEY',
-  'SUPABASE_SERVICE_ROLE_KEY',
-  'FRONTEND_URL',
-];
-
-const missingVars = requiredEnvVars.filter((varName) => !process.env[varName]);
-
-if (missingVars.length > 0) {
-  throw new Error(
-    `Missing required environment variables: ${missingVars.join(', ')}\n` +
-      'Please check your .env file and ensure all required variables are set.'
-  );
-}
-
 export default config;

backend/src/services/chatServer.ts

@@ -2,18 +2,26 @@ import WebSocket from 'ws';
 import { supabase } from '../lib/supabase';
 import { detectCrisis, getCrisisResourcesMessage } from './crisisDetection';
 
+export interface AuthenticatedWebSocket extends WebSocket {
+  isAlive?: boolean;
+  roomId?: string;
+  userId?: string;
+  nickname?: string;
+}
+
 interface ChatMessage {
-  type: 'join' | 'leave' | 'chat' | 'crisis_alert';
+  type: 'join' | 'leave' | 'chat' | 'crisis_alert' | 'typing';
   roomId?: string;
   userId?: string;
   nickname?: string;
   content?: string;
   riskLevel?: string;
   timestamp?: string;
+  isTyping?: boolean;
 }
 
 interface RoomMember {
-  ws: WebSocket;
+  ws: AuthenticatedWebSocket;
   userId: string;
   nickname: string;
 }
@@ -30,7 +38,8 @@ export class ChatServer {
 
     // Heartbeat to detect dead connections
     setInterval(() => {
-      this.wss.clients.forEach((ws: any) => {
+      this.wss.clients.forEach((client) => {
+        const ws = client as AuthenticatedWebSocket;
         if (ws.isAlive === false) {
           return ws.terminate();
         }
@@ -40,12 +49,13 @@ export class ChatServer {
     }, 30000);
   }
 
-  private handleConnection(ws: WebSocket) {
+  private handleConnection(client: WebSocket) {
+    const ws = client as AuthenticatedWebSocket;
     console.log('New WebSocket connection');
 
-    (ws as any).isAlive = true;
+    ws.isAlive = true;
     ws.on('pong', () => {
-      (ws as any).isAlive = true;
+      ws.isAlive = true;
     });
 
     ws.on('message', async (data: string) => {
@@ -68,7 +78,7 @@ export class ChatServer {
     });
   }
 
-  private async handleMessage(ws: WebSocket, message: ChatMessage) {
+  private async handleMessage(ws: AuthenticatedWebSocket, message: ChatMessage) {
     switch (message.type) {
       case 'join':
         await this.handleJoin(ws, message);
@@ -79,12 +89,29 @@ export class ChatServer {
       case 'chat':
         await this.handleChatMessage(ws, message);
         break;
+      case 'typing':
+        this.handleTyping(ws, message);
+        break;
       default:
         ws.send(JSON.stringify({ type: 'error', message: 'Unknown message type' }));
     }
   }
 
-  private async handleJoin(ws: WebSocket, message: ChatMessage) {
+  private handleTyping(ws: AuthenticatedWebSocket, message: ChatMessage) {
+    const { roomId, userId, nickname } = ws;
+
+    if (roomId && userId) {
+      // Broadcast to other users in the room
+      this.broadcastToRoom(roomId, {
+        type: 'typing',
+        userId,
+        nickname,
+        isTyping: message.isTyping,
+      }, userId); // Exclude sender
+    }
+  }
+
+  private async handleJoin(ws: AuthenticatedWebSocket, message: ChatMessage) {
     const { roomId, userId, nickname } = message;
 
     if (!roomId || !userId || !nickname) {
@@ -102,9 +129,9 @@ export class ChatServer {
       room.add({ ws, userId, nickname });
 
       // Store connection metadata
-      (ws as any).roomId = roomId;
-      (ws as any).userId = userId;
-      (ws as any).nickname = nickname;
+      ws.roomId = roomId;
+      ws.userId = userId;
+      ws.nickname = nickname;
 
       // Fetch recent messages from database (without profile join - nicknames come from messages)
       const { data: messages, error } = await supabase
@@ -148,10 +175,8 @@ export class ChatServer {
     }
   }
 
-  private handleLeave(ws: WebSocket, message: ChatMessage) {
-    const roomId = (ws as any).roomId;
-    const userId = (ws as any).userId;
-    const nickname = (ws as any).nickname;
+  private handleLeave(ws: AuthenticatedWebSocket, message: ChatMessage) {
+    const { roomId, userId, nickname } = ws;
 
     if (roomId && userId) {
       const room = this.rooms.get(roomId);
@@ -176,11 +201,9 @@ export class ChatServer {
     }
   }
 
-  private async handleChatMessage(ws: WebSocket, message: ChatMessage) {
+  private async handleChatMessage(ws: AuthenticatedWebSocket, message: ChatMessage) {
     const { content } = message;
-    const roomId = (ws as any).roomId;
-    const userId = (ws as any).userId;
-    const nickname = (ws as any).nickname;
+    const { roomId, userId, nickname } = ws;
 
     if (!content || !roomId || !userId) {
       ws.send(JSON.stringify({ type: 'error', message: 'Missing required fields' }));
@@ -238,9 +261,8 @@ export class ChatServer {
     }
   }
 
-  private handleDisconnect(ws: WebSocket) {
-    const roomId = (ws as any).roomId;
-    const userId = (ws as any).userId;
+  private handleDisconnect(ws: AuthenticatedWebSocket) {
+    const { roomId, userId } = ws;
 
     if (roomId && userId) {
       const room = this.rooms.get(roomId);
@@ -256,13 +278,13 @@ export class ChatServer {
     console.log('WebSocket disconnected');
   }
 
-  private broadcastToRoom(roomId: string, message: any) {
+  private broadcastToRoom(roomId: string, message: any, excludeUserId?: string) {
     const room = this.rooms.get(roomId);
     if (!room) return;
 
     const messageStr = JSON.stringify(message);
     room.forEach((member) => {
-      if (member.ws.readyState === WebSocket.OPEN) {
+      if (member.userId !== excludeUserId && member.ws.readyState === WebSocket.OPEN) {
         member.ws.send(messageStr);
       }
     });