import 'dart:async';
import 'dart:convert';
import 'dart:io';
import 'package:angel_container/mirrors.dart';
import 'package:angel_framework/angel_framework.dart';
import 'package:matcher/matcher.dart';
import 'package:mock_request/mock_request.dart';
import 'package:test/test.dart';
final Uri $foo = Uri.parse('http://localhost:3000/foo');
/// Additional tests to improve coverage of server.dart
main() {
group('scoping', () {
var parent = new Angel(reflector: MirrorsReflector())
..configuration['two'] = 2;
var child = new Angel(reflector: MirrorsReflector());
parent.mount('/child', child);
test('sets children', () {
expect(parent.children, contains(child));
});
test('sets parent', () {
expect(child.parent, parent);
});
test('properties can climb up hierarchy', () {
expect(child.findProperty('two'), 2);
});
});
test('custom server generator', () {
var app = new Angel(reflector: MirrorsReflector());
var http = new AngelHttp.custom(app, HttpServer.bind);
expect(http.serverGenerator, HttpServer.bind);
});
test('default error handler', () async {
var app = new Angel(reflector: MirrorsReflector());
var http = new AngelHttp(app);
var rq = new MockHttpRequest('GET', $foo);
rq.close();
var rs = rq.response;
var req = await http.createRequestContext(rq);
var res = await http.createResponseContext(rs);
var e = new AngelHttpException(null,
statusCode: 321, message: 'Hello', errors: ['foo', 'bar']);
await app.errorHandler(e, req, res);
await http.sendResponse(rq, req, res);
expect(
ContentType.parse(rs.headers.value('content-type')).mimeType,
'text/html',
);
expect(rs.statusCode, e.statusCode);
var body = await rs.transform(utf8.decoder).join();
expect(body, contains('
${e.message}'));
expect(body, contains('foo'));
expect(body, contains('bar'));
});
test('plug-ins run on startup', () async {
var app = new Angel(reflector: MirrorsReflector());
app.startupHooks.add((app) => app.configuration['two'] = 2);
var http = new AngelHttp(app);
await http.startServer();
expect(app.configuration['two'], 2);
await app.close();
await http.close();
});
test('warning when adding routes to flattened router', () {
var app = new Angel(reflector: MirrorsReflector())
..optimizeForProduction(force: true);
app.dumpTree();
app.get('/', (req, res) => 2);
app.mount('/foo', new Router()..get('/', (req, res) => 3));
});
test('services close on close call', () async {
var app = new Angel(reflector: MirrorsReflector());
var svc = new CustomCloseService();
expect(svc.value, 2);
app.use('/', svc);
await app.close();
expect(svc.value, 3);
});
test('global injection added to injection map', () async {
var app = new Angel(reflector: MirrorsReflector())
..configuration['a'] = 'b';
var http = new AngelHttp(app);
app.get('/', ioc((String a) => a));
var rq = new MockHttpRequest('GET', Uri.parse('/'))..close();
await http.handleRequest(rq);
var body = await rq.response.transform(utf8.decoder).join();
expect(body, json.encode('b'));
});
test('global injected serializer', () async {
var app = new Angel(reflector: MirrorsReflector())..serializer = (_) => 'x';
var http = new AngelHttp(app);
app.get($foo.path, (req, ResponseContext res) => res.serialize(null));
var rq = new MockHttpRequest('GET', $foo)..close();
await http.handleRequest(rq);
var body = await rq.response.transform(utf8.decoder).join();
expect(body, 'x');
});
group('handler results', () {
var app = new Angel(reflector: MirrorsReflector());
var http = new AngelHttp(app);
app.responseFinalizers
.add((req, res) => throw new AngelHttpException.forbidden());
RequestContext req;
ResponseContext res;
setUp(() async {
var rq = new MockHttpRequest('GET', $foo)..close();
req = await http.createRequestContext(rq);
res = await http.createResponseContext(rq.response);
});
group('getHandlerResult', () {
test('return request handler', () async {
var handler = (req, res) => (req, res) async {
return 2;
};
var r = await app.getHandlerResult(handler, req, res);
expect(r, 2);
});
test('return future', () async {
var handler = new Future.value(2);
expect(await app.getHandlerResult(handler, req, res), 2);
});
});
group('executeHandler', () {
test('return Stream', () async {
var handler = (req, res) => new Stream.fromIterable([2, 3]);
expect(await app.executeHandler(handler, req, res), isFalse);
});
test('end response', () async {
var handler = (req, res) => res.end();
expect(await app.executeHandler(handler, req, res), isFalse);
});
});
});
group('handleAngelHttpException', () {
Angel app;
AngelHttp http;
setUp(() async {
app = new Angel(reflector: MirrorsReflector());
app.get('/wtf', (req, res) => throw new AngelHttpException.forbidden());
app.get('/wtf2', (req, res) => throw new AngelHttpException.forbidden());
http = new AngelHttp(app);
await http.startServer('127.0.0.1', 0);
var oldHandler = app.errorHandler;
app.errorHandler = (e, req, res) {
print('FATAL: ${e.error ?? e}');
print(e.stackTrace);
return oldHandler(e, req, res);
};
});
tearDown(() => app.close());
test('can send json', () async {
var rq = new MockHttpRequest('GET', new Uri(path: 'wtf'))
..headers.set('accept', 'application/json');
rq.close();
http.handleRequest(rq);
await rq.response.toList();
expect(rq.response.statusCode, 403);
expect(rq.response.headers.contentType.mimeType, 'application/json');
});
test('can throw in finalizer', () async {
var rq = new MockHttpRequest('GET', new Uri(path: 'wtf'))
..headers.set('accept', 'application/json');
rq.close();
http.handleRequest(rq);
await rq.response.toList();
expect(rq.response.statusCode, 403);
expect(rq.response.headers.contentType.mimeType, 'application/json');
});
test('can send html', () async {
var rq = new MockHttpRequest('GET', new Uri(path: 'wtf2'));
rq.headers.set('accept', 'text/html');
rq.close();
http.handleRequest(rq);
await rq.response.toList();
expect(rq.response.statusCode, 403);
expect(rq.response.headers.contentType?.mimeType, 'text/html');
});
});
}
class CustomCloseService extends Service {
int value = 2;
@override
void close() {
value = 3;
super.close();
}
}
@Expose('/foo')
class FooController extends Controller {
@Expose('/bar')
bar() async => 'baz';
}