Make the event source configurable

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 ()