platform/lib/io.dart

69 lines
1.7 KiB
Dart
Raw Normal View History

2016-06-25 18:37:49 +00:00
/// Command-line client library for the Angel framework.
library angel_client.cli;
import 'dart:async';
2016-12-09 00:24:07 +00:00
import 'package:http/http.dart' as http;
2016-06-25 18:37:49 +00:00
import 'package:json_god/json_god.dart' as god;
2019-01-06 02:08:31 +00:00
import 'package:path/path.dart' as p;
2016-09-03 12:02:32 +00:00
import 'angel_client.dart';
2016-12-09 00:24:07 +00:00
import 'base_angel_client.dart';
2016-09-03 12:02:32 +00:00
export 'angel_client.dart';
2016-06-25 18:37:49 +00:00
/// Queries an Angel server via REST.
2016-12-09 00:24:07 +00:00
class Rest extends BaseAngelClient {
2017-06-03 17:43:01 +00:00
final List<Service> _services = [];
2018-08-26 22:41:01 +00:00
Rest(String path) : super(new http.Client() as http.BaseClient, path);
2016-06-25 18:37:49 +00:00
@override
Service<Id, Data> service<Id, Data>(String path,
{Type type, AngelDeserializer deserializer}) {
2019-01-06 02:08:31 +00:00
var url = baseUrl.replace(path: p.join(baseUrl.path, path));
var s = new RestService<Id, Data>(client, this, url, type);
2017-06-03 17:43:01 +00:00
_services.add(s);
return s;
2016-06-25 18:37:49 +00:00
}
2017-06-03 17:43:01 +00:00
2017-02-28 21:56:59 +00:00
@override
2019-01-06 02:08:31 +00:00
Stream<String> authenticateViaPopup(String url,
{String eventName = 'token'}) {
2018-08-26 22:41:01 +00:00
throw new UnimplementedError(
'Opening popup windows is not supported in the `dart:io` client.');
2017-02-28 21:56:59 +00:00
}
2017-06-03 17:43:01 +00:00
Future close() async {
2019-04-20 15:21:15 +00:00
await super.close();
await Future.wait(_services.map((s) => s.close())).then((_) {
2017-06-03 17:43:01 +00:00
_services.clear();
});
}
2016-06-25 18:37:49 +00:00
}
/// Queries an Angel service via REST.
class RestService<Id, Data> extends BaseAngelService<Id, Data> {
2016-12-09 00:24:07 +00:00
final Type type;
2016-06-25 18:37:49 +00:00
2019-01-06 02:08:31 +00:00
RestService(http.BaseClient client, BaseAngelClient app, url, this.type)
2016-12-09 00:24:07 +00:00
: super(client, app, url);
2016-06-25 18:37:49 +00:00
2017-06-03 17:43:01 +00:00
@override
Data deserialize(x) {
2016-12-09 00:24:07 +00:00
if (type != null) {
2017-01-25 23:25:31 +00:00
return x.runtimeType == type
? x as Data
: god.deserializeDatum(x, outputType: type) as Data;
2016-12-09 00:24:07 +00:00
}
return x as Data;
2016-06-25 18:37:49 +00:00
}
@override
2016-12-09 00:24:07 +00:00
makeBody(x) {
if (type != null) {
return super.makeBody(god.serializeObject(x));
2016-06-25 18:37:49 +00:00
}
2016-12-09 00:24:07 +00:00
return super.makeBody(x);
2016-06-25 18:37:49 +00:00
}
}