86 lines
2.5 KiB
Elixir
86 lines
2.5 KiB
Elixir
defmodule BDS.CliSyncTest do
|
|
use ExUnit.Case, async: false
|
|
|
|
import Ecto.Query
|
|
|
|
alias BDS.CliSync
|
|
alias BDS.CliSync.Watcher
|
|
alias BDS.Repo
|
|
|
|
setup do
|
|
:ok = Ecto.Adapters.SQL.Sandbox.checkout(BDS.Repo)
|
|
Repo.delete_all(BDS.CliSync.Notification)
|
|
:ok
|
|
end
|
|
|
|
test "cli mutations are written to db_notifications, processed on file change, and marked seen" do
|
|
assert {:ok, notification} = CliSync.cli_mutation_performed("post", "post-1", :updated)
|
|
assert notification.from_cli == true
|
|
assert notification.seen_at == nil
|
|
|
|
assert {:ok, processed} = CliSync.db_file_change_detected()
|
|
assert [%{entity_type: "post", entity_id: "post-1", action: :updated}] = processed
|
|
|
|
seen_notification = Repo.get!(BDS.CliSync.Notification, notification.id)
|
|
assert is_integer(seen_notification.seen_at)
|
|
end
|
|
|
|
test "watcher broadcasts entity change events after database mutations are detected" do
|
|
Ecto.Adapters.SQL.Sandbox.mode(BDS.Repo, {:shared, self()})
|
|
Phoenix.PubSub.subscribe(BDS.PubSub, Watcher.topic())
|
|
|
|
watcher =
|
|
start_supervised!({Watcher, poll_interval_ms: 60_000, debounce_ms: 0})
|
|
|
|
Ecto.Adapters.SQL.Sandbox.allow(BDS.Repo, self(), watcher)
|
|
|
|
assert {:ok, notification} = CliSync.cli_mutation_performed("post", "post-1", :updated)
|
|
|
|
:ok = Watcher.poll_now(watcher)
|
|
|
|
assert_receive {:entity_changed, %{entity: "post", entity_id: "post-1", action: :updated}},
|
|
500
|
|
|
|
seen_notification = Repo.get!(BDS.CliSync.Notification, notification.id)
|
|
assert is_integer(seen_notification.seen_at)
|
|
end
|
|
|
|
test "processed notifications are pruned after one hour and unprocessed notifications after one day" do
|
|
now = BDS.Persistence.now_ms()
|
|
|
|
Repo.insert!(%BDS.CliSync.Notification{
|
|
entity_type: "post",
|
|
entity_id: "processed-old",
|
|
action: :updated,
|
|
from_cli: true,
|
|
seen_at: now - 10,
|
|
created_at: now - 3_600_001
|
|
})
|
|
|
|
Repo.insert!(%BDS.CliSync.Notification{
|
|
entity_type: "media",
|
|
entity_id: "unprocessed-old",
|
|
action: :deleted,
|
|
from_cli: true,
|
|
seen_at: nil,
|
|
created_at: now - 86_400_001
|
|
})
|
|
|
|
Repo.insert!(%BDS.CliSync.Notification{
|
|
entity_type: "script",
|
|
entity_id: "fresh",
|
|
action: :created,
|
|
from_cli: true,
|
|
seen_at: nil,
|
|
created_at: now
|
|
})
|
|
|
|
assert {:ok, %{processed: 1, unprocessed: 1}} = CliSync.prune_notifications(now)
|
|
|
|
remaining_ids =
|
|
Repo.all(from notification in BDS.CliSync.Notification, select: notification.entity_id)
|
|
|
|
assert remaining_ids == ["fresh"]
|
|
end
|
|
end
|