All files / src/app/api/admin/email/queue 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
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
/**
 * Email Queue Admin API
 *
 * Provides endpoints for monitoring and managing the email queue.
 */

import { NextRequest, NextResponse } from 'next/server';
import {
  withAdmin,
  withErrorHandling,
  successResponse,
  errorResponse,
  ApiSuccessResponse,
  ApiErrorResponse,
} from '@/lib/api';
import {
  getEmailQueueStats,
  pauseEmailQueue,
  resumeEmailQueue,
  cleanEmailQueue,
  retryEmailJob,
} from '@/lib/queue';
import { getWorkerStatus } from '@/lib/queue/emailWorker';
import { QueueStats } from '@/lib/queue/types';

// ============================================================================
// TYPES
// ============================================================================

interface EmailQueueResponse {
  queue: QueueStats;
  worker: {
    running: boolean;
    concurrency: number;
    rateLimit: { max: number; duration: number };
  };
  recentEmails: {
    sent: number;
    failed: number;
    pending: number;
  };
}

// ============================================================================
// GET - Queue Statistics
// ============================================================================

async function handleGet(): Promise<
  NextResponse<ApiSuccessResponse<EmailQueueResponse> | ApiErrorResponse>
> {
  // Get queue stats
  const queueStats = await getEmailQueueStats();
  const workerStatus = getWorkerStatus();

  // Note: EmailLog counts will be available after prisma generate
  // For now, return zeros - the queue stats are the primary source of truth
  const recentEmails = {
    sent: queueStats.completed,
    failed: queueStats.failed,
    pending: queueStats.waiting + queueStats.delayed,
  };

  return successResponse({
    queue: queueStats,
    worker: workerStatus,
    recentEmails,
  });
}

// ============================================================================
// POST - Queue Actions
// ============================================================================

interface QueueAction {
  action: 'pause' | 'resume' | 'clean' | 'retry';
  jobId?: string;
  cleanStatus?: 'completed' | 'failed';
  gracePeriodMs?: number;
}

async function handlePost(
  request: NextRequest
): Promise<NextResponse<ApiSuccessResponse<{ success: boolean; message: string }> | ApiErrorResponse>> {
  const body = await request.json() as QueueAction;
  const { action, jobId, cleanStatus, gracePeriodMs } = body;

  let result: boolean;
  let message: string;

  switch (action) {
    case 'pause':
      result = await pauseEmailQueue();
      message = result ? 'Queue paused' : 'Failed to pause queue (Redis not available)';
      break;

    case 'resume':
      result = await resumeEmailQueue();
      message = result ? 'Queue resumed' : 'Failed to resume queue (Redis not available)';
      break;

    case 'clean':
      const cleanedCount = await cleanEmailQueue(cleanStatus || 'completed', gracePeriodMs);
      result = true;
      message = `Cleaned ${cleanedCount} ${cleanStatus || 'completed'} jobs`;
      break;

    case 'retry':
      if (!jobId) {
        return errorResponse('MISSING_JOB_ID', 'Job ID required for retry', { status: 400 });
      }
      result = await retryEmailJob(jobId);
      message = result ? `Job ${jobId} retry initiated` : `Failed to retry job ${jobId}`;
      break;

    default:
      return errorResponse('UNKNOWN_ACTION', `Unknown action: ${action}`, { status: 400 });
  }

  return successResponse({ success: result, message });
}

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

export const GET = withErrorHandling(
  withAdmin(handleGet)
);

export const POST = withErrorHandling(
  withAdmin(handlePost)
);