summaryrefslogtreecommitdiff
path: root/src/wasp-bus.el
diff options
context:
space:
mode:
authorLLLL Colonq <llll@colonq>2024-09-13 13:52:38 -0400
committerLLLL Colonq <llll@colonq>2024-09-13 13:52:38 -0400
commitd93ab7e848bf0f4bc1087504eecd7c959d19bf6c (patch)
treef4f1806ceb56d2a68c9641313000f9a50fa77d78 /src/wasp-bus.el
parentcc3ccebbd3af825f5e4866532906f1a7a2756518 (diff)
Update :3
Diffstat (limited to 'src/wasp-bus.el')
-rw-r--r--src/wasp-bus.el11
1 files changed, 7 insertions, 4 deletions
diff --git a/src/wasp-bus.el b/src/wasp-bus.el
index 7ac672c9..aa950b29 100644
--- a/src/wasp-bus.el
+++ b/src/wasp-bus.el
@@ -4,7 +4,6 @@
(require 'dash)
(require 's)
-(require 'wasp-utils)
(defgroup wasp nil
"Pub/sub bus client."
@@ -33,6 +32,10 @@
(defvar w/bus-event-handlers nil
"List of pairs of events and handler functions.")
+(defun w/bus-clean-string (s)
+ "Remove special characters from S."
+ (replace-regexp-in-string "[^[:print:]]" "" s))
+
(defun w/handle-message (msg)
"Handle the message MSG."
(let* ((ev (car msg))
@@ -40,7 +43,7 @@
(handler (alist-get ev w/bus-event-handlers nil nil #'equal)))
(if handler
(funcall handler body)
- (w/write-log (format "Unknown incoming event: %S" ev)))))
+ (message (format "Unknown incoming event: %S" ev)))))
(defun w/get-complete-line ()
"Kill a line followed by a newline if it exists, and nil otherwise."
@@ -54,7 +57,7 @@
"Call `w/handle-message' on every complete line of the current buffer."
(let ((l (w/get-complete-line)))
(when (and l (not (s-blank? l)))
- (w/handle-message (read (w/clean-string l)))
+ (w/handle-message (read (w/bus-clean-string l)))
(w/handle-lines))))
(defun w/process-filter (proc data)
"Process filter for pub/sub bus connection on PROC and DATA."
@@ -86,7 +89,7 @@
(defun w/sub-all ()
"Subscribe to all events in `w/bus-event-handlers'."
(--each w/bus-event-handlers
- (w/write-log (format "Subscribing to: %S" (car it)))
+ (message (format "Subscribing to: %S" (car it)))
(w/sub (car it))))
(defun w/disconnect ()