Craze-Data-check/src/lib/supabase.ts

import { ExcelRow } from '../types';

const SUPABASE_URL = 'https://hwithddwaapyhnfwcesj.supabase.co';
const SUPABASE_KEY = 'sb_publishable_fGXkh0bSrAOqSk2jWKAzSg_NJD9YPCv';

export async function saveRowToSupabase(articleNo: string, rowData: ExcelRow) {
  try {
    const response = await fetch(`${SUPABASE_URL}/rest/v1/products_sync?id=eq.${encodeURIComponent(articleNo)}`, {
      method: 'PATCH',
      headers: {
        'apikey': SUPABASE_KEY,
        'Authorization': `Bearer ${SUPABASE_KEY}`,
        'Content-Type': 'application/json'
      },
      body: JSON.stringify({
        id: articleNo,
        data: rowData,
        status_check: 'pending',
        updated_at: new Date().toISOString()
      })
    });

    if (!response.ok) {
        const errorData = await response.json().catch(() => ({}));
        console.error('Initial PATCH failed:', response.status, errorData);

        // If PATCH didn't find the record, try UPSERT
        const upsertResponse = await fetch(`${SUPABASE_URL}/rest/v1/products_sync`, {
          method: 'POST',
          headers: {
            'apikey': SUPABASE_KEY,
            'Authorization': `Bearer ${SUPABASE_KEY}`,
            'Content-Type': 'application/json',
            'Prefer': 'resolution=merge-duplicates'
          },
          body: JSON.stringify({
            id: articleNo,
            data: rowData,
            status_check: 'pending',
            updated_at: new Date().toISOString()
          })
        });

        if (!upsertResponse.ok) {
          const upsertError = await upsertResponse.json().catch(() => ({}));
          console.error('UPSERT failed:', upsertResponse.status, upsertError);
          return false;
        }
        return true;
    }
    return true;
  } catch (error) {
    console.error('Error saving to Supabase:', error);
    return false;
  }
}

export async function getAllSyncedRows(): Promise<Record<string, { data: ExcelRow, status: string }>> {
  try {
    const response = await fetch(`${SUPABASE_URL}/rest/v1/products_sync`, {
      headers: {
        'apikey': SUPABASE_KEY,
        'Authorization': `Bearer ${SUPABASE_KEY}`
      }
    });

    if (!response.ok) return {};

    const data = await response.json();
    const result: Record<string, { data: ExcelRow, status: string }> = {};
    data.forEach((item: any) => {
      result[item.id] = { 
        data: item.data, 
        status: item.status_check || 'original' 
      };
    });
    return result;
  } catch (error) {
    console.error('Error fetching from Supabase:', error);
    return {};
  }
}

export async function resetAllPendingRows() {
  try {
    const response = await fetch(`${SUPABASE_URL}/rest/v1/products_sync?status_check=eq.pending`, {
      method: 'PATCH',
      headers: {
        'apikey': SUPABASE_KEY,
        'Authorization': `Bearer ${SUPABASE_KEY}`,
        'Content-Type': 'application/json'
      },
      body: JSON.stringify({
        status_check: 'original',
        updated_at: new Date().toISOString()
      })
    });
    return response.ok;
  } catch (error) {
    console.error('Error resetting statuses in Supabase:', error);
    return false;
  }
}