|
1 | | -defmodule QuantumStorageEtsTest do |
| 1 | +defmodule QuantumStoragePersistentEtsTest do |
2 | 2 | @moduledoc false |
3 | 3 |
|
4 | 4 | use ExUnit.Case |
5 | | - doctest QuantumStorageEts |
| 5 | + doctest QuantumStoragePersistentEts |
6 | 6 |
|
7 | 7 | defmodule Scheduler do |
8 | | - use Quantum, otp_app: :quantum_storage_ets |
| 8 | + use Quantum, otp_app: :quantum_storage_persistent_ets |
9 | 9 | end |
10 | 10 |
|
11 | 11 | setup %{test: test} do |
12 | | - storage = start_supervised!({QuantumStorageEts, name: Module.concat(__MODULE__, test)}) |
| 12 | + storage = |
| 13 | + start_supervised!({QuantumStoragePersistentEts, name: Module.concat(__MODULE__, test)}) |
13 | 14 |
|
14 | | - assert :ok = QuantumStorageEts.purge(storage, A) |
15 | | - assert :ok = QuantumStorageEts.purge(storage, B) |
| 15 | + assert :ok = QuantumStoragePersistentEts.purge(storage, A) |
| 16 | + assert :ok = QuantumStoragePersistentEts.purge(storage, B) |
16 | 17 |
|
17 | 18 | {:ok, storage: storage} |
18 | 19 | end |
19 | 20 |
|
20 | 21 | describe "purge/1" do |
21 | 22 | test "purges correct module", %{storage: storage} do |
22 | | - assert :ok = QuantumStorageEts.add_job(storage, A, Scheduler.new_job()) |
23 | | - assert :ok = QuantumStorageEts.purge(storage, A) |
24 | | - assert [] = QuantumStorageEts.jobs(storage, A) |
| 23 | + assert :ok = QuantumStoragePersistentEts.add_job(storage, A, Scheduler.new_job()) |
| 24 | + assert :ok = QuantumStoragePersistentEts.purge(storage, A) |
| 25 | + assert [] = QuantumStoragePersistentEts.jobs(storage, A) |
25 | 26 | end |
26 | 27 |
|
27 | 28 | test "does not purge incorrect module", %{storage: storage} do |
28 | 29 | job = Scheduler.new_job() |
29 | | - assert :ok = QuantumStorageEts.add_job(storage, A, job) |
30 | | - assert :ok = QuantumStorageEts.purge(storage, B) |
31 | | - assert [^job] = QuantumStorageEts.jobs(storage, A) |
| 30 | + assert :ok = QuantumStoragePersistentEts.add_job(storage, A, job) |
| 31 | + assert :ok = QuantumStoragePersistentEts.purge(storage, B) |
| 32 | + assert [^job] = QuantumStoragePersistentEts.jobs(storage, A) |
32 | 33 | end |
33 | 34 | end |
34 | 35 |
|
35 | 36 | describe "add_job/2" do |
36 | 37 | test "adds job", %{storage: storage} do |
37 | 38 | job = Scheduler.new_job() |
38 | | - assert :ok = QuantumStorageEts.add_job(storage, A, job) |
39 | | - assert [^job] = QuantumStorageEts.jobs(storage, A) |
| 39 | + assert :ok = QuantumStoragePersistentEts.add_job(storage, A, job) |
| 40 | + assert [^job] = QuantumStoragePersistentEts.jobs(storage, A) |
40 | 41 | end |
41 | 42 | end |
42 | 43 |
|
43 | 44 | describe "delete_job/2" do |
44 | 45 | test "deletes job", %{storage: storage} do |
45 | 46 | job = Scheduler.new_job() |
46 | | - assert :ok = QuantumStorageEts.add_job(storage, A, job) |
47 | | - assert :ok = QuantumStorageEts.delete_job(storage, A, job.name) |
48 | | - assert [] = QuantumStorageEts.jobs(storage, A) |
| 47 | + assert :ok = QuantumStoragePersistentEts.add_job(storage, A, job) |
| 48 | + assert :ok = QuantumStoragePersistentEts.delete_job(storage, A, job.name) |
| 49 | + assert [] = QuantumStoragePersistentEts.jobs(storage, A) |
49 | 50 | end |
50 | 51 |
|
51 | 52 | test "does not fail when deleting unknown job", %{storage: storage} do |
52 | 53 | job = Scheduler.new_job() |
53 | | - assert :ok = QuantumStorageEts.add_job(storage, A, job) |
| 54 | + assert :ok = QuantumStoragePersistentEts.add_job(storage, A, job) |
54 | 55 |
|
55 | | - assert :ok = QuantumStorageEts.delete_job(storage, A, make_ref()) |
| 56 | + assert :ok = QuantumStoragePersistentEts.delete_job(storage, A, make_ref()) |
56 | 57 | end |
57 | 58 |
|
58 | 59 | test "does not fail when deleting job from unknown scheduler", %{storage: storage} do |
59 | | - assert :ok = QuantumStorageEts.delete_job(storage, A, make_ref()) |
| 60 | + assert :ok = QuantumStoragePersistentEts.delete_job(storage, A, make_ref()) |
60 | 61 | end |
61 | 62 | end |
62 | 63 |
|
63 | 64 | describe "update_job_state/2" do |
64 | 65 | test "updates job", %{storage: storage} do |
65 | 66 | job = Scheduler.new_job() |
66 | | - assert :ok = QuantumStorageEts.add_job(storage, A, job) |
67 | | - assert :ok = QuantumStorageEts.update_job_state(storage, A, job.name, :inactive) |
68 | | - assert [%{state: :inactive}] = QuantumStorageEts.jobs(storage, A) |
| 67 | + assert :ok = QuantumStoragePersistentEts.add_job(storage, A, job) |
| 68 | + assert :ok = QuantumStoragePersistentEts.update_job_state(storage, A, job.name, :inactive) |
| 69 | + assert [%{state: :inactive}] = QuantumStoragePersistentEts.jobs(storage, A) |
69 | 70 | end |
70 | 71 |
|
71 | 72 | test "does not fail when updating unknown job", %{storage: storage} do |
72 | 73 | job = Scheduler.new_job() |
73 | | - assert :ok = QuantumStorageEts.add_job(storage, A, job) |
| 74 | + assert :ok = QuantumStoragePersistentEts.add_job(storage, A, job) |
74 | 75 |
|
75 | | - assert :ok = QuantumStorageEts.update_job_state(storage, A, make_ref(), :inactive) |
| 76 | + assert :ok = QuantumStoragePersistentEts.update_job_state(storage, A, make_ref(), :inactive) |
76 | 77 | end |
77 | 78 |
|
78 | 79 | test "does not fail when updating job from unknown scheduler", %{storage: storage} do |
79 | | - assert :ok = QuantumStorageEts.delete_job(storage, A, make_ref()) |
| 80 | + assert :ok = QuantumStoragePersistentEts.delete_job(storage, A, make_ref()) |
80 | 81 | end |
81 | 82 | end |
82 | 83 |
|
83 | 84 | describe "update_last_execution_date/2" do |
84 | 85 | test "sets time on scheduler", %{storage: storage} do |
85 | 86 | date = NaiveDateTime.utc_now() |
86 | | - assert :ok = QuantumStorageEts.update_last_execution_date(storage, A, date) |
87 | | - assert ^date = QuantumStorageEts.last_execution_date(storage, A) |
| 87 | + assert :ok = QuantumStoragePersistentEts.update_last_execution_date(storage, A, date) |
| 88 | + assert ^date = QuantumStoragePersistentEts.last_execution_date(storage, A) |
88 | 89 | end |
89 | 90 |
|
90 | 91 | test "sets time only on right scheduler", %{storage: storage} do |
91 | 92 | date = NaiveDateTime.utc_now() |
92 | | - assert :ok = QuantumStorageEts.update_last_execution_date(storage, A, date) |
93 | | - assert :unknown = QuantumStorageEts.last_execution_date(storage, B) |
| 93 | + assert :ok = QuantumStoragePersistentEts.update_last_execution_date(storage, A, date) |
| 94 | + assert :unknown = QuantumStoragePersistentEts.last_execution_date(storage, B) |
94 | 95 | end |
95 | 96 | end |
96 | 97 |
|
97 | 98 | describe "last_execution_date/1" do |
98 | 99 | test "gets time", %{storage: storage} do |
99 | 100 | date = NaiveDateTime.utc_now() |
100 | | - assert :ok = QuantumStorageEts.update_last_execution_date(storage, A, date) |
101 | | - assert ^date = QuantumStorageEts.last_execution_date(storage, A) |
| 101 | + assert :ok = QuantumStoragePersistentEts.update_last_execution_date(storage, A, date) |
| 102 | + assert ^date = QuantumStoragePersistentEts.last_execution_date(storage, A) |
102 | 103 | end |
103 | 104 |
|
104 | 105 | test "get unknown otherwise", %{storage: storage} do |
105 | | - assert :unknown = QuantumStorageEts.last_execution_date(storage, A) |
| 106 | + assert :unknown = QuantumStoragePersistentEts.last_execution_date(storage, A) |
106 | 107 | end |
107 | 108 | end |
108 | 109 | end |
0 commit comments