File size: 3,731 Bytes
c9c49ab | 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 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 | defmodule Plausible.Site.TrackerScriptIdCacheTest do
use Plausible.DataCase, async: false
@moduletag :ee_only
on_ee do
alias Plausible.Site.TrackerScriptConfiguration
alias Plausible.Site.TrackerScriptIdCache
describe "public cache interface" do
test "cache caches tracker scripts by id", %{test: test} do
{:ok, _} =
Supervisor.start_link(
[
{TrackerScriptIdCache,
[
cache_name: test,
child_id: :test_cache_tracker_script,
ets_options: [read_concurrency: true]
]}
],
strategy: :one_for_one,
name: :"cache_supervisor_#{test}"
)
site = new_site(domain: "site1.example.com")
config = create_config(site)
:ok = TrackerScriptIdCache.refresh_all(cache_name: test)
{:ok, _} = Plausible.Repo.delete(config)
assert TrackerScriptIdCache.size(test) == 1
assert TrackerScriptIdCache.get(config.id, force?: true, cache_name: test) == true
refute TrackerScriptIdCache.get("nonexistent", cache_name: test, force?: true)
end
test "refresh all and put works", %{test: test} do
{:ok, _} = start_test_cache(test)
site1 = new_site()
site2 = new_site()
site3 = new_site()
configs = [create_config(site1), create_config(site2)]
cache_opts = [cache_name: test, force?: true]
for config <- configs do
assert TrackerScriptIdCache.get(config.id, cache_opts) == nil
end
assert :ok = TrackerScriptIdCache.refresh_all(cache_opts)
for config <- configs do
result = TrackerScriptIdCache.get(config.id, cache_opts)
assert result == true
end
new_config = create_config(site3)
TrackerScriptIdCache.broadcast_put(
new_config.id,
true,
cache_opts
)
# wait for broadcast put to take effect
assert eventually(fn ->
result = TrackerScriptIdCache.get(new_config.id, cache_opts)
{result == true, result}
end)
for config <- [new_config | configs] do
result = TrackerScriptIdCache.get(config.id, cache_opts)
assert result == true
end
end
test "refreshes only recently added configurations", %{test: test} do
{:ok, _} = start_test_cache(test)
site1 = new_site()
site2 = new_site()
past_date = ~N[2021-01-01 00:00:00]
old_config = create_config(site1, inserted_at: past_date, updated_at: past_date)
new_config = create_config(site2)
cache_opts = [cache_name: test, force?: true]
assert TrackerScriptIdCache.get(old_config.id, cache_opts) == nil
assert TrackerScriptIdCache.get(new_config.id, cache_opts) == nil
assert :ok = TrackerScriptIdCache.refresh_updated_recently(cache_opts)
refute TrackerScriptIdCache.get(old_config.id, cache_opts)
assert TrackerScriptIdCache.get(new_config.id, cache_opts)
end
end
defp start_test_cache(cache_name) do
%{start: {m, f, a}} =
TrackerScriptIdCache.child_spec(cache_name: cache_name, ets_options: [:bag])
apply(m, f, a)
end
defp create_config(site, opts \\ []) do
config = %TrackerScriptConfiguration{
site_id: site.id,
installation_type: :manual,
hash_based_routing: true,
outbound_links: true,
file_downloads: true,
form_submissions: true
}
config
|> Ecto.Changeset.change(opts)
|> Repo.insert!()
|> Repo.preload(:site)
end
end
end
|