feat: add ecosystem filter (CM-1236) (#4237)

Signed-off-by: Umberto Sgueglia <usgueglia@contractor.linuxfoundation.org>

Author: ulemons

backend/src/api/public/v1/ossprey/packageScatter.ts

@@ -24,11 +24,12 @@ function normalizeToArray(v: unknown): unknown[] | undefined {
 
 const scatterQuerySchema = z.object({
   status: z.preprocess(normalizeToArray, z.array(statusEnum).min(1)).optional(),
+  ecosystem: z.string().min(1).optional(),
 })
 
 export async function packageScatterHandler(req: Request, res: Response): Promise<void> {
-  const { status } = validateOrThrow(scatterQuerySchema, req.query)
+  const { status, ecosystem } = validateOrThrow(scatterQuerySchema, req.query)
   const qx = await getPackagesQx()
-  const points = await listPackagesForScatter(qx, { status })
+  const points = await listPackagesForScatter(qx, { status, ecosystem })
   ok(res, { points, total: points.length })
 }

services/libs/data-access-layer/src/osspckgs/api.ts

@@ -667,9 +667,9 @@ export interface ScatterPoint {
 
 export async function listPackagesForScatter(
   qx: QueryExecutor,
-  options: { status?: string[] } = {},
+  options: { status?: string[]; ecosystem?: string } = {},
 ): Promise<ScatterPoint[]> {
-  const { status } = options
+  const { status, ecosystem } = options
 
   // 'unassigned' covers packages with no stewardship row (s.id IS NULL) in addition
   // to rows explicitly marked unassigned. All other statuses filter via s.status = ANY(...).
@@ -678,6 +678,7 @@ export async function listPackagesForScatter(
   const statusFilter = status?.length
     ? `AND (s.status = ANY($(status)::text[])${includesUnassigned ? ' OR s.id IS NULL' : ''})`
     : ''
+  const ecosystemFilter = ecosystem ? `AND p.ecosystem = $(ecosystem)` : ''
 
   const rows: Array<{
     purl: string
@@ -714,10 +715,11 @@ export async function listPackagesForScatter(
     ) r_sc ON true
     WHERE p.is_critical = true
     ${statusFilter}
+    ${ecosystemFilter}
     ORDER BY p.impact DESC NULLS LAST, p.purl ASC
     LIMIT 2000
     `,
-    { status },
+    { status, ecosystem },
   )
 
   return rows.map((r) => ({