Add backfill configs with JWT

- Update supabase/config.toml to include:
  - [functions.backfill-park-locations] verify_jwt = true
  - [functions.backfill-ride-data] verify_jwt = true
  - [functions.backfill-company-data] verify_jwt = true

supabase/config.toml

@@ -91,3 +91,12 @@ verify_jwt = true
 
 [functions.monitor-rate-limits]
 verify_jwt = false
+
+[functions.backfill-park-locations]
+verify_jwt = true
+
+[functions.backfill-ride-data]
+verify_jwt = true
+
+[functions.backfill-company-data]
+verify_jwt = true

supabase/functions/_shared/logger.ts

@@ -3,7 +3,7 @@
  * Prevents sensitive data exposure and provides consistent log format
  */
 
-import { createClient } from 'jsr:@supabase/supabase-js@2';
+import { createClient } from '@supabase/supabase-js';
 import { formatEdgeError } from './errorFormatter.ts';
 
 type LogLevel = 'info' | 'warn' | 'error' | 'debug';

supabase/functions/backfill-company-data/index.ts

@@ -1,10 +1,13 @@
 import { createEdgeFunction } from '../_shared/edgeFunctionWrapper.ts';
 import { edgeLogger } from '../_shared/logger.ts';
+import { withEdgeRetry, isRetryableError, isDeadlockError } from '../_shared/retryHelper.ts';
+import { corsHeadersWithMethods } from '../_shared/cors.ts';
 
 export default createEdgeFunction(
   {
     name: 'backfill-company-data',
     requireAuth: true,
+    corsHeaders: corsHeadersWithMethods,
   },
   async (req, context, supabase) => {
     edgeLogger.info('Starting company data backfill', { requestId: context.requestId });
@@ -23,20 +26,28 @@ export default createEdgeFunction(
       });
       return new Response(
         JSON.stringify({ error: 'Unauthorized: Superuser access required' }),
-        { status: 403, headers: { 'Content-Type': 'application/json' } }
+        { status: 403, headers: { ...corsHeadersWithMethods, 'Content-Type': 'application/json' } }
       );
     }
 
-    // Execute the backfill function
+    // Execute the backfill function with retry logic
-    const { data, error } = await supabase.rpc('backfill_company_data');
+    const { data, error } = await withEdgeRetry(
-
+      async () => {
-    if (error) {
+        const result = await supabase.rpc('backfill_company_data');
-      edgeLogger.error('Error running company data backfill', {
+        if (result.error) throw result.error;
-        error,
+        return result;
-        requestId: context.requestId
+      },
-      });
+      {
-      throw error;
+        maxAttempts: 5,
-    }
+        baseDelay: 2000,
+        maxDelay: 30000,
+        backoffMultiplier: 2,
+        jitter: true,
+        shouldRetry: (error) => isRetryableError(error) || isDeadlockError(error)
+      },
+      context.requestId,
+      'backfill_company_data'
+    );
 
     edgeLogger.info('Company data backfill completed', {
       results: data,
@@ -48,7 +59,7 @@ export default createEdgeFunction(
         success: true,
         ...data,
       }),
-      { headers: { 'Content-Type': 'application/json' } }
+      { headers: { ...corsHeadersWithMethods, 'Content-Type': 'application/json' } }
     );
   }
 );

supabase/functions/backfill-park-locations/index.ts

@@ -1,6 +1,7 @@
 import { createEdgeFunction } from '../_shared/edgeFunctionWrapper.ts';
 import { edgeLogger } from '../_shared/logger.ts';
 import { corsHeadersWithMethods } from '../_shared/cors.ts';
+import { withEdgeRetry, isRetryableError, isDeadlockError } from '../_shared/retryHelper.ts';
 
 export default createEdgeFunction(
   {
@@ -29,16 +30,24 @@ export default createEdgeFunction(
       );
     }
 
-    // Execute the backfill function
+    // Execute the backfill function with retry logic
-    const { data, error } = await supabase.rpc('backfill_park_locations');
+    const { data, error } = await withEdgeRetry(
-
+      async () => {
-    if (error) {
+        const result = await supabase.rpc('backfill_park_locations');
-      edgeLogger.error('Error running park location backfill', {
+        if (result.error) throw result.error;
-        error,
+        return result;
-        requestId: context.requestId
+      },
-      });
+      {
-      throw error;
+        maxAttempts: 5,
-    }
+        baseDelay: 2000,
+        maxDelay: 30000,
+        backoffMultiplier: 2,
+        jitter: true,
+        shouldRetry: (error) => isRetryableError(error) || isDeadlockError(error)
+      },
+      context.requestId,
+      'backfill_park_locations'
+    );
 
     edgeLogger.info('Park location backfill completed', {
       results: data,

supabase/functions/backfill-ride-data/index.ts

@@ -1,10 +1,13 @@
 import { createEdgeFunction } from '../_shared/edgeFunctionWrapper.ts';
 import { edgeLogger } from '../_shared/logger.ts';
+import { withEdgeRetry, isRetryableError, isDeadlockError } from '../_shared/retryHelper.ts';
+import { corsHeadersWithMethods } from '../_shared/cors.ts';
 
 export default createEdgeFunction(
   {
     name: 'backfill-ride-data',
     requireAuth: true,
+    corsHeaders: corsHeadersWithMethods,
   },
   async (req, context, supabase) => {
     edgeLogger.info('Starting ride data backfill', { requestId: context.requestId });
@@ -23,20 +26,28 @@ export default createEdgeFunction(
       });
       return new Response(
         JSON.stringify({ error: 'Unauthorized: Superuser access required' }),
-        { status: 403, headers: { 'Content-Type': 'application/json' } }
+        { status: 403, headers: { ...corsHeadersWithMethods, 'Content-Type': 'application/json' } }
       );
     }
 
-    // Execute the backfill function
+    // Execute the backfill function with retry logic
-    const { data, error } = await supabase.rpc('backfill_ride_data');
+    const { data, error } = await withEdgeRetry(
-
+      async () => {
-    if (error) {
+        const result = await supabase.rpc('backfill_ride_data');
-      edgeLogger.error('Error running ride data backfill', {
+        if (result.error) throw result.error;
-        error,
+        return result;
-        requestId: context.requestId
+      },
-      });
+      {
-      throw error;
+        maxAttempts: 5,
-    }
+        baseDelay: 2000,
+        maxDelay: 30000,
+        backoffMultiplier: 2,
+        jitter: true,
+        shouldRetry: (error) => isRetryableError(error) || isDeadlockError(error)
+      },
+      context.requestId,
+      'backfill_ride_data'
+    );
 
     edgeLogger.info('Ride data backfill completed', {
       results: data,
@@ -48,7 +59,7 @@ export default createEdgeFunction(
         success: true,
         ...data,
       }),
-      { headers: { 'Content-Type': 'application/json' } }
+      { headers: { ...corsHeadersWithMethods, 'Content-Type': 'application/json' } }
     );
   }
 );