// Copyright (c) 2015, the Dart project authors.  Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.

@TestOn('vm')
import 'dart:async';
import 'dart:io';

import 'package:http/http.dart' as http;
import 'package:shelf/shelf_io.dart';
import 'package:test/test.dart';

import 'test_util.dart';

void main() {
  late IOServer server;

  setUp(() async {
    try {
      server = await IOServer.bind(InternetAddress.loopbackIPv6, 0);
    } on SocketException catch (_) {
      server = await IOServer.bind(InternetAddress.loopbackIPv4, 0);
    }
  });

  tearDown(() => server.close());

  test('serves HTTP requests with the mounted handler', () async {
    server.mount(syncHandler);
    expect(await http.read(server.url), equals('Hello from /'));
  });

  test('Handles malformed requests gracefully.', () async {
    server.mount(syncHandler);
    final rs = await http
        .get(Uri.parse('${server.url}/%D0%C2%BD%A8%CE%C4%BC%FE%BC%D0.zip'));
    expect(rs.statusCode, 400);
    expect(rs.body, 'Bad Request');
  });

  test('delays HTTP requests until a handler is mounted', () async {
    expect(http.read(server.url), completion(equals('Hello from /')));
    await Future.delayed(Duration.zero);

    server.mount(asyncHandler);
  });

  test('disallows more than one handler from being mounted', () async {
    server.mount((_) => throw UnimplementedError());
    expect(
      () => server.mount((_) => throw UnimplementedError()),
      throwsStateError,
    );
    expect(
      () => server.mount((_) => throw UnimplementedError()),
      throwsStateError,
    );
  });
}