Edge Functions

Authorization: Bearer YOUR_JWT_TOKEN
Content-Type: application/json
Accept: text/event-stream  # Required for SSE

{
  "dataset_id": "uuid",
  "storage_path": "uploads/data.csv",
  "column_mapping": [
    {
      "csv_index": 0,
      "target_field": "sale_date",
      "data_type": "date"
    },
    {
      "csv_index": 1,
      "target_field": "amount",
      "data_type": "number"
    },
    {
      "csv_index": 2,
      "target_field": "vin_number",
      "data_type": "text"
    }
  ],
  "options": {
    "skip_header": true,
    "batch_size": 1000,
    "calculate_fields": true
  }
}

event: progress
data: {"processed": 1000, "total": 5000, "percent": 20}

event: progress
data: {"processed": 2000, "total": 5000, "percent": 40, "errors_count": 2}

event: complete
data: {"success": true, "rows_imported": 5000, "duration_ms": 3456, "errors_count": 2}

event: error
data: {"error": "Dataset not found: uuid", "details": "No rows returned"}

import { createClient } from '@supabase/supabase-js'

const supabase = createClient(url, anonKey)

async function importCSV(
  datasetId: string,
  storagePath: string,
  columnMapping: ColumnMapping[]
) {
  const { data: { session } } = await supabase.auth.getSession()

  const response = await fetch(
    `${supabaseUrl}/functions/v1/import-csv`,
    {
      method: 'POST',
      headers: {
        'Authorization': `Bearer ${session?.access_token}`,
        'Content-Type': 'application/json',
        'Accept': 'text/event-stream'
      },
      body: JSON.stringify({
        dataset_id: datasetId,
        storage_path: storagePath,
        column_mapping: columnMapping,
        options: { skip_header: true }
      })
    }
  )

  const reader = response.body?.getReader()
  const decoder = new TextDecoder()

  while (true) {
    const { done, value } = await reader!.read()
    if (done) break

    const chunk = decoder.decode(value)
    const lines = chunk.split('\n')

    for (const line of lines) {
      if (line.startsWith('data: ')) {
        const data = JSON.parse(line.slice(6))
        console.log('Progress:', data.percent + '%')
      }
    }
  }
}

{
  "dataset_id": "uuid",
  "natural_language_query": "Show me total sales by month for 2024",
  "conversation_history": [
    {
      "role": "user",
      "content": "What are the top selling categories?"
    },
    {
      "role": "assistant",
      "content": "SELECT category, SUM(amount) as total..."
    }
  ]
}

{
  "sql": "SELECT DATE_TRUNC('month', sale_date) as month, SUM(sale_amount) as total FROM report_data_rows WHERE dataset_id = 'uuid' AND EXTRACT(YEAR FROM sale_date) = 2024 GROUP BY month ORDER BY month",
  "explanation": "This query groups sales by month for 2024 and calculates the total amount for each month.",
  "visualization_suggestion": {
    "chart_type": "line",
    "x_axis": "month",
    "y_axis": "total"
  },
  "tokens_used": 456,
  "validation_warnings": []
}

{
  "error": "Dataset not found or access denied",
  "code": "NOT_FOUND"
}

{
  "error": "Failed to generate SQL query",
  "code": "LLM_ERROR",
  "details": "OpenAI API timeout"
}

{
  "error": "Generated SQL failed validation",
  "code": "VALIDATION_ERROR",
  "details": "Query contains disallowed operation: DROP"
}

async function generateSQL(datasetId: string, query: string) {
  const response = await supabase.functions.invoke('generate-sql', {
    body: {
      dataset_id: datasetId,
      natural_language_query: query,
      conversation_history: []
    }
  })

  if (response.error) {
    throw new Error(response.error.message)
  }

  return response.data
}

// Usage
const result = await generateSQL(
  'dataset-uuid',
  'Show me the top 5 locations by car count'
)

console.log('SQL:', result.sql)
console.log('Chart type:', result.visualization_suggestion.chart_type)

{
  "sql": "SELECT location_name, SUM(car_count) as total FROM report_data_rows WHERE dataset_id = 'uuid' GROUP BY location_name",
  "dataset_id": "uuid",
  "format": "json",
  "cache_key": "optional-cache-key"
}

{
  "data": [
    {"location_name": "North Lot", "total": 4567},
    {"location_name": "South Lot", "total": 3456},
    {"location_name": "East Lot", "total": 2345}
  ],
  "row_count": 3,
  "columns": [
    {"name": "location_name", "type": "text"},
    {"name": "total", "type": "number"}
  ],
  "execution_time_ms": 45,
  "cached": false
}

"location_name","total"
"North Lot",4567
"South Lot",3456
"East Lot",2345

{
  "error": "SQL validation failed",
  "code": "VALIDATION_ERROR",
  "details": "Query contains disallowed operation: DROP"
}

{
  "error": "Rate limit exceeded. Maximum 10 queries per minute.",
  "code": "RATE_LIMITED"
}

{
  "error": "Query execution failed",
  "code": "EXECUTION_ERROR",
  "details": "column \"invalid_column\" does not exist"
}

{
  "notifications": [
    {
      "location_id": "loc-uuid",
      "location_name": "North Lot",
      "tokens": [
        "ExponentPushToken[xxx1]",
        "ExponentPushToken[xxx2]"
      ]
    }
  ],
  "notification_type": "submission_reminder",
  "custom_title": "Submission Reminder",
  "custom_body": "Time to submit count for North Lot"
}

{
  "success": true,
  "sent_at": "2025-01-15T10:30:00.000Z",
  "total_messages": 15,
  "successful": 13,
  "failed": 2,
  "invalid_tokens_removed": 1,
  "errors": [
    "Expo API error (batch 1): DeviceNotRegistered"
  ]
}

{
  "message_id": "msg-uuid",
  "channel_id": "chan-uuid",
  "auction_id": "auction-uuid",
  "sender_id": "sender-uuid",
  "sender_name": "John Doe",
  "content": "Hey @jane, check this out!",
  "channel_name": "general",
  "mentions": ["user-uuid-jane"]
}

{
  "success": true,
  "sent": 5,
  "errors": []
}

curl -X POST 'https://your-project.supabase.co/functions/v1/check-pending-submissions' \
  -H "Authorization: Bearer SERVICE_ROLE_KEY"

{
  "success": true,
  "checked_at": "2025-01-15T10:30:00.000Z",
  "pending_count": 5,
  "notifications_to_send": [
    {
      "location_id": "loc-uuid-1",
      "location_name": "North Lot",
      "minutes_overdue": 45,
      "users": [
        {
          "user_id": "user-uuid",
          "user_name": "John Doe",
          "user_email": "[email protected]",
          "tokens": ["ExponentPushToken[xxx]"]
        }
      ]
    }
  ]
}

-- Schedule check every 15 minutes
SELECT cron.schedule(
  'check-pending-submissions',
  '*/15 * * * *',
  $$
  SELECT net.http_post(
    url := 'https://your-project.supabase.co/functions/v1/check-pending-submissions',
    headers := jsonb_build_object(
      'Authorization', 'Bearer ' || current_setting('app.service_role_key'),
      'Content-Type', 'application/json'
    )
  );
  $$
);

-- View job status
SELECT * FROM cron.job_run_details
WHERE jobid = (SELECT jobid FROM cron.job WHERE jobname = 'check-pending-submissions')
ORDER BY start_time DESC
LIMIT 10;

{
  "auction_id": "auction-uuid",
  "role": "team_member",
  "email": "[email protected]"
}

{
  "invite_link": "https://app.auctionexcellence.com/invite/abc123xyz789",
  "token": "abc123xyz789",
  "expires_at": "2025-01-22T10:30:00.000Z"
}

async function generateInviteLink(auctionId: string, role?: string) {
  const response = await supabase.functions.invoke('generate-invite-link', {
    body: {
      auction_id: auctionId,
      role: role || 'team_member'
    }
  })

  if (response.error) {
    throw new Error(response.error.message)
  }

  return response.data.invite_link
}

// Usage - shareable link (no email)
const link = await generateInviteLink('auction-uuid', 'team_member')
console.log('Share this link:', link)

{
  "invite_id": "invite-uuid"
}

{
  "success": true,
  "message_id": "resend-message-id"
}

{
  "success": false,
  "error": "Invite has expired"
}

{
  "success": false,
  "error": "Invite not found"
}

<!-- Email Preview -->
You've been invited!

John Smith has invited you to join Acme Auto Auction on Auction Excellence.

You'll be joining as a Team Member.

[Accept Invitation]

This invitation expires in 7 days.

// After creating an invite, send the email
async function inviteAndNotify(auctionId: string, email: string, role: string) {
  // 1. Create the invite
  const { data: invite, error } = await supabase.rpc('invite_user_to_auction', {
    p_auction_id: auctionId,
    p_email: email,
    p_role: role
  })

  if (error) throw error

  // 2. Send the email
  const emailResponse = await supabase.functions.invoke('send-invite-email', {
    body: { invite_id: invite[0].invite_id }
  })

  if (emailResponse.error) {
    console.error('Email failed:', emailResponse.error)
  }

  return invite[0]
}