processor: log before write; logging afterwards doesn't mean write is completed

2 files changed, 5 insertions, 5 deletions

diff --git a/src/weepinbell/processor/janitor.clj b/src/weepinbell/processor/janitor.clj
index ba75d30..e3c0b16 100644
--- a/src/weepinbell/processor/janitor.clj
+++ b/src/weepinbell/processor/janitor.clj
@@ -7,8 +7,8 @@
     (let [{:keys [verified? new? id old-data]} data]

       (if (and (not new?) (not verified?))

         (do ;; delete old unverified webmention 

+          (timbre/warn "webmention" id "no longer valid, deleting...")

           ((:delete storage) id)

           ((:on-delete callbacks) old-data)

-          (timbre/warn "webmention" id "no longer valid, deleted.")

           (-> data (assoc :ok? false)))

         (-> data (assoc :ok? true))))))

diff --git a/src/weepinbell/processor/writer.clj b/src/weepinbell/processor/writer.clj
index 7728dbb..02043f1 100644
--- a/src/weepinbell/processor/writer.clj
+++ b/src/weepinbell/processor/writer.clj
@@ -7,11 +7,11 @@
     (let [{:keys [id new? new-data]} data]

       (if new?

         (do ;; append new webmention

+          (timbre/info "new webmention" id "processed, writing to storage...")

           ((:append storage) new-data)

-          ((:on-create callbacks) new-data)

-          (timbre/info "new webmention" id "received."))

+          ((:on-create callbacks) new-data))

         (do ;; update old webmention

+          (timbre/info "webmention" id "exists, updating...")

           ((:update storage) id new-data)

-          ((:on-update callbacks) new-data)

-          (timbre/info "webmention" id "updated.")))

+          ((:on-update callbacks) new-data)))

       (-> data (assoc :ok? true)))))