(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)
(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"
"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))
(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 <mudsync-ws-server>
+ (create-actor <mudsync-ws-server>
#:network-manager (actor-id nm)
#:port web-server-port
#:http-handler (wrap-apply http-handler)
(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)))