|
2 | 2 | (:require [monglorious.core :refer :all] |
3 | 3 | [monger.core :as mg] |
4 | 4 | [monger.collection :as mc] |
5 | | - [monglorious.test-helpers :refer :all]) |
| 5 | + [monglorious.test-helpers :refer :all] |
| 6 | + [clj-time.core :as t] |
| 7 | + [clj-time.format :as f] |
| 8 | + [clj-time.coerce :as c]) |
6 | 9 | (:use midje.sweet) |
7 | | - (:import (com.mongodb MongoQueryException) |
8 | | - (java.util Date) |
9 | | - (java.time Instant) |
10 | | - (java.time.temporal ChronoUnit))) |
| 10 | + (:import (com.mongodb MongoQueryException))) |
11 | 11 |
|
12 | 12 | ;; Test run-command-transform() |
13 | 13 | (against-background |
|
259 | 259 | [(before :contents |
260 | 260 | (let [conn (mg/connect) |
261 | 261 | db (mg/get-db conn "testdb") |
262 | | - now (Instant/now)] |
| 262 | + now (t/now)] |
263 | 263 | (mc/remove db "timeDocs") |
264 | | - (mc/insert-batch db "timeDocs" [{:time (Date/from (.plus now 2 ChronoUnit/HOURS)) :metric "queriesRan" :value 0} |
265 | | - {:time (Date/from (.plus now 1 ChronoUnit/HOURS)) :metric "queriesRan" :value 1} |
266 | | - {:time (Date/from now) :metric "queriesRan" :value 2} |
267 | | - {:time (Date/from (.minus now 1 ChronoUnit/HOURS)) :metric "queriesRan" :value 3} |
268 | | - {:time (Date/from (.minus now 2 ChronoUnit/HOURS)) :metric "queriesRan" :value 4} |
269 | | - {:time (Date/from (.minus now 3 ChronoUnit/HOURS)) :metric "queriesRan" :value 5} |
270 | | - {:time (Date/from (.minus now 4 ChronoUnit/HOURS)) :metric "queriesRan" :value 6} |
271 | | - {:time (Date/from (.minus now 5 ChronoUnit/HOURS)) :metric "queriesRan" :value 7} |
272 | | - {:time (Date/from (Instant/parse "2017-02-15T00:00:00.000Z")) :metric "queriesRan" :value 8} |
273 | | - {:time (Date/from (Instant/parse "2017-02-14T20:45:01.000Z")) :metric "queriesRan" :value 8}]))) |
| 264 | + (mc/insert-batch db "timeDocs" [{:time (c/to-date (t/plus now (t/hours 2))) :metric "queriesRan" :value 0} |
| 265 | + {:time (c/to-date (t/plus now (t/hours 1))) :metric "queriesRan" :value 1} |
| 266 | + {:time (c/to-date now) :metric "queriesRan" :value 2} |
| 267 | + {:time (c/to-date (t/minus now (t/hours 1))) :metric "queriesRan" :value 3} |
| 268 | + {:time (c/to-date (t/minus now (t/hours 2))) :metric "queriesRan" :value 4} |
| 269 | + {:time (c/to-date (t/minus now (t/hours 3))) :metric "queriesRan" :value 5} |
| 270 | + {:time (c/to-date (t/minus now (t/hours 4))) :metric "queriesRan" :value 6} |
| 271 | + {:time (c/to-date (t/minus now (t/hours 5))) :metric "queriesRan" :value 7} |
| 272 | + {:time (c/to-date (f/parse "2017-02-15T00:00:00.000Z")) :metric "queriesRan" :value 8} |
| 273 | + {:time (c/to-date (f/parse "2017-02-14T20:45:01.000Z")) :metric "queriesRan" :value 8}]))) |
274 | 274 | (after :contents |
275 | 275 | (let [conn (mg/connect)] |
276 | 276 | (mg/drop-db conn "testdb")))] |
|
283 | 283 | (execute {} "testdb" "db.timeDocs.find({ time: { $gt: new ISODate() } }).count()") => 2 |
284 | 284 | (execute {} "testdb" "db.timeDocs.find({ time: { $lt: new ISODate() } }).count()") => 8 |
285 | 285 | (execute {} "testdb" "db.timeDocs.find({ time: { $lt: new ISODate('2017-02-15T00:00:00.000Z') } }).count()") => 1 |
286 | | - (execute {} "testdb" "db.timeDocs.find({ time: { $lte: new ISODate('2017-02-15T00:00:00.000Z') } }).count()") => 2)) |
| 286 | + (execute {} "testdb" "db.timeDocs.find({ time: { $lte: new ISODate('2017-02-15T00:00:00.000Z') } }).count()") => 2 |
| 287 | + (execute {} "testdb" "db.timeDocs.find({ time: { $lt: new ISODate('2017-02-17') } }).count()") => 2)) |
0 commit comments