| // 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/get_log.dart'; |
| |
| void main() async { |
| final server = await HttpServer.bind(InternetAddress.anyIPv4, 8080); |
| server.listen(dispatchingServer); |
| print("Server started at ip:port ${server.address}:${server.port}"); |
| } |
| |
| Future<void> dispatchingServer(HttpRequest request) async { |
| try { |
| if (request.uri.path.startsWith('/log/')) { |
| return await serveLog(request); |
| } |
| return await serveFrontPage(request); |
| } on UserVisibleFailure catch (e) { |
| print(e); |
| showError(request, e); |
| } 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 Test Logs</title> |
| </head> |
| <body> |
| <h1>Dart Test Logs</h1> |
| URL formats: |
| <ul> |
| <li>/logs/any/[configuration name]/latest/[test name] |
| <li>/logs/any/[configuration name]/[build number]/[test name] |
| <li>/logs/any/[configuration name]/latest/[test name prefix]* |
| <li>/logs/[builder]/[configuration name]/latest/[test name] |
| <li>/logs/[builder]/*/latest/[test name] |
| </ul> |
| and all combinations of these except /logs/any/*/... . |
| </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 = builder == 'any' |
| ? await getLatestConfigurationBuildNumber(configuration) |
| : await getLatestBuildNumber(builder); |
| return redirectTemporary( |
| request, '/log/$builder/$configuration/$actualBuild/$test'); |
| } |
| final log = await getLog(builder, build, configuration, test); |
| if (log == null) { |
| throw UserVisibleFailure('No logs found for test $test on build $build of ' |
| 'builder $builder, configuration $configuration'); |
| } |
| 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> notFound(HttpRequest request) { |
| request.response.statusCode = HttpStatus.notFound; |
| return request.response.close(); |
| } |
| |
| Future<void> showError(HttpRequest request, UserVisibleFailure failure) { |
| request.response.headers.contentType = ContentType.text; |
| request.response.write(failure.toString()); |
| return request.response.close(); |
| } |
| |
| Future<void> serverError(HttpRequest request) { |
| try { |
| request.response.statusCode = HttpStatus.internalServerError; |
| } catch (e) { |
| print(e); |
| } |
| return request.response.close(); |
| } |
