aboutsummaryrefslogtreecommitdiff
path: root/test/clj/queue_api
diff options
context:
space:
mode:
Diffstat (limited to 'test/clj/queue_api')
-rw-r--r--test/clj/queue_api/test/db/core_test.clj208
1 files changed, 115 insertions, 93 deletions
diff --git a/test/clj/queue_api/test/db/core_test.clj b/test/clj/queue_api/test/db/core_test.clj
index 3909c31..08c8a2a 100644
--- a/test/clj/queue_api/test/db/core_test.clj
+++ b/test/clj/queue_api/test/db/core_test.clj
@@ -6,92 +6,96 @@
[clj-time.core :as time]
[mount.core :as mount]))
-(def base-schema [;;Job that will be kept :unassigned
- {:job/id "dfa7744f-8d61-4d37-885f-dbef2d4df13b"
- :job/type "rewards-question"
- :job/status :unassigned
- :job/date (time/date-time 2018 2 19 1 0 1)
- :job/urgent false}
- {:job/id "c471f9e0-fbbd-461d-adb0-7466c2d9830f"
- :job/type "purchases-question"
- :job/status :unassigned
- :job/date (time/date-time 2018 2 19 1 0 0)
- :job/urgent false}
- {:job/id "51ab0771-f1e4-4268-868f-9029a58f6612"
- :job/type "rewards-question"
- :job/status :unassigned
- :job/date (time/date-time 2018 2 18 1 0 2)
- :job/urgent true}
- {:job/id "96cf6f11-591d-4cde-9ab0-56e371acb6d2"
- :job/type "rewards-question"
- :job/status :unassigned
- :job/date (time/date-time 2018 2 18 1 0 1)
- :job/urgent false}
- {:job/id "6e90db58-7a6d-46e2-a02a-e33dc82e6e33"
- :job/type "purchases-question"
- :job/status :unassigned
- :job/date (time/date-time 2018 2 18 1 0 0)
- :job/urgent true}
- {:job/id "f90e149e-fa51-4212-a6bf-8cf81c78d28c"
- :job/type "purchases-question"
- :job/status :unassigned
- :job/date (time/date-time 2018 2 17 1 0 0)
- :job/urgent false}
- ;;Job that will be changed to processing
- {:job/id "b201d085-91b5-4a13-9a74-7861426e9996"
- :job/type "purchases-question"
- :job/status :unassigned
- :job/date (time/date-time 2018 2 18 1 0 4)
- :job/urgent true}
- ;;Job that will be changed to completed
- {:job/id "1e0d939d-494b-48d2-9247-b5ae207a519a"
- :job/type "bills-question"
- :job/status :unassigned
- :job/date (time/date-time 2018 2 18 1 0 3)
- :job/urgent false}
- {:job/id "aa327540-4e24-47f4-9e9c-81cdd5195934"
- :job/type "bills-question"
- :job/status :unassigned
- :job/date (time/date-time 2018 2 18 1 0 6)
- :job/urgent true}
- {:job/id "3cdc52fe-b538-40a6-a9d7-92fa840c2c4b"
- :job/type "purchases-question"
- :job/status :unassigned
- :job/date (time/date-time 2018 2 18 1 0 8)
- :job/urgent true}
- ;;Agents
- {:agent/id "644be0ce-035d-48cb-867e-8e6de2714a8d"
- :agent/name "Dummy Derp"
- :agent/primary-skillset ["rewards-question" "bills-question"]
- :agent/secondary-skillset []}
- {:agent/id "ff02347a-1b2d-440c-a2a1-7a593dba564e"
- :agent/name "Derpinson"
- :agent/primary-skillset ["nil-question"]
- :agent/secondary-skillset ["purchases-question"]}
- ;;Change job status to :completed and link agent
- {:job/id "1e0d939d-494b-48d2-9247-b5ae207a519a"
- :job/status :completed
- :job/agent [:agent/id "644be0ce-035d-48cb-867e-8e6de2714a8d"]}
- {:job/id "aa327540-4e24-47f4-9e9c-81cdd5195934"
- :job/status :completed
- :job/agent [:agent/id "644be0ce-035d-48cb-867e-8e6de2714a8d"]}
- {:job/id "3cdc52fe-b538-40a6-a9d7-92fa840c2c4b"
- :job/status :completed
- :job/agent [:agent/id "644be0ce-035d-48cb-867e-8e6de2714a8d"]}
- ;;Change job status to processing and link agent
- {:job/id "b201d085-91b5-4a13-9a74-7861426e9996"
- :job/status :processing
- :job/agent [:agent/id "644be0ce-035d-48cb-867e-8e6de2714a8d"]}
- ;;Link agent with job that it is being processed
- {:agent/id "644be0ce-035d-48cb-867e-8e6de2714a8d"
- :agent/job [:job/id "b201d085-91b5-4a13-9a74-7861426e9996"]}])
+(def base-schema
+ "Scenario base for tests, it has most of possible combinations to simulate a real setup"
+ [;;Jobs that will be kept :unassigned
+ {:job/id "dfa7744f-8d61-4d37-885f-dbef2d4df13b"
+ :job/type "rewards-question"
+ :job/status :unassigned
+ :job/date (time/date-time 2018 2 19 1 0 1)
+ :job/urgent false}
+ {:job/id "c471f9e0-fbbd-461d-adb0-7466c2d9830f"
+ :job/type "purchases-question"
+ :job/status :unassigned
+ :job/date (time/date-time 2018 2 19 1 0 0)
+ :job/urgent false}
+ {:job/id "51ab0771-f1e4-4268-868f-9029a58f6612"
+ :job/type "rewards-question"
+ :job/status :unassigned
+ :job/date (time/date-time 2018 2 18 1 0 2)
+ :job/urgent true}
+ {:job/id "96cf6f11-591d-4cde-9ab0-56e371acb6d2"
+ :job/type "rewards-question"
+ :job/status :unassigned
+ :job/date (time/date-time 2018 2 18 1 0 1)
+ :job/urgent false}
+ {:job/id "6e90db58-7a6d-46e2-a02a-e33dc82e6e33"
+ :job/type "purchases-question"
+ :job/status :unassigned
+ :job/date (time/date-time 2018 2 18 1 0 0)
+ :job/urgent true}
+ {:job/id "f90e149e-fa51-4212-a6bf-8cf81c78d28c"
+ :job/type "purchases-question"
+ :job/status :unassigned
+ :job/date (time/date-time 2018 2 17 1 0 0)
+ :job/urgent false}
+ ;;Job that will be changed to processing
+ {:job/id "b201d085-91b5-4a13-9a74-7861426e9996"
+ :job/type "purchases-question"
+ :job/status :unassigned
+ :job/date (time/date-time 2018 2 18 1 0 4)
+ :job/urgent true}
+ ;;Jobs that will be changed to completed
+ {:job/id "1e0d939d-494b-48d2-9247-b5ae207a519a"
+ :job/type "bills-question"
+ :job/status :unassigned
+ :job/date (time/date-time 2018 2 18 1 0 3)
+ :job/urgent false}
+ {:job/id "aa327540-4e24-47f4-9e9c-81cdd5195934"
+ :job/type "bills-question"
+ :job/status :unassigned
+ :job/date (time/date-time 2018 2 18 1 0 6)
+ :job/urgent true}
+ {:job/id "3cdc52fe-b538-40a6-a9d7-92fa840c2c4b"
+ :job/type "purchases-question"
+ :job/status :unassigned
+ :job/date (time/date-time 2018 2 18 1 0 8)
+ :job/urgent true}
+ ;;Agents
+ {:agent/id "644be0ce-035d-48cb-867e-8e6de2714a8d"
+ :agent/name "Dummy Derp"
+ :agent/primary-skillset ["rewards-question" "bills-question"]
+ :agent/secondary-skillset []}
+ {:agent/id "ff02347a-1b2d-440c-a2a1-7a593dba564e"
+ :agent/name "Derpinson"
+ :agent/primary-skillset ["nil-question"]
+ :agent/secondary-skillset ["purchases-question"]}
+ ;;Change job status to :completed and link agent
+ {:job/id "1e0d939d-494b-48d2-9247-b5ae207a519a"
+ :job/status :completed
+ :job/agent [:agent/id "644be0ce-035d-48cb-867e-8e6de2714a8d"]}
+ {:job/id "aa327540-4e24-47f4-9e9c-81cdd5195934"
+ :job/status :completed
+ :job/agent [:agent/id "644be0ce-035d-48cb-867e-8e6de2714a8d"]}
+ {:job/id "3cdc52fe-b538-40a6-a9d7-92fa840c2c4b"
+ :job/status :completed
+ :job/agent [:agent/id "644be0ce-035d-48cb-867e-8e6de2714a8d"]}
+ ;;Change job status to processing and link agent
+ {:job/id "b201d085-91b5-4a13-9a74-7861426e9996"
+ :job/status :processing
+ :job/agent [:agent/id "644be0ce-035d-48cb-867e-8e6de2714a8d"]}
+ ;;Link agent with job that it is being processed
+ {:agent/id "644be0ce-035d-48cb-867e-8e6de2714a8d"
+ :agent/job [:job/id "b201d085-91b5-4a13-9a74-7861426e9996"]}])
-(def complete-schema [{:job/id "51ab0771-f1e4-4268-868f-9029a58f6612"
- :job/status :completed
- :job/agent [:agent/id "644be0ce-035d-48cb-867e-8e6de2714a8d"]}
- {:job/id "6e90db58-7a6d-46e2-a02a-e33dc82e6e33"
- :job/status :completed
- :job/agent [:agent/id "ff02347a-1b2d-440c-a2a1-7a593dba564e"]}])
+(def complete-schema
+ "It completes some jobs and links them to an agent"
+ [{:job/id "51ab0771-f1e4-4268-868f-9029a58f6612"
+ :job/status :completed
+ :job/agent [:agent/id "644be0ce-035d-48cb-867e-8e6de2714a8d"]}
+ {:job/id "6e90db58-7a6d-46e2-a02a-e33dc82e6e33"
+ :job/status :completed
+ :job/agent [:agent/id "ff02347a-1b2d-440c-a2a1-7a593dba564e"]}])
(use-fixtures
:each
@@ -117,7 +121,7 @@
(is (not (empty? tx-data))))))
(deftest add-job-test
- (testing "test adding job"
+ (testing "Test adding job"
(let [tx (add-job {:id "2dc043a4-6708-4b1e-885d-e59082733e4d"
:type "rewards-question"
:urgent false})
@@ -125,7 +129,7 @@
(is (not (empty? tx-data))))))
(deftest q-status-test
- (testing "test query job by status"
+ (testing "Test query job by status"
(are [left right]
(= left right)
#{["96cf6f11-591d-4cde-9ab0-56e371acb6d2"]
@@ -141,7 +145,7 @@
#{} (q-status :nil))))
(deftest sum-queue-test
- (testing "test get summary of current state of the queue"
+ (testing "test get summary of the current state of the queue"
(is (= {:completed ["1e0d939d-494b-48d2-9247-b5ae207a519a"
"aa327540-4e24-47f4-9e9c-81cdd5195934"
"3cdc52fe-b538-40a6-a9d7-92fa840c2c4b"],
@@ -155,7 +159,7 @@
(sum-queue)))))
(deftest q-job-test
- (testing "test query job"
+ (testing "Test query job"
(is (= [(job "96cf6f11-591d-4cde-9ab0-56e371acb6d2")
(job "dfa7744f-8d61-4d37-885f-dbef2d4df13b")]
(q-job false :unassigned "rewards-question")))
@@ -180,7 +184,7 @@
(is (= [] (agent-jobs "644be0ce-035d-48cb-867e-8e6de2714a8d" :unassigned)))))
(deftest sum-agent-test
- (testing "Test sum-agent"
+ (testing "Test get summary of an agent"
(is (= {"bills-question" 2
"purchases-question" 1}
(sum-agent "644be0ce-035d-48cb-867e-8e6de2714a8d")))
@@ -258,6 +262,24 @@
(job "dfa7744f-8d61-4d37-885f-dbef2d4df13b") (:agent/job (agent "644be0ce-035d-48cb-867e-8e6de2714a8d"))
;; last empty iteration
nil (dequeue-job "644be0ce-035d-48cb-867e-8e6de2714a8d")
- :completed (:job/status (job "dfa7744f-8d61-4d37-885f-dbef2d4df13b")))))
-
-
+ :completed (:job/status (job "dfa7744f-8d61-4d37-885f-dbef2d4df13b"))))
+ (testing "Testing Derpinson dequeuing process"
+ (are [left right]
+ (= left right)
+ ;;first iteration
+ "6e90db58-7a6d-46e2-a02a-e33dc82e6e33" (dequeue-job "ff02347a-1b2d-440c-a2a1-7a593dba564e")
+ :processing (:job/status (job "6e90db58-7a6d-46e2-a02a-e33dc82e6e33"))
+ (job "6e90db58-7a6d-46e2-a02a-e33dc82e6e33") (:agent/job (agent "ff02347a-1b2d-440c-a2a1-7a593dba564e"))
+ ;;second iteration
+ "f90e149e-fa51-4212-a6bf-8cf81c78d28c" (dequeue-job "ff02347a-1b2d-440c-a2a1-7a593dba564e")
+ :completed (:job/status (job "6e90db58-7a6d-46e2-a02a-e33dc82e6e33"))
+ :processing (:job/status (job "f90e149e-fa51-4212-a6bf-8cf81c78d28c"))
+ (job "f90e149e-fa51-4212-a6bf-8cf81c78d28c") (:agent/job (agent "ff02347a-1b2d-440c-a2a1-7a593dba564e"))
+ ;;third iteration
+ "c471f9e0-fbbd-461d-adb0-7466c2d9830f" (dequeue-job "ff02347a-1b2d-440c-a2a1-7a593dba564e")
+ :completed (:job/status (job "f90e149e-fa51-4212-a6bf-8cf81c78d28c"))
+ :processing (:job/status (job "c471f9e0-fbbd-461d-adb0-7466c2d9830f"))
+ (job "c471f9e0-fbbd-461d-adb0-7466c2d9830f") (:agent/job (agent "ff02347a-1b2d-440c-a2a1-7a593dba564e"))
+ ;;last empty iteration
+ nil (dequeue-job "ff02347a-1b2d-440c-a2a1-7a593dba564e")
+ :completed (:job/status (job "c471f9e0-fbbd-461d-adb0-7466c2d9830f")))))