176990 Implement get presubmit guard summaries api

app_dart/lib/server.dart

@@ -9,6 +9,7 @@ import 'cocoon_service.dart';
 import 'src/request_handlers/get_engine_artifacts_ready.dart';
 import 'src/request_handlers/get_presubmit_checks.dart';
 import 'src/request_handlers/get_presubmit_guard.dart';
+import 'src/request_handlers/get_presubmit_guard_summaries.dart';
 import 'src/request_handlers/get_tree_status_changes.dart';
 import 'src/request_handlers/github_webhook_replay.dart';
 import 'src/request_handlers/lookup_hash.dart';
@@ -190,6 +191,11 @@ Server createServer({
       authenticationProvider: authProvider,
       firestore: firestore,
     ),
+    '/api/get-presubmit-guard-summaries': GetPresubmitGuardSummaries(
+      config: config,
+      authenticationProvider: authProvider,
+      firestore: firestore,
+    ),
     '/api/get-presubmit-checks': GetPresubmitChecks(
       config: config,
       authenticationProvider: authProvider,

app_dart/lib/src/request_handlers/get_presubmit_guard.dart

@@ -63,18 +63,18 @@ final class GetPresubmitGuard extends ApiRequestHandler {
     // Consolidate metadata from the first record.
     final first = guards.first;
 
-    final GuardStatus guardStatus;
-    if (guards.any((g) => g.failedBuilds > 0)) {
-      guardStatus = GuardStatus.failed;
-    } else if (guards.every(
-      (g) => g.failedBuilds == 0 && g.remainingBuilds == 0,
-    )) {
-      guardStatus = GuardStatus.succeeded;
-    } else if (guards.every((g) => g.remainingBuilds == g.builds.length)) {
-      guardStatus = GuardStatus.waitingForBackfill;
-    } else {
-      guardStatus = GuardStatus.inProgress;
-    }
+    final totalFailed = guards.fold<int>(0, (sum, g) => sum + g.failedBuilds);
+    final totalRemaining = guards.fold<int>(
+      0,
+      (sum, g) => sum + g.remainingBuilds,
+    );
+    final totalBuilds = guards.fold<int>(0, (sum, g) => sum + g.builds.length);
+
+    final guardStatus = GuardStatus.calculate(
+      failedBuilds: totalFailed,
+      remainingBuilds: totalRemaining,
+      totalBuilds: totalBuilds,
+    );
 
     final response = rpc_model.PresubmitGuardResponse(
       prNum: first.pullRequestId,

app_dart/lib/src/request_handlers/get_presubmit_guard_summaries.dart

@@ -0,0 +1,112 @@
+// Copyright 2026 The Flutter Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+import 'dart:async';
+import 'dart:io';
+import 'dart:math';
+
+import 'package:cocoon_common/guard_status.dart';
+import 'package:cocoon_common/rpc_model.dart' as rpc_model;
+import 'package:github/github.dart';
+import 'package:meta/meta.dart';
+
+import '../../cocoon_service.dart';
+import '../model/firestore/presubmit_guard.dart';
+import '../request_handling/api_request_handler.dart';
+import '../service/firestore/unified_check_run.dart';
+
+/// Request handler for retrieving all presubmit guards for a specific pull request.
+///
+/// GET: /api/get-presubmit-guard-summaries
+///
+/// Parameters:
+///   repo: (string in query) required. The repository name (e.g., 'flutter').
+///   pr: (int in query) required. The pull request number.
+///   owner: (string in query) optional. The repository owner (e.g., 'flutter').
+@immutable
+final class GetPresubmitGuardSummaries extends ApiRequestHandler {
+  /// Defines the [GetPresubmitGuardSummaries] handler.
+  const GetPresubmitGuardSummaries({
+    required super.config,
+    required super.authenticationProvider,
+    required FirestoreService firestore,
+  }) : _firestore = firestore;
+
+  final FirestoreService _firestore;
+
+  /// The name of the query parameter for the repository name (e.g. 'flutter').
+  static const String kRepoParam = 'repo';
+
+  /// The name of the query parameter for the pull request number.
+  static const String kPRParam = 'pr';
+
+  /// The name of the query parameter for the repository owner (e.g. 'flutter').
+  static const String kOwnerParam = 'owner';
+
+  @override
+  Future<Response> get(Request request) async {
+    checkRequiredQueryParameters(request, [kRepoParam, kPRParam]);
+
+    final repo = request.uri.queryParameters[kRepoParam]!;
+    final prNumber = int.parse(request.uri.queryParameters[kPRParam]!);
+    final owner = request.uri.queryParameters[kOwnerParam] ?? 'flutter';
+
+    final slug = RepositorySlug(owner, repo);
+    final guards = await UnifiedCheckRun.getPresubmitGuardsForPullRequest(
+      firestoreService: _firestore,
+      slug: slug,
+      pullRequestId: prNumber,
+    );
+
+    if (guards.isEmpty) {
+      return Response.json({
+        'error': 'No guards found for PR $prNumber in $slug',
+      }, statusCode: HttpStatus.notFound);
+    }
+
+    // Group guards by commitSha
+    final groupedGuards = <String, List<PresubmitGuard>>{};
+    for (final guard in guards) {
+      groupedGuards.putIfAbsent(guard.commitSha, () => []).add(guard);
+    }
+
+    final responseGuards = <rpc_model.PresubmitGuardSummary>[];
+    for (final entry in groupedGuards.entries) {
+      final sha = entry.key;
+      final shaGuards = entry.value;
+
+      final totalFailed = shaGuards.fold<int>(
+        0,
+        (int sum, PresubmitGuard g) => sum + g.failedBuilds,
+      );
+      final totalRemaining = shaGuards.fold<int>(
+        0,
+        (int sum, PresubmitGuard g) => sum + g.remainingBuilds,
+      );
+      final totalBuilds = shaGuards.fold<int>(
+        0,
+        (int sum, PresubmitGuard g) => sum + g.builds.length,
+      );
+      final earliestCreationTime = shaGuards.fold<int>(
+        // assuming creation time is always in the past :)
+        DateTime.now().millisecondsSinceEpoch,
+        (int curr, PresubmitGuard g) => min(g.creationTime, curr),
+      );
+
+      responseGuards.add(
+        rpc_model.PresubmitGuardSummary(
+          commitSha: sha,
+          creationTime: earliestCreationTime,
+          guardStatus: GuardStatus.calculate(
+            failedBuilds: totalFailed,
+            remainingBuilds: totalRemaining,
+            totalBuilds: totalBuilds,
+          ),
+        ),
+      );
+    }
+
+    return Response.json(responseGuards);
+  }
+}

app_dart/lib/src/service/firestore/unified_check_run.dart

@@ -243,6 +243,19 @@ final class UnifiedCheckRun {
     );
   }
 
+  /// Queries for [PresubmitGuard] records by [slug] and [pullRequestId].
+  static Future<List<PresubmitGuard>> getPresubmitGuardsForPullRequest({
+    required FirestoreService firestoreService,
+    required RepositorySlug slug,
+    required int pullRequestId,
+  }) async {
+    return await _queryPresubmitGuards(
+      firestoreService: firestoreService,
+      slug: slug,
+      pullRequestId: pullRequestId,
+    );
+  }
+
   static Future<List<PresubmitGuard>> _queryPresubmitGuards({
     required FirestoreService firestoreService,
     Transaction? transaction,

app_dart/test/request_handlers/get_presubmit_guard_summaries_test.dart

@@ -0,0 +1,129 @@
+// Copyright 2026 The Flutter Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+import 'dart:convert';
+import 'dart:io';
+
+import 'package:cocoon_common/guard_status.dart';
+import 'package:cocoon_common/rpc_model.dart' as rpc_model;
+import 'package:cocoon_common/task_status.dart';
+import 'package:cocoon_integration_test/testing.dart';
+import 'package:cocoon_server_test/test_logging.dart';
+import 'package:cocoon_service/src/request_handlers/get_presubmit_guard_summaries.dart';
+import 'package:cocoon_service/src/request_handling/exceptions.dart';
+import 'package:github/github.dart';
+import 'package:test/test.dart';
+
+import '../src/request_handling/request_handler_tester.dart';
+
+void main() {
+  useTestLoggerPerTest();
+
+  late RequestHandlerTester tester;
+  late GetPresubmitGuardSummaries handler;
+  late FakeFirestoreService firestore;
+
+  Future<List<rpc_model.PresubmitGuardSummary>?> getResponse() async {
+    final response = await tester.get(handler);
+    if (response.statusCode != HttpStatus.ok) {
+      return null;
+    }
+    final responseBody = await utf8.decoder
+        .bind(response.body as Stream<List<int>>)
+        .transform(json.decoder)
+        .single;
+    return (responseBody as List<dynamic>)
+        .map(
+          (e) => rpc_model.PresubmitGuardSummary.fromJson(
+            e as Map<String, Object?>,
+          ),
+        )
+        .toList();
+  }
+
+  setUp(() {
+    firestore = FakeFirestoreService();
+    tester = RequestHandlerTester();
+    handler = GetPresubmitGuardSummaries(
+      config: FakeConfig(),
+      authenticationProvider: FakeDashboardAuthentication(),
+      firestore: firestore,
+    );
+  });
+
+  test('missing parameters', () async {
+    tester.request = FakeHttpRequest();
+    expect(tester.get(handler), throwsA(isA<BadRequestException>()));
+  });
+
+  test('no guards found', () async {
+    tester.request = FakeHttpRequest(
+      queryParametersValue: {
+        GetPresubmitGuardSummaries.kRepoParam: 'flutter',
+        GetPresubmitGuardSummaries.kPRParam: '123',
+      },
+    );
+
+    final response = await tester.get(handler);
+    expect(response.statusCode, HttpStatus.notFound);
+  });
+
+  test('returns multiple guards grouped by commitSha', () async {
+    final slug = RepositorySlug('flutter', 'flutter');
+    const prNumber = 123;
+
+    // SHA1: Two stages, both succeeded.
+    final guard1a = generatePresubmitGuard(
+      slug: slug,
+      pullRequestId: prNumber,
+      commitSha: 'sha1',
+      checkRun: generateCheckRun(1),
+      creationTime: 100,
+      builds: {'test1': TaskStatus.succeeded},
+      remainingBuilds: 0,
+    );
+
+    final guard1b = generatePresubmitGuard(
+      slug: slug,
+      pullRequestId: prNumber,
+      commitSha: 'sha1',
+      checkRun: generateCheckRun(2),
+      creationTime: 110,
+      builds: {'test2': TaskStatus.succeeded},
+      remainingBuilds: 0,
+    );
+
+    // SHA2: One stage, failed.
+    final guard2 = generatePresubmitGuard(
+      slug: slug,
+      pullRequestId: prNumber,
+      commitSha: 'sha2',
+      checkRun: generateCheckRun(3),
+      creationTime: 200,
+      builds: {'test3': TaskStatus.failed},
+      failedBuilds: 1,
+      remainingBuilds: 0,
+    );
+
+    firestore.putDocuments([guard1a, guard1b, guard2]);
+
+    tester.request = FakeHttpRequest(
+      queryParametersValue: {
+        GetPresubmitGuardSummaries.kRepoParam: 'flutter',
+        GetPresubmitGuardSummaries.kPRParam: prNumber.toString(),
+      },
+    );
+
+    final result = (await getResponse())!;
+    expect(result.length, 2);
+
+    final item1 = result.firstWhere((g) => g.commitSha == 'sha1');
+    expect(item1.creationTime, 100); // earliest
+    expect(item1.guardStatus, GuardStatus.succeeded);
+
+    final item2 = result.firstWhere((g) => g.commitSha == 'sha2');
+    expect(item2.creationTime, 200);
+    expect(item2.guardStatus, GuardStatus.failed);
+  });
+}

app_dart/test/request_handlers/get_presubmit_guard_test.dart

@@ -78,18 +78,15 @@ void main() {
       commitSha: sha,
       stage: CiStage.fusionTests,
       builds: {'test1': TaskStatus.succeeded},
+      remainingBuilds: 0,
     );
-    guard1.failedBuilds = 0;
-    guard1.remainingBuilds = 0;
 
     final guard2 = generatePresubmitGuard(
       slug: slug,
       commitSha: sha,
       stage: CiStage.fusionEngineBuild,
       builds: {'engine1': TaskStatus.inProgress},
     );
-    guard2.failedBuilds = 0;
-    guard2.remainingBuilds = 1;
 
     firestore.putDocuments([guard1, guard2]);
 
@@ -124,9 +121,9 @@ void main() {
       slug: slug,
       commitSha: sha,
       builds: {'test1': TaskStatus.failed},
+      failedBuilds: 1,
+      remainingBuilds: 0,
     );
-    guard.failedBuilds = 1;
-    guard.remainingBuilds = 0;
 
     firestore.putDocuments([guard]);
 
@@ -151,9 +148,8 @@ void main() {
         slug: slug,
         commitSha: sha,
         builds: {'test1': TaskStatus.succeeded},
+        remainingBuilds: 0,
       );
-      guard.failedBuilds = 0;
-      guard.remainingBuilds = 0;
 
       firestore.putDocuments([guard]);
 
@@ -178,8 +174,6 @@ void main() {
       commitSha: sha,
       builds: {'test1': TaskStatus.waitingForBackfill},
     );
-    guard.failedBuilds = 0;
-    guard.remainingBuilds = 1;
 
     firestore.putDocuments([guard]);
 

conductor/archive/get_presubmit_guard_summaries_20260211/index.md

@@ -0,0 +1,5 @@
+# Track get_presubmit_guards_20260211 Context
+
+- [Specification](./spec.md)
+- [Implementation Plan](./plan.md)
+- [Metadata](./metadata.json)

conductor/archive/get_presubmit_guard_summaries_20260211/metadata.json

@@ -0,0 +1,8 @@
+{
+  "track_id": "get_presubmit_guards_20260211",
+  "type": "feature",
+  "status": "new",
+  "created_at": "2026-02-11T12:00:00Z",
+  "updated_at": "2026-02-11T12:00:00Z",
+  "description": "Implement getPresubmitGuardsForPullRequest request handler"
+}