platform/lib/browser.dart
2016-11-27 22:28:41 -05:00

169 lines
4.6 KiB
Dart

/// Browser library for the Angel framework.
library angel_client.browser;
import 'dart:async' show Completer, Future;
import 'dart:convert' show JSON;
import 'dart:html' show HttpRequest;
import 'angel_client.dart';
import 'auth_types.dart' as auth_types;
export 'angel_client.dart';
_buildQuery(Map params) {
if (params == null || params == {}) return "";
String result = "";
return result;
}
_send(HttpRequest request, [data]) {
final completer = new Completer<HttpRequest>();
request
..onLoadEnd.listen((_) {
completer.complete(request.response);
})
..onError.listen((_) {
try {
throw new Exception(
'Request failed with status code ${request.status}.');
} catch (e, st) {
completer.completeError(e, st);
}
});
request.send(data);
return completer.future;
}
/// Queries an Angel server via REST.
class Rest extends Angel {
String _authToken;
Rest(String basePath) : super(basePath);
@override
Future<AngelAuthResult> authenticate(
{String type: auth_types.LOCAL,
credentials,
String authEndpoint: '/auth'}) async {
final url = '$authEndpoint/$type';
if (type == auth_types.LOCAL) {
final completer = new Completer();
final request = new HttpRequest();
request.open('POST', url);
request.responseType = 'json';
request.setRequestHeader("Accept", "application/json");
request.setRequestHeader("Content-Type", "application/json");
request
..onLoadEnd.listen((_) {
completer
.complete(new _AngelAuthResultImpl.fromMap(request.response));
})
..onError.listen((_) {
try {
throw new Exception(
'Request failed with status code ${request.status}.');
} catch (e, st) {
completer.completeError(e, st);
}
});
request.send(credentials);
return completer.future;
} else {
throw new Exception('angel_client cannot authenticate as "$type" yet.');
}
}
@override
RestService service(String path, {Type type}) {
String uri = path.replaceAll(new RegExp(r"(^\/)|(\/+$)"), "");
return new _RestServiceImpl(this, "$basePath/$uri");
}
}
abstract class RestService extends Service {
RestService._(String basePath);
}
class _AngelAuthResultImpl implements AngelAuthResult {
final Map<String, dynamic> data = {};
final String token;
_AngelAuthResultImpl({this.token, Map<String, dynamic> data: const {}}) {
this.data.addAll(data ?? {});
}
factory _AngelAuthResultImpl.fromMap(Map data) =>
new _AngelAuthResultImpl(token: data['token'], data: data['data']);
}
/// Queries an Angel service via REST.
class _RestServiceImpl extends RestService {
final Rest app;
String _basePath;
String get basePath => _basePath;
_RestServiceImpl(this.app, String basePath) : super._(basePath) {
_basePath = basePath;
}
_makeBody(data) {
return JSON.encode(data);
}
Future<HttpRequest> buildRequest(String url,
{String method: "POST", bool write: true}) async {
HttpRequest request = new HttpRequest();
request.open(method, url);
request.responseType = "json";
request.setRequestHeader("Accept", "application/json");
if (write) request.setRequestHeader("Content-Type", "application/json");
if (app._authToken != null)
request.setRequestHeader("Authorization", "Bearer ${app._authToken}");
return request;
}
@override
Future<List> index([Map params]) async {
final request = await buildRequest('$basePath/${_buildQuery(params)}',
method: 'GET', write: false);
return await _send(request);
}
@override
Future read(id, [Map params]) async {
final request = await buildRequest('$basePath/$id${_buildQuery(params)}',
method: 'GET', write: false);
return await _send(request);
}
@override
Future create(data, [Map params]) async {
final request = await buildRequest("$basePath/${_buildQuery(params)}");
return await _send(request, _makeBody(data));
}
@override
Future modify(id, data, [Map params]) async {
final request = await buildRequest("$basePath/$id${_buildQuery(params)}",
method: "PATCH");
return await _send(request, _makeBody(data));
}
@override
Future update(id, data, [Map params]) async {
final request = await buildRequest("$basePath/$id${_buildQuery(params)}");
return await _send(request, _makeBody(data));
}
@override
Future remove(id, [Map params]) async {
final request = await buildRequest("$basePath/$id${_buildQuery(params)}",
method: "DELETE");
return await _send(request);
}
}