From cb1bac4e07abe46fee5de8e2136c835c5c5cd0b7 Mon Sep 17 00:00:00 2001 From: Bryce Covert Date: Thu, 23 Dec 2021 07:31:08 -0800 Subject: [PATCH] turning everything on. --- src/clj/auto_ap/background/requests.clj | 6 ++++-- src/clj/auto_ap/import/transactions.clj | 2 +- src/clj/auto_ap/import/yodlee.clj | 2 +- src/clj/auto_ap/server.clj | 14 ++++++-------- 4 files changed, 12 insertions(+), 12 deletions(-) diff --git a/src/clj/auto_ap/background/requests.clj b/src/clj/auto_ap/background/requests.clj index fad4cc76..dcbad6d0 100644 --- a/src/clj/auto_ap/background/requests.clj +++ b/src/clj/auto_ap/background/requests.clj @@ -20,7 +20,10 @@ (let [[{:keys [message-id receipt-handle body]}] (:messages (sqs/receive-message {:queue-url queue-url :wait-time-seconds 1 :count 1}))] + (when message-id + (sqs/delete-message {:queue-url queue-url + :receipt-handle receipt-handle} ) (log/infof "processing message %s with body %s" message-id body ) (cond (= ":intuit" body) @@ -46,8 +49,7 @@ (p/import-plaid) (catch Exception e (log/error e)))) - (sqs/delete-message {:queue-url queue-url - :receipt-handle receipt-handle} ))))) + )))) (defn fake-message [] (sqs/send-message {:queue-url (:requests-queue-url env) diff --git a/src/clj/auto_ap/import/transactions.clj b/src/clj/auto_ap/import/transactions.clj index f2b2034a..5ef65959 100644 --- a/src/clj/auto_ap/import/transactions.clj +++ b/src/clj/auto_ap/import/transactions.clj @@ -186,7 +186,7 @@ :error (not= "POSTED" (:transaction/status transaction)) - :not-posted + :not-ready (and (:bank-account/start-date bank-account) (not (t/after? (coerce/to-date-time (:transaction/date transaction)) diff --git a/src/clj/auto_ap/import/yodlee.clj b/src/clj/auto_ap/import/yodlee.clj index 0b2cbe7d..876c86a8 100644 --- a/src/clj/auto_ap/import/yodlee.clj +++ b/src/clj/auto_ap/import/yodlee.clj @@ -66,5 +66,5 @@ (mount/defstate import-worker - :start (scheduler/every (* 1000 60 60 4) import-yodlee) + :start (scheduler/every (* 1000 60 60 8) import-yodlee) :stop (scheduler/stop import-worker)) diff --git a/src/clj/auto_ap/server.clj b/src/clj/auto_ap/server.clj index 7cde2592..ede4b6bb 100644 --- a/src/clj/auto_ap/server.clj +++ b/src/clj/auto_ap/server.clj @@ -45,8 +45,12 @@ #'sysco/sysco-invoice-importer #'auto-ap.background.invoices/close-auto-invoices-worker #'gq-clients/current-balance-worker - - + #'yodlee/import-worker + #'yodlee2/import-worker + #'yodlee2/account-worker + #'intuit/import-worker + #'intuit/account-worker + #'plaid/import-worker #'migrate/migrate-start]))] (log/info "starting without " without) @@ -55,10 +59,4 @@ (apply mount/start-without without))) (comment - #'yodlee/import-worker - #'yodlee2/import-worker - #'yodlee2/account-worker - #'intuit/import-worker - #'intuit/account-worker - #'plaid/import-worker )