X-Git-Url: https://jxself.org/git/?p=mudsync.git;a=blobdiff_plain;f=mudsync%2Fnetworking.scm;h=2a193ae5d0d144b34a9d07e006b1c0abc84da576;hp=b541c1ee99da72ff881e73c2a6bfc0b2e4891e3d;hb=086e3362830393bcd51a3d79fe50c66ca15b7112;hpb=0327c09557568d1fefd7d642333c21c8a9f655db diff --git a/mudsync/networking.scm b/mudsync/networking.scm index b541c1e..2a193ae 100644 --- a/mudsync/networking.scm +++ b/mudsync/networking.scm @@ -60,7 +60,8 @@ (web-server-port %default-web-server-port)) (if web-server-port (nm-install-web-server actor server web-server-port)) - (nm-install-socket actor server port))) + ;; (nm-install-socket actor server port) + )) (send-to-client nm-send-to-client-id) (new-socket-client nm-new-socket-client) (new-web-client nm-new-web-client) @@ -164,7 +165,7 @@ (hash-set! (nm-clients nm) client-id (cons 'websocket ws-client-id)) (<- (nm-send-input-to nm) 'new-client #:client client-id) - (<-reply message client-id)) + client-id) (define (nm-client-receive-loop nm client-socket client-id) "Make a method to receive client data" @@ -183,11 +184,11 @@ "Handle a closed port" (format #t "DEBUG: handled closed port ~a\n" client-id) (hash-remove! (nm-clients nm) client-id) - (<-* `(#:actor ,nm) (nm-send-input-to nm) 'client-closed #:client client-id)) + (<- (nm-send-input-to nm) 'client-closed #:client client-id)) (define (nm-handle-line nm client-id line) "Handle an incoming line of input from a client" - (<-* `(#:actor ,nm) (nm-send-input-to nm) 'client-input + (<- (nm-send-input-to nm) 'client-input #:data line #:client client-id)) @@ -226,7 +227,7 @@ like the web one" (define (nm-install-web-server nm server web-server-port) "This installs the web server, which we see in use below...." (set! (.web-server nm) - (create-actor nm + (create-actor #:network-manager (actor-id nm) #:port web-server-port #:http-handler (wrap-apply http-handler) @@ -315,8 +316,8 @@ like the web one" (define (websocket-client-connect websocket-server client-id) (let ((nm-client-id - (mbody-val (<-wait (.network-manager websocket-server) - 'new-web-client client-id)))) + (<-wait (.network-manager websocket-server) + 'new-web-client client-id))) (hash-set! (.nm-client-ids websocket-server) client-id nm-client-id)))