blob: b680190674bfa69f4ed5df9bfd4e6d7de9064059 [file] [log] [blame]
// Copyright (c) 2019, the Dart project authors. Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.
import 'package:firebase_functions_interop/firebase_functions_interop.dart';
import 'package:node_http/node_http.dart' as http;
import 'package:node_interop/node.dart';
import 'builder.dart';
import 'commits_cache.dart';
import 'firestore_impl.dart';
import 'tryjob.dart';
final commits = CommitsCache(FirestoreServiceImpl(), http.NodeClient());
void main() {
functions['receiveChanges'] =
Future<void> receiveChanges(Message message, EventContext context) async {
final results = (message.json as List).cast<Map<String, dynamic>>();
final first = results.first;
final String commit = first['commit_hash'];
final int countChunks = message.attributes.containsKey('num_chunks')
? int.parse(message.attributes['num_chunks'])
: null;
final String buildbucketID = message.attributes['buildbucket_id'];
final String baseRevision = message.attributes['base_revision'];
try {
var firestore = FirestoreServiceImpl();
if (commit.startsWith('refs/changes')) {
return await Tryjob(commit, countChunks, buildbucketID, baseRevision,
commits, firestore, http.NodeClient())
} else {
return await Build(commit, first, countChunks, commits, firestore)
} catch (e, trace) {
console.error('Uncaught exception in cloud function', e.toString(),
trace.toString(), 'first record: $first');