seed-emails

POST /functions/v1/seed-emails

curl -i --location --request POST \
  'https://your-project.supabase.co/functions/v1/seed-emails' \
  --header 'Authorization: Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9...' \
  --header 'Content-Type: application/json' \
  --data '{
    "connectionId": "550e8400-e29b-41d4-a716-446655440000"
  }'

curl -i --location --request POST \
  'https://your-project.supabase.co/functions/v1/seed-emails' \
  --header 'Authorization: Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9...' \
  --header 'Content-Type: application/json' \
  --data '{
    "seedId": "123e4567-e89b-12d3-a456-426614174000",
    "resume": true
  }'

{
  "seedId": "123e4567-e89b-12d3-a456-426614174000",
  "status": "processing",
  "done": false,
  "processed": 30,
  "transactions": 5,
  "total": 450
}

{
  "done": false,
  "processed": 60,
  "transactions": 12,
  "total": 450
}

{
  "done": true,
  "processed": 450,
  "transactions": 87,
  "total": 450
}

{
  "message": "No messages found",
  "totalMessages": 0
}

{
  "error": "Missing connectionId parameter"
}

{
  "error": "Seed not found or unauthorized"
}

{
  "error": "Connection not found or unauthorized"
}

{
  "error": "Method not allowed"
}

{
  "error": "A seed is already in progress",
  "seedId": "123e4567-e89b-12d3-a456-426614174000"
}

{
  "error": "Gmail authentication expired or invalid",
  "code": "GMAIL_RECONNECT_REQUIRED",
  "reconnectRequired": true
}

{
  "error": "Failed to create seed"
}

{
  "error": "Failed to process seed chunk"
}

{
  "error": "Internal server error"
}

GET https://www.googleapis.com/gmail/v1/users/me/messages
  ?q=after:{YYYY/MM/DD}
  &pageToken={optional}

{
  user_id: string,
  user_oauth_token_id: string,
  status: 'processing',
  message_ids: string[],        // All message IDs to process
  total_emails: number,
  last_processed_index: 0,
  transactions_found: 0,
  emails_processed_by_ai: 0
}

fetch(`${supabaseUrl}/functions/v1/seed-emails`, {
  method: 'POST',
  headers: {
    'Content-Type': 'application/json',
    'Authorization': `Bearer ${authToken}`,
  },
  body: JSON.stringify({ seedId, resume: true }),
})

{
  last_processed_index: number,
  emails_processed_by_ai: number,
  transactions_found: number,
  status: 'processing' | 'completed'
}

for (let i = 0; i < chunk.length; i += 10) {
  const batch = chunk.slice(i, i + 10)
  await Promise.all(batch.map(processMessage))
}

{
  user_id: string,
  user_oauth_token_id: string,
  source_email: string,
  source_message_id: string,
  date: string,
  amount: number,
  currency: string,
  transaction_type: string,
  transaction_description: string,
  transaction_date: string,
  merchant: string,
  category: string
}

{
  user_oauth_token_id: string,
  message_id: string,
  reason: string  // AI reasoning
}

const threeMonthsAgo = new Date()
threeMonthsAgo.setMonth(threeMonthsAgo.getMonth() - 3)
const afterDate = threeMonthsAgo.toISOString().split('T')[0].replace(/-/g, '/')
// Results in: "2024/12/04" for query "after:2024/12/04"

{
  typeKey: 'seed_completed_with_transactions',
  actionPath: '/transactions',
  iconKey: 'mail',
  i18nParams: {
    count: number,
    totalEmails: number
  }
}

{
  typeKey: 'seed_completed_no_new',
  actionPath: '/transactions',
  iconKey: 'mail',
  i18nParams: {
    count: 0,
    totalEmails: number
  }
}

{
  typeKey: 'seed_failed',
  actionPath: '/settings',
  iconKey: 'alert',
  i18nParams: {
    reason: string
  },
  metadata: {
    seedId: string,
    stage: 'initial' | 'resume'
  }
}

await ensureFreshAccessToken(supabase, tokenData, 'seed_chunk')

fetch(url, options).catch(err => console.error('Auto-invoke failed:', err))

const { data: userData } = await supabase.auth.admin.getUserById(userId)
const userFullName = userData?.user?.user_metadata?.full_name