fix: adding auth to eventsource
parent
a20f01d32c
commit
5ab96112ea
|
@ -34,6 +34,7 @@ class EventSource extends Stream<Event> {
|
||||||
// interface attributes
|
// interface attributes
|
||||||
|
|
||||||
final Uri url;
|
final Uri url;
|
||||||
|
final String authToken;
|
||||||
|
|
||||||
EventSourceReadyState get readyState => _readyState;
|
EventSourceReadyState get readyState => _readyState;
|
||||||
|
|
||||||
|
@ -55,7 +56,7 @@ class EventSource extends Stream<Event> {
|
||||||
|
|
||||||
/// Create a new EventSource by connecting to the specified url.
|
/// Create a new EventSource by connecting to the specified url.
|
||||||
static Future<EventSource> connect(url,
|
static Future<EventSource> connect(url,
|
||||||
{http.Client client, String lastEventId}) async {
|
{http.Client client, String lastEventId, String authToken}) async {
|
||||||
// parameter initialization
|
// parameter initialization
|
||||||
url = url is Uri ? url : Uri.parse(url);
|
url = url is Uri ? url : Uri.parse(url);
|
||||||
client = client ?? new http.Client();
|
client = client ?? new http.Client();
|
||||||
|
@ -82,6 +83,7 @@ class EventSource extends Stream<Event> {
|
||||||
var request = new http.Request("GET", url);
|
var request = new http.Request("GET", url);
|
||||||
request.headers["Cache-Control"] = "no-cache";
|
request.headers["Cache-Control"] = "no-cache";
|
||||||
request.headers["Accept"] = "text/event-stream";
|
request.headers["Accept"] = "text/event-stream";
|
||||||
|
request.headers["Authorization"] = "Bearer $authToken";
|
||||||
if (_lastEventId.isNotEmpty) {
|
if (_lastEventId.isNotEmpty) {
|
||||||
request.headers["Last-Event-ID"] = _lastEventId;
|
request.headers["Last-Event-ID"] = _lastEventId;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue