test fixes

src/services/aiService.server.ts

@@ -23,6 +23,7 @@ import * as db from './db/index.db';
 import { flyerQueue } from './queueService.server';
 import type { Job } from 'bullmq';
 import { createFlyerAndItems } from './db/flyer.db';
+import { getBaseUrl } from '../utils/serverUtils';
 import { generateFlyerIcon } from '../utils/imageProcessor';
 import path from 'path';
 import { ValidationError } from './db/errors.db'; // Keep this import for ValidationError
@@ -824,6 +825,8 @@ async enqueueFlyerProcessing(
         .join(', ');
     }
 
+    const baseUrl = getBaseUrl(logger);
+
     // 3. Add job to the queue
     const job = await flyerQueue.add('process-flyer', {
       filePath: file.path,
@@ -832,6 +835,7 @@ async enqueueFlyerProcessing(
       userId: userProfile?.user.user_id,
       submitterIp: submitterIp,
       userProfileAddress: userProfileAddress,
+      baseUrl: baseUrl,
     });
 
     logger.info(
@@ -926,20 +930,7 @@ async enqueueFlyerProcessing(
     const iconsDir = path.join(path.dirname(file.path), 'icons');
     const iconFileName = await generateFlyerIcon(file.path, iconsDir, logger);
 
-    // Construct proper URLs including protocol and host to satisfy DB constraints.
-    let baseUrl = (process.env.FRONTEND_URL || process.env.BASE_URL || '').trim();
-    if (!baseUrl || !baseUrl.startsWith('http')) {
-      const port = process.env.PORT || 3000;
-      const fallbackUrl = `http://localhost:${port}`;
-      if (baseUrl) {
-        logger.warn(
-          `FRONTEND_URL/BASE_URL is invalid or incomplete ('${baseUrl}'). Falling back to default local URL: ${fallbackUrl}`,
-        );
-      }
-      baseUrl = fallbackUrl;
-    }
-    baseUrl = baseUrl.endsWith('/') ? baseUrl.slice(0, -1) : baseUrl;
-
+    const baseUrl = getBaseUrl(logger);
     const iconUrl = `${baseUrl}/flyer-images/icons/${iconFileName}`;
     const imageUrl = `${baseUrl}/flyer-images/${file.filename}`;