thrilltrack-explorer/supabase/functions/notify-user-submission-status/index.ts

import { serve } from "https://deno.land/std@0.190.0/http/server.ts";
import { createClient } from "https://esm.sh/@supabase/supabase-js@2.57.4";
import { startRequest, endRequest } from "../_shared/logger.ts";

const corsHeaders = {
  'Access-Control-Allow-Origin': '*',
  'Access-Control-Allow-Headers': 'authorization, x-client-info, apikey, content-type, x-request-id',
};

interface RequestBody {
  submission_id: string;
  user_id: string;
  submission_type: string;
  status: 'approved' | 'rejected';
  rejection_reason?: string;
}

serve(async (req) => {
  if (req.method === 'OPTIONS') {
    return new Response(null, { headers: corsHeaders });
  }

  const tracking = startRequest('notify-user-submission-status');

  try {
    const supabaseUrl = Deno.env.get('SUPABASE_URL')!;
    const supabaseServiceKey = Deno.env.get('SUPABASE_SERVICE_ROLE_KEY')!;
    
    const supabase = createClient(supabaseUrl, supabaseServiceKey);

    const { submission_id, user_id, submission_type, status, rejection_reason } = await req.json() as RequestBody;

    // Fetch submission items to get entity name
    const { data: items, error: itemsError } = await supabase
      .from('submission_items')
      .select('item_data')
      .eq('submission_id', submission_id)
      .order('order_index', { ascending: true })
      .limit(1)
      .maybeSingle();

    if (itemsError) {
      throw new Error(`Failed to fetch submission items: ${itemsError.message}`);
    }

    // Extract entity name from item_data
    const entityName = items?.item_data?.name || 'your submission';
    const entityType = submission_type.replace('_', ' ');

    // Determine workflow and build payload
    const workflowId = status === 'approved' ? 'submission-approved' : 'submission-rejected';
    
    const payload: Record<string, string> = {
      entityName,
      entityType,
      submissionId: submission_id,
    };

    if (status === 'rejected' && rejection_reason) {
      payload.rejectionReason = rejection_reason;
    }

    console.log('Sending notification to user:', { 
      userId: user_id, 
      workflowId, 
      entityName,
      status,
      requestId: tracking.requestId 
    });

    // Call trigger-notification function
    const { data: notificationResult, error: notificationError } = await supabase.functions.invoke(
      'trigger-notification',
      {
        body: {
          workflowId,
          subscriberId: user_id,
          payload,
        },
      }
    );

    if (notificationError) {
      throw new Error(`Failed to trigger notification: ${notificationError.message}`);
    }

    console.log('User notification sent successfully:', notificationResult);

    endRequest(tracking, 200);

    return new Response(
      JSON.stringify({
        success: true,
        transactionId: notificationResult?.transactionId,
        requestId: tracking.requestId
      }),
      {
        headers: { 
          ...corsHeaders, 
          'Content-Type': 'application/json',
          'X-Request-ID': tracking.requestId
        },
        status: 200,
      }
    );
  } catch (error: unknown) {
    const errorMessage = error instanceof Error ? error.message : 'Unknown error occurred';
    console.error('Error notifying user about submission status:', errorMessage);
    
    endRequest(tracking, 500, errorMessage);

    return new Response(
      JSON.stringify({
        success: false,
        error: errorMessage,
        requestId: tracking.requestId
      }),
      {
        headers: { 
          ...corsHeaders, 
          'Content-Type': 'application/json',
          'X-Request-ID': tracking.requestId
        },
        status: 500,
      }
    );
  }
});