devfs_web_test.dart 47.6 KB
Newer Older
Ian Hickson's avatar
Ian Hickson committed
1
// Copyright 2014 The Flutter Authors. All rights reserved.
2 3 4
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

5
import 'dart:async';
6
import 'dart:io' hide Directory, File;
7

8 9
import 'package:dwds/dwds.dart';
import 'package:fake_async/fake_async.dart';
10
import 'package:flutter_tools/src/artifacts.dart';
11
import 'package:flutter_tools/src/base/file_system.dart';
12
import 'package:flutter_tools/src/base/logger.dart';
13
import 'package:flutter_tools/src/base/platform.dart';
14
import 'package:flutter_tools/src/build_info.dart';
15
import 'package:flutter_tools/src/build_system/targets/shader_compiler.dart';
16
import 'package:flutter_tools/src/compile.dart';
17
import 'package:flutter_tools/src/convert.dart';
18
import 'package:flutter_tools/src/devfs.dart';
19
import 'package:flutter_tools/src/device.dart';
20
import 'package:flutter_tools/src/globals.dart' as globals;
21
import 'package:flutter_tools/src/html_utils.dart';
22
import 'package:flutter_tools/src/isolated/devfs_web.dart';
23
import 'package:flutter_tools/src/web/compile.dart';
24
import 'package:logging/logging.dart' as logging;
25
import 'package:package_config/package_config.dart';
26
import 'package:shelf/shelf.dart';
27
import 'package:test/fake.dart';
28
import 'package:vm_service/vm_service.dart' as vm_service;
29 30 31 32 33 34 35 36 37 38 39 40 41

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() {
42 43 44 45 46 47 48 49
  late Testbed testbed;
  late WebAssetServer webAssetServer;
  late ReleaseAssetServer releaseAssetServer;
  late Platform linux;
  late PackageConfig packages;
  late Platform windows;
  late FakeHttpServer httpServer;
  late BufferLogger logger;
50 51

  setUpAll(() async {
52
    packages = PackageConfig(<Package>[
53
      Package('flutter_tools', Uri.file('/flutter_tools/lib/').normalizePath()),
54
    ]);
55
  });
56 57

  setUp(() {
58
    httpServer = FakeHttpServer();
59
    linux = FakePlatform(environment: <String, String>{});
60
    windows = FakePlatform(operatingSystem: 'windows', environment: <String, String>{});
61
    logger = BufferLogger.test();
62
    testbed = Testbed(setup: () {
63
      webAssetServer = WebAssetServer(
64
        httpServer,
65 66
        packages,
        InternetAddress.loopbackIPv4,
67 68
        <String, String>{},
        <String, String>{},
69
        NullSafetyMode.unsound,
70
      );
71 72
      releaseAssetServer = ReleaseAssetServer(
        globals.fs.file('main.dart').uri,
73
        fileSystem: globals.fs,
74
        flutterRoot: null, // ignore: avoid_redundant_argument_values
75
        platform: FakePlatform(),
76
        webBuildDirectory: null, // ignore: avoid_redundant_argument_values
77
      );
78 79
    }, overrides: <Type, Generator>{
      Logger: () => logger,
80 81 82
    });
  });

83 84 85
  test('.log() reports warnings', () => testbed.run(() {
    const String unresolvedUriMessage = 'Unresolved uri:';
    const String otherMessage = 'Something bad happened';
86 87 88 89

    final List<logging.LogRecord> events = <logging.LogRecord>[
      logging.LogRecord(
        logging.Level.WARNING,
90
        unresolvedUriMessage,
91 92 93 94
        'DartUri',
      ),
      logging.LogRecord(
        logging.Level.WARNING,
95
        otherMessage,
96 97 98 99 100
        'DartUri',
      ),
    ];

    events.forEach(log);
101 102
    expect(logger.warningText, contains(unresolvedUriMessage));
    expect(logger.warningText, contains(otherMessage));
103 104
  }));

105
  test('Handles against malformed manifest', () => testbed.run(() async {
106
    final File source = globals.fs.file('source')
107
      ..writeAsStringSync('main() {}');
108
    final File sourcemap = globals.fs.file('sourcemap')
109
      ..writeAsStringSync('{}');
110 111
    final File metadata = globals.fs.file('metadata')
      ..writeAsStringSync('{}');
112 113

    // Missing ending offset.
114
    final File manifestMissingOffset = globals.fs.file('manifestA')
115 116 117 118 119 120 121
      ..writeAsStringSync(json.encode(<String, Object>{
        '/foo.js': <String, Object>{
          'code': <int>[0],
          'sourcemap': <int>[0],
          'metadata': <int>[0],
        },
      }));
122
    final File manifestOutOfBounds = globals.fs.file('manifest')
123 124 125 126 127 128 129
      ..writeAsStringSync(json.encode(<String, Object>{
        '/foo.js': <String, Object>{
          'code': <int>[0, 100],
          'sourcemap': <int>[0],
          'metadata': <int>[0],
        },
      }));
130

131 132
    expect(webAssetServer.write(source, manifestMissingOffset, sourcemap, metadata), isEmpty);
    expect(webAssetServer.write(source, manifestOutOfBounds, sourcemap, metadata), isEmpty);
133 134 135
  }));

  test('serves JavaScript files from in memory cache', () => testbed.run(() async {
136
    final File source = globals.fs.file('source')
137
      ..writeAsStringSync('main() {}');
138
    final File sourcemap = globals.fs.file('sourcemap')
139
      ..writeAsStringSync('{}');
140 141
    final File metadata = globals.fs.file('metadata')
      ..writeAsStringSync('{}');
142
    final File manifest = globals.fs.file('manifest')
143 144 145 146 147 148 149
      ..writeAsStringSync(json.encode(<String, Object>{
        '/foo.js': <String, Object>{
          'code': <int>[0, source.lengthSync()],
          'sourcemap': <int>[0, 2],
          'metadata':  <int>[0, 2],
        },
      }));
150
    webAssetServer.write(source, manifest, sourcemap, metadata);
151

152 153
    final Response response = await webAssetServer
      .handleRequest(Request('GET', Uri.parse('http://foobar/foo.js')));
154

155
    expect(response.headers, allOf(<Matcher>[
156 157
      containsPair(HttpHeaders.contentLengthHeader, source.lengthSync().toString()),
      containsPair(HttpHeaders.contentTypeHeader, 'application/javascript'),
158
      containsPair(HttpHeaders.etagHeader, isNotNull),
159 160
    ]));
    expect((await response.read().toList()).first, source.readAsBytesSync());
161 162 163 164
  }, overrides: <Type, Generator>{
    Platform: () => linux,
  }));

165 166 167 168 169 170 171 172 173
  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')
174 175 176 177 178 179 180
      ..writeAsStringSync(json.encode(<String, Object>{
        '/foo.js': <String, Object>{
          'code': <int>[0, source.lengthSync()],
          'sourcemap': <int>[0, sourcemap.lengthSync()],
          'metadata':  <int>[0, metadata.lengthSync()],
        },
      }));
181 182
    webAssetServer.write(source, manifest, sourcemap, metadata);

183
    final String? merged = await webAssetServer.metadataContents('main_module.ddc_merged_metadata');
184 185
    expect(merged, equals(metadataContents));

186
    final String? single = await webAssetServer.metadataContents('foo.js.metadata');
187 188 189 190 191
    expect(single, equals(metadataContents));
  }, overrides: <Type, Generator>{
    Platform: () => linux,
  }));

192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207
  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),
208
      containsPair(HttpHeaders.cacheControlHeader, 'max-age=0, must-revalidate'),
209 210 211 212
    ]));
    expect((await response.read().toList()).first, source.readAsBytesSync());
  }));

213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231
  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),
232
      containsPair(HttpHeaders.cacheControlHeader, 'max-age=0, must-revalidate'),
233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252
    ]));
    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);
  }));

253 254 255 256 257 258 259 260 261 262 263 264 265
  test('serves index.html at / if href attribute is $kBaseHrefPlaceholder', () => testbed.run(() async {
    const String htmlContent = '<html><head><base href ="$kBaseHrefPlaceholder"></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.ok);
    expect(await response.readAsString(), htmlContent.replaceAll(kBaseHrefPlaceholder, '/'));
  }));

266 267 268 269 270 271 272 273 274 275 276 277 278 279 280
  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);
  }));

281 282 283 284 285 286 287 288
  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(
289
      httpServer,
290 291
      packages,
      InternetAddress.loopbackIPv4,
292 293
      <String, String>{},
      <String, String>{},
294
      NullSafetyMode.unsound,
295 296 297 298 299 300 301 302 303 304 305 306 307
    );

    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(
308
      httpServer,
309 310
      packages,
      InternetAddress.loopbackIPv4,
311 312
      <String, String>{},
      <String, String>{},
313
      NullSafetyMode.unsound,
314 315 316 317 318 319 320 321 322 323 324 325 326 327 328
    );

    // 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(
329
        httpServer,
330 331
        packages,
        InternetAddress.loopbackIPv4,
332 333
        <String, String>{},
        <String, String>{},
334
        NullSafetyMode.unsound,
335 336 337 338 339 340 341 342 343 344 345 346 347 348
      ),
      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(
349
        httpServer,
350 351
        packages,
        InternetAddress.loopbackIPv4,
352 353
        <String, String>{},
        <String, String>{},
354
        NullSafetyMode.unsound,
355 356 357 358 359
      ),
      throwsToolExit(),
    );
  }));

360
  test('serves JavaScript files from in memory cache not from manifest', () => testbed.run(() async {
361
    webAssetServer.writeFile('foo.js', 'main() {}');
362

363 364
    final Response response = await webAssetServer
      .handleRequest(Request('GET', Uri.parse('http://foobar/foo.js')));
365

366
    expect(response.headers, allOf(<Matcher>[
367 368 369
      containsPair(HttpHeaders.contentLengthHeader, '9'),
      containsPair(HttpHeaders.contentTypeHeader, 'application/javascript'),
      containsPair(HttpHeaders.etagHeader, isNotNull),
370
      containsPair(HttpHeaders.cacheControlHeader, 'max-age=0, must-revalidate'),
371 372
    ]));
    expect((await response.read().toList()).first, utf8.encode('main() {}'));
373 374
  }));

375
  test('Returns notModified when the ifNoneMatch header matches the etag', () => testbed.run(() async {
376
    webAssetServer.writeFile('foo.js', 'main() {}');
377 378 379

    final Response response = await webAssetServer
      .handleRequest(Request('GET', Uri.parse('http://foobar/foo.js')));
380
    final String etag = response.headers[HttpHeaders.etagHeader]!;
381 382 383

    final Response cachedResponse = await webAssetServer
      .handleRequest(Request('GET', Uri.parse('http://foobar/foo.js'), headers: <String, String>{
384
        HttpHeaders.ifNoneMatchHeader: etag,
385 386 387 388 389 390
      }));

    expect(cachedResponse.statusCode, HttpStatus.notModified);
    expect(await cachedResponse.read().toList(), isEmpty);
  }));

391 392 393 394 395 396
  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);
397

398
    final Response response = await webAssetServer
399
      .handleRequest(Request('GET', Uri.parse('http://foobar/bar/baz')));
400

401 402
    expect(response.statusCode, HttpStatus.ok);
    expect(await response.readAsString(), htmlContent);
403 404
  }));

405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445
  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);
  }));

446 447 448 449 450 451 452 453 454
  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>')));
  }));

455 456 457 458 459
  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('{}');
460 461
    final File metadata = globals.fs.file('metadata')
      ..writeAsStringSync('{}');
462
    final File manifest = globals.fs.file('manifest')
463 464 465 466 467 468 469
      ..writeAsStringSync(json.encode(<String, Object>{
        '/foo.dart.lib.js': <String, Object>{
          'code': <int>[0, source.lengthSync()],
          'sourcemap': <int>[0, 2],
          'metadata': <int>[0, 2],
        },
      }));
470
    webAssetServer.write(source, manifest, sourcemap, metadata);
471 472 473 474 475 476 477

    final Response response = await webAssetServer
      .handleRequest(Request('GET', Uri.parse('http://foobar/foo.dart.js')));

    expect(response.statusCode, HttpStatus.ok);
  }));

478 479 480 481 482
  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('{}');
483 484
    final File metadata = globals.fs.file('metadata')
      ..writeAsStringSync('{}');
485
    final File manifest = globals.fs.file('manifest')
486 487 488 489 490 491 492
      ..writeAsStringSync(json.encode(<String, Object>{
        '/foo.js': <String, Object>{
          'code': <int>[0, source.lengthSync()],
          'sourcemap': <int>[0, 2],
          'metadata': <int>[0, 2],
        },
      }));
493
    webAssetServer.write(source, manifest, sourcemap, metadata);
494 495 496 497
    final Response response = await webAssetServer
      .handleRequest(Request('GET', Uri.parse('http://localhost/foo.js')));

    expect(response.headers, allOf(<Matcher>[
498 499 500
      containsPair(HttpHeaders.contentLengthHeader, source.lengthSync().toString()),
      containsPair(HttpHeaders.contentTypeHeader, 'application/javascript'),
      containsPair(HttpHeaders.etagHeader, isNotNull),
501
      containsPair(HttpHeaders.cacheControlHeader, 'max-age=0, must-revalidate'),
502 503
    ]));
    expect((await response.read().toList()).first, source.readAsBytesSync());
504 505 506 507
  }, overrides: <Type, Generator>{
    Platform: () => windows,
  }));

508 509 510 511 512 513 514 515
   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>[
516 517 518
      containsPair(HttpHeaders.contentLengthHeader, source.lengthSync().toString()),
      containsPair(HttpHeaders.contentTypeHeader, 'image/png'),
      containsPair(HttpHeaders.etagHeader, isNotNull),
519
      containsPair(HttpHeaders.cacheControlHeader, 'max-age=0, must-revalidate'),
520 521 522
    ]));
    expect((await response.read().toList()).first, source.readAsBytesSync());
  }));
523 524 525 526 527 528 529 530 531 532 533
  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),
534
      containsPair(HttpHeaders.cacheControlHeader, 'max-age=0, must-revalidate'),
535 536 537
    ]));
    expect((await response.read().toList()).first, source.readAsBytesSync());
  }));
538

539 540 541 542
   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);
543 544 545 546
    final Response response = await webAssetServer
      .handleRequest(Request('GET', Uri.parse('http://foobar/assets/foo.png')));

    expect(response.headers, allOf(<Matcher>[
547 548 549
      containsPair(HttpHeaders.contentLengthHeader, source.lengthSync().toString()),
      containsPair(HttpHeaders.contentTypeHeader, 'image/png'),
      containsPair(HttpHeaders.etagHeader, isNotNull),
550
      containsPair(HttpHeaders.cacheControlHeader, 'max-age=0, must-revalidate'),
551 552
    ]));
    expect((await response.read().toList()).first, source.readAsBytesSync());
553 554 555 556
  }, overrides: <Type,  Generator>{
    Platform: () => windows,
  }));

557
  test('serves Dart files from in filesystem on Linux/macOS', () => testbed.run(() async {
558
    final File source = globals.fs.file('foo.dart').absolute
559 560 561
      ..createSync(recursive: true)
      ..writeAsStringSync('void main() {}');

562 563
    final Response response = await webAssetServer
      .handleRequest(Request('GET', Uri.parse('http://foobar/foo.dart')));
564

565
    expect(response.headers, containsPair(HttpHeaders.contentLengthHeader, source.lengthSync().toString()));
566
    expect((await response.read().toList()).first, source.readAsBytesSync());
567 568 569 570 571
  }, overrides: <Type,  Generator>{
    Platform: () => linux,
  }));

  test('serves asset files from in filesystem with known mime type', () => testbed.run(() async {
572
    final File source = globals.fs.file(globals.fs.path.join('build', 'flutter_assets', 'foo.png'))
573 574 575
      ..createSync(recursive: true)
      ..writeAsBytesSync(kTransparentImage);

576 577
    final Response response = await webAssetServer
      .handleRequest(Request('GET', Uri.parse('http://foobar/assets/foo.png')));
578

579
    expect(response.headers, allOf(<Matcher>[
580 581
      containsPair(HttpHeaders.contentLengthHeader, source.lengthSync().toString()),
      containsPair(HttpHeaders.contentTypeHeader, 'image/png'),
582 583
    ]));
    expect((await response.read().toList()).first, source.readAsBytesSync());
584 585
  }));

586 587 588
  test('serves asset files from in filesystem with known mime type and empty content', () => testbed.run(() async {
    final File source = globals.fs.file(globals.fs.path.join('web', 'foo.js'))
      ..createSync(recursive: true);
589

590
    final Response response = await webAssetServer
591
        .handleRequest(Request('GET', Uri.parse('http://foobar/foo.js')));
592

593
    expect(response.headers, allOf(<Matcher>[
594
      containsPair(HttpHeaders.contentLengthHeader, '0'),
595
      containsPair(HttpHeaders.contentTypeHeader, 'text/javascript'),
596 597
    ]));
    expect((await response.read().toList()).first, source.readAsBytesSync());
598 599
  }));

600
  test('serves asset files from in filesystem with unknown mime type', () => testbed.run(() async {
601
    final File source = globals.fs.file(globals.fs.path.join('build', 'flutter_assets', 'foo'))
602
      ..createSync(recursive: true)
603
      ..writeAsBytesSync(List<int>.filled(100, 0));
604

605 606
    final Response response = await webAssetServer
      .handleRequest(Request('GET', Uri.parse('http://foobar/assets/foo')));
607

608
    expect(response.headers, allOf(<Matcher>[
609
      containsPair(HttpHeaders.contentLengthHeader, '100'),
610
      containsPair(HttpHeaders.contentTypeHeader, 'application/octet-stream'),
611 612
    ]));
    expect((await response.read().toList()).first, source.readAsBytesSync());
613 614
  }));

615
  test('serves valid etag header for asset files with non-ascii characters', () => testbed.run(() async {
616 617 618 619 620 621
    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π')));
622
    final String etag = response.headers[HttpHeaders.etagHeader]!;
623 624 625 626

    expect(etag.runes, everyElement(predicate((int char) => char < 255)));
  }));

627 628
  test('serves /packages/<package>/<path> files as if they were '
       'package:<package>/<path> uris', () => testbed.run(() async {
629
    final Uri? expectedUri = packages.resolve(
630 631 632 633
        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]);
634 635 636 637 638

    final Response response = await webAssetServer
      .handleRequest(Request('GET', Uri.parse('http:///packages/flutter_tools/foo.dart')));

    expect(response.headers, allOf(<Matcher>[
639
      containsPair(HttpHeaders.contentLengthHeader, '3'),
640
      containsPair(HttpHeaders.contentTypeHeader, 'text/x-dart'),
641 642
    ]));
    expect((await response.read().toList()).first, source.readAsBytesSync());
643 644
  }));

645 646 647
  test('calling dispose closes the http server', () => testbed.run(() async {
    await webAssetServer.dispose();

648
    expect(httpServer.closed, true);
649
  }));
650 651

  test('Can start web server with specified assets', () => testbed.run(() async {
652 653 654 655 656
    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('{}');
657
    outputFile.parent.childFile('a.metadata').writeAsStringSync('{}');
658

659 660
    final ResidentCompiler residentCompiler = FakeResidentCompiler()
      ..output = const CompilerOutput('a', 0, <Uri>[]);
661 662 663 664 665

    final WebDevFS webDevFS = WebDevFS(
      hostname: 'localhost',
      port: 0,
      packagesFilePath: '.packages',
666
      urlTunneller: null, // ignore: avoid_redundant_argument_values
667
      useSseForDebugProxy: true,
668
      useSseForDebugBackend: true,
669
      useSseForInjectedClient: true,
670
      nullAssertions: true,
671
      nativeNullAssertions: true,
672 673 674 675
      buildInfo: const BuildInfo(
        BuildMode.debug,
        '',
        treeShakeIcons: false,
676
        nullSafetyMode: NullSafetyMode.unsound,
677 678
      ),
      enableDwds: false,
679
      enableDds: false,
680 681
      entrypoint: Uri.base,
      testMode: true,
682 683
      expressionCompiler: null, // ignore: avoid_redundant_argument_values
      chromiumLauncher: null, // ignore: avoid_redundant_argument_values
684
      nullSafetyMode: NullSafetyMode.unsound,
685 686 687 688 689 690
    );
    webDevFS.requireJS.createSync(recursive: true);
    webDevFS.stackTraceMapper.createSync(recursive: true);

    final Uri uri = await webDevFS.create();
    webDevFS.webAssetServer.entrypointCacheDirectory = globals.fs.currentDirectory;
691
    final String webPrecompiledSdk = globals.artifacts!
692
      .getHostArtifact(HostArtifact.webPrecompiledSdk).path;
693
    final String webPrecompiledSdkSourcemaps = globals.artifacts!
694
      .getHostArtifact(HostArtifact.webPrecompiledSdkSourcemaps).path;
695
    final String webPrecompiledCanvaskitSdk = globals.artifacts!
696
      .getHostArtifact(HostArtifact.webPrecompiledCanvaskitSdk).path;
697
    final String webPrecompiledCanvaskitSdkSourcemaps = globals.artifacts!
698
      .getHostArtifact(HostArtifact.webPrecompiledCanvaskitSdkSourcemaps).path;
699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723
    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,
724
      pathToReload: '',
725
      dillOutputPath: 'out.dill',
726
      shaderCompiler: const FakeShaderCompiler(),
727 728 729 730 731 732
    );

    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);
733
    expect(webDevFS.webAssetServer.getFile('flutter.js'), isNotNull);
734
    expect(webDevFS.webAssetServer.getFile('flutter_service_worker.js'), isNotNull);
735
    expect(webDevFS.webAssetServer.getFile('version.json'),isNotNull);
736 737 738 739
    expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js'), 'HELLO');
    expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js.map'), 'THERE');

    // Update to the SDK.
740
    globals.fs.file(webPrecompiledSdk).writeAsStringSync('BELLOW');
741 742 743 744 745

    // New SDK should be visible..
    expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js'), 'BELLOW');

    // Toggle CanvasKit
746 747
    expect(webDevFS.webAssetServer.webRenderer, WebRendererMode.html);
    webDevFS.webAssetServer.webRenderer = WebRendererMode.canvaskit;
748

749 750 751 752 753 754 755 756
    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
757
    expect(uri.host, 'localhost');
758 759 760 761 762 763 764 765 766 767 768 769

    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 {
    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('{}');
770
    outputFile.parent.childFile('a.metadata').writeAsStringSync('{}');
771

772 773
    final ResidentCompiler residentCompiler = FakeResidentCompiler()
      ..output = const CompilerOutput('a', 0, <Uri>[]);
774 775 776 777 778

    final WebDevFS webDevFS = WebDevFS(
      hostname: 'localhost',
      port: 0,
      packagesFilePath: '.packages',
779
      urlTunneller: null, // ignore: avoid_redundant_argument_values
780
      useSseForDebugProxy: true,
781
      useSseForDebugBackend: true,
782
      useSseForInjectedClient: true,
783
      nullAssertions: true,
784
      nativeNullAssertions: true,
785 786 787 788 789
      buildInfo: const BuildInfo(
        BuildMode.debug,
        '',
        treeShakeIcons: false,
      ),
790
      enableDwds: false,
791
      enableDds: false,
792 793
      entrypoint: Uri.base,
      testMode: true,
794 795
      expressionCompiler: null, // ignore: avoid_redundant_argument_values
      chromiumLauncher: null, // ignore: avoid_redundant_argument_values
796
      nullSafetyMode: NullSafetyMode.sound,
797 798 799 800
    );
    webDevFS.requireJS.createSync(recursive: true);
    webDevFS.stackTraceMapper.createSync(recursive: true);

801
    final Uri uri = await webDevFS.create();
802 803 804 805 806 807
    webDevFS.webAssetServer.entrypointCacheDirectory = globals.fs.currentDirectory;
    globals.fs.currentDirectory
      .childDirectory('lib')
      .childFile('web_entrypoint.dart')
      ..createSync(recursive: true)
      ..writeAsStringSync('GENERATED');
808
    final String webPrecompiledSdk = globals.artifacts!
809
      .getHostArtifact(HostArtifact.webPrecompiledSoundSdk).path;
810
    final String webPrecompiledSdkSourcemaps = globals.artifacts!
811
      .getHostArtifact(HostArtifact.webPrecompiledSoundSdkSourcemaps).path;
812
    final String webPrecompiledCanvaskitSdk = globals.artifacts!
813
      .getHostArtifact(HostArtifact.webPrecompiledCanvaskitSoundSdk).path;
814
    final String webPrecompiledCanvaskitSdkSourcemaps = globals.artifacts!
815
      .getHostArtifact(HostArtifact.webPrecompiledCanvaskitSoundSdkSourcemaps).path;
816
    globals.fs.file(webPrecompiledSdk)
817 818
      ..createSync(recursive: true)
      ..writeAsStringSync('HELLO');
819
    globals.fs.file(webPrecompiledSdkSourcemaps)
820 821
      ..createSync(recursive: true)
      ..writeAsStringSync('THERE');
822
    globals.fs.file(webPrecompiledCanvaskitSdk)
823 824
      ..createSync(recursive: true)
      ..writeAsStringSync('OL');
825
    globals.fs.file(webPrecompiledCanvaskitSdkSourcemaps)
826 827
      ..createSync(recursive: true)
      ..writeAsStringSync('CHUM');
828 829

    await webDevFS.update(
830
      mainUri: globals.fs.file(globals.fs.path.join('lib', 'main.dart')).uri,
831 832 833 834
      generator: residentCompiler,
      trackWidgetCreation: true,
      bundleFirstUpload: true,
      invalidatedFiles: <Uri>[],
835
      packageConfig: PackageConfig.empty,
836
      pathToReload: '',
837
      dillOutputPath: '',
838
      shaderCompiler: const FakeShaderCompiler(),
839 840
    );

841 842 843 844
    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);
845
    expect(webDevFS.webAssetServer.getFile('flutter.js'), isNotNull);
846
    expect(webDevFS.webAssetServer.getFile('flutter_service_worker.js'), isNotNull);
847
    expect(webDevFS.webAssetServer.getFile('version.json'), isNotNull);
848 849
    expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js'), 'HELLO');
    expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js.map'), 'THERE');
850 851

    // Update to the SDK.
852
    globals.fs.file(webPrecompiledSdk).writeAsStringSync('BELLOW');
853 854

    // New SDK should be visible..
855
    expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js'), 'BELLOW');
856

857
    // Toggle CanvasKit
858
    webDevFS.webAssetServer.webRenderer = WebRendererMode.canvaskit;
859 860 861 862
    expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js'), 'OL');
    expect(await webDevFS.webAssetServer.dartSourceContents('dart_sdk.js.map'), 'CHUM');

    // Generated entrypoint.
863 864
    expect(await webDevFS.webAssetServer.dartSourceContents('web_entrypoint.dart'),
      contains('GENERATED'));
865

866
    // served on localhost
867
    expect(uri.host, 'localhost');
868 869

    await webDevFS.destroy();
870 871
  }, overrides: <Type, Generator>{
    Artifacts: () => Artifacts.test(),
872 873
  }));

874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891
  test('.connect() will never call vmServiceFactory twice', () => testbed.run(() async {
    await FakeAsync().run<Future<void>>((FakeAsync time) {
      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('{}');

      final WebDevFS webDevFS = WebDevFS(
        // if this is any other value, we will do a real ip lookup
        hostname: 'any',
        port: 0,
        packagesFilePath: '.packages',
        urlTunneller: null,
        useSseForDebugProxy: true,
        useSseForDebugBackend: true,
        useSseForInjectedClient: true,
892
        nullAssertions: true,
893 894 895 896 897 898 899 900 901 902 903 904
        nativeNullAssertions: true,
        buildInfo: const BuildInfo(
          BuildMode.debug,
          '',
          treeShakeIcons: false,
        ),
        enableDwds: true,
        enableDds: false,
        entrypoint: Uri.base,
        testMode: true,
        expressionCompiler: null,
        chromiumLauncher: null,
905
        nullSafetyMode: NullSafetyMode.sound,
906 907 908 909 910 911 912 913 914 915 916
      );
      webDevFS.requireJS.createSync(recursive: true);
      webDevFS.stackTraceMapper.createSync(recursive: true);
      final FakeAppConnection firstConnection = FakeAppConnection();
      final FakeAppConnection secondConnection = FakeAppConnection();

      final Future<void> done = webDevFS.create().then<void>((Uri _) {
        // In non-test mode, webDevFS.create() would have initialized DWDS
        webDevFS.webAssetServer.dwds = FakeDwds(<AppConnection>[firstConnection, secondConnection]);

        int vmServiceFactoryInvocationCount = 0;
917
        Future<vm_service.VmService> vmServiceFactory(Uri uri, {CompressionOptions? compression, required Logger logger}) {
918 919 920 921 922 923 924 925 926
          if (vmServiceFactoryInvocationCount > 0) {
            fail('Called vmServiceFactory twice!');
          }
          vmServiceFactoryInvocationCount += 1;
          return Future<vm_service.VmService>.delayed(
            const Duration(seconds: 2),
            () => FakeVmService(),
          );
        }
927
        return webDevFS.connect(false, vmServiceFactory: vmServiceFactory).then<void>((ConnectionResult? firstConnectionResult) {
928 929 930 931 932 933 934 935 936 937 938
          return webDevFS.destroy();
        });
      });
      time.elapse(const Duration(seconds: 1));
      time.elapse(const Duration(seconds: 2));
      return done;
    });
  }, overrides: <Type, Generator>{
    Artifacts: () => Artifacts.test(),
  }));

939 940 941 942 943 944 945 946 947 948 949
  test('Can start web server with hostname any', () => testbed.run(() async {
    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('{}');

    final WebDevFS webDevFS = WebDevFS(
      hostname: 'any',
      port: 0,
      packagesFilePath: '.packages',
950
      urlTunneller: null, // ignore: avoid_redundant_argument_values
951
      useSseForDebugProxy: true,
952
      useSseForDebugBackend: true,
953
      useSseForInjectedClient: true,
954
      buildInfo: BuildInfo.debug,
955
      enableDwds: false,
956
      enableDds: false,
957 958
      entrypoint: Uri.base,
      testMode: true,
959 960
      expressionCompiler: null, // ignore: avoid_redundant_argument_values
      chromiumLauncher: null, // ignore: avoid_redundant_argument_values
961
      nullAssertions: true,
962
      nativeNullAssertions: true,
963
      nullSafetyMode: NullSafetyMode.sound,
964 965 966 967 968 969
    );
    webDevFS.requireJS.createSync(recursive: true);
    webDevFS.stackTraceMapper.createSync(recursive: true);

    final Uri uri = await webDevFS.create();

970
    expect(uri.host, 'localhost');
971 972
    await webDevFS.destroy();
  }));
973 974 975 976 977 978 979 980 981 982 983 984

  test('Can start web server with canvaskit enabled', () => testbed.run(() async {
    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('{}');

    final WebDevFS webDevFS = WebDevFS(
      hostname: 'localhost',
      port: 0,
      packagesFilePath: '.packages',
985
      urlTunneller: null, // ignore: avoid_redundant_argument_values
986
      useSseForDebugProxy: true,
987
      useSseForDebugBackend: true,
988
      useSseForInjectedClient: true,
989
      nullAssertions: true,
990
      nativeNullAssertions: true,
991 992 993 994 995 996 997 998 999
      buildInfo: const BuildInfo(
        BuildMode.debug,
        '',
        treeShakeIcons: false,
        dartDefines: <String>[
          'FLUTTER_WEB_USE_SKIA=true',
        ]
      ),
      enableDwds: false,
1000
      enableDds: false,
1001 1002
      entrypoint: Uri.base,
      testMode: true,
1003 1004
      expressionCompiler: null, // ignore: avoid_redundant_argument_values
      chromiumLauncher: null, // ignore: avoid_redundant_argument_values
1005
      nullSafetyMode: NullSafetyMode.sound,
1006 1007 1008 1009 1010 1011
    );
    webDevFS.requireJS.createSync(recursive: true);
    webDevFS.stackTraceMapper.createSync(recursive: true);

    await webDevFS.create();

1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027
    expect(webDevFS.webAssetServer.webRenderer, WebRendererMode.canvaskit);

    await webDevFS.destroy();
  }));

  test('Can start web server with auto detect enabled', () => testbed.run(() async {
    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('{}');

    final WebDevFS webDevFS = WebDevFS(
      hostname: 'localhost',
      port: 0,
      packagesFilePath: '.packages',
1028
      urlTunneller: null, // ignore: avoid_redundant_argument_values
1029 1030
      useSseForDebugProxy: true,
      useSseForDebugBackend: true,
1031
      useSseForInjectedClient: true,
1032
      nullAssertions: true,
1033
      nativeNullAssertions: true,
1034
      buildInfo: const BuildInfo(
1035 1036 1037 1038 1039 1040
        BuildMode.debug,
        '',
        treeShakeIcons: false,
        dartDefines: <String>[
          'FLUTTER_WEB_AUTO_DETECT=true',
        ]
1041 1042
      ),
      enableDwds: false,
1043
      enableDds: false,
1044 1045
      entrypoint: Uri.base,
      testMode: true,
1046 1047
      expressionCompiler: null, // ignore: avoid_redundant_argument_values
      chromiumLauncher: null, // ignore: avoid_redundant_argument_values
1048
      nullSafetyMode: NullSafetyMode.sound,
1049 1050 1051 1052 1053 1054
    );
    webDevFS.requireJS.createSync(recursive: true);
    webDevFS.stackTraceMapper.createSync(recursive: true);

    await webDevFS.create();

1055
    expect(webDevFS.webAssetServer.webRenderer, WebRendererMode.auto);
1056 1057 1058

    await webDevFS.destroy();
  }));
1059 1060 1061 1062 1063 1064 1065 1066 1067

  test('allows frame embedding', () async {
    final WebAssetServer webAssetServer = await WebAssetServer.start(
      null,
      'localhost',
      0,
      null,
      true,
      true,
1068
      true,
1069 1070 1071 1072 1073 1074
      const BuildInfo(
        BuildMode.debug,
        '',
        treeShakeIcons: false,
      ),
      false,
1075
      false,
1076 1077
      Uri.base,
      null,
1078
      NullSafetyMode.unsound,
1079 1080 1081 1082 1083
      testMode: true);

    expect(webAssetServer.defaultResponseHeaders['x-frame-options'], null);
    await webAssetServer.dispose();
  });
1084 1085 1086 1087 1088 1089 1090 1091 1092 1093 1094 1095 1096 1097

  test('WebAssetServer responds to POST requests with 404 not found', () => testbed.run(() async {
    final Response response = await webAssetServer.handleRequest(
      Request('POST', Uri.parse('http://foobar/something')),
    );
    expect(response.statusCode, 404);
  }));

  test('ReleaseAssetServer responds to POST requests with 404 not found', () => testbed.run(() async {
    final Response response = await releaseAssetServer.handle(
      Request('POST', Uri.parse('http://foobar/something')),
    );
    expect(response.statusCode, 404);
  }));
1098

nt4f04uNd's avatar
nt4f04uNd committed
1099
  test('WebAssetServer strips leading base href off of asset requests', () => testbed.run(() async {
1100 1101 1102 1103 1104 1105 1106
    const String htmlContent = '<html><head><base href="/foo/"></head><body id="test"></body></html>';
    globals.fs.currentDirectory
      .childDirectory('web')
      .childFile('index.html')
      ..createSync(recursive: true)
      ..writeAsStringSync(htmlContent);
    final WebAssetServer webAssetServer = WebAssetServer(
1107
      FakeHttpServer(),
1108 1109 1110 1111
      PackageConfig.empty,
      InternetAddress.anyIPv4,
      <String, String>{},
      <String, String>{},
1112
      NullSafetyMode.sound,
1113 1114 1115 1116
    );

    expect(await webAssetServer.metadataContents('foo/main_module.ddc_merged_metadata'), null);
    // Not base href.
1117
    expect(() async => webAssetServer.metadataContents('bar/main_module.ddc_merged_metadata'), throwsException);
1118 1119
  }));

1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136 1137
  test('DevFS URI includes any specified base path.', () => testbed.run(() async {
    final File outputFile = globals.fs.file(globals.fs.path.join('lib', 'main.dart'))
      ..createSync(recursive: true);
    const String htmlContent = '<html><head><base href="/foo/"></head><body id="test"></body></html>';
    globals.fs.currentDirectory
      .childDirectory('web')
      .childFile('index.html')
      ..createSync(recursive: true)
      ..writeAsStringSync(htmlContent);
    outputFile.parent.childFile('a.sources').writeAsStringSync('');
    outputFile.parent.childFile('a.json').writeAsStringSync('{}');
    outputFile.parent.childFile('a.map').writeAsStringSync('{}');
    outputFile.parent.childFile('a.metadata').writeAsStringSync('{}');

    final WebDevFS webDevFS = WebDevFS(
      hostname: 'localhost',
      port: 0,
      packagesFilePath: '.packages',
1138
      urlTunneller: null, // ignore: avoid_redundant_argument_values
1139 1140
      useSseForDebugProxy: true,
      useSseForDebugBackend: true,
1141
      useSseForInjectedClient: true,
1142
      nullAssertions: true,
1143 1144 1145
      nativeNullAssertions: true,
      buildInfo: BuildInfo.debug,
      enableDwds: false,
1146
      enableDds: false,
1147 1148
      entrypoint: Uri.base,
      testMode: true,
1149 1150
      expressionCompiler: null, // ignore: avoid_redundant_argument_values
      chromiumLauncher: null, // ignore: avoid_redundant_argument_values
1151
      nullSafetyMode: NullSafetyMode.unsound,
1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166
    );
    webDevFS.requireJS.createSync(recursive: true);
    webDevFS.stackTraceMapper.createSync(recursive: true);

    final Uri uri = await webDevFS.create();

    // served on localhost
    expect(uri.host, 'localhost');
    // Matches base URI specified in html.
    expect(uri.path, '/foo');

    await webDevFS.destroy();
  }, overrides: <Type, Generator>{
    Artifacts: () => Artifacts.test(),
  }));
1167 1168
}

1169 1170 1171 1172 1173 1174 1175 1176 1177 1178
class FakeHttpServer extends Fake implements HttpServer {
  bool closed = false;

  @override
  Future<void> close({bool force = false}) async {
    closed = true;
  }
}

class FakeResidentCompiler extends Fake implements ResidentCompiler {
1179
  CompilerOutput? output;
1180 1181 1182 1183 1184

  @override
  void addFileSystemRoot(String root) { }

  @override
1185 1186 1187 1188 1189
  Future<CompilerOutput?> recompile(Uri mainUri, List<Uri>? invalidatedFiles, {
    String? outputPath,
    PackageConfig? packageConfig,
    String? projectRootPath,
    FileSystem? fs,
1190
    bool suppressErrors = false,
1191
    bool checkDartPluginRegistry = false,
1192
    File? dartPluginRegistrant,
1193
    Uri? nativeAssetsYaml,
1194 1195 1196 1197
  }) async {
    return output;
  }
}
1198 1199 1200 1201 1202

class FakeShaderCompiler implements DevelopmentShaderCompiler {
  const FakeShaderCompiler();

  @override
1203 1204 1205 1206
  void configureCompiler(
    TargetPlatform? platform, {
    required ImpellerStatus impellerStatus,
  }) { }
1207 1208 1209 1210 1211 1212

  @override
  Future<DevFSContent> recompileShader(DevFSContent inputShader) {
    throw UnimplementedError();
  }
}
1213 1214

class FakeDwds extends Fake implements Dwds {
1215
  FakeDwds(Iterable<AppConnection> connectedAppsIterable) :
1216 1217 1218 1219 1220 1221 1222 1223 1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 1234 1235 1236 1237 1238 1239
    connectedApps = Stream<AppConnection>.fromIterable(connectedAppsIterable);

  @override
  final Stream<AppConnection> connectedApps;

  @override
  Future<DebugConnection> debugConnection(AppConnection appConnection) => Future<DebugConnection>.value(FakeDebugConnection());
}

class FakeAppConnection extends Fake implements AppConnection {
  @override
  void runMain() {}
}

class FakeDebugConnection extends Fake implements DebugConnection {
  FakeDebugConnection({
    this.uri = 'http://foo',
  });

  @override
  final String uri;
}

class FakeVmService extends Fake implements vm_service.VmService {}