// Copyright (c) 2017, 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:async';
import 'logger.dart';
import 'cache_new.dart';
import 'luci_api.dart';
import 'util.dart';

const UNINTERESTING_BUILDER_SUFFIXES = const [
  "-dev",
  "-stable",
  "-integration"
];

const String DART_CLIENT = 'client.dart';

/// Fetches all builds for a given [commit]-hash, by searching the latest
/// [amount] builds.
Future<List<BuildDetail>> fetchBuildsForCommmit(LuciApi luciApi, Logger logger,
    String client, String commit, CreateCacheFunction createCache,
    [int amount = 1]) {
  logger.info(
      "Sorry - this is going to take some time, since we have to look into all "
      "$amount latest builds for all bots for client ${client}.\n"
      "Subsequent queries run faster if caching is not turned off...");

  logger.debug("Finding primary bots for client $client");
  var futureBuildBots = getPrimaryBuilders(
      luciApi, client, createCache(duration: new Duration(minutes: 30)));

  var cache = createCache(duration: new Duration(minutes: 30));

  return futureBuildBots.then((buildBots) {
    var buildBotBuilds = new List<List<BuildDetail>>();
    var futureDetails = buildBots.map((buildBot) {
      return luciApi
          .getBuildBotDetails(client, buildBot, cache, amount)
          .then(buildBotBuilds.add)
          .catchError(
              errorLogger(logger, "Could not get details for $buildBot", []));
    });
    return Future.wait(futureDetails).then((details) {
      return buildBotBuilds.expand((id) => id);
    }).then((details) {
      return details.where((buildDetail) {
        return buildDetail.allChanges
            .any((change) => change.revision.startsWith(commit));
      }).toList();
    });
  });
}

/// [getBuilderGroups] fetches all builder groups not in -dev, -stable and
/// -integration from CBE.
Future<List<String>> getBuilderGroups(
    LuciApi luciApi, String client, WithCacheFunction withCache) {
  var result = luciApi.getJsonFromChromeBuildExtract(client, withCache);
  return result.then((json) {
    var builders = json["builders"];
    return builders.keys.fold<Map<String, Object>>({},
        (Map<String, Object> map, builderKey) {
      if (UNINTERESTING_BUILDER_SUFFIXES.any((x) => builderKey.contains(x))) {
        return map;
      }
      map[sanitizeCategory(builders[builderKey]["category"])] = true;
      return map;
    }).keys;
  });
}

/// [getAllBuilders] fetches all builders from CBE.
Future<List<String>> getAllBuilders(
    LuciApi luciApi, String client, WithCacheFunction withCache) {
  var result = luciApi.getJsonFromChromeBuildExtract(client, withCache);
  return result.then((json) {
    return json["builders"].keys;
  });
}

/// [getPrimaryBuilders] fetches all primary builders from CBE.
Future<List<String>> getPrimaryBuilders(
    LuciApi luciApi, String client, WithCacheFunction withCache) {
  var result = getAllBuilders(luciApi, client, withCache);
  return result.then((builders) {
    return builders
        .where((builderKey) =>
            !UNINTERESTING_BUILDER_SUFFIXES.any((x) => builderKey.contains(x)))
        .toList();
  });
}

/// [getPrimaryBuilders] gets all builders in builder group [builderGroup].
Future<List<String>> getBuildersInBuilderGroup(LuciApi luciApi, String client,
    WithCacheFunction withCache, String builderGroup) {
  var result = luciApi.getJsonFromChromeBuildExtract(client, withCache);
  return result.then((json) {
    var builders = json["builders"];
    return builders.keys.where((builder) {
      return sanitizeCategory(builders[builder]["category"]) == builderGroup;
    }).toList();
  });
}