// scripts/backfill-attendance.mjs
import { createClient } from '@supabase/supabase-js';

const supabase = createClient(
  process.env.SUPABASE_URL,
  process.env.SUPABASE_SERVICE_KEY
);

const EXTERNAL_API = process.env.EXTERNAL_API_URL;
const API_KEY = process.env.EXTERNAL_API_KEY;

async function fetchAttendance(monthsBack = 6) {
  const endDate = new Date();
  const startDate = new Date();
  startDate.setMonth(startDate.getMonth() - monthsBack);

  const allRecords = [];
  let page = 1;

  while (true) {
    const res = await fetch(
      `${EXTERNAL_API}/api/attendance?start=${startDate.toISOString().split('T')[0]}&end=${endDate.toISOString().split('T')[0]}&page=${page}`,
      { headers: { Authorization: `Bearer ${API_KEY}` } }
    );

    const data = await res.json();
    if (!data.records?.length) break;

    allRecords.push(...data.records);
    page++;
    console.log(`  Fetched page ${page}: ${data.records.length} records`);
  }

  return allRecords;
}

function transformRecord(record) {
  return {
    date: record.date,
    employee_id: record.emp_id,
    employee_name: record.emp_name,
    check_in: record.time_in || null,
    check_out: record.time_out || null,
    status: record.status || 'hadir',
    raw_data: record,
  };
}

async function upsertBatch(records) {
  const transformed = records.map(transformRecord);
  const { error } = await supabase
    .from('attendance')
    .upsert(transformed, {
      onConflict: 'employee_id,date',
      ignoreDuplicates: false,
    });

  if (error) throw error;
  return transformed.length;
}

async function main() {
  console.log('🚀 Starting backfill...');
  const records = await fetchAttendance(6);
  console.log(`📊 Total records fetched: ${records.length}`);

  // Process in batches of 100
  const BATCH_SIZE = 100;
  let total = 0;

  for (let i = 0; i < records.length; i += BATCH_SIZE) {
    const batch = records.slice(i, i + BATCH_SIZE);
    const count = await upsertBatch(batch);
    total += count;
    console.log(`  Batch ${Math.floor(i / BATCH_SIZE) + 1}: ${count} upserted`);
  }

  console.log(`✅ Backfill complete! ${total} records synced.`);
}

main().catch(console.error);

// scripts/daily-sync.mjs
import { createClient } from '@supabase/supabase-js';

const supabase = createClient(
  process.env.SUPABASE_URL,
  process.env.SUPABASE_SERVICE_KEY
);

const EXTERNAL_API = process.env.EXTERNAL_API_URL;
const API_KEY = process.env.EXTERNAL_API_KEY;

async function syncToday() {
  const today = new Date().toISOString().split('T')[0];

  const res = await fetch(
    `${EXTERNAL_API}/api/attendance?date=${today}`,
    { headers: { Authorization: `Bearer ${API_KEY}` } }
  );

  const data = await res.json();
  if (!data.records?.length) {
    console.log(`📭 No records for ${today}`);
    return;
  }

  const transformed = data.records.map((r) => ({
    date: r.date,
    employee_id: r.emp_id,
    employee_name: r.emp_name,
    check_in: r.time_in || null,
    check_out: r.time_out || null,
    status: r.status || 'hadir',
    raw_data: r,
  }));

  const { error } = await supabase
    .from('attendance')
    .upsert(transformed, { onConflict: 'employee_id,date' });

  if (error) throw error;
  console.log(`✅ Synced ${transformed.length} records for ${today}`);
}

syncToday()
  .then(() => process.exit(0))
  .catch((e) => {
    console.error('❌ Sync failed:', e.message);
    process.exit(1);
  });