cf2ad35d2b
git-subtree-dir: packages/production git-subtree-mainline:c97363d290git-subtree-split:5ac875c504
46 lines
1.6 KiB
Dart
46 lines
1.6 KiB
Dart
import 'dart:async';
|
|
import 'dart:isolate';
|
|
import 'package:angel_framework/angel_framework.dart';
|
|
import 'package:angel_production/angel_production.dart';
|
|
import 'package:pub_sub/pub_sub.dart' as pub_sub;
|
|
|
|
main(List<String> args) => Runner('example', configureServer).run(args);
|
|
|
|
Future configureServer(Angel app) async {
|
|
// Use the injected `pub_sub.Client` to send messages.
|
|
var client = app.container.make<pub_sub.Client>();
|
|
var greeting = 'Hello! This is the default greeting.';
|
|
|
|
// We can listen for an event to perform some behavior.
|
|
//
|
|
// Here, we use message passing to synchronize some common state.
|
|
var onGreetingChanged = await client.subscribe('greeting_changed');
|
|
onGreetingChanged
|
|
.cast<String>()
|
|
.listen((newGreeting) => greeting = newGreeting);
|
|
|
|
// Add some routes...
|
|
app.get('/', (req, res) => 'Hello, production world!');
|
|
|
|
app.get('/404', (req, res) {
|
|
res.statusCode = 404;
|
|
return res.close();
|
|
});
|
|
|
|
// Create some routes to demonstrate message passing.
|
|
app.get('/greeting', (req, res) => greeting);
|
|
|
|
// This route will push a new value for `greeting`.
|
|
app.get('/change_greeting/:newGreeting', (req, res) {
|
|
greeting = req.params['newGreeting'] as String;
|
|
client.publish('greeting_changed', greeting);
|
|
return 'Changed greeting -> $greeting';
|
|
});
|
|
|
|
// The `Runner` helps with fault tolerance.
|
|
app.get('/crash', (req, res) {
|
|
// We'll crash this instance deliberately, but the Runner will auto-respawn for us.
|
|
Timer(const Duration(seconds: 3), Isolate.current.kill);
|
|
return 'Crashing in 3s...';
|
|
});
|
|
}
|