|
| 1 | +// Copyright (c) 2020, the Dart project authors. Please see the AUTHORS file |
| 2 | +// for details. All rights reserved. Use of this source code is governed by a |
| 3 | +// BSD-style license that can be found in the LICENSE file. |
| 4 | + |
| 5 | +// @dart = 2.9 |
| 6 | + |
| 7 | +import 'dart:io'; |
| 8 | + |
| 9 | +import 'package:http/http.dart' as http; |
| 10 | +import 'package:http/io_client.dart'; |
| 11 | +import 'package:shelf/shelf.dart'; |
| 12 | +import 'package:shelf_proxy/shelf_proxy.dart'; |
| 13 | +import 'package:test/test.dart'; |
| 14 | + |
| 15 | +import '../fixtures/context.dart'; |
| 16 | +import '../fixtures/logging.dart'; |
| 17 | +import '../fixtures/utilities.dart'; |
| 18 | + |
| 19 | +void setCurrentLogWriter() { |
| 20 | + configureLogWriter( |
| 21 | + customLogWriter: (level, message, |
| 22 | + {loggerName, error, stackTrace, verbose}) => |
| 23 | + printOnFailure('[$level] $loggerName: $message')); |
| 24 | +} |
| 25 | + |
| 26 | +void main() { |
| 27 | + group('Asset handler', () { |
| 28 | + final context = TestContext(); |
| 29 | + Handler assetHandler; |
| 30 | + http.Client client; |
| 31 | + |
| 32 | + setUpAll(() async { |
| 33 | + setCurrentLogWriter(); |
| 34 | + await context.setUp(enableExpressionEvaluation: true, verbose: true); |
| 35 | + |
| 36 | + client = IOClient(HttpClient() |
| 37 | + ..maxConnectionsPerHost = 200 |
| 38 | + ..idleTimeout = const Duration(seconds: 30) |
| 39 | + ..connectionTimeout = const Duration(seconds: 30)); |
| 40 | + |
| 41 | + var assetServerPort = daemonPort(context.workingDirectory); |
| 42 | + var pathToServe = context.pathToServe; |
| 43 | + |
| 44 | + assetHandler = proxyHandler( |
| 45 | + 'http://localhost:$assetServerPort/$pathToServe/', |
| 46 | + client: client); |
| 47 | + }); |
| 48 | + |
| 49 | + tearDownAll(() async { |
| 50 | + client.close(); |
| 51 | + await context.tearDown(); |
| 52 | + }); |
| 53 | + |
| 54 | + setUp(setCurrentLogWriter); |
| 55 | + |
| 56 | + Future<void> readAsString(String path) async { |
| 57 | + var request = Request('GET', Uri.parse('http://foo:0000/$path')); |
| 58 | + var response = await assetHandler(request); |
| 59 | + var result = await response.readAsString(); |
| 60 | + expect(result, isNotNull, |
| 61 | + reason: 'Failed to read $path: ${response.statusCode}'); |
| 62 | + } |
| 63 | + |
| 64 | + Future<void> readAsBytes(String path) async { |
| 65 | + var request = Request('GET', Uri.parse('http://foo:0000/$path')); |
| 66 | + var response = await assetHandler(request); |
| 67 | + var result = await response.read().toList(); |
| 68 | + expect(result, isNotNull, |
| 69 | + reason: 'Failed to read $path: ${response.statusCode}'); |
| 70 | + } |
| 71 | + |
| 72 | + test('can read dill files', () async { |
| 73 | + var path = 'hello_world/main.unsound.ddc.full.dill'; |
| 74 | + await readAsBytes(path); |
| 75 | + }); |
| 76 | + |
| 77 | + test('can read large number of resources simultaneously', () async { |
| 78 | + final n = 1000; |
| 79 | + var futures = [ |
| 80 | + for (var i = 0; i < n; i++) |
| 81 | + readAsString('hello_world/main.unsound.ddc.js.map'), |
| 82 | + for (var i = 0; i < n; i++) |
| 83 | + readAsString('hello_world/main.unsound.ddc.js'), |
| 84 | + for (var i = 0; i < n; i++) |
| 85 | + readAsBytes('hello_world/main.unsound.ddc.full.dill'), |
| 86 | + ]; |
| 87 | + |
| 88 | + await expectLater(Future.wait(futures), completes); |
| 89 | + }); |
| 90 | + }); |
| 91 | +} |
0 commit comments