Merge pull request #52 from AgentWorkforce/relaycast-integration

feat: reactions, thread improvements, REST fallback for relaycast integration

Author: khaliqgant

packages/dashboard-server/src/mocks/fixtures.ts

@@ -56,6 +56,10 @@ export const mockMessages: Message[] = [
     to: 'claude-1',
     content: 'Please implement user authentication with JWT tokens',
     timestamp: new Date(Date.now() - 300000).toISOString(),
+    reactions: [
+      { emoji: '👍', count: 2, agents: ['claude-1', 'architect'] },
+      { emoji: '🚀', count: 1, agents: ['reviewer'] },
+    ],
   },
   {
     id: 'msg-002',
@@ -64,13 +68,17 @@ export const mockMessages: Message[] = [
     content: 'I\'ll implement JWT authentication. Let me start by creating the auth middleware.',
     timestamp: new Date(Date.now() - 295000).toISOString(),
     thread: 'msg-001',
+    reactions: [
+      { emoji: '✅', count: 1, agents: ['user'] },
+    ],
   },
   {
     id: 'msg-003',
     from: 'claude-1',
     to: 'architect',
     content: 'What\'s the preferred token expiration time for the JWT implementation?',
     timestamp: new Date(Date.now() - 290000).toISOString(),
+    replyCount: 2,
   },
   {
     id: 'msg-004',
@@ -80,13 +88,28 @@ export const mockMessages: Message[] = [
     timestamp: new Date(Date.now() - 280000).toISOString(),
     thread: 'msg-003',
   },
+  {
+    id: 'msg-004b',
+    from: 'claude-1',
+    to: 'architect',
+    content: 'Got it, implementing with those values. Will add refresh token rotation too.',
+    timestamp: new Date(Date.now() - 270000).toISOString(),
+    thread: 'msg-003',
+    reactions: [
+      { emoji: '👍', count: 1, agents: ['architect'] },
+    ],
+  },
   {
     id: 'msg-005',
     from: 'reviewer',
     to: '*',
     content: 'PR #42 has been reviewed. Ready for merge.',
     timestamp: new Date(Date.now() - 200000).toISOString(),
     isBroadcast: true,
+    reactions: [
+      { emoji: '🎉', count: 3, agents: ['user', 'claude-1', 'architect'] },
+      { emoji: '👏', count: 1, agents: ['user'] },
+    ],
   },
 ];
 

packages/dashboard-server/src/mocks/routes.ts

@@ -6,6 +6,7 @@
  */
 
 import type { Express, Request, Response } from 'express';
+import type { Message } from './types.js';
 import {
   mockAgents,
   mockMessages,
@@ -649,6 +650,133 @@ export function registerMockRoutes(app: Express, verbose: boolean): void {
     });
   });
 
+  // ===== Reactions =====
+
+  app.post('/api/messages/:id/reactions', (req: Request, res: Response) => {
+    const { id } = req.params;
+    const { emoji } = req.body || {};
+    log(`POST /api/messages/${id}/reactions - ${emoji}`);
+
+    const message = mockMessages.find(m => m.id === id);
+    if (!message) {
+      res.status(404).json({ ok: false, error: { code: 'message_not_found', message: 'Message not found' } });
+      return;
+    }
+
+    const agentName = req.body.from || mockUser.displayName;
+    if (!message.reactions) message.reactions = [];
+    const existing = message.reactions.find(r => r.emoji === emoji);
+    if (existing) {
+      if (!existing.agents.includes(agentName)) {
+        existing.agents.push(agentName);
+        existing.count++;
+      }
+    } else {
+      message.reactions.push({ emoji, count: 1, agents: [agentName] });
+    }
+
+    res.status(201).json({
+      ok: true,
+      data: { id: `reaction-${Date.now()}`, message_id: id, emoji, agent_name: agentName, created_at: new Date().toISOString() },
+    });
+  });
+
+  app.delete('/api/messages/:id/reactions/:emoji', (req: Request, res: Response) => {
+    const { id, emoji } = req.params;
+    log(`DELETE /api/messages/${id}/reactions/${emoji}`);
+
+    const message = mockMessages.find(m => m.id === id);
+    if (!message) {
+      res.status(404).json({ ok: false, error: { code: 'message_not_found', message: 'Message not found' } });
+      return;
+    }
+
+    if (message.reactions) {
+      const existing = message.reactions.find(r => r.emoji === emoji);
+      if (existing) {
+        const agentToRemove = (req.body && req.body.from) || mockUser.displayName;
+      existing.agents = existing.agents.filter(a => a !== agentToRemove);
+        existing.count = existing.agents.length;
+        if (existing.count === 0) {
+          message.reactions = message.reactions.filter(r => r.emoji !== emoji);
+        }
+      }
+    }
+
+    res.status(204).end();
+  });
+
+  app.get('/api/messages/:id/reactions', (req: Request, res: Response) => {
+    const { id } = req.params;
+    log(`GET /api/messages/${id}/reactions`);
+
+    const message = mockMessages.find(m => m.id === id);
+    if (!message) {
+      res.status(404).json({ ok: false, error: { code: 'message_not_found', message: 'Message not found' } });
+      return;
+    }
+
+    res.json({ ok: true, data: message.reactions || [] });
+  });
+
+  // ===== Thread Replies =====
+
+  app.get('/api/messages/:id/replies', (req: Request, res: Response) => {
+    const { id } = req.params;
+    log(`GET /api/messages/${id}/replies`);
+
+    const parent = mockMessages.find(m => m.id === id);
+    if (!parent) {
+      res.status(404).json({ ok: false, error: { code: 'message_not_found', message: 'Message not found' } });
+      return;
+    }
+
+    const replies = mockMessages
+      .filter(m => m.thread === id)
+      .sort((a, b) => new Date(a.timestamp).getTime() - new Date(b.timestamp).getTime());
+
+    res.json({
+      ok: true,
+      data: {
+        parent: { ...parent, reply_count: replies.length },
+        replies,
+      },
+    });
+  });
+
+  app.post('/api/messages/:id/replies', (req: Request, res: Response) => {
+    const { id } = req.params;
+    const { text } = req.body || {};
+    log(`POST /api/messages/${id}/replies`);
+
+    const parent = mockMessages.find(m => m.id === id);
+    if (!parent) {
+      res.status(404).json({ ok: false, error: { code: 'message_not_found', message: 'Message not found' } });
+      return;
+    }
+
+    const replyFrom = req.body.from || mockUser.displayName;
+    const reply: Message = {
+      id: `msg-reply-${Date.now()}`,
+      from: replyFrom,
+      to: parent.from === replyFrom ? parent.to : parent.from,
+      content: text,
+      timestamp: new Date().toISOString(),
+      thread: id as string,
+    };
+
+    mockMessages.push(reply);
+
+    // Update parent reply count
+    if (parent.replyCount !== undefined) {
+      parent.replyCount++;
+    } else {
+      parent.replyCount = mockMessages.filter(m => m.thread === id).length;
+    }
+
+    res.status(201).json({ ok: true, data: reply });
+  });
+
   // ===== Relay Message =====
 
   app.post('/api/relay/send', (req: Request, res: Response) => {
@@ -1178,5 +1306,24 @@ export function registerMockRoutes(app: Express, verbose: boolean): void {
     });
   });
 
+  // ===== Relaycast compatibility (v1 API) =====
+
+  app.get('/v1/workspace', (req: Request, res: Response) => {
+    const auth = req.headers.authorization;
+    log(`GET /v1/workspace - auth: ${auth ? 'present' : 'missing'}`);
+    if (!auth?.startsWith('Bearer rk_live_')) {
+      res.status(401).json({ ok: false, error: { code: 'unauthorized', message: 'Invalid API key' } });
+      return;
+    }
+    res.json({
+      ok: true,
+      data: {
+        id: mockWorkspaces[0].id,
+        name: mockWorkspaces[0].name,
+        status: 'active',
+      },
+    });
+  });
+
   console.log('[mock] Mock API routes registered');
 }

packages/dashboard-server/src/mocks/types.ts

@@ -15,6 +15,12 @@ export interface Agent {
   projectPath?: string;
 }
 
+export interface Reaction {
+  emoji: string;
+  count: number;
+  agents: string[];
+}
+
 export interface Message {
   id: string;
   from: string;
@@ -25,13 +31,15 @@ export interface Message {
   isBroadcast?: boolean;
   isUrgent?: boolean;
   status?: string;
+  replyCount?: number;
   data?: Record<string, unknown>;
   attachments?: Array<{
     id: string;
     filename: string;
     mimeType: string;
     size: number;
   }>;
+  reactions?: Reaction[];
 }
 
 export interface Session {

packages/dashboard/package.json

@@ -13,11 +13,17 @@
       "types": "./dist/index.d.ts",
       "import": "./dist/index.js"
     },
+    "./components/*": "./src/components/*.tsx",
+    "./hooks/*": "./src/components/hooks/*.ts",
+    "./lib/*": "./src/lib/*.ts",
+    "./types": "./src/types/index.ts",
+    "./src/app/*.css": "./src/app/*.css",
     "./out/*": "./out/*"
   },
   "files": [
     "out",
     "dist",
+    "src",
     "README.md"
   ],
   "scripts": {