Add some more api functions and atom feed integration

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*))