blob: 00636312e4eed72c3921e0834ec67d5e687e1c94 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
|
(ns com.github.ivarref.yoltq.migrate-test
(:require [clojure.test :refer [deftest is]]
[com.github.ivarref.yoltq.ext-sys :as ext]
[com.github.ivarref.yoltq.migrate :as m]
[com.github.ivarref.yoltq.impl :as impl]
[com.github.ivarref.yoltq.test-utils :as tu]
[com.github.ivarref.yoltq.utils :as u]
[datomic.api :as d]))
(deftest to-v2-migration
(with-bindings {#'ext/*squuid-atom* (atom 0)}
(let [conn (tu/empty-conn)]
@(d/transact conn impl/schema)
@(d/transact conn [{:com.github.ivarref.yoltq/id (u/squuid)
:com.github.ivarref.yoltq/queue-name :dummy
:com.github.ivarref.yoltq/status u/status-processing
:com.github.ivarref.yoltq/init-time 1
:com.github.ivarref.yoltq/processing-time 2}])
@(d/transact conn [{:com.github.ivarref.yoltq/id (u/squuid)
:com.github.ivarref.yoltq/queue-name :dummy
:com.github.ivarref.yoltq/status u/status-init
:com.github.ivarref.yoltq/init-time 3}])
(is (= [[[:db/cas
[:com.github.ivarref.yoltq/id
#uuid "00000000-0000-0000-0000-000000000001"]
:com.github.ivarref.yoltq/version
nil
"2"]
[:db/cas
[:com.github.ivarref.yoltq/id
#uuid "00000000-0000-0000-0000-000000000001"]
:com.github.ivarref.yoltq/init-time
1
1000]
[:db/cas
[:com.github.ivarref.yoltq/id
#uuid "00000000-0000-0000-0000-000000000001"]
:com.github.ivarref.yoltq/processing-time
2
1000]]
[[:db/cas
[:com.github.ivarref.yoltq/id
#uuid "00000000-0000-0000-0000-000000000002"]
:com.github.ivarref.yoltq/version
nil
"2"]
[:db/cas
[:com.github.ivarref.yoltq/id
#uuid "00000000-0000-0000-0000-000000000002"]
:com.github.ivarref.yoltq/init-time
3
1000]]]
(m/migrate! {:conn conn
:now-ms 1000
:loop? true})))
(is (= []
(m/migrate! {:conn conn
:now-ms 1000
:loop? true}))))))
(deftest to-v2-migration-real-time
(with-bindings {#'ext/*squuid-atom* (atom 0)}
(let [conn (tu/empty-conn)
id (u/squuid)]
@(d/transact conn impl/schema)
@(d/transact conn [{:com.github.ivarref.yoltq/id id
:com.github.ivarref.yoltq/queue-name :dummy
:com.github.ivarref.yoltq/status u/status-init
:com.github.ivarref.yoltq/init-time 1}])
(Thread/sleep 100)
@(d/transact conn [{:com.github.ivarref.yoltq/id id
:com.github.ivarref.yoltq/init-time 2}])
(let [tx-times (->> (d/q '[:find [?txinst ...]
:in $ ?e
:where
[?e :com.github.ivarref.yoltq/init-time _ ?tx true]
[?tx :db/txInstant ?txinst]]
(d/history (d/db conn))
[:com.github.ivarref.yoltq/id id])
(sort)
(vec))]
(is (= 2 (count tx-times)))
(m/migrate! {:conn conn})
(is (= (.getTime (last tx-times))
(d/q '[:find ?init-time .
:in $ ?e
:where
[?e :com.github.ivarref.yoltq/init-time ?init-time]]
(d/db conn)
[:com.github.ivarref.yoltq/id id])))))))
|
