import 'dart:async'; import 'dart:convert' show Encoding; import 'package:angel_http_exception/angel_http_exception.dart'; import 'dart:convert'; import 'package:http/src/base_client.dart' as http; import 'package:http/src/base_request.dart' as http; import 'package:http/src/request.dart' as http; import 'package:http/src/response.dart' as http; import 'package:http/src/streamed_response.dart' as http; import 'angel_client.dart'; final RegExp straySlashes = new RegExp(r"(^/)|(/+$)"); const Map _readHeaders = const {'Accept': 'application/json'}; const Map _writeHeaders = const { 'Accept': 'application/json', 'Content-Type': 'application/json' }; _buildQuery(Map params) { if (params == null || params.isEmpty || params['query'] is! Map) return ""; List query = []; params['query'].forEach((k, v) { query.add('$k=${Uri.encodeQueryComponent(v.toString())}'); }); return '?' + query.join('&'); } bool _invalid(http.Response response) => response.statusCode == null || response.statusCode < 200 || response.statusCode >= 300; AngelHttpException failure(http.Response response, {error, StackTrace stack}) { try { final v = json.decode(response.body); if (v is Map && v['isError'] == true) { return new AngelHttpException.fromMap(v); } else { return new AngelHttpException(error, message: 'Unhandled exception while connecting to Angel backend.', statusCode: response.statusCode, stackTrace: stack); } } catch (e, st) { return new AngelHttpException(error ?? e, message: 'Unhandled exception while connecting to Angel backend.', statusCode: response.statusCode, stackTrace: stack ?? st); } } abstract class BaseAngelClient extends Angel { final StreamController _onAuthenticated = new StreamController(); final List _services = []; final http.BaseClient client; @override Stream get onAuthenticated => _onAuthenticated.stream; BaseAngelClient(this.client, String basePath) : super(basePath); @override Future authenticate( {String type, credentials, String authEndpoint: '/auth', String reviveEndpoint: '/auth/token'}) async { if (type == null) { final url = '$basePath$reviveEndpoint'; String token; if (credentials is String) token = credentials; else if (credentials is Map && credentials.containsKey('token')) token = credentials['token'].toString(); if (token == null) { throw new ArgumentError( 'If `type` is not set, a JWT is expected as the `credentials` argument.'); } final response = await client.post(url, headers: { 'Accept': 'application/json', 'Content-Type': 'application/json', 'Authorization': 'Bearer $token' }); if (_invalid(response)) { throw failure(response); } try { final v = json.decode(response.body); if (v is! Map || !(v as Map).containsKey('data') || !(v as Map).containsKey('token')) { throw new AngelHttpException.notAuthenticated( message: "Auth endpoint '$url' did not return a proper response."); } var r = new AngelAuthResult.fromMap(v as Map); _onAuthenticated.add(r); return r; } on AngelHttpException { rethrow; } catch (e, st) { throw failure(response, error: e, stack: st); } } else { final url = '$basePath$authEndpoint/$type'; http.Response response; if (credentials != null) { response = await client.post(url, body: json.encode(credentials), headers: _writeHeaders); } else { response = await client.post(url, headers: _writeHeaders); } if (_invalid(response)) { throw failure(response); } try { final v = json.decode(response.body); if (v is! Map || !(v as Map).containsKey('data') || !(v as Map).containsKey('token')) { throw new AngelHttpException.notAuthenticated( message: "Auth endpoint '$url' did not return a proper response."); } var r = new AngelAuthResult.fromMap(v as Map); _onAuthenticated.add(r); return r; } on AngelHttpException { rethrow; } catch (e, st) { throw failure(response, error: e, stack: st); } } } Future close() async { client.close(); _onAuthenticated.close(); Future.wait(_services.map((s) => s.close())).then((_) { _services.clear(); }); } Future logout() async { authToken = null; } /// Sends a non-streaming [Request] and returns a non-streaming [Response]. Future sendUnstreamed( String method, url, Map headers, [body, Encoding encoding]) async { var request = new http.Request(method, url is Uri ? url : Uri.parse(url.toString())); if (headers != null) request.headers.addAll(headers); if (authToken?.isNotEmpty == true) request.headers['Authorization'] = 'Bearer $authToken'; if (encoding != null) request.encoding = encoding; if (body != null) { if (body is String) { request.body = body; } else if (body is List) { request.bodyBytes = new List.from(body); } else if (body is Map) { request.bodyFields = new Map.from(body); } else { throw new ArgumentError('Invalid request body "$body".'); } } return http.Response.fromStream(await client.send(request)); } @override Service service(String path, {Type type, AngelDeserializer deserializer}) { String uri = path.toString().replaceAll(straySlashes, ""); var s = new BaseAngelService(client, this, '$basePath/$uri', deserializer: deserializer); _services.add(s); return s; } String _join(url) { final head = basePath.replaceAll(new RegExp(r'/+$'), ''); final tail = url.replaceAll(straySlashes, ''); return '$head/$tail'; } @override Future delete(String url, {Map headers}) async { return sendUnstreamed('DELETE', _join(url), headers); } @override Future get(String url, {Map headers}) async { return sendUnstreamed('GET', _join(url), headers); } @override Future head(String url, {Map headers}) async { return sendUnstreamed('HEAD', _join(url), headers); } @override Future patch(String url, {body, Map headers}) async { return sendUnstreamed('PATCH', _join(url), headers, body); } @override Future post(String url, {body, Map headers}) async { return sendUnstreamed('POST', _join(url), headers, body); } @override Future put(String url, {body, Map headers}) async { return sendUnstreamed('PUT', _join(url), headers, body); } } class BaseAngelService extends Service { @override final BaseAngelClient app; final String basePath; final http.BaseClient client; final AngelDeserializer deserializer; final StreamController _onIndexed = new StreamController(), _onRead = new StreamController(), _onCreated = new StreamController(), _onModified = new StreamController(), _onUpdated = new StreamController(), _onRemoved = new StreamController(); @override Stream get onIndexed => _onIndexed.stream; @override Stream get onRead => _onRead.stream; @override Stream get onCreated => _onCreated.stream; @override Stream get onModified => _onModified.stream; @override Stream get onUpdated => _onUpdated.stream; @override Stream get onRemoved => _onRemoved.stream; @override Future close() async { _onIndexed.close(); _onRead.close(); _onCreated.close(); _onModified.close(); _onUpdated.close(); _onRemoved.close(); } BaseAngelService(this.client, this.app, this.basePath, {this.deserializer}); deserialize(x) { return deserializer != null ? deserializer(x) : x; } makeBody(x) { return json.encode(x); } Future send(http.BaseRequest request) { if (app.authToken != null && app.authToken.isNotEmpty) { request.headers['Authorization'] = 'Bearer ${app.authToken}'; } return client.send(request); } @override Future index([Map params]) async { final response = await app.sendUnstreamed( 'GET', '$basePath${_buildQuery(params)}', _readHeaders); try { if (_invalid(response)) { if (_onIndexed.hasListener) _onIndexed.addError(failure(response)); else throw failure(response); } final v = json.decode(response.body); if (v is! List) { _onIndexed.add(v); return v; } var r = v.map(deserialize).toList(); _onIndexed.add(r); return r; } catch (e, st) { if (_onIndexed.hasListener) _onIndexed.addError(e, st); else throw failure(response, error: e, stack: st); } } @override Future read(id, [Map params]) async { final response = await app.sendUnstreamed( 'GET', '$basePath/$id${_buildQuery(params)}', _readHeaders); try { if (_invalid(response)) { if (_onRead.hasListener) _onRead.addError(failure(response)); else throw failure(response); } var r = deserialize(json.decode(response.body)); _onRead.add(r); return r; } catch (e, st) { if (_onRead.hasListener) _onRead.addError(e, st); else throw failure(response, error: e, stack: st); } } @override Future create(data, [Map params]) async { final response = await app.sendUnstreamed('POST', '$basePath/${_buildQuery(params)}', _writeHeaders, makeBody(data)); try { if (_invalid(response)) { if (_onCreated.hasListener) _onCreated.addError(failure(response)); else throw failure(response); } var r = deserialize(json.decode(response.body)); _onCreated.add(r); return r; } catch (e, st) { if (_onCreated.hasListener) _onCreated.addError(e, st); else throw failure(response, error: e, stack: st); } } @override Future modify(id, data, [Map params]) async { final response = await app.sendUnstreamed('PATCH', '$basePath/$id${_buildQuery(params)}', _writeHeaders, makeBody(data)); try { if (_invalid(response)) { if (_onModified.hasListener) _onModified.addError(failure(response)); else throw failure(response); } var r = deserialize(json.decode(response.body)); _onModified.add(r); return r; } catch (e, st) { if (_onModified.hasListener) _onModified.addError(e, st); else throw failure(response, error: e, stack: st); } } @override Future update(id, data, [Map params]) async { final response = await app.sendUnstreamed('POST', '$basePath/$id${_buildQuery(params)}', _writeHeaders, makeBody(data)); try { if (_invalid(response)) { if (_onUpdated.hasListener) _onUpdated.addError(failure(response)); else throw failure(response); } var r = deserialize(json.decode(response.body)); _onUpdated.add(r); return r; } catch (e, st) { if (_onUpdated.hasListener) _onUpdated.addError(e, st); else throw failure(response, error: e, stack: st); } } @override Future remove(id, [Map params]) async { final response = await app.sendUnstreamed( 'DELETE', '$basePath/$id${_buildQuery(params)}', _readHeaders); try { if (_invalid(response)) { if (_onRemoved.hasListener) _onRemoved.addError(failure(response)); else throw failure(response); } var r = deserialize(json.decode(response.body)); _onRemoved.add(r); return r; } catch (e, st) { if (_onRemoved.hasListener) _onRemoved.addError(e, st); else throw failure(response, error: e, stack: st); } } }