notid/integreat
1
0
Fork 0
Code Issues Pull Requests 2 Actions Packages Projects Releases Wiki Activity

multiple environments.

Browse Source
This commit is contained in:
Bryce Covert
2018-04-08 22:12:27 -07:00
parent 9dabb633a7
commit 2f400fc3c9
9 changed files with 33 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/clj/auto_ap/background/mail.clj
View File

@@ -5,6 +5,7 @@
[clojure-mail.message :as message]
[clojure.string :as str]
[clojure.java.io :as io]
[config.core :refer [env]]
[auto-ap.parse :as parse]
[auto-ap.db.invoices :as invoices]
[auto-ap.db.companies :as companies]
@@ -20,13 +21,12 @@
Flags$Flag AuthenticationFailedException]
(com.sun.mail.imap IMAPStore)))
(def queue-url "https://sqs.us-east-1.amazonaws.com/679918342773/integreat-mail-prod")
(defn process-sqs []
(try
(println "Fetching messages from sqs...")
(let [companies (companies/get-all)]
(doseq [message (:messages (sqs/receive-message {:queue-url queue-url
(doseq [message (:messages (sqs/receive-message {:queue-url (:invoice-import-queue-url env)
:wait-time-seconds 5
:max-number-of-messages 10
#_#_:attribute-names ["All"]}))]
@@ -46,7 +46,7 @@
(io/copy (:body pdf-stream) (io/file filename))
(invoices/import (parse/parse-file filename filename) companies)
(io/delete-file filename))))))
(sqs/delete-message (assoc message :queue-url queue-url ))))
(sqs/delete-message (assoc message :queue-url (:invoice-import-queue-url env) ))))
(catch Exception e
(println e))))