From aaecb6b3ff2fb859f59760b7b74cac906954172a Mon Sep 17 00:00:00 2001 From: Christopher Baines Date: Mon, 24 Apr 2023 10:43:27 +0100 Subject: Make the event source configurable --- bffe/server.scm | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) (limited to 'bffe') 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 "#" 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 () -- cgit v1.2.3