Preserve Supabase bucket routing for legacy storage paths

.env.example

@@ -26,6 +26,9 @@ INPUT_BUCKET=relv-turnitin-inputs
 REPORT_BUCKET=relv-turnitin-reports
 DIAGNOSTICS_BUCKET=relv-turnitin-diagnostics
 SESSION_BUCKET=relv-turnitin-sessions
+SUPABASE_INPUT_BUCKET=turnitin-inputs
+SUPABASE_REPORT_BUCKET=turnitin-reports
+SUPABASE_SESSION_BUCKET=turnitin-sessions
 R2_ACCOUNT_ID=
 R2_ACCESS_KEY_ID=
 R2_SECRET_ACCESS_KEY=

src/config.ts

@@ -28,6 +28,14 @@ export const config = {
   reportBucket: process.env.REPORT_BUCKET || 'turnitin-reports',
   diagnosticsBucket: process.env.DIAGNOSTICS_BUCKET || 'turnitin-diagnostics',
   sessionBucket: process.env.SESSION_BUCKET || 'turnitin-sessions',
+  // Plain storage paths were created before R2 and must always resolve
+  // against the original Supabase bucket names after the R2 switch.
+  supabaseInputBucket:
+    process.env.SUPABASE_INPUT_BUCKET || 'turnitin-inputs',
+  supabaseReportBucket:
+    process.env.SUPABASE_REPORT_BUCKET || 'turnitin-reports',
+  supabaseSessionBucket:
+    process.env.SUPABASE_SESSION_BUCKET || 'turnitin-sessions',
   r2AccountId: process.env.R2_ACCOUNT_ID || '',
   r2AccessKeyId: process.env.R2_ACCESS_KEY_ID || '',
   r2SecretAccessKey: process.env.R2_SECRET_ACCESS_KEY || '',

src/db/storage.ts

@@ -45,7 +45,7 @@ export async function uploadInputFile(
   }
 
   const { error } = await supabase.storage
-    .from(config.inputBucket)
+    .from(config.supabaseInputBucket)
     .upload(storagePath, fileBuffer, {
       contentType: getMimeType(ext),
       upsert,
@@ -94,7 +94,7 @@ export async function uploadInputFileFromPath(
   // legacy objects/deployments; R2 is the configured destination for new jobs.
   const fileBuffer = await fs.promises.readFile(localPath);
   const { error } = await supabase.storage
-    .from(config.inputBucket)
+    .from(config.supabaseInputBucket)
     .upload(storagePath, fileBuffer, {
       contentType: getMimeType(ext),
       upsert,
@@ -126,7 +126,7 @@ export async function downloadInputFile(storagePath: string, localPath: string):
   }
 
   const { data, error } = await supabase.storage
-    .from(config.inputBucket)
+    .from(config.supabaseInputBucket)
     .download(storagePath);
 
   if (error) {
@@ -150,7 +150,7 @@ export async function deleteInputFile(storagePath: string): Promise<void> {
   }
 
   const { error } = await supabase.storage
-    .from(config.inputBucket)
+    .from(config.supabaseInputBucket)
     .remove([storagePath]);
   if (error) {
     logger.error('Failed to delete staged input file', {
@@ -196,7 +196,7 @@ export async function uploadReportPdf(
   const fileBuffer = fs.readFileSync(localPdfPath);
 
   const { error } = await supabase.storage
-    .from(config.reportBucket)
+    .from(config.supabaseReportBucket)
     .upload(storagePath, fileBuffer, {
       contentType: 'application/pdf',
       upsert: true,
@@ -245,7 +245,7 @@ export async function uploadReceiptPdf(
   const fileBuffer = fs.readFileSync(localPdfPath);
 
   const { error } = await supabase.storage
-    .from(config.reportBucket)
+    .from(config.supabaseReportBucket)
     .upload(storagePath, fileBuffer, {
       contentType: 'application/pdf',
       upsert: true,
@@ -280,7 +280,7 @@ export async function deleteReportPdf(storagePath: string): Promise<void> {
   }
 
   const { error } = await supabase.storage
-    .from(config.reportBucket)
+    .from(config.supabaseReportBucket)
     .remove([storagePath]);
 
   if (error) {
@@ -317,7 +317,7 @@ export async function uploadStorageState(
   }
 
   const { error } = await supabase.storage
-    .from(config.sessionBucket)
+    .from(config.supabaseSessionBucket)
     .upload(storagePath, Buffer.from(stateJson, 'utf-8'), {
       contentType: 'application/json',
       upsert: true,
@@ -349,7 +349,7 @@ export async function downloadStorageState(storagePath: string): Promise<string
   }
 
   const { data, error } = await supabase.storage
-    .from(config.sessionBucket)
+    .from(config.supabaseSessionBucket)
     .download(storagePath);
 
   if (error) {
@@ -390,8 +390,16 @@ export async function createSignedUrl(
     }
   }
 
+  const legacyBucket =
+    bucket === config.reportBucket
+      ? config.supabaseReportBucket
+      : bucket === config.inputBucket
+        ? config.supabaseInputBucket
+        : bucket === config.sessionBucket
+          ? config.supabaseSessionBucket
+          : bucket;
   const { data, error } = await supabase.storage
-    .from(bucket)
+    .from(legacyBucket)
     .createSignedUrl(
       filePath,
       expiresInSeconds,