1
export const dynamic = "force-dynamic"
2
import type { NextRequest } from 'next/server';
3
import { adminDb } from '@/src/lib/firebase/admin';
4
import { getFirestore, QuerySnapshot } from 'firebase-admin/firestore';
5
 
6
export function GET(request: NextRequest) {
7
  console.log('🤖 Cron job started:', new Date().toISOString());
8
  
9
  const authHeader = request.headers.get('authorization');
10
//   if (authHeader !== `Bearer ${process.env.CRON_SECRET}`) {
11
//     return new Response('Unauthorized', {
12
//       status: 401,
13
//     });
14
//   } 
15

16
  checkAndCompleteExpiredTasks();
17
  console.log('✅ Cron job completed:', new Date().toISOString());
18
  return Response.json({ success: true });
19
}
20

21
async function checkAndCompleteExpiredTasks() {
22
  try {
23
    const now = new Date().toISOString();
24
    console.log('📅 Checking for expired tasks at:', now);
25
    
26
    const tasksRef = adminDb.collection('agent_tasks');
27
    console.log('📚 Collection reference created');
28
    let snapshot;
29
    try {
30
        snapshot = await tasksRef.where('status', '==', 'created').get();
31
        console.log("Query executed, snapshot size:", snapshot.size);
32
      } catch (error) {
33
        console.error('Error fetching tasks:', error);
34
      }
35
    console.log("Query executed, snapshot size:", snapshot?.size)
36
    
37
    let expiredTasks: Object[] = [];
38
    snapshot?.forEach(doc => {
39
        const data = doc.data();
40
        if (data.taskFinishTime <= now) {
41
            expiredTasks.push({
42
                id: doc.id,
43
                ...data
44
            });
45
            console.log("Found expired task:", doc.id);
46
        }
47
    })
48

49
    console.log("🔍 Found", expiredTasks.length, "expired tasks");
50
    if (expiredTasks.length > 0) {
51
        const completionPromises = expiredTasks.map(async (task: any) => {
52
            const taskId = task.id;
53
            console.log(`⚡ Processing task ${taskId}`);
54
            
55
            try {
56
            const response = await fetch(
57
                `${process.env.NEXT_PUBLIC_APP_URL}/api/agents/tasks/${taskId}/complete`,
58
                {
59
                method: 'POST',
60
                headers: {
61
                    'Content-Type': 'application/json',
62
                    // Add any necessary authentication headers
63
                }
64
                }
65
            );
66

67
            if (!response.ok) {
68
                console.error(`❌ Failed to complete task ${taskId}: ${response.statusText}`);
69
                throw new Error(`Failed to complete task ${taskId}: ${response.statusText}`);
70
            }
71

72
            console.log(`✅ Successfully completed task ${taskId}`);
73
            } catch (error) {
74
            console.error(`❌ Error completing task ${taskId}:`, error);
75
            }
76
        });
77
    }
78
    console.log('🏁 Finished processing all expired tasks');
79
    
80
  } catch (error) {
81
    console.error('💥 Detailed error in checkAndCompleteExpiredTasks:', {
82
      message: (error as Error).message,
83
      code: (error as any).code,
84
      stack: (error as Error).stack
85
    });
86
    throw error;
87
  }
88
}