app_dart/tool/local_server.dart

// 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:io' as io;

import 'package:appengine/appengine.dart';
import 'package:cocoon_integration_test/testing.dart';
import 'package:cocoon_server/google_auth_provider.dart';
import 'package:cocoon_server_test/fake_secret_manager.dart';
import 'package:cocoon_service/cocoon_service.dart';
import 'package:cocoon_service/server.dart';

import 'package:cocoon_service/src/request_handling/http_io.dart';
import 'package:cocoon_service/src/service/big_query.dart';
import 'package:cocoon_service/src/service/build_status_service.dart';
import 'package:cocoon_service/src/service/commit_service.dart';
import 'package:cocoon_service/src/service/firebase_jwt_validator.dart';
import 'package:cocoon_service/src/service/get_files_changed.dart';
import 'package:cocoon_service/src/service/scheduler/ci_yaml_fetcher.dart';
import 'package:http/http.dart' as http;

Future<void> main() async {
  final cache = CacheService(inMemory: false);
  final config = Config(
    cache,
    FakeSecretManager(),
    initialConfig: DynamicConfig.fromJson({}),
    httpClient: MappingHttpClient(http.Client()),
  );
  final firestore = FakeFirestoreService();

  // TODO(matanlurey): This will not work, but matches the behavior of what
  // the default FakeConfig service did before refactoring.
  // https://github.com/flutter/cocoon/blob/2995f3a4b8c778bf41df5cd1a42dce966202a6b9/app_dart/lib/src/service/config.dart#L505-L507
  final bigQuery = await BigQueryService.from(const GoogleAuthProvider());

  final firebaseJwtValidator = FirebaseJwtValidator(cache: cache);
  final dashboardAuthProvider = DashboardAuthentication(
    cache: cache,
    firebaseJwtValidator: firebaseJwtValidator,
    firestore: firestore,
  );
  final presubmitAuthProvider = PresubmitAuthentication(
    cache: cache,
    config: config,
    firebaseJwtValidator: firebaseJwtValidator,
    firestore: firestore,
  );
  final AuthenticationProvider swarmingAuthProvider =
      SwarmingAuthenticationProvider(config: config);

  final buildBucketClient = BuildBucketClient(
    accessTokenService: AccessTokenService.defaultProvider(config),
    httpClient: config.httpClient,
  );

  // Gerrit service class to communicate with GoB.
  final gerritService = GerritService(
    config: config,
    authClient: config.httpClient,
  );

  /// LUCI service class to communicate with buildBucket service.
  final luciBuildService = LuciBuildService(
    config: config,
    cache: cache,
    buildBucketClient: buildBucketClient,
    gerritService: gerritService,
    pubsub: const PubSub(),
    firestore: firestore,
  );

  /// Github checks api service used to provide luci test execution status on the Github UI.
  final githubChecksService = GithubChecksService(config);

  final ciYamlFetcher = CiYamlFetcher(
    config: config,
    cache: cache,
    firestore: firestore,
  );

  final contentHashService = FakeContentAwareHashService(config: config);

  /// Cocoon scheduler service to manage validating commits in presubmit and postsubmit.
  final scheduler = Scheduler(
    cache: cache,
    config: config,
    githubChecksService: githubChecksService,
    githubService: await config.createDefaultGitHubService(),
    getFilesChanged: GithubApiGetFilesChanged(config),
    luciBuildService: luciBuildService,
    ciYamlFetcher: ciYamlFetcher,
    contentAwareHash: contentHashService,
    firestore: firestore,
    bigQuery: bigQuery,
  );

  final branchService = BranchService(
    config: config,
    gerritService: gerritService,
  );

  final commitService = CommitService(config: config, firestore: firestore);

  final buildStatusService = BuildStatusService(
    firestore: firestore,
    config: config,
  );

  final server = createServer(
    config: config,
    firestore: firestore,
    bigQuery: bigQuery,
    cache: cache,
    dashboardAuthProvider: dashboardAuthProvider,
    presubmitAuthProvider: presubmitAuthProvider,
    branchService: branchService,
    buildBucketClient: buildBucketClient,
    gerritService: gerritService,
    scheduler: scheduler,
    luciBuildService: luciBuildService,
    githubChecksService: githubChecksService,
    commitService: commitService,
    swarmingAuthProvider: swarmingAuthProvider,
    ciYamlFetcher: ciYamlFetcher,
    buildStatusService: buildStatusService,
    contentAwareHashService: contentHashService,
  );

  return runAppEngine(
    (io.HttpRequest request) async {
      await server(request.toRequest());
    },
    onAcceptingConnections: (io.InternetAddress address, int port) {
      final host = address.isLoopback ? 'localhost' : address.host;
      print('Serving requests at http://$host:$port/');
    },
  );
}