51 lines
1.6 KiB
Dart
51 lines
1.6 KiB
Dart
import 'dart:async';
|
|
import 'package:angel_framework/angel_framework.dart';
|
|
import 'package:angel_websocket/server.dart';
|
|
import 'package:eventsource/eventsource.dart';
|
|
import 'package:eventsource/src/encoder.dart';
|
|
import 'package:eventsource/publisher.dart';
|
|
import 'package:stream_channel/stream_channel.dart';
|
|
|
|
class AngelEventSourcePublisher {
|
|
final AngelWebSocket webSocketDriver;
|
|
|
|
final String channel;
|
|
|
|
int _count = 0;
|
|
|
|
AngelEventSourcePublisher(this.webSocketDriver, {this.channel: ''});
|
|
|
|
Future handleRequest(RequestContext req, ResponseContext res) async {
|
|
if (!req.accepts('text/event-stream', strict: false))
|
|
throw new AngelHttpException.badRequest();
|
|
|
|
res.headers.addAll({
|
|
'cache-control': 'no-cache, no-store, must-revalidate',
|
|
'content-type': 'text/event-stream',
|
|
'connection': 'keep-alive',
|
|
});
|
|
|
|
var acceptsGzip =
|
|
(req.headers['accept-encoding']?.contains('gzip') == true);
|
|
|
|
if (acceptsGzip) res.headers['content-encoding'] = 'gzip';
|
|
|
|
var eventSink = new EventSourceEncoder(compressed: acceptsGzip)
|
|
.startChunkedConversion(res);
|
|
|
|
// Listen for events.
|
|
var ctrl = new StreamChannelController();
|
|
|
|
// Incoming events are strings, and should be sent via the eventSink.
|
|
ctrl.local.stream.cast<String>().listen((data) {
|
|
eventSink.add(new Event(
|
|
id: (_count++).toString(),
|
|
data: data,
|
|
));
|
|
});
|
|
|
|
// Create a new WebSocketContext, and hand it off to the driver.
|
|
var socket = new WebSocketContext(ctrl.foreign, req, res);
|
|
return await webSocketDriver.handleClient(socket);
|
|
}
|
|
}
|