Function listSubjectsWithConnections

packages/core/sdk/src/executor.ts:6936–6973

(
        options?: AdminListSubjectsOptions,
      )

      // per-subject query produced. Subjects with no connections still report
      // an empty array rather than dropping out of the page.
      const listSubjectsWithConnections = (
        options?: AdminListSubjectsOptions,
      ): Effect.Effect<readonly AdminSubjectWithConnections[], StorageFailure> =>
        Effect.gen(function* () {
          const subjects = yield* listSubjects(options);
          // No page, no connection query — `in ([])` is a query that cannot
          // match, so issuing it would be pure latency.
          if (subjects.length === 0) return [];

          const rows = yield* platformCore.findMany("connection", {
            where: (b: AnyCb) =>
              b.and(
                b("owner", "=", "user"),
                b(
                  "subject",
                  "in",
                  subjects.map((entry) => entry.externalId),
                ),
              ),
            orderBy: [
              ["integration", "asc"],
              ["name", "asc"],
            ],
          });

          const bySubject = new Map<string, AdminConnection[]>();
          for (const row of rows) {
            const connection = rowToAdminConnection(row);
            const bucket = bySubject.get(row.subject);
            if (bucket) bucket.push(connection);
            else bySubject.set(row.subject, [connection]);
          }

          return subjects.map((entry) => ({
            ...entry,
            connections: bySubject.get(entry.externalId) ?? [],
          }));
        });

      // Absent subject short-circuits: no connection query is issued for a
      // principal the tenant never recorded.