Fix code review items: atomic qty increment, unit updatedAt, suppliers/all endpoint, SKU unique index

packages/backend/src/db/migrations/0038_product_sku_unique.sql

@@ -0,0 +1,2 @@
+-- Add unique index on products.sku (null values are excluded from uniqueness)
+CREATE UNIQUE INDEX IF NOT EXISTS products_sku_unique ON product (sku) WHERE sku IS NOT NULL;

packages/backend/src/routes/v1/inventory.ts

@@ -73,6 +73,11 @@ export const inventoryRoutes: FastifyPluginAsync = async (app) => {
     return reply.send(result)
   })
 
+  app.get('/suppliers/all', { preHandler: [app.authenticate, app.requirePermission('inventory.view')] }, async (request, reply) => {
+    const rows = await SupplierService.listAll(app.db)
+    return reply.send({ data: rows })
+  })
+
   app.get('/suppliers/:id', { preHandler: [app.authenticate, app.requirePermission('inventory.view')] }, async (request, reply) => {
     const { id } = request.params as { id: string }
     const supplier = await SupplierService.getById(app.db, id)

packages/backend/src/services/inventory.service.ts

@@ -131,6 +131,14 @@ export const SupplierService = {
     return paginatedResponse(data, total, params.page, params.limit)
   },
 
+  async listAll(db: PostgresJsDatabase<any>) {
+    return db
+      .select()
+      .from(suppliers)
+      .where(eq(suppliers.isActive, true))
+      .orderBy(suppliers.name)
+  },
+
   async update(db: PostgresJsDatabase<any>, id: string, input: SupplierUpdateInput) {
     const [supplier] = await db
       .update(suppliers)

packages/backend/src/services/product.service.ts

@@ -225,7 +225,7 @@ export const InventoryUnitService = {
       if (!valid) throw new ValidationError(`Invalid status: "${input.status}"`)
     }
 
-    const updates: Record<string, unknown> = { ...input }
+    const updates: Record<string, unknown> = { ...input, updatedAt: new Date() }
     if (input.purchaseCost !== undefined) updates.purchaseCost = input.purchaseCost.toString()
 
     const [unit] = await db
@@ -317,14 +317,11 @@ export const StockReceiptService = {
       })
       .returning()
 
-    // For non-serialized products, increment qty_on_hand
-    const [product] = await db.select().from(products).where(eq(products.id, productId)).limit(1)
-    if (product && !product.isSerialized) {
-      await db
-        .update(products)
-        .set({ qtyOnHand: product.qtyOnHand + input.qty, updatedAt: new Date() })
-        .where(eq(products.id, productId))
-    }
+    // For non-serialized products, increment qty_on_hand atomically
+    await db
+      .update(products)
+      .set({ qtyOnHand: sql`${products.qtyOnHand} + ${input.qty}`, updatedAt: new Date() })
+      .where(and(eq(products.id, productId), eq(products.isSerialized, false)))
 
     return receipt
   },