diff options
Diffstat (limited to 'src/main.lisp')
| -rw-r--r-- | src/main.lisp | 82 |
1 files changed, 80 insertions, 2 deletions
diff --git a/src/main.lisp b/src/main.lisp index ee37ddc..d789921 100644 --- a/src/main.lisp +++ b/src/main.lisp @@ -4,7 +4,8 @@ (:local-nicknames (:jzon :com.inuoe.jzon) (:mapi :nullbot/matrix-api) - (:sseq :split-sequence)) + (:sseq :split-sequence) + (:dex :dexador)) (:export #:start)) (in-package #:nullbot) @@ -14,6 +15,19 @@ :token (uiop:getenv "NULLBOT_TOKEN") :homeserver "matrix.nullring.xyz")) +(defparameter +feed-url+ "https://list.nullring.xyz/discussion/new.atom") +(defparameter +feed-room-id+ "!ShuXi5ohrPUtKHkrNO:matrix.nullring.xyz") +(defparameter +feed-cache-path+ #P"./nullbot_cache.sexp") +(defparameter +feed-sleep-minutes+ 1) + +(defparameter +prefix+ "$") + +(defun get-temp + (&aux + (endpoint "https://api.weather.gc.ca/collections/swob-realtime/items?f=json&lang=en&url=CYVR&sortby=-date_tm-value&limit=1&properties=date_tm-value,air_temp,air_temp-uom,air_temp-qa") + (data (jzon:parse (dex:get endpoint)))) + (hash-get (aref (gethash "features" data) 0) '("properties" "air_temp"))) + (defun process-roommsg (content room-id sender &aux @@ -25,7 +39,9 @@ (when (and (> (length body) 0) (equal (aref (car split-body) 0) #\$)) (cond ((string= command "$help") - (mapi:sendmsg *bot* room-id "Unlike some other bots, I'm nice :3"))))) + (mapi:sendmsg *bot* room-id "Unlike some other bots, I'm nice :3")) + ((string= command "$weather") + (mapi:sendmsg *bot* room-id (format nil "It's ~a degrees in Vancouver" (get-temp))))))) (defmethod mapi:on-event ((obj nullbot) event room-id @@ -35,3 +51,65 @@ (cond ((string= msgtype "m.room.message") (process-roommsg (gethash "content" event) room-id sender)))) + +(defun node-val (obj) + (car (xmls:node-children obj))) + +(defun node-attr (obj name) + (second (assoc name (xmls:node-attrs obj) :test #'string=))) + +;; TODO: make this into a generic f-n maybe and also make it not dumb +(defun get-node-by-name (obj name) + (check-type obj xmls:node) + (check-type name string) + (loop for child in (xmls:node-children obj) + when (and (xmls:node-p child) (string= name (xmls:node-name child))) + return child)) + +(defun send-entry (entry) + (mapi:sendmsg + *bot* + +feed-room-id+ + (format nil "New message on mailing list!~%Title: ~a~%From: ~a~%Link: ~a~%" + (getf entry :title) + (getf entry :author) + (getf entry :link)))) + +(defun write-entries (entries) + (with-open-file (str +feed-cache-path+ + :direction :output + :if-does-not-exist :create + :if-exists :supersede) + (format str "~s" entries))) + +(defun feed-thread () + (loop while (bt2:with-lock-held ((mapi:lock *bot*)) (mapi:listening *bot*)) do + (format t "Doing another poll~%") + (let* ((feed-str (dex:get +feed-url+)) + (xmlobj (xmls:parse feed-str)) + (entries (loop for entry in (xmls:node-children xmlobj) + when (string= (xmls:node-name entry) "entry") + collect `(:id ,(node-val (get-node-by-name entry "id")) + :title ,(node-val (get-node-by-name entry "title")) + :author ,(node-val (node-val (get-node-by-name entry "author"))) + :link ,(node-attr (get-node-by-name entry "link") "href")))) + (cached-entries)) + + (if (uiop:file-exists-p +feed-cache-path+) + (setf cached-entries (read-from-string (uiop:read-file-string +feed-cache-path+))) + (write-entries entries)) + + (when cached-entries + (loop for entry in entries + when (not (find (getf entry :id) + cached-entries + :test #'string= + :key (lambda (e) (getf e :id)))) + do (send-entry entry))) + ;; update the cache with the new entries + (write-entries entries)) + (sleep (* 60 +feed-sleep-minutes+)))) + +(defun start () + (bt2:make-thread #'feed-thread :name "nullbot polling thread") + (mapi:start *bot*)) |