@@ -307,7 +328,7 @@ export default function UniversalSearchPage() {
)}
-
+
))}
diff --git a/src/lib/server/universal-search-service.ts b/src/lib/server/universal-search-service.ts
index c1907f2..6f4e8a1 100644
--- a/src/lib/server/universal-search-service.ts
+++ b/src/lib/server/universal-search-service.ts
@@ -605,6 +605,135 @@ async function searchReferenceCollection
>(
};
}
+/**
+ * Stock purchase orders.
+ *
+ * Matching the header number alone made these effectively unfindable by
+ * anything a person actually remembers: live probe showed "saw chain",
+ * "protech" and product descriptions returning ZERO Stock Orders hits
+ * while only the literal `PO26101404STK` matched. An operator hunting a
+ * stock order thinks in product or supplier, not in our internal
+ * sequence number, so the source now matches:
+ * - purchase_number / status (header)
+ * - supplier name (resolved from `supplier` on the header)
+ * - every line's description / sku / supplier_sku / product_code
+ *
+ * The whole collection is small (165 headers, a few hundred lines), so
+ * this loads it into the shared reference cache and matches in memory
+ * rather than doing the chunked id dance the orders source needs.
+ */
+async function searchStockPurchases(
+ pb: AdminPocketBase,
+ ql: string,
+): Promise {
+ const headers = await loadReferenceRows>(
+ pb,
+ "stock_purchases",
+ "id,purchase_number,status,supplier",
+ );
+ if (headers.length === 0) {
+ return { type: "stock_purchase", label: "Stock Orders", hits: [], total: 0, truncated: false };
+ }
+
+ const lines = await loadReferenceRows>(
+ pb,
+ "stock_purchase_items",
+ "id,purchase,description,sku,supplier_sku,product_code",
+ );
+ const supplierIds = Array.from(
+ new Set(headers.map((h) => String(h.supplier ?? "")).filter(Boolean)),
+ );
+ const supplierNames = await fetchSupplierNameMap(pb, supplierIds);
+
+ const linesByPurchase = new Map[]>();
+ for (const line of lines) {
+ const key = String(line.purchase ?? "");
+ if (!key) continue;
+ const bucket = linesByPurchase.get(key);
+ if (bucket) bucket.push(line);
+ else linesByPurchase.set(key, [line]);
+ }
+
+ const scored: { hit: UniversalHit; score: number }[] = [];
+ for (const header of headers) {
+ const id = String(header.id);
+ const poLines = linesByPurchase.get(id) ?? [];
+ const supplierName = supplierNames.get(String(header.supplier ?? ""));
+
+ let score = bestScore(
+ [
+ [String(header.purchase_number ?? ""), "id"],
+ [supplierName, "name"],
+ [String(header.status ?? ""), "body"],
+ ],
+ ql,
+ );
+ // Label the surface that ACTUALLY matched, not just "a header
+ // matched" — a hit tagged "PO number" when the query was a supplier
+ // name tells the operator the tag is noise and stops them trusting
+ // any of them.
+ let matchedOn: string | undefined;
+ if (score > 0) {
+ matchedOn = scoreField(String(header.purchase_number ?? ""), ql, "id") > 0
+ ? "PO number"
+ : scoreField(supplierName, ql, "name") > 0
+ ? "supplier"
+ : "status";
+ }
+
+ if (score === 0) {
+ for (const line of poLines) {
+ const s = bestScore(
+ [
+ [String(line.sku ?? ""), "id"],
+ [String(line.supplier_sku ?? ""), "id"],
+ [String(line.description ?? ""), "name"],
+ ],
+ ql,
+ );
+ if (s > 0) {
+ score = s;
+ matchedOn =
+ String(line.sku ?? "").toLowerCase().includes(ql) ||
+ String(line.supplier_sku ?? "").toLowerCase().includes(ql)
+ ? "SKU"
+ : "item";
+ break;
+ }
+ }
+ }
+
+ if (score === 0) continue;
+
+ scored.push({
+ score,
+ hit: {
+ id,
+ title: String(header.purchase_number ?? id),
+ subtitle: [
+ `Stock PO · ${header.status ?? ""}`,
+ supplierName ? String(supplierNames.get(String(header.supplier))) : "",
+ poLines[0] ? String(poLines[0].description ?? "") : "",
+ ]
+ .filter(Boolean)
+ .join(" · "),
+ meta: `${poLines.length} line${poLines.length === 1 ? "" : "s"}`,
+ href: `/stock-orders/${id}`,
+ matchedOn,
+ },
+ });
+ }
+
+ scored.sort((a, b) => b.score - a.score);
+ return {
+ type: "stock_purchase",
+ label: "Stock Orders",
+ hits: scored.slice(0, HITS_PER_GROUP).map((s) => s.hit),
+ total: scored.length,
+ truncated: scored.length > HITS_PER_GROUP,
+ };
+}
+
/* ============================================================================
* Orchestrator
* ========================================================================== */
@@ -665,8 +794,13 @@ export async function warmUniversalSearchCaches(): Promise {
loadReferenceRows(pb, "customers", "id,customer,email,number"),
loadReferenceRows(pb, "stock_items", "id,name,sku,description,unit"),
- loadReferenceRows(pb, "purchase_orders", "id,po_number,status"),
- loadReferenceRows(pb, "stock_purchases", "id,purchase_number,status"),
+ loadReferenceRows(pb, "purchase_orders", "id,po_number,status,order"),
+ loadReferenceRows(pb, "stock_purchases", "id,purchase_number,status,supplier"),
+ loadReferenceRows(
+ pb,
+ "stock_purchase_items",
+ "id,purchase,description,sku,supplier_sku,product_code",
+ ),
]);
} catch {
// Best-effort. The first real search will simply rebuild.
@@ -744,31 +878,7 @@ export async function universalSearch(
),
runSource("stock_purchase", "Stock Orders", () =>
- searchReferenceCollection>(
- pb,
- {
- type: "stock_purchase",
- label: "Stock Orders",
- collection: "stock_purchases",
- fields: "id,purchase_number,status",
- score: (r, q) =>
- bestScore(
- [
- [String(r.purchase_number ?? ""), "id"],
- [String(r.status ?? ""), "body"],
- ],
- q,
- ),
- build: (r) => ({
- id: String(r.id),
- title: String(r.purchase_number ?? r.id),
- subtitle: `Stock PO · ${r.status ?? ""}`,
- href: `/stock-orders/${r.id}`,
- matchedOn: "PO number",
- }),
- },
- ql,
- ),
+ searchStockPurchases(pb, ql),
),
runSource("supplier", "Suppliers", () =>