Function list

showcase/harness/src/fleet/queue-client.test.ts:325–386

(
      _collection: string,
      opts: ListOpts = {},
    )

      return row as unknown as T;
    },
    async list<T>(
      _collection: string,
      opts: ListOpts = {},
    ): Promise<ListResult<T>> {
      // Honor `status` AND `probe_key` clauses faithfully (shared matcher) so
      // the claimNext candidate scan, the family-discovery exclusions, and the
      // sweepExpired scans are exercised the way real PB would serve them. A
      // clause on any OTHER field THROWS (see rowMatchesFilter) instead of
      // silently matching everything.
      let items = store.filter((r) => rowMatchesFilter(r, opts.filter));
      // SORT honesty (G1h): this fake used to IGNORE `sort` entirely — any
      // test depending on an order the production query requested passed
      // vacuously on insertion order. Model the two production sort keys
      // (rows here usually lack `created`, where the STABLE sort preserves
      // insertion order — PB's tie behavior for identical values) and THROW
      // on anything else, matching the fakes' unsupported philosophy.
      const desc = opts.sort?.startsWith("-") ?? false;
      const sortKey = desc ? opts.sort!.slice(1) : opts.sort;
      if (sortKey === "created") {
        items = [...items].sort((a, b) =>
          String((a as { created?: string }).created ?? "").localeCompare(
            String((b as { created?: string }).created ?? ""),
          ),
        );
      } else if (sortKey === "lease_expires_at") {
        items = [...items].sort((a, b) =>
          String(a.lease_expires_at ?? "").localeCompare(
            String(b.lease_expires_at ?? ""),
          ),
        );
      } else if (sortKey) {
        throw new Error(
          `fake-pb: unmodeled sort key "${sortKey}" — only created/lease_expires_at are honored`,
        );
      }
      if (desc) items.reverse();
      const totalItems = items.length;
      // PAGING honesty (G1h): perPage used to be ignored — a matched set
      // LARGER than the requested page came back whole, hiding truncation
      // behavior the production pagination depends on. Slice like PB.
      if (opts.perPage !== undefined) {
        const page = opts.page ?? 1;
        items = items.slice((page - 1) * opts.perPage, page * opts.perPage);
      }
      return {
        page: opts.page ?? 1,
        perPage: opts.perPage ?? items.length,
        totalPages:
          opts.skipTotal === true
            ? -1
            : opts.perPage !== undefined
              ? Math.max(1, Math.ceil(totalItems / opts.perPage))
              : 1,
        // Faithful to PB: a skipTotal list returns totalItems -1, NOT the
        // real count. A fake that returned real counts under skipTotal
        // would green-light code reading totals it never requested (the
        // fail-open class countPendingForFamily's skipTotal:false pin
        // exists to prevent).