Hans Dijkema
f8057fccc5
NB. does not work currently with the linux flatpak stuff. Signed-off-by: Hans Dijkema <hans@dijkewijk.nl>
105 lines
4.6 KiB
Racket
105 lines
4.6 KiB
Racket
(module webui-wire-ipc racket/base
|
|
|
|
(require "webui-wire-download.rkt"
|
|
racket/string
|
|
racket/system
|
|
)
|
|
|
|
(provide webui-ipc)
|
|
|
|
(define re-kind #px"^([^:]+)[:]")
|
|
|
|
(define (is-int? str)
|
|
(let ((re-num #px"^[0-9]+$"))
|
|
(if (regexp-match re-num str)
|
|
#t
|
|
#f)))
|
|
|
|
|
|
;; This function only expects one character, namely \n
|
|
;; In windows disable text mode on stdout/stderr of webui-wire.
|
|
(define (read-eol port)
|
|
(read-string 1 port))
|
|
|
|
(define (process-stderr-reader process-stderr event-queuer log-processor)
|
|
(thread (λ ()
|
|
(letrec ((reader (λ ()
|
|
(let* ((str-length (read-string 8 process-stderr))
|
|
(colon (read-string 1 process-stderr)))
|
|
(if (eof-object? colon)
|
|
(begin
|
|
(log-processor 'stderr-reader "webui-wire executable exited")
|
|
'process-ended)
|
|
(begin
|
|
(if (and (string? colon) (string=? colon ":") (is-int? str-length))
|
|
; process line
|
|
(let* ((length (string->number str-length))
|
|
(input-bytes (read-bytes length process-stderr))
|
|
(input (bytes->string/utf-8 input-bytes))
|
|
(m (regexp-match re-kind input))
|
|
)
|
|
(read-eol process-stderr)
|
|
(if (eq? m #f)
|
|
(log-processor 'stderr-reader
|
|
(format "Unexpected: no kind: input = ~a" input))
|
|
(let ((kind (string->symbol (list-ref m 1)))
|
|
(line (substring input (string-length (car m))))
|
|
)
|
|
(if (eq? kind 'EVENT)
|
|
(event-queuer line)
|
|
(log-processor kind line))))
|
|
)
|
|
; otherwise skip line
|
|
(let* ((line (read-line process-stderr))
|
|
(msg (string-trim (string-append str-length colon line))))
|
|
(log-processor 'stderr-reader msg))
|
|
)
|
|
(reader)
|
|
)
|
|
))
|
|
)
|
|
))
|
|
(reader)))
|
|
)
|
|
)
|
|
|
|
(define (webui-ipc event-queuer log-processor)
|
|
(let ((webui-wire-cmd (ww-get-webui-wire-command))
|
|
)
|
|
(call-with-values
|
|
(λ () (process webui-wire-cmd))
|
|
(λ (args)
|
|
(let ((process-stdout (car args))
|
|
(process-stdin (cadr args))
|
|
(pid (caddr args))
|
|
(process-stderr (cadddr args))
|
|
(signal-func (car (cddddr args)))
|
|
)
|
|
(let ((reader-thrd (process-stderr-reader process-stderr event-queuer log-processor))
|
|
(sem (make-semaphore 1))
|
|
)
|
|
(λ (cmd)
|
|
(semaphore-wait sem) ; Ensure thread safety
|
|
(displayln cmd process-stdin)
|
|
(flush-output process-stdin)
|
|
(let* ((str-length (read-string 8 process-stdout))
|
|
(colon (read-string 1 process-stdout)))
|
|
(unless (and (string? colon)
|
|
(string=? colon ":"))
|
|
(semaphore-post sem)
|
|
(error "Unexpected input from webui-wire executable"))
|
|
(let* ((length (string->number str-length))
|
|
(input-bytes (read-bytes length process-stdout))
|
|
(input (bytes->string/utf-8 input-bytes))
|
|
)
|
|
(read-eol process-stdout)
|
|
(semaphore-post sem)
|
|
input)))
|
|
)
|
|
)
|
|
)
|
|
)
|
|
)
|
|
)
|
|
|
|
) ; End of module |