dashboard/lib/service/dev_cocoon.dart - mirrors/cocoon - Git at Google

 // Copyright 2019 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:math' as math;

 import 'package:cocoon_common/rpc_model.dart';
 import 'package:cocoon_common/task_status.dart';

 import 'cocoon.dart';

 class _PausedCommitStatus {
   _PausedCommitStatus(CocoonResponse<List<CommitStatus>> status)
     : _completer = Completer<CocoonResponse<List<CommitStatus>>>(),
       _pausedStatus = status;

   final Completer<CocoonResponse<List<CommitStatus>>> _completer;
   CocoonResponse<List<CommitStatus>>? _pausedStatus;

   bool get isComplete => _pausedStatus == null;

   Future<CocoonResponse<List<CommitStatus>>> get future => _completer.future;

   void update(CocoonResponse<List<CommitStatus>> newStatus) {
     assert(_pausedStatus != null);
     _pausedStatus = newStatus;
   }

   void complete() {
     assert(_pausedStatus != null);
     _completer.complete(_pausedStatus!);
     _pausedStatus = null;
   }
 }

 /// [CocoonService] for local development purposes.
 ///
 /// This creates fake data that mimicks what production will send.
 class DevelopmentCocoonService implements CocoonService {
   DevelopmentCocoonService(this.now, {this.simulateLoadingDelays = false})
     : _random = math.Random(now.millisecondsSinceEpoch);

   final math.Random _random;

   final DateTime now;

   final bool simulateLoadingDelays;

   _PausedCommitStatus? _pausedStatus;
   bool _paused = false;
   bool get paused => _paused;
   set paused(bool pause) {
     if (_paused == pause) {
       return;
     }
     assert(_paused || _pausedStatus == null || _pausedStatus!.isComplete);
     if (_pausedStatus != null && !_pausedStatus!.isComplete) {
       _pausedStatus!.complete();
       _pausedStatus = null;
     }
     _paused = pause;
   }

   @override
   Future<CocoonResponse<List<CommitStatus>>> fetchCommitStatuses({
     CommitStatus? lastCommitStatus,
     String? branch,
     required String repo,
   }) async {
     final data = CocoonResponse<List<CommitStatus>>.data(
       _createFakeCommitStatuses(lastCommitStatus, repo, branch: branch),
     );
     if (_pausedStatus == null || _pausedStatus!.isComplete) {
       _pausedStatus = _PausedCommitStatus(data);
     } else {
       _pausedStatus!.update(data);
     }

     if (!_paused) {
       if (simulateLoadingDelays) {
         final delayedStatus = _pausedStatus;
         Future<void>.delayed(const Duration(seconds: 2), () {
           if (!_paused && !delayedStatus!.isComplete) {
             delayedStatus.complete();
           }
         });
       } else {
         _pausedStatus!.complete();
       }
     }

     return _pausedStatus!.future;
   }

   final _treeStatusChanges = <String, List<TreeStatusChange>>{};
   static final _defaultChanges = [
     TreeStatusChange(
       createdOn: DateTime.now().subtract(const Duration(hours: 1)),
       status: TreeStatus.success,
       authoredBy: 'Joe Admin',
       reason: 'Test',
     ),
     TreeStatusChange(
       createdOn: DateTime.now().subtract(const Duration(hours: 2)),
       status: TreeStatus.failure,
       authoredBy: 'Joe Admin',
       reason: 'Test',
     ),
   ];

   @override
   Future<CocoonResponse<List<TreeStatusChange>>> fetchTreeStatusChanges({
     required String idToken,
     required String repo,
   }) async {
     return CocoonResponse<List<TreeStatusChange>>.data(
       _treeStatusChanges.putIfAbsent(repo, () => [..._defaultChanges]),
     );
   }

   @override
   Future<CocoonResponse<void>> updateTreeStatus({
     required String idToken,
     required String repo,
     required TreeStatus status,
     String? reason,
   }) async {
     // At most 10 per.
     final list = _treeStatusChanges.putIfAbsent(
       repo,
       () => [..._defaultChanges],
     );
     list.insert(
       0,
       TreeStatusChange(
         createdOn: DateTime.now(),
         status: status,
         authoredBy: 'Joe Widget',
         reason: reason,
       ),
     );
     if (list.length > 10) {
       list.removeLast();
     }
     return const CocoonResponse<void>.data(null);
   }

   static const List<String> _repos = <String>['flutter', 'cocoon'];

   @override
   Future<CocoonResponse<List<String>>> fetchRepos() async {
     return const CocoonResponse<List<String>>.data(_repos);
   }

   @override
   Future<CocoonResponse<BuildStatusResponse>> fetchTreeBuildStatus({
     String? branch,
     required String repo,
   }) async {
     final failed = _random.nextBool();
     final response = BuildStatusResponse(
       buildStatus: failed ? BuildStatus.failure : BuildStatus.success,
       failingTasks: [
         if (failed) ...['failed_task_1', 'failed_task_2'],
       ],
     );
     return CocoonResponse<BuildStatusResponse>.data(response);
   }

   @override
   Future<CocoonResponse<List<Branch>>> fetchFlutterBranches() async {
     return CocoonResponse.data([
       Branch(channel: 'master', reference: 'master'),
       Branch(channel: 'stable', reference: 'flutter-3.13-candidate.0'),
       Branch(channel: 'beta', reference: 'flutter-3.15-candidate.5'),
       Branch(channel: 'dev', reference: 'flutter-3.15-candidate.12'),
     ]);
   }

   @override
   Future<CocoonResponse<bool>> vacuumGitHubCommits(
     String idToken, {
     required String repo,
     required String branch,
   }) async {
     return const CocoonResponse<bool>.error(
       'Unable to vacuum against fake data. Try building the app to use prod data.',
       statusCode: 501 /* Not implemented */,
     );
   }

   @override
   Future<CocoonResponse<bool>> rerunTask({
     required String? idToken,
     required String taskName,
     required String commitSha,
     required String repo,
     required String branch,
   }) async {
     return const CocoonResponse<bool>.error(
       'Unable to retry against fake data. Try building the app to use prod data.',
       statusCode: 501 /* Not implemented */,
     );
   }

   @override
   Future<CocoonResponse<void>> rerunCommit({
     required String? idToken,
     required String commitSha,
     required String repo,
     required String branch,
     Iterable<TaskStatus>? include,
   }) async {
     return const CocoonResponse<void>.error(
       'Unable to schedule against fake data. Try building the app to use prod data.',
       statusCode: 501 /* Not implemented */,
     );
   }

   static const int _commitGap = 2 * 60 * 1000; // 2 minutes between commits

   List<CommitStatus> _createFakeCommitStatuses(
     CommitStatus? lastCommitStatus,
     String repo, {
     String? branch,
   }) {
     branch ??= defaultBranches[repo]!;
     final baseTimestamp =
         lastCommitStatus != null
             ? (lastCommitStatus.commit.timestamp.toInt())
             : now.millisecondsSinceEpoch;
     final result = <CommitStatus>[];
     for (var index = 0; index < 25; index += 1) {
       final commitTimestamp = baseTimestamp - ((index + 1) * _commitGap);
       final random = math.Random(commitTimestamp);
       final commit = _createFakeCommit(
         commitTimestamp,
         random,
         repo,
         _commits[index],
         branch,
       );
       final status = CommitStatus(
         commit: commit,
         tasks: _createFakeTasks(commitTimestamp, commit, random),
       );
       result.add(status);
     }
     return result;
   }

   final List<String> _authors = <String>[
     'matan',
     'yegor',
     'john',
     'jenn',
     'kate',
     'stuart',
   ];
   final _avatars = [
     'https://avatars.githubusercontent.com/u/168174?v=4',
     'https://avatars.githubusercontent.com/u/211513?v=4',
     'https://avatars.githubusercontent.com/u/1924313?v=4',
     'https://avatars.githubusercontent.com/u/682784?v=4',
     'https://avatars.githubusercontent.com/u/16964204?v=4',
     'https://avatars.githubusercontent.com/u/122189?v=4',
   ];

   final List<int> _messagePrimes = <int>[3, 11, 17, 23, 31, 41, 47, 67, 79];
   final List<String> _words = <String>[
     'fixes',
     'issue',
     'crash',
     'developer',
     'blocker',
     'intermittent',
     'format',
   ];
   final List<String> _commits = <String>[
     '2d22b5e85f986f3fa2cf1bfaf085905c2182c270',
     '2fd76f920a38e4384248173d05ee482d5aeaf4c5',
     '77238bc7bf35489df03bc00ce2b2231a1afe6b06',
     '01d87b7a802e6ea388a066e773b1af3dace44053',
     '754039ae0cc524db1052da0f22c9275e32fe4f54',
     '1f5e006a398fa5d0e59f78cd5071e2532d2fe438',
     'a798b24044d567df62b8693b179932a8364c8dd8',
     '4389a8a3dbe1ed4c6a643641e95d7759f2158d9e',
     'c05e886884ec9adff2f43b87dbcb02e3507d971b',
     'a2acc46447cdfcd6628a897dea27ff64849bfc99',
     'd31d67ffb38fbd09ecf0a11ad5f6fd433cec9c9f',
     'e303d2c71c956c9c1eb7bf81473aac20d756eb75',
     '789f6bb335fe31de5d9c6adbab2fc169030a057f',
     'c97f0670658e04f096a3e57b20fa8241306ffcaa',
     'e8e31198861b5f53f04900bdf9a54e8bf6b7d597',
     '434a0a7d3c4c3bc633e06de7707ef590c54c20c3',
     'e7fca29b3f0408c7c1726e270a5aba0e28e74090',
     'dd6f94d8573a77506a122899a0592a956ac57bec',
     'cb19ec23d79b9d422f577722e5a14253fdcaea71',
     '4cb8c6498aedfd2ff0f89e34eb5da993a77392bd',
     'de892884aa089f22aced4d19a71b6a1d521c8db6',
     '214470ceb026525fa225d52dfe7d27db2c4ddf31',
     'e0f4628b4379286c433bab020b9e193fdc437d05',
     'be5975cb0b7fcad7ab2c3122a8df3d541befdeab',
     '06f7ab60d4914e00b342f098e1ef3e43e501b469',
     'e1005bea192673e54faa0c769d9f0fb7439a09b4',
     'e22d7f6bf2e1e1969dd963d39ad32c756fb0f20e',
     'f4b4b20bb27cbbd1c42eee7b17ce39c5819dc818',
     'd717ed969b6a477499eb3cf823c78dbe654ca709',
     '6a8d6a42b4c9f4b72caf0a3b808e50909686a2b7',
     'afaa9bfa5d26ab419f791d5ca97d602ec52a30a5',
     'f553212d9bfbc6e70c0d6a4ac3fe71208bb77ca1',
     'c35f8b79f4a5103603ceaaa14d1df3857a166fa1',
     '46447341838d480966926d0b32771e281af1c885',
     '4e3330081d4e0a3e109cf1cfb514072a90b999d7',
     '4199ef93c3184c29362520ea5292d854a8728494',
     'a0538938974c60cb9249acf8f0588c3df3c0e4b1',
     '49cac0b6c1e0d7d1d04865c328c8cbe5c8e0cda2',
     '97e3cc6295515f8292f5f57868506c70446594c3',
     'c94e577ef3b0ab48255633c63f0143d9e3eab6f8',
     '17d9af726fb6e4a4a8cc4f1becfc11dc9d4db96c',
     '4af6ec81ad538e3da23ee88cba65ed8687a72ea3',
     '69cb45166d2f4f61069e1f1a975dab3f48bed832',
     'ae227082570f75b614bb29593911ada5137654ad',
     '882b9fa44962df0b80d9a25b2553796bd4eba2ff',
     'e1f5c4c7178c34ce561c493b558df7450995a60c',
     '56d7272cd497c73502ec5a09bdf69b4c7ecbfd74',
     '36a99b302f7348848ec477ce867a8b78656d9c6c',
     '48be7a01565289f44c2c9d4ff1436800c52acf75',
     '422cb82e01ee0192256a05217102f45f2f74551d',
     'f8744d10460abae3d75e92336b3bb264bb78cc8c',
     '5000f246c8c568547c551b11e4b72acd0179e73c',
     '52c09522b288766a42900aa73f77216907d16b23',
     '61adb59fc097335b45b23fc884a78362b71a3e9b',
     'b81c3c58e5a6c45bc8728024068291a7e5f19c1a',
     'dec394e5401b62024ed71253e900c25a06eb46f9',
     'fbe142d2cb60fb981521cfe72961642d69db8784',
     '24a9c4557e0366945c179433fab8434c2c8ee59f',
     'ccc28f607ae11fe79c39c42d88798c19b1388af9',
     'd4d5ca665e56063fdd37d42d2192c64151915454',
     '4273fc07c3e8a36726087becdf331f7d63fc7e66',
     '5e0380895cc8e34a6a58f238b7fd33b9e0f027fe',
     '146908e48a8a9f92f59fae86a7a4ff28c0ce9109',
     '2779a449026423bc0f50a10eead2d9f3720b825c',
     'ff9b954908341360ffb39f5eee2857172a29c0e5',
     'b00b6d146c4f4af1d28260a3f28abd15f0105221',
     '4ffd03df44741d73877a0848935eea0d6cbfc1e9',
     'c2c5b73aaae2583cc235319e53200e0e15cda438',
     'b7b370faf46f4c682827fbb3967e1ef117b3b0d1',
     'bc6c9ac81e5909408518568729c2c3a147402928',
     'ba1aa77c5bc5fe545b245f2b1883af3dfeeae6c0',
     '97a7060a7e28ab1d13cb2f4ca90be624b417168e',
     '3df1da69ffcb4e00cf13c65c9f0497a56413e5e9',
     'ebb13b4ed0cb41814839d4084c064e62526b2ec0',
     '70b9d50722307f0f45ceed01d421d6a425e95291',
     '3f81ca7b73f21ca9b449c147942fbe4fcd31450d',
     '86d490939df232966dc6ba363ebc0baaac364701',
     '6ba51f3f61025543d66e59c2c1ae3d1b37d5d8d6',
     'b728942e1c9a9046c1a5c8d8a25a644d0db7160c',
     '920819252a398c0e3da9b6017b110ee047c1748e',
     'd7c114d803b1365ea3a975c9600fc8cfd9efb9d4',
     '792aa82143bb12e97f396cb2a462ad617dbd22bc',
   ];

   Commit _createFakeCommit(
     int commitTimestamp,
     math.Random random,
     String repo,
     String commitSha,
     String branch,
   ) {
     final author = random.nextInt(_authors.length);
     final message = commitTimestamp % 37 + author;
     final messageInc = _messagePrimes[message % _messagePrimes.length];
     return Commit(
       author: CommitAuthor(
         login: _authors[author],
         avatarUrl: _avatars[author],
       ),
       message: List<String>.generate(
         6,
         (int i) => _words[(message + i * messageInc) % _words.length],
       ).join(' '),
       repository: 'flutter/$repo',
       sha: commitSha,
       timestamp: commitTimestamp,
       branch: branch,
     );
   }

   static const Map<String, int> _repoTaskCount = <String, int>{
     'flutter/cocoon': 3,
     'flutter/flutter': 100,
     'flutter/engine': 20,
   };

   List<Task> _createFakeTasks(
     int commitTimestamp,
     Commit commit,
     math.Random random,
   ) {
     if (_repoTaskCount.containsKey(commit.repository) == false) {
       throw Exception(
         'Add ${commit.repository} to _repoTaskCount in DevCocoonService',
       );
     }
     return List<Task>.generate(
       _repoTaskCount[commit.repository]!,
       (int i) => _createFakeTask(commitTimestamp, i, random),
     );
   }

   static const _statuses = [
     TaskStatus.waitingForBackfill,
     TaskStatus.inProgress,
     TaskStatus.succeeded,
     TaskStatus.failed,
     TaskStatus.infraFailure,
     TaskStatus.skipped,
     TaskStatus.cancelled,
   ];

   static const _minAttempts = {
     TaskStatus.waitingForBackfill: 0,
     TaskStatus.inProgress: 1,
     TaskStatus.succeeded: 1,
     TaskStatus.failed: 1,
     TaskStatus.infraFailure: 1,
     TaskStatus.skipped: 0,
     TaskStatus.cancelled: 1,
   };

   static const _maxAttempts = {
     TaskStatus.waitingForBackfill: 0,
     TaskStatus.inProgress: 2,
     TaskStatus.succeeded: 1,
     TaskStatus.failed: 2,
     TaskStatus.infraFailure: 2,
     TaskStatus.skipped: 0,
     TaskStatus.cancelled: 1,
   };

   Task _createFakeTask(int commitTimestamp, int index, math.Random random) {
     final age = (now.millisecondsSinceEpoch - commitTimestamp) ~/ _commitGap;
     assert(age >= 0);
     // The [statusesProbability] list is an list of proportional
     // weights to give each of the values in _statuses when randomly
     // determining the status. So e.g. if one is 150, another 50, and
     // the rest 0, then the first has a 75% chance of being picked,
     // the second a 25% chance, and the rest a 0% chance.
     final statusesProbability = <int>[
       // bigger = more probable
       math.max(index % 2, 20 - age * 2), // TaskStatus.waitingForBackfill
       math.max(0, 10 - age * 2), // TaskStatus.inProgress
       math.min(10 + age * 2, 100), // TaskStatus.succeeded
       math.min(1 + age ~/ 3, 30), // TaskStatus.failed
       if (index % 15 == 0) // TaskStatus.infraFailure
         5
       else if (index % 25 == 0)
         15
       else
         1,
       if (index % 20 == 0) 30,
       1, // TaskStatus.cancelled
     ];
     // max is the sum of all the values in statusesProbability.
     final max = statusesProbability.fold(0, (int c, int p) => c + p);
     // weightedIndex is the random number in the range 0 <= weightedIndex < max.
     var weightedIndex = random.nextInt(max);
     // statusIndex is the actual index into _statuses that corresponds
     // to the randomly selected weightedIndex. So if
     // statusesProbability is 10,20,30 and weightedIndex is 15, then
     // the statusIndex will be 1 (corresponding to the second entry,
     // the one with weight 20, since lists are zero-indexed).
     var statusIndex = 0;
     while (weightedIndex > statusesProbability[statusIndex]) {
       weightedIndex -= statusesProbability[statusIndex];
       statusIndex += 1;
     }
     // Finally we get the actual status using statusIndex as an index into _statuses.
     final status = _statuses[statusIndex];
     final minAttempts = _minAttempts[status]!;
     final maxAttempts = _maxAttempts[status]!;
     final attempts =
         minAttempts + random.nextInt(maxAttempts - minAttempts + 1);

     final buildNumberList = List.generate(
       attempts > 1
           ? random.nextBool()
               ? attempts
               : attempts - 1
           : 1,
       (i) => i,
     );

     return Task(
       createTimestamp: commitTimestamp + index,
       startTimestamp: commitTimestamp + (index * 1000 * 60),
       endTimestamp: commitTimestamp + (index * 1000 * 60) + (index * 1000 * 60),

       builderName: 'Linux_android $index',
       attempts: attempts,
       currentBuildNumber:
           attempts == buildNumberList.length ? buildNumberList.last : null,
       buildNumberList: buildNumberList,
       isBringup: index == now.millisecondsSinceEpoch % 13,

       status: status,

       // Neither of these are strictly true from a domain perspective.
       lastAttemptFailed: random.nextBool() ? attempts > 1 : false,
       isFlaky: attempts > 1,
     );
   }
 }
	// Copyright 2019 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:math' as math;

	import 'package:cocoon_common/rpc_model.dart';
	import 'package:cocoon_common/task_status.dart';

	import 'cocoon.dart';

	class _PausedCommitStatus {
	_PausedCommitStatus(CocoonResponse<List<CommitStatus>> status)
	: _completer = Completer<CocoonResponse<List<CommitStatus>>>(),
	_pausedStatus = status;

	final Completer<CocoonResponse<List<CommitStatus>>> _completer;
	CocoonResponse<List<CommitStatus>>? _pausedStatus;

	bool get isComplete => _pausedStatus == null;

	Future<CocoonResponse<List<CommitStatus>>> get future => _completer.future;

	void update(CocoonResponse<List<CommitStatus>> newStatus) {
	assert(_pausedStatus != null);
	_pausedStatus = newStatus;
	}

	void complete() {
	assert(_pausedStatus != null);
	_completer.complete(_pausedStatus!);
	_pausedStatus = null;
	}
	}

	/// [CocoonService] for local development purposes.
	///
	/// This creates fake data that mimicks what production will send.
	class DevelopmentCocoonService implements CocoonService {
	DevelopmentCocoonService(this.now, {this.simulateLoadingDelays = false})
	: _random = math.Random(now.millisecondsSinceEpoch);

	final math.Random _random;

	final DateTime now;

	final bool simulateLoadingDelays;

	_PausedCommitStatus? _pausedStatus;
	bool _paused = false;
	bool get paused => _paused;
	set paused(bool pause) {
	if (_paused == pause) {
	return;
	}
	assert(_paused \|\| _pausedStatus == null \|\| _pausedStatus!.isComplete);
	if (_pausedStatus != null && !_pausedStatus!.isComplete) {
	_pausedStatus!.complete();
	_pausedStatus = null;
	}
	_paused = pause;
	}

	@override
	Future<CocoonResponse<List<CommitStatus>>> fetchCommitStatuses({
	CommitStatus? lastCommitStatus,
	String? branch,
	required String repo,
	}) async {
	final data = CocoonResponse<List<CommitStatus>>.data(
	_createFakeCommitStatuses(lastCommitStatus, repo, branch: branch),
	);
	if (_pausedStatus == null \|\| _pausedStatus!.isComplete) {
	_pausedStatus = _PausedCommitStatus(data);
	} else {
	_pausedStatus!.update(data);
	}

	if (!_paused) {
	if (simulateLoadingDelays) {
	final delayedStatus = _pausedStatus;
	Future<void>.delayed(const Duration(seconds: 2), () {
	if (!_paused && !delayedStatus!.isComplete) {
	delayedStatus.complete();
	}
	});
	} else {
	_pausedStatus!.complete();
	}
	}

	return _pausedStatus!.future;
	}

	final _treeStatusChanges = <String, List<TreeStatusChange>>{};
	static final _defaultChanges = [
	TreeStatusChange(
	createdOn: DateTime.now().subtract(const Duration(hours: 1)),
	status: TreeStatus.success,
	authoredBy: 'Joe Admin',
	reason: 'Test',
	),
	TreeStatusChange(
	createdOn: DateTime.now().subtract(const Duration(hours: 2)),
	status: TreeStatus.failure,
	authoredBy: 'Joe Admin',
	reason: 'Test',
	),
	];

	@override
	Future<CocoonResponse<List<TreeStatusChange>>> fetchTreeStatusChanges({
	required String idToken,
	required String repo,
	}) async {
	return CocoonResponse<List<TreeStatusChange>>.data(
	_treeStatusChanges.putIfAbsent(repo, () => [..._defaultChanges]),
	);
	}

	@override
	Future<CocoonResponse<void>> updateTreeStatus({
	required String idToken,
	required String repo,
	required TreeStatus status,
	String? reason,
	}) async {
	// At most 10 per.
	final list = _treeStatusChanges.putIfAbsent(
	repo,
	() => [..._defaultChanges],
	);
	list.insert(
	0,
	TreeStatusChange(
	createdOn: DateTime.now(),
	status: status,
	authoredBy: 'Joe Widget',
	reason: reason,
	),
	);
	if (list.length > 10) {
	list.removeLast();
	}
	return const CocoonResponse<void>.data(null);
	}

	static const List<String> _repos = <String>['flutter', 'cocoon'];

	@override
	Future<CocoonResponse<List<String>>> fetchRepos() async {
	return const CocoonResponse<List<String>>.data(_repos);
	}

	@override
	Future<CocoonResponse<BuildStatusResponse>> fetchTreeBuildStatus({
	String? branch,
	required String repo,
	}) async {
	final failed = _random.nextBool();
	final response = BuildStatusResponse(
	buildStatus: failed ? BuildStatus.failure : BuildStatus.success,
	failingTasks: [
	if (failed) ...['failed_task_1', 'failed_task_2'],
	],
	);
	return CocoonResponse<BuildStatusResponse>.data(response);
	}

	@override
	Future<CocoonResponse<List<Branch>>> fetchFlutterBranches() async {
	return CocoonResponse.data([
	Branch(channel: 'master', reference: 'master'),
	Branch(channel: 'stable', reference: 'flutter-3.13-candidate.0'),
	Branch(channel: 'beta', reference: 'flutter-3.15-candidate.5'),
	Branch(channel: 'dev', reference: 'flutter-3.15-candidate.12'),
	]);
	}

	@override
	Future<CocoonResponse<bool>> vacuumGitHubCommits(
	String idToken, {
	required String repo,
	required String branch,
	}) async {
	return const CocoonResponse<bool>.error(
	'Unable to vacuum against fake data. Try building the app to use prod data.',
	statusCode: 501 /* Not implemented */,
	);
	}

	@override
	Future<CocoonResponse<bool>> rerunTask({
	required String? idToken,
	required String taskName,
	required String commitSha,
	required String repo,
	required String branch,
	}) async {
	return const CocoonResponse<bool>.error(
	'Unable to retry against fake data. Try building the app to use prod data.',
	statusCode: 501 /* Not implemented */,
	);
	}

	@override
	Future<CocoonResponse<void>> rerunCommit({
	required String? idToken,
	required String commitSha,
	required String repo,
	required String branch,
	Iterable<TaskStatus>? include,
	}) async {
	return const CocoonResponse<void>.error(
	'Unable to schedule against fake data. Try building the app to use prod data.',
	statusCode: 501 /* Not implemented */,
	);
	}

	static const int _commitGap = 2 * 60 * 1000; // 2 minutes between commits

	List<CommitStatus> _createFakeCommitStatuses(
	CommitStatus? lastCommitStatus,
	String repo, {
	String? branch,
	}) {
	branch ??= defaultBranches[repo]!;
	final baseTimestamp =
	lastCommitStatus != null
	? (lastCommitStatus.commit.timestamp.toInt())
	: now.millisecondsSinceEpoch;
	final result = <CommitStatus>[];
	for (var index = 0; index < 25; index += 1) {
	final commitTimestamp = baseTimestamp - ((index + 1) * _commitGap);
	final random = math.Random(commitTimestamp);
	final commit = _createFakeCommit(
	commitTimestamp,
	random,
	repo,
	_commits[index],
	branch,
	);
	final status = CommitStatus(
	commit: commit,
	tasks: _createFakeTasks(commitTimestamp, commit, random),
	);
	result.add(status);
	}
	return result;
	}

	final List<String> _authors = <String>[
	'matan',
	'yegor',
	'john',
	'jenn',
	'kate',
	'stuart',
	];
	final _avatars = [
	'https://avatars.githubusercontent.com/u/168174?v=4',
	'https://avatars.githubusercontent.com/u/211513?v=4',
	'https://avatars.githubusercontent.com/u/1924313?v=4',
	'https://avatars.githubusercontent.com/u/682784?v=4',
	'https://avatars.githubusercontent.com/u/16964204?v=4',
	'https://avatars.githubusercontent.com/u/122189?v=4',
	];

	final List<int> _messagePrimes = <int>[3, 11, 17, 23, 31, 41, 47, 67, 79];
	final List<String> _words = <String>[
	'fixes',
	'issue',
	'crash',
	'developer',
	'blocker',
	'intermittent',
	'format',
	];
	final List<String> _commits = <String>[
	'2d22b5e85f986f3fa2cf1bfaf085905c2182c270',
	'2fd76f920a38e4384248173d05ee482d5aeaf4c5',
	'77238bc7bf35489df03bc00ce2b2231a1afe6b06',
	'01d87b7a802e6ea388a066e773b1af3dace44053',
	'754039ae0cc524db1052da0f22c9275e32fe4f54',
	'1f5e006a398fa5d0e59f78cd5071e2532d2fe438',
	'a798b24044d567df62b8693b179932a8364c8dd8',
	'4389a8a3dbe1ed4c6a643641e95d7759f2158d9e',
	'c05e886884ec9adff2f43b87dbcb02e3507d971b',
	'a2acc46447cdfcd6628a897dea27ff64849bfc99',
	'd31d67ffb38fbd09ecf0a11ad5f6fd433cec9c9f',
	'e303d2c71c956c9c1eb7bf81473aac20d756eb75',
	'789f6bb335fe31de5d9c6adbab2fc169030a057f',
	'c97f0670658e04f096a3e57b20fa8241306ffcaa',
	'e8e31198861b5f53f04900bdf9a54e8bf6b7d597',
	'434a0a7d3c4c3bc633e06de7707ef590c54c20c3',
	'e7fca29b3f0408c7c1726e270a5aba0e28e74090',
	'dd6f94d8573a77506a122899a0592a956ac57bec',
	'cb19ec23d79b9d422f577722e5a14253fdcaea71',
	'4cb8c6498aedfd2ff0f89e34eb5da993a77392bd',
	'de892884aa089f22aced4d19a71b6a1d521c8db6',
	'214470ceb026525fa225d52dfe7d27db2c4ddf31',
	'e0f4628b4379286c433bab020b9e193fdc437d05',
	'be5975cb0b7fcad7ab2c3122a8df3d541befdeab',
	'06f7ab60d4914e00b342f098e1ef3e43e501b469',
	'e1005bea192673e54faa0c769d9f0fb7439a09b4',
	'e22d7f6bf2e1e1969dd963d39ad32c756fb0f20e',
	'f4b4b20bb27cbbd1c42eee7b17ce39c5819dc818',
	'd717ed969b6a477499eb3cf823c78dbe654ca709',
	'6a8d6a42b4c9f4b72caf0a3b808e50909686a2b7',
	'afaa9bfa5d26ab419f791d5ca97d602ec52a30a5',
	'f553212d9bfbc6e70c0d6a4ac3fe71208bb77ca1',
	'c35f8b79f4a5103603ceaaa14d1df3857a166fa1',
	'46447341838d480966926d0b32771e281af1c885',
	'4e3330081d4e0a3e109cf1cfb514072a90b999d7',
	'4199ef93c3184c29362520ea5292d854a8728494',
	'a0538938974c60cb9249acf8f0588c3df3c0e4b1',
	'49cac0b6c1e0d7d1d04865c328c8cbe5c8e0cda2',
	'97e3cc6295515f8292f5f57868506c70446594c3',
	'c94e577ef3b0ab48255633c63f0143d9e3eab6f8',
	'17d9af726fb6e4a4a8cc4f1becfc11dc9d4db96c',
	'4af6ec81ad538e3da23ee88cba65ed8687a72ea3',
	'69cb45166d2f4f61069e1f1a975dab3f48bed832',
	'ae227082570f75b614bb29593911ada5137654ad',
	'882b9fa44962df0b80d9a25b2553796bd4eba2ff',
	'e1f5c4c7178c34ce561c493b558df7450995a60c',
	'56d7272cd497c73502ec5a09bdf69b4c7ecbfd74',
	'36a99b302f7348848ec477ce867a8b78656d9c6c',
	'48be7a01565289f44c2c9d4ff1436800c52acf75',
	'422cb82e01ee0192256a05217102f45f2f74551d',
	'f8744d10460abae3d75e92336b3bb264bb78cc8c',
	'5000f246c8c568547c551b11e4b72acd0179e73c',
	'52c09522b288766a42900aa73f77216907d16b23',
	'61adb59fc097335b45b23fc884a78362b71a3e9b',
	'b81c3c58e5a6c45bc8728024068291a7e5f19c1a',
	'dec394e5401b62024ed71253e900c25a06eb46f9',
	'fbe142d2cb60fb981521cfe72961642d69db8784',
	'24a9c4557e0366945c179433fab8434c2c8ee59f',
	'ccc28f607ae11fe79c39c42d88798c19b1388af9',
	'd4d5ca665e56063fdd37d42d2192c64151915454',
	'4273fc07c3e8a36726087becdf331f7d63fc7e66',
	'5e0380895cc8e34a6a58f238b7fd33b9e0f027fe',
	'146908e48a8a9f92f59fae86a7a4ff28c0ce9109',
	'2779a449026423bc0f50a10eead2d9f3720b825c',
	'ff9b954908341360ffb39f5eee2857172a29c0e5',
	'b00b6d146c4f4af1d28260a3f28abd15f0105221',
	'4ffd03df44741d73877a0848935eea0d6cbfc1e9',
	'c2c5b73aaae2583cc235319e53200e0e15cda438',
	'b7b370faf46f4c682827fbb3967e1ef117b3b0d1',
	'bc6c9ac81e5909408518568729c2c3a147402928',
	'ba1aa77c5bc5fe545b245f2b1883af3dfeeae6c0',
	'97a7060a7e28ab1d13cb2f4ca90be624b417168e',
	'3df1da69ffcb4e00cf13c65c9f0497a56413e5e9',
	'ebb13b4ed0cb41814839d4084c064e62526b2ec0',
	'70b9d50722307f0f45ceed01d421d6a425e95291',
	'3f81ca7b73f21ca9b449c147942fbe4fcd31450d',
	'86d490939df232966dc6ba363ebc0baaac364701',
	'6ba51f3f61025543d66e59c2c1ae3d1b37d5d8d6',
	'b728942e1c9a9046c1a5c8d8a25a644d0db7160c',
	'920819252a398c0e3da9b6017b110ee047c1748e',
	'd7c114d803b1365ea3a975c9600fc8cfd9efb9d4',
	'792aa82143bb12e97f396cb2a462ad617dbd22bc',
	];

	Commit _createFakeCommit(
	int commitTimestamp,
	math.Random random,
	String repo,
	String commitSha,
	String branch,
	) {
	final author = random.nextInt(_authors.length);
	final message = commitTimestamp % 37 + author;
	final messageInc = _messagePrimes[message % _messagePrimes.length];
	return Commit(
	author: CommitAuthor(
	login: _authors[author],
	avatarUrl: _avatars[author],
	),
	message: List<String>.generate(
	6,
	(int i) => _words[(message + i * messageInc) % _words.length],
	).join(' '),
	repository: 'flutter/$repo',
	sha: commitSha,
	timestamp: commitTimestamp,
	branch: branch,
	);
	}

	static const Map<String, int> _repoTaskCount = <String, int>{
	'flutter/cocoon': 3,
	'flutter/flutter': 100,
	'flutter/engine': 20,
	};

	List<Task> _createFakeTasks(
	int commitTimestamp,
	Commit commit,
	math.Random random,
	) {
	if (_repoTaskCount.containsKey(commit.repository) == false) {
	throw Exception(
	'Add ${commit.repository} to _repoTaskCount in DevCocoonService',
	);
	}
	return List<Task>.generate(
	_repoTaskCount[commit.repository]!,
	(int i) => _createFakeTask(commitTimestamp, i, random),
	);
	}

	static const _statuses = [
	TaskStatus.waitingForBackfill,
	TaskStatus.inProgress,
	TaskStatus.succeeded,
	TaskStatus.failed,
	TaskStatus.infraFailure,
	TaskStatus.skipped,
	TaskStatus.cancelled,
	];

	static const _minAttempts = {
	TaskStatus.waitingForBackfill: 0,
	TaskStatus.inProgress: 1,
	TaskStatus.succeeded: 1,
	TaskStatus.failed: 1,
	TaskStatus.infraFailure: 1,
	TaskStatus.skipped: 0,
	TaskStatus.cancelled: 1,
	};

	static const _maxAttempts = {
	TaskStatus.waitingForBackfill: 0,
	TaskStatus.inProgress: 2,
	TaskStatus.succeeded: 1,
	TaskStatus.failed: 2,
	TaskStatus.infraFailure: 2,
	TaskStatus.skipped: 0,
	TaskStatus.cancelled: 1,
	};

	Task _createFakeTask(int commitTimestamp, int index, math.Random random) {
	final age = (now.millisecondsSinceEpoch - commitTimestamp) ~/ _commitGap;
	assert(age >= 0);
	// The [statusesProbability] list is an list of proportional
	// weights to give each of the values in _statuses when randomly
	// determining the status. So e.g. if one is 150, another 50, and
	// the rest 0, then the first has a 75% chance of being picked,
	// the second a 25% chance, and the rest a 0% chance.
	final statusesProbability = <int>[
	// bigger = more probable
	math.max(index % 2, 20 - age * 2), // TaskStatus.waitingForBackfill
	math.max(0, 10 - age * 2), // TaskStatus.inProgress
	math.min(10 + age * 2, 100), // TaskStatus.succeeded
	math.min(1 + age ~/ 3, 30), // TaskStatus.failed
	if (index % 15 == 0) // TaskStatus.infraFailure
	5
	else if (index % 25 == 0)
	15
	else
	1,
	if (index % 20 == 0) 30,
	1, // TaskStatus.cancelled
	];
	// max is the sum of all the values in statusesProbability.
	final max = statusesProbability.fold(0, (int c, int p) => c + p);
	// weightedIndex is the random number in the range 0 <= weightedIndex < max.
	var weightedIndex = random.nextInt(max);
	// statusIndex is the actual index into _statuses that corresponds
	// to the randomly selected weightedIndex. So if
	// statusesProbability is 10,20,30 and weightedIndex is 15, then
	// the statusIndex will be 1 (corresponding to the second entry,
	// the one with weight 20, since lists are zero-indexed).
	var statusIndex = 0;
	while (weightedIndex > statusesProbability[statusIndex]) {
	weightedIndex -= statusesProbability[statusIndex];
	statusIndex += 1;
	}
	// Finally we get the actual status using statusIndex as an index into _statuses.
	final status = _statuses[statusIndex];
	final minAttempts = _minAttempts[status]!;
	final maxAttempts = _maxAttempts[status]!;
	final attempts =
	minAttempts + random.nextInt(maxAttempts - minAttempts + 1);

	final buildNumberList = List.generate(
	attempts > 1
	? random.nextBool()
	? attempts
	: attempts - 1
	: 1,
	(i) => i,
	);

	return Task(
	createTimestamp: commitTimestamp + index,
	startTimestamp: commitTimestamp + (index * 1000 * 60),
	endTimestamp: commitTimestamp + (index * 1000 * 60) + (index * 1000 * 60),

	builderName: 'Linux_android $index',
	attempts: attempts,
	currentBuildNumber:
	attempts == buildNumberList.length ? buildNumberList.last : null,
	buildNumberList: buildNumberList,
	isBringup: index == now.millisecondsSinceEpoch % 13,

	status: status,

	// Neither of these are strictly true from a domain perspective.
	lastAttemptFailed: random.nextBool() ? attempts > 1 : false,
	isFlaky: attempts > 1,
	);
	}
	}