platform/example/main.dart

98 lines
3.2 KiB
Dart
Raw Normal View History

2017-06-03 20:43:36 +00:00
import 'dart:convert';
import 'dart:io';
import 'package:angel_auth/angel_auth.dart';
import 'package:angel_framework/angel_framework.dart';
import 'package:angel_auth_oauth2/angel_auth_oauth2.dart';
2018-03-30 16:44:15 +00:00
import 'package:logging/logging.dart';
2017-06-03 20:43:36 +00:00
import 'package:oauth2/oauth2.dart' as oauth2;
2018-03-30 16:44:15 +00:00
final AngelAuthOAuth2Options oAuth2Config = new AngelAuthOAuth2Options(
2017-06-03 20:43:36 +00:00
callback: 'http://localhost:3000/auth/github/callback',
key: '6caeaf5d4c04936ec34f',
secret: '178360518cf9de4802e2346a4b6ebec525dc4427',
authorizationEndpoint: 'http://github.com/login/oauth/authorize',
2018-03-30 16:44:15 +00:00
tokenEndpoint: 'https://github.com/login/oauth/access_token',
getParameters: (contentType, body) {
if (contentType.type == 'application') {
if (contentType.subtype == 'x-www-form-urlencoded')
return Uri.splitQueryString(body);
2018-09-12 03:23:42 +00:00
else if (contentType.subtype == 'json')
return (json.decode(body) as Map).cast<String, String>();
2018-03-30 16:44:15 +00:00
}
2018-09-12 03:23:42 +00:00
throw new FormatException(
'Invalid content-type $contentType; expected application/x-www-form-urlencoded or application/json.');
2018-03-30 16:44:15 +00:00
});
2017-06-03 20:43:36 +00:00
main() async {
var app = new Angel();
app.use('/users', new MapService());
2018-03-30 16:44:15 +00:00
var auth =
new AngelAuth<User>(jwtKey: 'oauth2 example secret', allowCookie: false);
auth.deserializer =
2018-09-12 03:23:42 +00:00
(id) => app.service('users').read(id).then((u) => User.parse(u as Map));
2017-06-03 20:43:36 +00:00
auth.serializer = (User user) async => user.id;
2018-09-12 03:23:42 +00:00
auth.strategies['github'] = new OAuth2Strategy(
oAuth2Config,
(oauth2.Client client) async {
var response = await client.get('https://api.github.com/user');
var ghUser = json.decode(response.body);
var id = ghUser['id'];
Iterable<Map> matchingUsers = await app.service('users').index({
'query': {'githubId': id}
});
if (matchingUsers.isNotEmpty) {
// Return the corresponding user, if it exists
return User.parse(matchingUsers.firstWhere((u) => u['githubId'] == id));
} else {
// Otherwise,create a user
return await app
.service('users')
.create({'githubId': id}).then((u) => User.parse(u as Map));
}
},
);
2017-06-03 20:43:36 +00:00
app.get('/auth/github', auth.authenticate('github'));
app.get(
'/auth/github/callback',
auth.authenticate('github',
new AngelAuthOptions(callback: (req, res, jwt) async {
// In real-life, you might include a pop-up callback script.
//
// Use `confirmPopupAuthentication`, which is bundled with
// `package:angel_auth`.
res.write('Your JWT: $jwt');
})));
2018-03-30 16:44:15 +00:00
await app.configure(auth.configureServer);
app.logger = new Logger('angel')..onRecord.listen(print);
2017-06-03 20:43:36 +00:00
2018-03-30 16:44:15 +00:00
var http = new AngelHttp(app);
2018-09-12 03:23:42 +00:00
var server = await http.startServer(InternetAddress.loopbackIPv4, 3000);
2017-06-03 20:43:36 +00:00
var url = 'http://${server.address.address}:${server.port}';
print('Listening on $url');
print('View user listing: $url/users');
print('Sign in via Github: $url/auth/github');
}
class User extends Model {
@override
String id;
int githubId;
User({this.id, this.githubId});
static User parse(Map map) =>
2018-09-12 03:23:42 +00:00
new User(id: map['id'] as String, githubId: map['github_id'] as int);
2017-06-03 20:43:36 +00:00
Map<String, dynamic> toJson() => {'id': id, 'github_id': githubId};
}