All files / src/app/api/chat/message route.ts

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
export const dynamic = 'force-dynamic';

/**
 * Chat Message API
 * POST /api/chat/message - Send a message in a conversation
 */

import { NextRequest, NextResponse } from 'next/server';
import { getServerSession } from '@/lib/auth';
import {
  withErrorHandling,
  ApiError,
  ApiSuccessResponse,
  ApiErrorResponse,
} from '@/lib/api';
import { ChatService, generateBotResponse } from '@/services';
import { prisma } from '@/lib/prisma';
import { z } from 'zod';

// ============================================================================
// VALIDATION
// ============================================================================

const SendMessageSchema = z.object({
  conversationId: z.string().min(1, 'Conversation ID is required'),
  content: z.string().min(1, 'Message content is required').max(5000),
  contentType: z
    .enum(['TEXT', 'IMAGE', 'FILE', 'QUICK_REPLIES'])
    .optional()
    .default('TEXT'),
  attachments: z
    .array(
      z.object({
        url: z.string().url(),
        name: z.string(),
        type: z.string(),
        size: z.number().optional(),
      })
    )
    .optional(),
});

// ============================================================================
// HANDLERS
// ============================================================================

/**
 * POST /api/chat/message
 * Send a message in a conversation
 */
async function handlePost(
  request: NextRequest
): Promise<NextResponse<ApiSuccessResponse<unknown> | ApiErrorResponse>> {
  const session = await getServerSession();
  const body = await request.json();

  // Validate request body
  const parseResult = SendMessageSchema.safeParse(body);
  if (!parseResult.success) {
    throw ApiError.validation(
      'Invalid request data',
      parseResult.error.issues
    );
  }

  const { conversationId, content, contentType, attachments } = parseResult.data;

  // Verify conversation exists and user has access
  const conversation = await prisma.chatConversation.findUnique({
    where: { id: conversationId },
    select: { userId: true, visitorId: true, status: true },
  });

  if (!conversation) {
    throw ApiError.notFound('Conversation not found');
  }

  // Check access - user must be the conversation owner
  const userId = session?.user?.id;
  if (conversation.userId && conversation.userId !== userId) {
    throw ApiError.forbidden('You do not have access to this conversation');
  }

  // Check if conversation is closed
  if (conversation.status === 'CLOSED') {
    throw ApiError.badRequest('This conversation has been closed');
  }

  // Send the message
  const message = await ChatService.sendMessage({
    conversationId,
    senderId: userId,
    senderType: 'CUSTOMER',
    content,
    contentType,
    attachments,
  });

  // Try bot response if no agent assigned
  const messages = [message];
  const fullConversation = await prisma.chatConversation.findUnique({
    where: { id: conversationId },
    select: { assignedToId: true, status: true },
  });

  if (!fullConversation?.assignedToId && fullConversation?.status !== 'ACTIVE') {
    const botResponse = await generateBotResponse(content, userId);

    if (botResponse) {
      const botMessage = await ChatService.sendMessage({
        conversationId,
        senderType: 'BOT',
        content: botResponse.message,
        contentType: botResponse.contentType,
        attachments: botResponse.attachments as never,
      });

      messages.push(botMessage);
    }
  }

  return NextResponse.json({
    success: true,
    data: { messages },
  });
}

// ============================================================================
// EXPORTS
// ============================================================================

export const POST = withErrorHandling(handlePost);