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;
|
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 = [];
|
|
|
|
|
2016-12-09 00:24:07 +00:00
|
|
|
Rest(String path) : super(new http.Client(), path);
|
2016-06-25 18:37:49 +00:00
|
|
|
|
|
|
|
@override
|
2017-09-24 04:15:40 +00:00
|
|
|
Service service(String path, {Type type, AngelDeserializer deserializer}) {
|
2016-12-10 14:45:22 +00:00
|
|
|
String uri = path.replaceAll(straySlashes, "");
|
2017-09-24 04:15:40 +00:00
|
|
|
var s = new RestService(
|
|
|
|
client, this, "$basePath/$uri", 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
|
|
|
|
Stream<String> authenticateViaPopup(String url, {String eventName: 'token'}) {
|
|
|
|
throw new UnimplementedError('Opening popup windows is not supported in the `dart:io` client.');
|
|
|
|
}
|
2017-06-03 17:43:01 +00:00
|
|
|
|
|
|
|
Future close() async {
|
|
|
|
super.close();
|
|
|
|
Future.wait(_services.map((s) => s.close())).then((_) {
|
|
|
|
_services.clear();
|
|
|
|
});
|
|
|
|
}
|
2016-06-25 18:37:49 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/// Queries an Angel service via REST.
|
2017-09-24 04:15:40 +00:00
|
|
|
class RestService extends BaseAngelService {
|
2016-12-09 00:24:07 +00:00
|
|
|
final Type type;
|
2016-06-25 18:37:49 +00:00
|
|
|
|
2016-12-09 00:24:07 +00:00
|
|
|
RestService(http.BaseClient client, Angel app, String url, this.type)
|
|
|
|
: super(client, app, url);
|
2016-06-25 18:37:49 +00:00
|
|
|
|
2017-06-03 17:43:01 +00:00
|
|
|
@override
|
2016-12-09 00:24:07 +00:00
|
|
|
deserialize(x) {
|
|
|
|
if (type != null) {
|
2017-01-25 23:25:31 +00:00
|
|
|
return x.runtimeType == type
|
|
|
|
? x
|
|
|
|
: god.deserializeDatum(x, outputType: type);
|
2016-12-09 00:24:07 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return x;
|
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
|
|
|
}
|
|
|
|
}
|