ci: Bump version to 0.6.5 [skip ci]

package-lock.json

@@ -1,12 +1,12 @@
 {
   "name": "flyer-crawler",
-  "version": "0.6.3",
+  "version": "0.6.5",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "flyer-crawler",
-      "version": "0.6.3",
+      "version": "0.6.5",
       "dependencies": {
         "@bull-board/api": "^6.14.2",
         "@bull-board/express": "^6.14.2",

package.json

@@ -1,7 +1,7 @@
 {
   "name": "flyer-crawler",
   "private": true,
-  "version": "0.6.3",
+  "version": "0.6.5",
   "type": "module",
   "scripts": {
     "dev": "concurrently \"npm:start:dev\" \"vite\"",

src/hooks/useFlyerUploader.ts

@@ -106,7 +106,10 @@ export const useFlyerUploader = () => {
   // Consolidate state derivation for the UI from the react-query hooks using useMemo.
   // This improves performance by memoizing the derived state and makes the logic easier to follow.
   const { processingState, errorMessage, duplicateFlyerId, flyerId, statusMessage } = useMemo(() => {
+    // The order of these checks is critical. Errors must be checked first to override
+    // any stale `jobStatus` from a previous successful poll.
     const state: ProcessingState = (() => {
+      if (uploadMutation.isError || pollError) return 'error';
       if (uploadMutation.isPending) return 'uploading';
       if (jobStatus && (jobStatus.state === 'active' || jobStatus.state === 'waiting'))
         return 'polling';
@@ -114,7 +117,6 @@ export const useFlyerUploader = () => {
         if (!jobStatus.returnValue?.flyerId) return 'error';
         return 'completed';
       }
-      if (uploadMutation.isError || jobStatus?.state === 'failed' || pollError) return 'error';
       return 'idle';
     })();
 

src/tests/integration/flyer-processing.integration.test.ts

@@ -82,6 +82,7 @@ describe('Flyer Processing Background Job Integration Test', () => {
     let jobStatus;
     const maxRetries = 30; // Poll for up to 90 seconds (30 * 3s)
     for (let i = 0; i < maxRetries; i++) {
+      console.log(`Polling attempt ${i + 1}...`);
       await new Promise((resolve) => setTimeout(resolve, 3000)); // Wait 3 seconds between polls
       const statusReq = request.get(`/api/ai/jobs/${jobId}/status`);
       if (token) {
@@ -89,6 +90,7 @@ describe('Flyer Processing Background Job Integration Test', () => {
       }
       const statusResponse = await statusReq;
       jobStatus = statusResponse.body;
+      console.log(`Job status: ${JSON.stringify(jobStatus)}`);
       if (jobStatus.state === 'completed' || jobStatus.state === 'failed') {
         break;
       }

src/tests/utils/cleanup.ts

@@ -43,8 +43,6 @@ export const cleanupDb = async (ids: TestResourceIds) => {
       await pool.query('DELETE FROM public.user_watched_items WHERE user_id = ANY($1::uuid[])', [userIds]);
       await pool.query('DELETE FROM public.user_achievements WHERE user_id = ANY($1::uuid[])', [userIds]);
       await pool.query('DELETE FROM public.activity_log WHERE user_id = ANY($1::uuid[])', [userIds]);
-      await pool.query('DELETE FROM public.user_refresh_tokens WHERE user_id = ANY($1::uuid[])', [userIds]);
-      await pool.query('DELETE FROM public.password_reset_tokens WHERE user_id = ANY($1::uuid[])', [userIds]);
     }
 
     // --- Stage 2: Delete parent records that other things depend on ---