functions/node/gerrit_change.dart

// 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 'dart:convert';

import 'package:node_http/node_http.dart' as http;

import 'firestore.dart';

class GerritInfo {
  static const gerritUrl = 'https://dart-review.googlesource.com/changes';
  static const trivialKinds = const {
    'TRIVIAL_REBASE',
    'NO_CHANGE',
    'NO_CODE_CHANGE',
  };
  static const prefix = ")]}'\n";

  FirestoreService firestore;
  String review;
  String patchset;

  GerritInfo(int review, int patchset, this.firestore) {
    this.review = review.toString();
    this.patchset = patchset.toString();
  }

// Fetch the owner, changeId, message, and date of a Gerrit change.
  Future<void> update() async {
    if (await firestore.hasPatchset(review, patchset)) return;
    final client = http.NodeClient();
    // Get the Gerrit change's commit from the Gerrit API.
    final url = '$gerritUrl/$review?o=ALL_REVISIONS&o=DETAILED_ACCOUNTS';
    final response = await client.get(url);
    final protectedJson = response.body;
    if (!protectedJson.startsWith(prefix))
      throw Exception('Gerrit response missing prefix $prefix: $protectedJson');
    final reviewInfo = jsonDecode(protectedJson.substring(prefix.length))
        as Map<String, dynamic>;
    await firestore.storeReview(review, {'subject': reviewInfo['subject']});

    // Add the patchset information to the patchsets subcollection.
    final revisions = reviewInfo['revisions'].values.toList()
      ..sort((a, b) => (a['_number'] as int).compareTo(b['_number']));
    var patchsetGroupFirst;
    for (Map<String, dynamic> revision in revisions) {
      final number = revision['_number'];
      if (!trivialKinds.contains(revision['kind'])) {
        patchsetGroupFirst = number;
      }
      await firestore.storePatchset(review, number, {
        'number': number,
        'patchset_group': patchsetGroupFirst,
        'description': revision['description'],
        'kind': revision['kind']
      });
    }
  }
}