feat: surface pricing job failures

apps/api/src/app/server.js

@@ -144,6 +144,7 @@ async function startServer() {
       saleService: createSaleService({ saleRepository }),
       acquisitionService: createAcquisitionService({ acquisitionRepository }),
       pricingRepository,
+      pricingRefreshJobRepository,
     }),
     pricingService: createPricingService({ pricingRepository, pricingRefreshJobRepository, providerMappingRepository, pricingProviderRegistry: pricingProviders }),
     providerMappingService: createProviderMappingService({ providerMappingRepository }),

apps/api/src/modules/dashboard/services/dashboard-service.js

@@ -1,13 +1,14 @@
-export function createDashboardService({ productService, inventoryItemService, listingService, saleService, acquisitionService, pricingRepository }) {
+export function createDashboardService({ productService, inventoryItemService, listingService, saleService, acquisitionService, pricingRepository, pricingRefreshJobRepository }) {
   return {
     async get({ sellerId }) {
-      const [products, inventory, listings, sales, acquisitions, valuations] = await Promise.all([
+      const [products, inventory, listings, sales, acquisitions, valuations, failedPricingJobs] = await Promise.all([
         productService.listBySellerId(sellerId),
         inventoryItemService.listBySellerId(sellerId),
         listingService.list({ sellerId }),
         saleService.list({ sellerId }),
         acquisitionService.list({ sellerId }),
         pricingRepository?.listLatestValuationsForSeller(sellerId) ?? [],
+        pricingRefreshJobRepository?.countFailedForSeller(sellerId) ?? 0,
       ]);
 
       const activeListings = listings.filter(({ status }) => ['AVAILABLE', 'PENDING'].includes(status));
@@ -28,6 +29,7 @@ export function createDashboardService({ productService, inventoryItemService, l
           missingImages: listings.filter(({ imageCount }) => imageCount < 1).length,
           missingPricing: inventory.filter(({ id }) => !valuationByItem.has(id)).length,
           stalePricing: valuations.filter(({ calculatedAt }) => Date.now() - new Date(calculatedAt).getTime() > staleThreshold).length,
+          failedPricingJobs,
         },
         financials: {
           totalAcquisitionCostMinor: total(acquisitions, 'costBasisMinor'),

apps/api/src/modules/pricing/repositories/pricing-refresh-job-repository.js

@@ -31,6 +31,13 @@ export function createPricingRefreshJobRepository(db) {
       return job ?? null;
     },
 
+    async countFailedForSeller(sellerId) {
+      const rows = await db.select({ id: pricingRefreshJobs.id })
+        .from(pricingRefreshJobs)
+        .where(and(eq(pricingRefreshJobs.sellerId, sellerId), eq(pricingRefreshJobs.status, 'FAILED')));
+      return rows.length;
+    },
+
     async complete(id, observations, valuation) {
       const [completed] = await db.update(pricingRefreshJobs)
         .set({ status: 'COMPLETED', observations, valuation, error: null, updatedAt: new Date() })