90 lines
2.8 KiB
Dart
90 lines
2.8 KiB
Dart
/// Browser client library for the Angel framework.
|
|
library angel_client.browser;
|
|
|
|
import 'dart:async' show Future, Stream, StreamController, StreamSubscription, Timer;
|
|
import 'dart:html' show CustomEvent, Event, window;
|
|
import 'package:dart2_constant/convert.dart';
|
|
import 'package:http/browser_client.dart' as http;
|
|
import 'angel_client.dart';
|
|
// import 'auth_types.dart' as auth_types;
|
|
import 'base_angel_client.dart';
|
|
export 'angel_client.dart';
|
|
|
|
/// Queries an Angel server via REST.
|
|
class Rest extends BaseAngelClient {
|
|
Rest(String basePath) : super(new http.BrowserClient(), basePath);
|
|
|
|
@override
|
|
Future<AngelAuthResult> authenticate(
|
|
{String type,
|
|
credentials,
|
|
String authEndpoint: '/auth',
|
|
String reviveEndpoint: '/auth/token'}) async {
|
|
if (type == null) {
|
|
if (!window.localStorage.containsKey('token')) {
|
|
throw new Exception(
|
|
'Cannot revive token from localStorage - there is none.');
|
|
}
|
|
|
|
try {
|
|
final result = await super.authenticate(
|
|
type: null,
|
|
credentials: {'token': json.decode(window.localStorage['token'])},
|
|
reviveEndpoint: reviveEndpoint);
|
|
window.localStorage['token'] = json.encode(authToken = result.token);
|
|
window.localStorage['user'] = json.encode(result.data);
|
|
return result;
|
|
} catch (e, st) {
|
|
throw new AngelHttpException(e,
|
|
message: 'Failed to revive auth token.', stackTrace: st);
|
|
}
|
|
} else {
|
|
final result = await super.authenticate(
|
|
type: type, credentials: credentials, authEndpoint: authEndpoint);
|
|
window.localStorage['token'] = json.encode(authToken = result.token);
|
|
window.localStorage['user'] = json.encode(result.data);
|
|
return result;
|
|
}
|
|
}
|
|
|
|
@override
|
|
Stream<String> authenticateViaPopup(String url,
|
|
{String eventName: 'token', String errorMessage}) {
|
|
var ctrl = new StreamController<String>();
|
|
var wnd = window.open(url, 'angel_client_auth_popup');
|
|
|
|
Timer t;
|
|
StreamSubscription sub;
|
|
t = new Timer.periodic(new Duration(milliseconds: 500), (timer) {
|
|
if (!ctrl.isClosed) {
|
|
if (wnd.closed) {
|
|
ctrl.addError(new AngelHttpException.notAuthenticated(
|
|
message:
|
|
errorMessage ?? 'Authentication via popup window failed.'));
|
|
ctrl.close();
|
|
timer.cancel();
|
|
sub?.cancel();
|
|
}
|
|
} else
|
|
timer.cancel();
|
|
});
|
|
|
|
sub = window.on[eventName ?? 'token'].listen((Event ev) {
|
|
var e = ev as CustomEvent;
|
|
if (!ctrl.isClosed) {
|
|
ctrl.add(e.detail);
|
|
t.cancel();
|
|
ctrl.close();
|
|
sub.cancel();
|
|
}
|
|
});
|
|
|
|
return ctrl.stream;
|
|
}
|
|
|
|
@override
|
|
Future logout() {
|
|
window.localStorage.remove('token');
|
|
return super.logout();
|
|
}
|
|
}
|