fix(queue-status): read most-recent-success from the Redis it is written to (firecrawl#3819)

The scrape worker writes most-recent-success:{team_id} via
redisEvictConnection (REDIS_EVICT_URL ?? REDIS_RATE_LIMIT_URL), but the
v1/v2 queue-status controllers read it via getRedisConnection()
(REDIS_URL). In production these are separate Redis instances, so the
key is never visible to the reader and mostRecentSuccess is always
returned as null even while jobs are succeeding.

Read the key from redisEvictConnection so the value is fetched from the
same instance it is written to.

Co-authored-by: firecrawl-spring[bot] <254786068+firecrawl-spring[bot]@users.noreply.github.com>
Co-authored-by: micahstairs <micah@sideguide.dev>

Author: firecrawl-spring[bot]

apps/api/src/controllers/v1/queue-status.ts

@@ -2,7 +2,7 @@ import { RateLimiterMode } from "../../types";
 import { getACUCTeam } from "../auth";
 import { AuthCreditUsageChunkFromTeam, RequestWithAuth } from "./types";
 import { Response } from "express";
-import { getRedisConnection } from "../../services/queue-service";
+import { redisEvictConnection } from "../../services/redis";
 import { isFdbTeam } from "../../services/worker/nuq-router";
 import {
   nuqFdbHealthCheck,
@@ -82,7 +82,10 @@ export async function queueStatusController(
     }
   }
 
-  const mostRecentSuccess = await getRedisConnection().get(
+  // most-recent-success is written by the scrape worker via redisEvictConnection
+  // (REDIS_EVICT_URL), which is a different instance from getRedisConnection()
+  // (REDIS_URL). Read it from the same connection it is written to.
+  const mostRecentSuccess = await redisEvictConnection.get(
     "most-recent-success:" + req.auth.team_id,
   );
 

apps/api/src/controllers/v2/queue-status.ts

@@ -3,7 +3,7 @@ import { getACUCTeam } from "../auth";
 import { RequestWithAuth } from "./types";
 import { AuthCreditUsageChunkFromTeam } from "../v1/types";
 import { Response } from "express";
-import { getRedisConnection } from "../../services/queue-service";
+import { redisEvictConnection } from "../../services/redis";
 import { isFdbTeam } from "../../services/worker/nuq-router";
 import {
   nuqFdbHealthCheck,
@@ -83,7 +83,10 @@ export async function queueStatusController(
     }
   }
 
-  const mostRecentSuccess = await getRedisConnection().get(
+  // most-recent-success is written by the scrape worker via redisEvictConnection
+  // (REDIS_EVICT_URL), which is a different instance from getRedisConnection()
+  // (REDIS_URL). Read it from the same connection it is written to.
+  const mostRecentSuccess = await redisEvictConnection.get(
     "most-recent-success:" + req.auth.team_id,
   );