diff options
Diffstat (limited to 'bffe')
-rw-r--r-- | bffe/server.scm | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/bffe/server.scm b/bffe/server.scm index 5eb8d0d..c5f86ed 100644 --- a/bffe/server.scm +++ b/bffe/server.scm @@ -63,7 +63,7 @@ (lambda (scheduler port) (display "#<scheduler>" port))) -(define (make-state-channel) +(define (make-state-channel event-source) (let ((channel (make-channel))) (call-with-new-thread (lambda () @@ -80,7 +80,8 @@ (let ((response body (http-get - (string->uri "http://localhost:8746/state")))) + (string->uri + (string-append event-source "/state"))))) (let ((state (json-string->scm (utf8->string body)))) @@ -104,7 +105,7 @@ (get-message reply-channel))) -(define (make-events-channel initial-state-id) +(define (make-events-channel event-source initial-state-id) (let* ((submission-channel (make-channel)) (listener-channels-box (make-atomic-box vlist-null)) @@ -205,7 +206,8 @@ (let* ((response remote-port (http-get - (string->uri "http://localhost:8746/events") + (string->uri + (string-append event-source "/events")) #:headers `((last-event-id . ,(number->string @@ -450,10 +452,12 @@ #:code 500)))) (define* (start-bffe-web-server port host assets-directory + event-source metrics-registry #:key (controller-args '())) (define state-channel - (make-state-channel)) + (make-state-channel + event-source)) (call-with-error-handling (lambda () |