Function uploadAndSaveFile

frontend-workflow/src/services/fileService.ts:56–108

(
  blob: Blob,
  fileName: string,
  workflowType: string
)

}

export async function uploadAndSaveFile(
  blob: Blob,
  fileName: string,
  workflowType: string
): Promise<FileRecord | null> {
  try {
    const session = isSupabaseConfigured()
      ? (await supabase.auth.getSession()).data.session
      : null;
    if (isSupabaseConfigured() && !session?.access_token) {
      console.warn("[fileService] Skipping file upload because user is not authenticated");
      return null;
    }

    const sanitizedFileName = sanitizeFileName(fileName, workflowType);
    console.log(`[fileService] Original filename: ${fileName}`);
    console.log(`[fileService] Sanitized filename: ${sanitizedFileName}`);

    const formData = new FormData();
    formData.append('file', blob, sanitizedFileName);
    formData.append('workflow_type', workflowType);

    const response = await backendFetch('/api/v1/files/upload', {
      method: 'POST',
      body: formData,
    });

    if (!response.ok) {
      const errorText = await response.text();
      console.error("[fileService] Failed to upload file:", errorText);
      return null;
    }

    const data = await response.json();

    if (!data.success) {
      console.error("[fileService] Upload failed:", data);
      return null;
    }

    return {
      id: data.file_path, // Use file path as ID
      file_name: data.file_name,
      file_size: data.file_size,
      workflow_type: data.workflow_type,
      created_at: data.created_at,
      download_url: data.file_path, // Backend will serve via /outputs
    };
  } catch (err) {
    console.error("[fileService] Error uploading file:", err);
    return null;
  }
}

/**
 * Get all file records for the current user.