|
@@ -21,7 +21,7 @@
|
|
|
(quri:merge-uris
|
|
(quri:merge-uris
|
|
|
(quri:uri (plump:attribute link "href"))
|
|
(quri:uri (plump:attribute link "href"))
|
|
|
uri) nil))))
|
|
uri) nil))))
|
|
|
- (error (e) (log:error e))))
|
|
|
|
|
|
|
+ (error (e) (log:error url e))))
|
|
|
|
|
|
|
|
(defun build-feed (url)
|
|
(defun build-feed (url)
|
|
|
(let ((root (xml-request url)))
|
|
(let ((root (xml-request url)))
|
|
@@ -193,7 +193,6 @@
|
|
|
;; Cron
|
|
;; Cron
|
|
|
(defcron process-feeds ()
|
|
(defcron process-feeds ()
|
|
|
(dolist (feed (remove-if-not #'need-fetch-p (db/rss-get-active-feeds)))
|
|
(dolist (feed (remove-if-not #'need-fetch-p (db/rss-get-active-feeds)))
|
|
|
- (log:info "Fetching new items" (feed-url feed))
|
|
|
|
|
(dolist (item (%fetch-new-items feed))
|
|
(dolist (item (%fetch-new-items feed))
|
|
|
(dolist (chat-id (db/rss-get-feed-chats feed))
|
|
(dolist (chat-id (db/rss-get-feed-chats feed))
|
|
|
(telegram-send-message chat-id
|
|
(telegram-send-message chat-id
|
|
@@ -230,7 +229,7 @@
|
|
|
(if existing
|
|
(if existing
|
|
|
(setf feeds (remove existing feeds))
|
|
(setf feeds (remove existing feeds))
|
|
|
(push feed feeds)))))
|
|
(push feed feeds)))))
|
|
|
- (error (e) (log:error "~A" e))))
|
|
|
|
|
|
|
+ (error (e) (log:error "~A: ~A" url e))))
|
|
|
(db/rss-set-chat-feeds chat-id feeds)
|
|
(db/rss-set-chat-feeds chat-id feeds)
|
|
|
(%send-feeds chat-id (db/rss-get-chat-feeds chat-id))))))
|
|
(%send-feeds chat-id (db/rss-get-chat-feeds chat-id))))))
|
|
|
|
|
|
