Exchange ad-hoc tracing for slightly more principled log-info output.
This commit is contained in:
parent
b24cd754b0
commit
fd2e4cc23c
|
@ -59,9 +59,6 @@
|
||||||
[(? patch? p) `("patch" ,(patch->jsexpr p (lambda (v) #t)))]
|
[(? patch? p) `("patch" ,(patch->jsexpr p (lambda (v) #t)))]
|
||||||
[(message body) `("message" ,body)])))
|
[(message body) `("message" ,body)])))
|
||||||
|
|
||||||
(require racket/trace)
|
|
||||||
(trace drop lift)
|
|
||||||
|
|
||||||
(define drop-json-action drop)
|
(define drop-json-action drop)
|
||||||
(define lift-json-event lift)
|
(define lift-json-event lift)
|
||||||
(define lift-json-action lift)
|
(define lift-json-action lift)
|
||||||
|
|
|
@ -35,6 +35,7 @@
|
||||||
|
|
||||||
(arm-ping-timer!)
|
(arm-ping-timer!)
|
||||||
|
|
||||||
|
(log-info "\nStarting broker connection from ~v" c)
|
||||||
(until (retracted (advertise (websocket-message c server-id _)) #:meta-level 1)
|
(until (retracted (advertise (websocket-message c server-id _)) #:meta-level 1)
|
||||||
(assert (advertise (websocket-message server-id c _)) #:meta-level 1)
|
(assert (advertise (websocket-message server-id c _)) #:meta-level 1)
|
||||||
|
|
||||||
|
@ -46,14 +47,19 @@
|
||||||
(match (drop-json-action (string->jsexpr data))
|
(match (drop-json-action (string->jsexpr data))
|
||||||
['ping (send-event 'pong)]
|
['ping (send-event 'pong)]
|
||||||
['pong (void)]
|
['pong (void)]
|
||||||
[(? patch? p) (patch! (patch-without-at-meta p))]
|
[(? patch? p) (patch! (log-packet c 'inbound 'patch (patch-without-at-meta p)))]
|
||||||
[(message (at-meta _)) (void)]
|
[(message (at-meta _)) (void)]
|
||||||
[(message body) (send! body)]))
|
[(message body) (send! (log-packet c 'inbound 'message body))]))
|
||||||
|
|
||||||
(on-event
|
(on-event
|
||||||
[(? patch? p) (send-event (clean-patch p))]
|
[(? patch? p) (send-event (log-packet c 'outbound 'patch (clean-patch p)))]
|
||||||
[(message (at-meta _)) #f]
|
[(message (at-meta _)) #f]
|
||||||
[(? message? m) (send-event m)]))))
|
[(message body) (send-event (message (log-packet c 'outbound 'message body)))]))
|
||||||
|
(log-info "\nEnding broker connection from ~v" c)))
|
||||||
|
|
||||||
|
(define (log-packet c direction kind value)
|
||||||
|
(log-info "\nBroker: ~v: ~a ~a\n~v" c direction kind value)
|
||||||
|
value)
|
||||||
|
|
||||||
(define stuff-to-prune
|
(define stuff-to-prune
|
||||||
(trie-union-all #:combiner (lambda (v1 v2) (trie-success #t))
|
(trie-union-all #:combiner (lambda (v1 v2) (trie-success #t))
|
||||||
|
|
Loading…
Reference in New Issue