| // Copyright 2014 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'; |
| |
| import 'package:dwds/dwds.dart'; |
| import 'package:flutter_tools/src/artifacts.dart'; |
| import 'package:flutter_tools/src/base/file_system.dart'; |
| import 'package:flutter_tools/src/base/io.dart'; |
| import 'package:flutter_tools/src/base/platform.dart'; |
| import 'package:flutter_tools/src/build_info.dart'; |
| import 'package:flutter_tools/src/isolated/devfs_web.dart'; |
| import 'package:flutter_tools/src/compile.dart'; |
| import 'package:flutter_tools/src/convert.dart'; |
| import 'package:flutter_tools/src/globals.dart' as globals; |
| import 'package:mockito/mockito.dart'; |
| import 'package:package_config/package_config.dart'; |
| import 'package:shelf/shelf.dart'; |
| |
| import '../../src/common.dart'; |
| import '../../src/testbed.dart'; |
| |
| const List<int> kTransparentImage = <int>[ |
| 0x89, 0x50, 0x4E, 0x47, 0x0D, 0x0A, 0x1A, 0x0A, 0x00, 0x00, 0x00, 0x0D, 0x49, |
| 0x48, 0x44, 0x52, 0x00, 0x00, 0x00, 0x01, 0x00, 0x00, 0x00, 0x01, 0x08, 0x06, |
| 0x00, 0x00, 0x00, 0x1F, 0x15, 0xC4, 0x89, 0x00, 0x00, 0x00, 0x0A, 0x49, 0x44, |
| 0x41, 0x54, 0x78, 0x9C, 0x63, 0x00, 0x01, 0x00, 0x00, 0x05, 0x00, 0x01, 0x0D, |
| 0x0A, 0x2D, 0xB4, 0x00, 0x00, 0x00, 0x00, 0x49, 0x45, 0x4E, 0x44, 0xAE, |
| ]; |
| |
| void main() { |
| Testbed testbed; |
| WebAssetServer webAssetServer; |
| Platform linux; |
| PackageConfig packages; |
| Platform windows; |
| MockHttpServer mockHttpServer; |
| |
| setUpAll(() async { |
| packages = PackageConfig(<Package>[ |
| Package('flutter_tools', Uri.file('/flutter_tools/lib/').normalizePath()) |
| ]); |
| }); |
| |
| setUp(() { |
| mockHttpServer = MockHttpServer(); |
| linux = FakePlatform(operatingSystem: 'linux', environment: <String, String>{}); |
| windows = FakePlatform(operatingSystem: 'windows', environment: <String, String>{}); |
| testbed = Testbed(setup: () { |
| webAssetServer = WebAssetServer( |
| mockHttpServer, |
| packages, |
| InternetAddress.loopbackIPv4, |
| null, |
| null, |
| null, |
| ); |
| }); |
| }); |
| |
| test('Handles against malformed manifest', () => testbed.run(() async { |
| final File source = globals.fs.file('source') |
| ..writeAsStringSync('main() {}'); |
| final File sourcemap = globals.fs.file('sourcemap') |
| ..writeAsStringSync('{}'); |
| final File metadata = globals.fs.file('metadata') |
| ..writeAsStringSync('{}'); |
| |
| // Missing ending offset. |
| final File manifestMissingOffset = globals.fs.file('manifestA') |
| ..writeAsStringSync(json.encode(<String, Object>{'/foo.js': <String, Object>{ |
| 'code': <int>[0], |
| 'sourcemap': <int>[0], |
| 'metadata': <int>[0], |
| }})); |
| final File manifestOutOfBounds = globals.fs.file('manifest') |
| ..writeAsStringSync(json.encode(<String, Object>{'/foo.js': <String, Object>{ |
| 'code': <int>[0, 100], |
| 'sourcemap': <int>[0], |
| 'metadata': <int>[0], |
| }})); |
| |
| expect(webAssetServer.write(source, manifestMissingOffset, sourcemap, metadata), isEmpty); |
| expect(webAssetServer.write(source, manifestOutOfBounds, sourcemap, metadata), isEmpty); |
| })); |
| |
| test('serves JavaScript files from in memory cache', () => testbed.run(() async { |
| final File source = globals.fs.file('source') |
| ..writeAsStringSync('main() {}'); |
| final File sourcemap = globals.fs.file('sourcemap') |
| ..writeAsStringSync('{}'); |
| final File metadata = globals.fs.file('metadata') |
| ..writeAsStringSync('{}'); |
| final File manifest = globals.fs.file('manifest') |
| ..writeAsStringSync(json.encode(<String, Object>{'/foo.js': <String, Object>{ |
| 'code': <int>[0, source.lengthSync()], |
| 'sourcemap': <int>[0, 2], |
| 'metadata': <int>[0, 2], |
| }})); |
| webAssetServer.write(source, manifest, sourcemap, metadata); |
| |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/foo.js'))); |
| |
| expect(response.headers, allOf(<Matcher>[ |
| containsPair(HttpHeaders.contentLengthHeader, source.lengthSync().toString()), |
| containsPair(HttpHeaders.contentTypeHeader, 'application/javascript'), |
| containsPair(HttpHeaders.etagHeader, isNotNull) |
| ])); |
| expect((await response.read().toList()).first, source.readAsBytesSync()); |
| }, overrides: <Type, Generator>{ |
| Platform: () => linux, |
| })); |
| |
| test('serves metadata files from in memory cache', () => testbed.run(() async { |
| const String metadataContents = '{"name":"foo"}'; |
| final File source = globals.fs.file('source') |
| ..writeAsStringSync('main() {}'); |
| final File sourcemap = globals.fs.file('sourcemap') |
| ..writeAsStringSync('{}'); |
| final File metadata = globals.fs.file('metadata') |
| ..writeAsStringSync(metadataContents); |
| final File manifest = globals.fs.file('manifest') |
| ..writeAsStringSync(json.encode(<String, Object>{'/foo.js': <String, Object>{ |
| 'code': <int>[0, source.lengthSync()], |
| 'sourcemap': <int>[0, sourcemap.lengthSync()], |
| 'metadata': <int>[0, metadata.lengthSync()], |
| }})); |
| webAssetServer.write(source, manifest, sourcemap, metadata); |
| |
| final String merged = await webAssetServer.metadataContents('main_module.ddc_merged_metadata'); |
| expect(merged, equals(metadataContents)); |
| |
| final String single = await webAssetServer.metadataContents('foo.js.metadata'); |
| expect(single, equals(metadataContents)); |
| }, overrides: <Type, Generator>{ |
| Platform: () => linux, |
| })); |
| |
| test('Removes leading slashes for valid requests to avoid requesting outside' |
| ' of served directory', () => testbed.run(() async { |
| globals.fs.file('foo.png').createSync(); |
| globals.fs.currentDirectory = globals.fs.directory('project_directory') |
| ..createSync(); |
| |
| final File source = globals.fs.file(globals.fs.path.join('web', 'foo.png')) |
| ..createSync(recursive: true) |
| ..writeAsBytesSync(kTransparentImage); |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar////foo.png'))); |
| |
| expect(response.headers, allOf(<Matcher>[ |
| containsPair(HttpHeaders.contentLengthHeader, source.lengthSync().toString()), |
| containsPair(HttpHeaders.contentTypeHeader, 'image/png'), |
| containsPair(HttpHeaders.etagHeader, isNotNull), |
| containsPair(HttpHeaders.cacheControlHeader, 'max-age=0, must-revalidate') |
| ])); |
| expect((await response.read().toList()).first, source.readAsBytesSync()); |
| })); |
| |
| test('takes base path into account when serving', () => testbed.run(() async { |
| webAssetServer.basePath = 'base/path'; |
| |
| globals.fs.file('foo.png').createSync(); |
| globals.fs.currentDirectory = globals.fs.directory('project_directory') |
| ..createSync(); |
| |
| final File source = globals.fs.file(globals.fs.path.join('web', 'foo.png')) |
| ..createSync(recursive: true) |
| ..writeAsBytesSync(kTransparentImage); |
| final Response response = |
| await webAssetServer.handleRequest( |
| Request('GET', Uri.parse('http://foobar/base/path/foo.png')), |
| ); |
| |
| expect(response.headers, allOf(<Matcher>[ |
| containsPair(HttpHeaders.contentLengthHeader, source.lengthSync().toString()), |
| containsPair(HttpHeaders.contentTypeHeader, 'image/png'), |
| containsPair(HttpHeaders.etagHeader, isNotNull), |
| containsPair(HttpHeaders.cacheControlHeader, 'max-age=0, must-revalidate') |
| ])); |
| expect((await response.read().toList()).first, source.readAsBytesSync()); |
| })); |
| |
| test('serves index.html at the base path', () => testbed.run(() async { |
| webAssetServer.basePath = 'base/path'; |
| |
| const String htmlContent = '<html><head></head><body id="test"></body></html>'; |
| final Directory webDir = globals.fs.currentDirectory |
| .childDirectory('web') |
| ..createSync(); |
| webDir.childFile('index.html').writeAsStringSync(htmlContent); |
| |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/base/path/'))); |
| |
| expect(response.statusCode, HttpStatus.ok); |
| expect(await response.readAsString(), htmlContent); |
| })); |
| |
| test('does not serve outside the base path', () => testbed.run(() async { |
| webAssetServer.basePath = 'base/path'; |
| |
| const String htmlContent = '<html><head></head><body id="test"></body></html>'; |
| final Directory webDir = globals.fs.currentDirectory |
| .childDirectory('web') |
| ..createSync(); |
| webDir.childFile('index.html').writeAsStringSync(htmlContent); |
| |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/'))); |
| |
| expect(response.statusCode, HttpStatus.notFound); |
| })); |
| |
| test('parses base path from index.html', () => testbed.run(() async { |
| const String htmlContent = '<html><head><base href="/foo/bar/"></head><body id="test"></body></html>'; |
| final Directory webDir = globals.fs.currentDirectory |
| .childDirectory('web') |
| ..createSync(); |
| webDir.childFile('index.html').writeAsStringSync(htmlContent); |
| |
| final WebAssetServer webAssetServer = WebAssetServer( |
| mockHttpServer, |
| packages, |
| InternetAddress.loopbackIPv4, |
| null, |
| null, |
| null, |
| ); |
| |
| expect(webAssetServer.basePath, 'foo/bar'); |
| })); |
| |
| test('handles lack of base path in index.html', () => testbed.run(() async { |
| const String htmlContent = '<html><head></head><body id="test"></body></html>'; |
| final Directory webDir = globals.fs.currentDirectory |
| .childDirectory('web') |
| ..createSync(); |
| webDir.childFile('index.html').writeAsStringSync(htmlContent); |
| |
| final WebAssetServer webAssetServer = WebAssetServer( |
| mockHttpServer, |
| packages, |
| InternetAddress.loopbackIPv4, |
| null, |
| null, |
| null, |
| ); |
| |
| // Defaults to "/" when there's no base element. |
| expect(webAssetServer.basePath, ''); |
| })); |
| |
| test('throws if base path is relative', () => testbed.run(() async { |
| const String htmlContent = '<html><head><base href="foo/bar/"></head><body id="test"></body></html>'; |
| final Directory webDir = globals.fs.currentDirectory |
| .childDirectory('web') |
| ..createSync(); |
| webDir.childFile('index.html').writeAsStringSync(htmlContent); |
| |
| expect( |
| () => WebAssetServer( |
| mockHttpServer, |
| packages, |
| InternetAddress.loopbackIPv4, |
| null, |
| null, |
| null, |
| ), |
| throwsToolExit(), |
| ); |
| })); |
| |
| test('throws if base path does not end with slash', () => testbed.run(() async { |
| const String htmlContent = '<html><head><base href="/foo/bar"></head><body id="test"></body></html>'; |
| final Directory webDir = globals.fs.currentDirectory |
| .childDirectory('web') |
| ..createSync(); |
| webDir.childFile('index.html').writeAsStringSync(htmlContent); |
| |
| expect( |
| () => WebAssetServer( |
| mockHttpServer, |
| packages, |
| InternetAddress.loopbackIPv4, |
| null, |
| null, |
| null, |
| ), |
| throwsToolExit(), |
| ); |
| })); |
| |
| test('serves JavaScript files from in memory cache not from manifest', () => testbed.run(() async { |
| webAssetServer.writeFile('foo.js', 'main() {}'); |
| |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/foo.js'))); |
| |
| expect(response.headers, allOf(<Matcher>[ |
| containsPair(HttpHeaders.contentLengthHeader, '9'), |
| containsPair(HttpHeaders.contentTypeHeader, 'application/javascript'), |
| containsPair(HttpHeaders.etagHeader, isNotNull), |
| containsPair(HttpHeaders.cacheControlHeader, 'max-age=0, must-revalidate') |
| ])); |
| expect((await response.read().toList()).first, utf8.encode('main() {}')); |
| })); |
| |
| test('Returns notModified when the ifNoneMatch header matches the etag', () => testbed.run(() async { |
| webAssetServer.writeFile('foo.js', 'main() {}'); |
| |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/foo.js'))); |
| final String etag = response.headers[HttpHeaders.etagHeader]; |
| |
| final Response cachedResponse = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/foo.js'), headers: <String, String>{ |
| HttpHeaders.ifNoneMatchHeader: etag |
| })); |
| |
| expect(cachedResponse.statusCode, HttpStatus.notModified); |
| expect(await cachedResponse.read().toList(), isEmpty); |
| })); |
| |
| test('serves index.html when path is unknown', () => testbed.run(() async { |
| const String htmlContent = '<html><head></head><body id="test"></body></html>'; |
| final Directory webDir = globals.fs.currentDirectory |
| .childDirectory('web') |
| ..createSync(); |
| webDir.childFile('index.html').writeAsStringSync(htmlContent); |
| |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/bar/baz'))); |
| |
| expect(response.statusCode, HttpStatus.ok); |
| expect(await response.readAsString(), htmlContent); |
| })); |
| |
| test('does not serve outside the base path', () => testbed.run(() async { |
| webAssetServer.basePath = 'base/path'; |
| |
| const String htmlContent = '<html><head></head><body id="test"></body></html>'; |
| final Directory webDir = globals.fs.currentDirectory |
| .childDirectory('web') |
| ..createSync(); |
| webDir.childFile('index.html').writeAsStringSync(htmlContent); |
| |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/'))); |
| |
| expect(response.statusCode, HttpStatus.notFound); |
| })); |
| |
| test('does not serve index.html when path is inside assets or packages', () => testbed.run(() async { |
| const String htmlContent = '<html><head></head><body id="test"></body></html>'; |
| final Directory webDir = globals.fs.currentDirectory |
| .childDirectory('web') |
| ..createSync(); |
| webDir.childFile('index.html').writeAsStringSync(htmlContent); |
| |
| Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/assets/foo/bar.png'))); |
| expect(response.statusCode, HttpStatus.notFound); |
| |
| response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/packages/foo/bar.dart.js'))); |
| expect(response.statusCode, HttpStatus.notFound); |
| |
| webAssetServer.basePath = 'base/path'; |
| |
| response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/base/path/assets/foo/bar.png'))); |
| expect(response.statusCode, HttpStatus.notFound); |
| |
| response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/base/path/packages/foo/bar.dart.js'))); |
| expect(response.statusCode, HttpStatus.notFound); |
| })); |
| |
| test('serves default index.html', () => testbed.run(() async { |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/'))); |
| |
| expect(response.statusCode, HttpStatus.ok); |
| expect((await response.read().toList()).first, |
| containsAllInOrder(utf8.encode('<html>'))); |
| })); |
| |
| test('handles web server paths without .lib extension', () => testbed.run(() async { |
| final File source = globals.fs.file('source') |
| ..writeAsStringSync('main() {}'); |
| final File sourcemap = globals.fs.file('sourcemap') |
| ..writeAsStringSync('{}'); |
| final File metadata = globals.fs.file('metadata') |
| ..writeAsStringSync('{}'); |
| final File manifest = globals.fs.file('manifest') |
| ..writeAsStringSync(json.encode(<String, Object>{'/foo.dart.lib.js': <String, Object>{ |
| 'code': <int>[0, source.lengthSync()], |
| 'sourcemap': <int>[0, 2], |
| 'metadata': <int>[0, 2], |
| }})); |
| webAssetServer.write(source, manifest, sourcemap, metadata); |
| |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/foo.dart.js'))); |
| |
| expect(response.statusCode, HttpStatus.ok); |
| })); |
| |
| test('serves JavaScript files from in memory cache on Windows', () => testbed.run(() async { |
| final File source = globals.fs.file('source') |
| ..writeAsStringSync('main() {}'); |
| final File sourcemap = globals.fs.file('sourcemap') |
| ..writeAsStringSync('{}'); |
| final File metadata = globals.fs.file('metadata') |
| ..writeAsStringSync('{}'); |
| final File manifest = globals.fs.file('manifest') |
| ..writeAsStringSync(json.encode(<String, Object>{'/foo.js': <String, Object>{ |
| 'code': <int>[0, source.lengthSync()], |
| 'sourcemap': <int>[0, 2], |
| 'metadata': <int>[0, 2], |
| }})); |
| webAssetServer.write(source, manifest, sourcemap, metadata); |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://localhost/foo.js'))); |
| |
| expect(response.headers, allOf(<Matcher>[ |
| containsPair(HttpHeaders.contentLengthHeader, source.lengthSync().toString()), |
| containsPair(HttpHeaders.contentTypeHeader, 'application/javascript'), |
| containsPair(HttpHeaders.etagHeader, isNotNull), |
| containsPair(HttpHeaders.cacheControlHeader, 'max-age=0, must-revalidate') |
| ])); |
| expect((await response.read().toList()).first, source.readAsBytesSync()); |
| }, overrides: <Type, Generator>{ |
| Platform: () => windows, |
| })); |
| |
| test('serves asset files from in filesystem with url-encoded paths', () => testbed.run(() async { |
| final File source = globals.fs.file(globals.fs.path.join('build', 'flutter_assets', Uri.encodeFull('abcd象形å—.png'))) |
| ..createSync(recursive: true) |
| ..writeAsBytesSync(kTransparentImage); |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/assets/abcd%25E8%25B1%25A1%25E5%25BD%25A2%25E5%25AD%2597.png'))); |
| |
| expect(response.headers, allOf(<Matcher>[ |
| containsPair(HttpHeaders.contentLengthHeader, source.lengthSync().toString()), |
| containsPair(HttpHeaders.contentTypeHeader, 'image/png'), |
| containsPair(HttpHeaders.etagHeader, isNotNull), |
| containsPair(HttpHeaders.cacheControlHeader, 'max-age=0, must-revalidate') |
| ])); |
| expect((await response.read().toList()).first, source.readAsBytesSync()); |
| })); |
| test('serves files from web directory', () => testbed.run(() async { |
| final File source = globals.fs.file(globals.fs.path.join('web', 'foo.png')) |
| ..createSync(recursive: true) |
| ..writeAsBytesSync(kTransparentImage); |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/foo.png'))); |
| |
| expect(response.headers, allOf(<Matcher>[ |
| containsPair(HttpHeaders.contentLengthHeader, source.lengthSync().toString()), |
| containsPair(HttpHeaders.contentTypeHeader, 'image/png'), |
| containsPair(HttpHeaders.etagHeader, isNotNull), |
| containsPair(HttpHeaders.cacheControlHeader, 'max-age=0, must-revalidate') |
| ])); |
| expect((await response.read().toList()).first, source.readAsBytesSync()); |
| })); |
| |
| test('serves asset files from in filesystem with known mime type on Windows', () => testbed.run(() async { |
| final File source = globals.fs.file(globals.fs.path.join('build', 'flutter_assets', 'foo.png')) |
| ..createSync(recursive: true) |
| ..writeAsBytesSync(kTransparentImage); |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/assets/foo.png'))); |
| |
| expect(response.headers, allOf(<Matcher>[ |
| containsPair(HttpHeaders.contentLengthHeader, source.lengthSync().toString()), |
| containsPair(HttpHeaders.contentTypeHeader, 'image/png'), |
| containsPair(HttpHeaders.etagHeader, isNotNull), |
| containsPair(HttpHeaders.cacheControlHeader, 'max-age=0, must-revalidate') |
| ])); |
| expect((await response.read().toList()).first, source.readAsBytesSync()); |
| }, overrides: <Type, Generator>{ |
| Platform: () => windows, |
| })); |
| |
| test('serves Dart files from in filesystem on Linux/macOS', () => testbed.run(() async { |
| final File source = globals.fs.file('foo.dart').absolute |
| ..createSync(recursive: true) |
| ..writeAsStringSync('void main() {}'); |
| |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/foo.dart'))); |
| |
| expect(response.headers, containsPair(HttpHeaders.contentLengthHeader, source.lengthSync().toString())); |
| expect((await response.read().toList()).first, source.readAsBytesSync()); |
| }, overrides: <Type, Generator>{ |
| Platform: () => linux, |
| })); |
| |
| test('serves asset files from in filesystem with known mime type', () => testbed.run(() async { |
| final File source = globals.fs.file(globals.fs.path.join('build', 'flutter_assets', 'foo.png')) |
| ..createSync(recursive: true) |
| ..writeAsBytesSync(kTransparentImage); |
| |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/assets/foo.png'))); |
| |
| expect(response.headers, allOf(<Matcher>[ |
| containsPair(HttpHeaders.contentLengthHeader, source.lengthSync().toString()), |
| containsPair(HttpHeaders.contentTypeHeader, 'image/png'), |
| ])); |
| expect((await response.read().toList()).first, source.readAsBytesSync()); |
| })); |
| |
| test('serves asset files files from in filesystem with unknown mime type and length > 12', () => testbed.run(() async { |
| final File source = globals.fs.file(globals.fs.path.join('build', 'flutter_assets', 'foo')) |
| ..createSync(recursive: true) |
| ..writeAsBytesSync(List<int>.filled(100, 0)); |
| |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/assets/foo'))); |
| |
| expect(response.headers, allOf(<Matcher>[ |
| containsPair(HttpHeaders.contentLengthHeader, '100'), |
| containsPair(HttpHeaders.contentTypeHeader, 'application/octet-stream'), |
| ])); |
| expect((await response.read().toList()).first, source.readAsBytesSync()); |
| })); |
| |
| test('serves asset files files from in filesystem with unknown mime type and length < 12', () => testbed.run(() async { |
| final File source = globals.fs.file(globals.fs.path.join('build', 'flutter_assets', 'foo')) |
| ..createSync(recursive: true) |
| ..writeAsBytesSync(<int>[1, 2, 3]); |
| |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/assets/foo'))); |
| |
| expect(response.headers, allOf(<Matcher>[ |
| containsPair(HttpHeaders.contentLengthHeader, '3'), |
| containsPair(HttpHeaders.contentTypeHeader, 'application/octet-stream'), |
| ])); |
| expect((await response.read().toList()).first, source.readAsBytesSync()); |
| })); |
| |
| test('serves valid etag header for asset files with non-ascii chracters', () => testbed.run(() async { |
| globals.fs.file(globals.fs.path.join('build', 'flutter_assets', 'fooπ')) |
| ..createSync(recursive: true) |
| ..writeAsBytesSync(<int>[1, 2, 3]); |
| |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http://foobar/assets/fooπ'))); |
| final String etag = response.headers[HttpHeaders.etagHeader]; |
| |
| expect(etag.runes, everyElement(predicate((int char) => char < 255))); |
| })); |
| |
| test('serves /packages/<package>/<path> files as if they were ' |
| 'package:<package>/<path> uris', () => testbed.run(() async { |
| final Uri expectedUri = packages.resolve( |
| Uri.parse('package:flutter_tools/foo.dart')); |
| final File source = globals.fs.file(globals.fs.path.fromUri(expectedUri)) |
| ..createSync(recursive: true) |
| ..writeAsBytesSync(<int>[1, 2, 3]); |
| |
| final Response response = await webAssetServer |
| .handleRequest(Request('GET', Uri.parse('http:///packages/flutter_tools/foo.dart'))); |
| |
| expect(response.headers, allOf(<Matcher>[ |
| containsPair(HttpHeaders.contentLengthHeader, '3'), |
| containsPair(HttpHeaders.contentTypeHeader, 'application/octet-stream'), |
| ])); |
| expect((await response.read().toList()).first, source.readAsBytesSync()); |
| })); |
| |
| test('calling dispose closes the http server', () => testbed.run(() async { |
| await webAssetServer.dispose(); |
| |
| verify(mockHttpServer.close()).called(1); |
| })); |
| |
| test('Can start web server with specified assets', () => testbed.run(() async { |
| globals.fs.file('.packages').writeAsStringSync('\n'); |
| final File outputFile = globals.fs.file(globals.fs.path.join('lib', 'main.dart')) |
| ..createSync(recursive: true); |
| outputFile.parent.childFile('a.sources').writeAsStringSync(''); |
| outputFile.parent.childFile('a.json').writeAsStringSync('{}'); |
| outputFile.parent.childFile('a.map').writeAsStringSync('{}'); |
| outputFile.parent.childFile('a.metadata').writeAsStringSync('{}'); |
| outputFile.parent.childFile('.packages').writeAsStringSync('\n'); |
| |
| final ResidentCompiler residentCompiler = MockResidentCompiler(); |
| when(residentCompiler.recompile( |
| any, |
| any, |
| outputPath: anyNamed('outputPath'), |
| packageConfig: anyNamed('packageConfig'), |
| )).thenAnswer((Invocation invocation) async { |
| return const CompilerOutput('a', 0, <Uri>[]); |
| }); |
| |
| final WebDevFS webDevFS = WebDevFS( |
| hostname: 'localhost', |
| port: 0, |
| packagesFilePath: '.packages', |
| urlTunneller: null, |
| useSseForDebugProxy: true, |
| useSseForDebugBackend: true, |
| nullAssertions: true, |
| buildInfo: const BuildInfo( |
| BuildMode.debug, |
| '', |
| treeShakeIcons: false, |
| nullSafetyMode: NullSafetyMode.unsound, |
| ), |
| enableDwds: false, |
| entrypoint: Uri.base, |
| testMode: true, |
| expressionCompiler: null, |
| chromiumLauncher: null, |
| ); |
| webDevFS.requireJS.createSync(recursive: true); |
| webDevFS.stackTraceMapper.createSync(recursive: true); |
| |
| final Uri uri = await webDevFS.create(); |
| webDevFS.webAssetServer.entrypointCacheDirectory = globals.fs.currentDirectory; |
| final String webPrecompiledSdk = globals.artifacts |
| .getArtifactPath(Artifact.webPrecompiledSdk); |
| final String webPrecompiledSdkSourcemaps = globals.artifacts |
| .getArtifactPath(Artifact.webPrecompiledSdkSourcemaps); |
| final String webPrecompiledCanvaskitSdk = globals.artifacts |
| .getArtifactPath(Artifact.webPrecompiledCanvaskitSdk); |
| final String webPrecompiledCanvaskitSdkSourcemaps = globals.artifacts |
| .getArtifactPath(Artifact.webPrecompiledCanvaskitSdkSourcemaps); |
| globals.fs.currentDirectory |
| .childDirectory('lib') |
| .childFile('web_entrypoint.dart') |
| ..createSync(recursive: true) |
| ..writeAsStringSync('GENERATED'); |
| globals.fs.file(webPrecompiledSdk) |
| ..createSync(recursive: true) |
| ..writeAsStringSync('HELLO'); |
| globals.fs.file(webPrecompiledSdkSourcemaps) |
| ..createSync(recursive: true) |
| ..writeAsStringSync('THERE'); |
| globals.fs.file(webPrecompiledCanvaskitSdk) |
| ..createSync(recursive: true) |
| ..writeAsStringSync('OL'); |
| globals.fs.file(webPrecompiledCanvaskitSdkSourcemaps) |
| ..createSync(recursive: true) |
| ..writeAsStringSync('CHUM'); |
| |
| await webDevFS.update( |
| mainUri: globals.fs.file(globals.fs.path.join('lib', 'main.dart')).uri, |
| generator: residentCompiler, |
| trackWidgetCreation: true, |
| bundleFirstUpload: true, |
| invalidatedFiles: <Uri>[], |
| packageConfig: PackageConfig.empty, |
| pathToReload: '', |
| ); |
| |
| expect(webDevFS.webAssetServer.getFile('require.js'), isNotNull); |
| expect(webDevFS.webAssetServer.getFile('stack_trace_mapper.js'), isNotNull); |
| expect(webDevFS.webAssetServer.getFile('main.dart'), isNotNull); |
| expect(webDevFS.webAssetServer.getFile('manifest.json'), isNotNull); |
| expect(webDevFS.webAssetServer.getFile('flutter_service_worker.js'), isNotNull); |
| expect(webDevFS.webAssetServer.getFile('version.json'),isNotNull); |
| expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js'), 'HELLO'); |
| expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js.map'), 'THERE'); |
| |
| // Update to the SDK. |
| globals.fs.file(webPrecompiledSdk).writeAsStringSync('BELLOW'); |
| |
| // New SDK should be visible.. |
| expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js'), 'BELLOW'); |
| |
| // Toggle CanvasKit |
| expect(webDevFS.webAssetServer.canvasKitRendering, false); |
| webDevFS.webAssetServer.canvasKitRendering = true; |
| |
| expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js'), 'OL'); |
| expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js.map'), 'CHUM'); |
| |
| // Generated entrypoint. |
| expect(await webDevFS.webAssetServer.dartSourceContents('web_entrypoint.dart'), |
| contains('GENERATED')); |
| |
| // served on localhost |
| expect(uri, Uri.http('localhost:0', '')); |
| |
| await webDevFS.destroy(); |
| }, overrides: <Type, Generator>{ |
| Artifacts: () => Artifacts.test(), |
| })); |
| |
| test('Can start web server with specified assets in sound null safety mode', () => testbed.run(() async { |
| globals.fs.file('.packages').writeAsStringSync('\n'); |
| final File outputFile = globals.fs.file(globals.fs.path.join('lib', 'main.dart')) |
| ..createSync(recursive: true); |
| outputFile.parent.childFile('a.sources').writeAsStringSync(''); |
| outputFile.parent.childFile('a.json').writeAsStringSync('{}'); |
| outputFile.parent.childFile('a.map').writeAsStringSync('{}'); |
| outputFile.parent.childFile('a.metadata').writeAsStringSync('{}'); |
| outputFile.parent.childFile('.packages').writeAsStringSync('\n'); |
| |
| final ResidentCompiler residentCompiler = MockResidentCompiler(); |
| when(residentCompiler.recompile( |
| any, |
| any, |
| outputPath: anyNamed('outputPath'), |
| packageConfig: anyNamed('packageConfig'), |
| )).thenAnswer((Invocation invocation) async { |
| return const CompilerOutput('a', 0, <Uri>[]); |
| }); |
| |
| final WebDevFS webDevFS = WebDevFS( |
| hostname: 'localhost', |
| port: 0, |
| packagesFilePath: '.packages', |
| urlTunneller: null, |
| useSseForDebugProxy: true, |
| useSseForDebugBackend: true, |
| nullAssertions: true, |
| buildInfo: const BuildInfo( |
| BuildMode.debug, |
| '', |
| treeShakeIcons: false, |
| nullSafetyMode: NullSafetyMode.autodetect, |
| ), |
| enableDwds: false, |
| entrypoint: Uri.base, |
| testMode: true, |
| expressionCompiler: null, |
| chromiumLauncher: null, |
| ); |
| webDevFS.requireJS.createSync(recursive: true); |
| webDevFS.stackTraceMapper.createSync(recursive: true); |
| |
| final Uri uri = await webDevFS.create(); |
| webDevFS.webAssetServer.entrypointCacheDirectory = globals.fs.currentDirectory; |
| globals.fs.currentDirectory |
| .childDirectory('lib') |
| .childFile('web_entrypoint.dart') |
| ..createSync(recursive: true) |
| ..writeAsStringSync('GENERATED'); |
| final String webPrecompiledSoundSdk = globals.artifacts |
| .getArtifactPath(Artifact.webPrecompiledSoundSdk); |
| final String webPrecompiledSoundSdkSourcemaps = globals.artifacts |
| .getArtifactPath(Artifact.webPrecompiledSoundSdkSourcemaps); |
| final String webPrecompiledCanvaskitSoundSdk = globals.artifacts |
| .getArtifactPath(Artifact.webPrecompiledCanvaskitSoundSdk); |
| final String webPrecompiledCanvaskitSoundSdkSourcemaps = globals.artifacts |
| .getArtifactPath(Artifact.webPrecompiledCanvaskitSoundSdkSourcemaps); |
| globals.fs.file(webPrecompiledSoundSdk) |
| ..createSync(recursive: true) |
| ..writeAsStringSync('HELLO'); |
| globals.fs.file(webPrecompiledSoundSdkSourcemaps) |
| ..createSync(recursive: true) |
| ..writeAsStringSync('THERE'); |
| globals.fs.file(webPrecompiledCanvaskitSoundSdk) |
| ..createSync(recursive: true) |
| ..writeAsStringSync('OL'); |
| globals.fs.file(webPrecompiledCanvaskitSoundSdkSourcemaps) |
| ..createSync(recursive: true) |
| ..writeAsStringSync('CHUM'); |
| |
| await webDevFS.update( |
| mainUri: globals.fs.file(globals.fs.path.join('lib', 'main.dart')).uri, |
| generator: residentCompiler, |
| trackWidgetCreation: true, |
| bundleFirstUpload: true, |
| invalidatedFiles: <Uri>[], |
| packageConfig: PackageConfig.empty, |
| pathToReload: '', |
| ); |
| |
| expect(webDevFS.webAssetServer.getFile('require.js'), isNotNull); |
| expect(webDevFS.webAssetServer.getFile('stack_trace_mapper.js'), isNotNull); |
| expect(webDevFS.webAssetServer.getFile('main.dart'), isNotNull); |
| expect(webDevFS.webAssetServer.getFile('manifest.json'), isNotNull); |
| expect(webDevFS.webAssetServer.getFile('flutter_service_worker.js'), isNotNull); |
| expect(webDevFS.webAssetServer.getFile('version.json'), isNotNull); |
| expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js'), 'HELLO'); |
| expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js.map'), 'THERE'); |
| |
| // Update to the SDK. |
| globals.fs.file(webPrecompiledSoundSdk).writeAsStringSync('BELLOW'); |
| |
| // New SDK should be visible.. |
| expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js'), 'BELLOW'); |
| |
| // Toggle CanvasKit |
| webDevFS.webAssetServer.canvasKitRendering = true; |
| expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js'), 'OL'); |
| expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js.map'), 'CHUM'); |
| |
| // Generated entrypoint. |
| expect(await webDevFS.webAssetServer.dartSourceContents('web_entrypoint.dart'), |
| contains('GENERATED')); |
| |
| // served on localhost |
| expect(uri, Uri.http('localhost:0', '')); |
| |
| await webDevFS.destroy(); |
| }, overrides: <Type, Generator>{ |
| Artifacts: () => Artifacts.test(), |
| })); |
| |
| test('Can start web server with hostname any', () => testbed.run(() async { |
| globals.fs.file('.packages').writeAsStringSync('\n'); |
| final File outputFile = globals.fs.file(globals.fs.path.join('lib', 'main.dart')) |
| ..createSync(recursive: true); |
| outputFile.parent.childFile('a.sources').writeAsStringSync(''); |
| outputFile.parent.childFile('a.json').writeAsStringSync('{}'); |
| outputFile.parent.childFile('a.map').writeAsStringSync('{}'); |
| outputFile.parent.childFile('.packages').writeAsStringSync('\n'); |
| |
| final ResidentCompiler residentCompiler = MockResidentCompiler(); |
| when(residentCompiler.recompile( |
| any, |
| any, |
| outputPath: anyNamed('outputPath'), |
| packageConfig: anyNamed('packageConfig'), |
| )).thenAnswer((Invocation invocation) async { |
| return const CompilerOutput('a', 0, <Uri>[]); |
| }); |
| |
| final WebDevFS webDevFS = WebDevFS( |
| hostname: 'any', |
| port: 0, |
| packagesFilePath: '.packages', |
| urlTunneller: null, |
| useSseForDebugProxy: true, |
| useSseForDebugBackend: true, |
| buildInfo: BuildInfo.debug, |
| enableDwds: false, |
| entrypoint: Uri.base, |
| testMode: true, |
| expressionCompiler: null, |
| chromiumLauncher: null, |
| nullAssertions: true, |
| ); |
| webDevFS.requireJS.createSync(recursive: true); |
| webDevFS.stackTraceMapper.createSync(recursive: true); |
| |
| final Uri uri = await webDevFS.create(); |
| |
| expect(uri, Uri.http('localhost:0', '')); |
| await webDevFS.destroy(); |
| })); |
| |
| test('Can start web server with canvaskit enabled', () => testbed.run(() async { |
| globals.fs.file('.packages').writeAsStringSync('\n'); |
| final File outputFile = globals.fs.file(globals.fs.path.join('lib', 'main.dart')) |
| ..createSync(recursive: true); |
| outputFile.parent.childFile('a.sources').writeAsStringSync(''); |
| outputFile.parent.childFile('a.json').writeAsStringSync('{}'); |
| outputFile.parent.childFile('a.map').writeAsStringSync('{}'); |
| outputFile.parent.childFile('.packages').writeAsStringSync('\n'); |
| |
| final ResidentCompiler residentCompiler = MockResidentCompiler(); |
| when(residentCompiler.recompile( |
| any, |
| any, |
| outputPath: anyNamed('outputPath'), |
| packageConfig: anyNamed('packageConfig'), |
| )).thenAnswer((Invocation invocation) async { |
| return const CompilerOutput('a', 0, <Uri>[]); |
| }); |
| |
| final WebDevFS webDevFS = WebDevFS( |
| hostname: 'localhost', |
| port: 0, |
| packagesFilePath: '.packages', |
| urlTunneller: null, |
| useSseForDebugProxy: true, |
| useSseForDebugBackend: true, |
| nullAssertions: true, |
| buildInfo: const BuildInfo( |
| BuildMode.debug, |
| '', |
| treeShakeIcons: false, |
| dartDefines: <String>[ |
| 'FLUTTER_WEB_USE_SKIA=true', |
| ] |
| ), |
| enableDwds: false, |
| entrypoint: Uri.base, |
| testMode: true, |
| expressionCompiler: null, |
| chromiumLauncher: null, |
| ); |
| webDevFS.requireJS.createSync(recursive: true); |
| webDevFS.stackTraceMapper.createSync(recursive: true); |
| |
| await webDevFS.create(); |
| |
| expect(webDevFS.webAssetServer.canvasKitRendering, true); |
| |
| await webDevFS.destroy(); |
| })); |
| |
| test('allows frame embedding', () async { |
| final WebAssetServer webAssetServer = await WebAssetServer.start( |
| null, |
| 'localhost', |
| 0, |
| null, |
| true, |
| true, |
| const BuildInfo( |
| BuildMode.debug, |
| '', |
| treeShakeIcons: false, |
| ), |
| false, |
| Uri.base, |
| null, |
| testMode: true); |
| |
| expect(webAssetServer.defaultResponseHeaders['x-frame-options'], null); |
| await webAssetServer.dispose(); |
| }); |
| } |
| |
| class MockHttpServer extends Mock implements HttpServer {} |
| class MockResidentCompiler extends Mock implements ResidentCompiler {} |
| class MockDwds extends Mock implements Dwds {} |