// 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.

/// Serves the log over HTTP for a failing test on a given runner and build

import 'dart:async';
import 'dart:io';

import 'package:dart_ci/src/approvals_feed.dart';
import 'package:dart_ci/src/get_log.dart';

void main() async {
  await refresh();
  final server = await HttpServer.bind(InternetAddress.anyIPv4, 8080);
  server.listen(dispatchingServer);
  print("Server started at ip:port ${server.address}:${server.port}");
  Timer.periodic(Duration(minutes: 10), (timer) async {
    try {
      await refresh();
    } catch (e, t) {
      print(e);
      print(t);
    }
  });
}

Future<void> refresh() async {
  await getApprovals();
}

Future<void> dispatchingServer(HttpRequest request) async {
  try {
    if (request.uri.path == '/') {
      return await serveFrontPage(request);
    } else if (request.uri.path.startsWith('/log/')) {
      return await serveLog(request);
    } else if (request.uri.path.startsWith('/changes')) {
      return await serveChanges(request);
    } else if (request.uri.path.startsWith('/approvals/')) {
      return await serveApprovals(request);
    } else {
      return await notFound(request);
    }
  } catch (e, t) {
    print(e);
    print(t);
    serverError(request);
  }
}

void serveFrontPage(HttpRequest request) async {
  request.response.headers.contentType = ContentType.html;
  request.response.write("""<!DOCTYPE html>
<html lang="en">
  <head>
    <meta charset="utf-8">
    <title>Dart Continuous Integration</title>
  </head>
  <body>
    <h1>Dart Continuous Integration</h1>
    <h2><a href="https://dart-ci.firebaseapp.com/#showAllCommits=false&showLatestFailures=true">Results Feed</a></h2>
    <h2><a href="approvals/">Approvals Feed</a></h2>
  </body>
</html>
""");
  request.response.close();
}

Future<void> serveLog(HttpRequest request) async {
  final parts = request.uri.pathSegments;
  final builder = parts[1];
  final configuration = parts[2];
  final build = parts[3];
  final test = parts.skip(4).join('/');

  if (build == 'latest') {
    final actualBuild = await getLatestBuildNumber(builder);
    return redirectTemporary(
        request, '/log/$builder/$configuration/$actualBuild/$test');
  }
  final log = await getLog(builder, build, configuration, test);
  if (log == null) {
    return noLog(request, builder, build, test);
  }
  final response = request.response;
  response.headers.contentType = ContentType.text;
  response.headers.expires = DateTime.now().add(const Duration(days: 30));
  response.write(log);
  return response.close();
}

Future<void> redirectTemporary(HttpRequest request, String newPath) {
  request.response.headers.add(HttpHeaders.locationHeader, newPath);
  request.response.statusCode = HttpStatus.movedTemporarily;
  return request.response.close();
}

Future<void> serveChanges(HttpRequest request) async {
  return request.response.redirect(Uri.parse(
      'https://dart-ci.firebaseapp.com/#showAllCommits=false&showLatestFailures=true'),
      status: HttpStatus.movedPermanently);
}

Future<void> notFound(HttpRequest request) {
  request.response.statusCode = HttpStatus.notFound;
  return request.response.close();
}

Future<void> noLog(
    HttpRequest request, String builder, String build, String test) async {
  request.response.headers.contentType = ContentType.text;
  request.response
      .write("No log for test $test on build $build of builder $builder");
  return request.response.close();
}

Future<void> serverError(HttpRequest request) {
  try {
    request.response.statusCode = HttpStatus.internalServerError;
  } catch (e) {
    print(e);
  }
  return request.response.close();
}