library shelf_proxy.proxy_test;

import 'dart:async';
import 'dart:io';

import 'package:scheduled_test/scheduled_test.dart';
import 'package:shelf/shelf.dart';
import 'package:shelf/shelf_io.dart' as shelf_io;
import 'package:shelf_proxy/shelf_proxy.dart';

import 'test_util.dart';

void main() {
  group('arguments', () {
    group('root uri must be http or https', () {
      test('http works', () {
        expect(createProxyHandler(Uri.parse('http://example.com')), isNotNull);
      });
      test('http works', () {
        expect(createProxyHandler(Uri.parse('https://example.com')), isNotNull);
      });
      test('ftp does not work', () {
        expect(() => createProxyHandler(Uri.parse('ftp://example.com')),
            throwsArgumentError);
      });
    });

    group('root uri must be absolute without query', () {
      test('http works', () {
        expect(createProxyHandler(Uri.parse('http://example.com')), isNotNull);
      });

      test('with trailing slash works', () {
        expect(createProxyHandler(Uri.parse('http://example.com/')), isNotNull);
      });

      test('with trailing slash works', () {
        expect(createProxyHandler(Uri.parse('http://example.com/path')),
            isNotNull);
      });

      test('with path item', () {
        expect(createProxyHandler(Uri.parse('http://example.com/path')),
            isNotNull);
      });

      test('with path item and trailing slash', () {
        expect(createProxyHandler(Uri.parse('http://example.com/path/')),
            isNotNull);
      });

      test('with a fragment', () {
        expect(
            () => createProxyHandler(Uri.parse('http://example.com/path#foo')),
            throwsArgumentError);
      });

      test('with a query', () {
        expect(
            () => createProxyHandler(Uri.parse('http://example.com/path?a=b')),
            throwsArgumentError);
      });
    });
  });

  group('requests', () {
    test('root', () {
      _scheduleServer(_handler);

      schedule(() {
        var url = new Uri.http('localhost:$_serverPort', '');
        var handler = createProxyHandler(url);

        return makeRequest(handler, '/').then((response) {
          expect(response.statusCode, HttpStatus.OK);
          expect(response.readAsString(), completion('root with slash'));
        });
      });
    });

    test('/bar', () {
      _scheduleServer(_handler);

      schedule(() {
        var url = new Uri.http('localhost:$_serverPort', '');
        var handler = createProxyHandler(url);

        return makeRequest(handler, '/bar').then((response) {
          expect(response.statusCode, HttpStatus.OK);
          expect(response.readAsString(), completion('bar'));
        });
      });
    });

    test('/bar/', () {
      _scheduleServer(_handler);

      schedule(() {
        var url = new Uri.http('localhost:$_serverPort', '');
        var handler = createProxyHandler(url);

        return makeRequest(handler, '/bar/').then((response) {
          expect(response.statusCode, HttpStatus.OK);
          expect(response.readAsString(), completion('bar with slash'));
        });
      });
    });

    test('only GET is supported', () {
      _scheduleServer(_handler);

      schedule(() {
        var url = new Uri.http('localhost:$_serverPort', '');
        var handler = createProxyHandler(url);

        return makeRequest(handler, '/', method: 'PUT').then((response) {
          expect(response.statusCode, HttpStatus.METHOD_NOT_ALLOWED);
        });
      });
    });
  });
}

Response _handler(Request request) {
  if (request.method != 'GET') {
    return new Response.forbidden("I don't like method ${request.method}.");
  }

  String content;
  switch (request.url.path) {
    case '':
      content = 'root';
      break;
    case '/':
      content = 'root with slash';
      break;
    case '/bar':
      content = 'bar';
      break;
    case '/bar/':
      content = 'bar with slash';
      break;
    default:
      return new Response.notFound("I don't like '${request.url.path}'.");
  }
  return new Response.ok(content);
}

int _serverPort;

Future _scheduleServer(Handler handler) {
  return schedule(() => shelf_io.serve(handler, 'localhost', 0).then((server) {
    currentSchedule.onComplete.schedule(() {
      _serverPort = null;
      return server.close(force: true);
    });

    _serverPort = server.port;
  }));
}