144 lines
4 KiB
Dart
144 lines
4 KiB
Dart
import 'dart:convert';
|
|
import 'dart:io';
|
|
import 'package:angel_container/mirrors.dart';
|
|
import 'package:angel_framework/angel_framework.dart';
|
|
import 'package:angel_framework/http.dart';
|
|
import 'package:http/http.dart' as http;
|
|
import 'package:test/test.dart';
|
|
import 'common.dart';
|
|
|
|
main() {
|
|
Map headers = <String, String>{
|
|
'Accept': 'application/json',
|
|
'Content-Type': 'application/json'
|
|
};
|
|
|
|
Angel app;
|
|
HttpServer server;
|
|
String url;
|
|
http.Client client;
|
|
HookedService todoService;
|
|
|
|
setUp(() async {
|
|
app = new Angel(reflector: MirrorsReflector());
|
|
client = new http.Client();
|
|
app.use('/todos', new MapService());
|
|
app.use('/books', new BookService());
|
|
|
|
todoService = app.findHookedService<MapService>('todos');
|
|
|
|
todoService.beforeAllStream().listen((e) {
|
|
print('Fired ${e.eventName}! Data: ${e.data}; Params: ${e.params}');
|
|
});
|
|
|
|
app.errorHandler = (e, req, res) {
|
|
throw e.error;
|
|
};
|
|
|
|
server = await new AngelHttp(app).startServer();
|
|
url = "http://${server.address.host}:${server.port}";
|
|
});
|
|
|
|
tearDown(() async {
|
|
await server.close(force: true);
|
|
app = null;
|
|
url = null;
|
|
client.close();
|
|
client = null;
|
|
todoService = null;
|
|
});
|
|
|
|
test("listen before and after", () async {
|
|
int count = 0;
|
|
|
|
todoService
|
|
..beforeIndexed.listen((_) {
|
|
count++;
|
|
})
|
|
..afterIndexed.listen((_) {
|
|
count++;
|
|
});
|
|
|
|
var response = await client.get("$url/todos");
|
|
print(response.body);
|
|
expect(count, equals(2));
|
|
});
|
|
|
|
test("cancel before", () async {
|
|
todoService.beforeCreated
|
|
..listen((HookedServiceEvent event) {
|
|
event.cancel({"hello": "hooked world"});
|
|
})
|
|
..listen((HookedServiceEvent event) {
|
|
event.cancel({"this_hook": "should never run"});
|
|
});
|
|
|
|
var response = await client.post("$url/todos",
|
|
body: json.encode({"arbitrary": "data"}),
|
|
headers: headers as Map<String, String>);
|
|
print(response.body);
|
|
Map result = json.decode(response.body);
|
|
expect(result["hello"], equals("hooked world"));
|
|
});
|
|
|
|
test("cancel after", () async {
|
|
todoService.afterIndexed
|
|
..listen((HookedServiceEvent event) async {
|
|
// Hooks can be Futures ;)
|
|
event.cancel([
|
|
{"angel": "framework"}
|
|
]);
|
|
})
|
|
..listen((HookedServiceEvent event) {
|
|
event.cancel({"this_hook": "should never run either"});
|
|
});
|
|
|
|
var response = await client.get("$url/todos");
|
|
print(response.body);
|
|
List result = json.decode(response.body);
|
|
expect(result[0]["angel"], equals("framework"));
|
|
});
|
|
|
|
test('metadata', () async {
|
|
final service = new HookedService(new IncrementService())..addHooks(app);
|
|
expect(service.inner, isNot(const IsInstanceOf<MapService>()));
|
|
IncrementService.TIMES = 0;
|
|
await service.index();
|
|
expect(IncrementService.TIMES, equals(2));
|
|
});
|
|
|
|
test('inject request + response', () async {
|
|
HookedService books = app.findService('books');
|
|
|
|
books.beforeIndexed.listen((e) {
|
|
expect([e.request, e.response], everyElement(isNotNull));
|
|
print('Indexing books at path: ${e.request.path}');
|
|
});
|
|
|
|
var response = await client.get('$url/books');
|
|
print(response.body);
|
|
|
|
var result = json.decode(response.body);
|
|
expect(result, isList);
|
|
expect(result, isNotEmpty);
|
|
expect(result[0], equals({'foo': 'bar'}));
|
|
});
|
|
|
|
test('contains provider in before and after', () async {
|
|
var svc = new HookedService(new AnonymousService(index: ([p]) async => []));
|
|
|
|
ensureProviderIsPresent(HookedServiceEvent e) {
|
|
var type = e.isBefore ? 'before' : 'after';
|
|
print('Params to $type ${e.eventName}: ${e.params}');
|
|
expect(e.params, isMap);
|
|
expect(e.params.keys, contains('provider'));
|
|
expect(e.params['provider'], const IsInstanceOf<Providers>());
|
|
}
|
|
|
|
svc
|
|
..beforeAll(ensureProviderIsPresent)
|
|
..afterAll(ensureProviderIsPresent);
|
|
|
|
await svc.index({'provider': const Providers('testing')});
|
|
});
|
|
}
|