plausible/analytics
1
1
Fork 0
mirror of https://github.com/plausible/analytics.git synced 2024-11-22 10:43:38 +03:00
Code Issues Packages Projects Releases Wiki Activity

Update tests

Browse Source
This commit is contained in:
Karl-Aksel Puulmann 2024-11-20 10:06:37 +02:00
parent 8bcc2caa18
commit 19987ca4c0
2 changed files with 30 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
extra/lib/plausible/stats/sampling_cache.ex
View File

@ -50,7 +50,6 @@ defmodule Plausible.Stats.SamplingCache do
end
def thirty_days_ago() do
Date.utc_today()
|> Date.add(-30)
Date.shift(Date.utc_today(), day: -30)
end
end

31
test/plausible/stats/sampling_cache_test.exs
View File

@ -12,43 +12,68 @@ defmodule Plausible.Stats.SamplingCacheTest do
Plausible.IngestRepo.insert_all(Plausible.Ingestion.Counters.Record, [
%{
site_id: 2,
site_id: 1,
domain: "1.com",
value: 11_000_000,
event_timebucket: add(now, -1, :day),
metric: "buffered"
},
%{
site_id: 2,
domain: "2.com",
value: 11_000_000,
event_timebucket: add(now, -1, :day),
metric: "buffered"
},
%{
site_id: 2,
domain: "2.com",
value: 11_000_000,
event_timebucket: add(now, -5, :day),
metric: "buffered"
},
%{
site_id: 2,
domain: "2.com",
value: 11_000_000,
event_timebucket: add(now, -35, :day),
metric: "buffered"
},
%{
site_id: 3,
domain: "3.com",
value: 44_000_000,
event_timebucket: add(now, -35, :day),
metric: "buffered"
},
%{
site_id: 4,
domain: "4.com",
value: 11_000_000,
event_timebucket: add(now, -35, :day),
metric: "buffered"
}
])
{:ok, _} = start_test_cache(test)
start_test_cache(test)
assert SamplingCache.get(1, force?: true, cache_name: test) == nil
assert SamplingCache.get(2, force?: true, cache_name: test) == 22_000_000
assert SamplingCache.get(3, force?: true, cache_name: test) == nil
assert SamplingCache.get(4, force?: true, cache_name: test) == nil
Plausible.IngestRepo.insert_all(Plausible.Ingestion.Counters.Record, [
%{
site_id: 1,
value: 11_000_000,
event_timebucket: add(now, -1, :day),
metric: "buffered"
}
])
:ok = SamplingCache.refresh_all(cache_name: test)
assert SamplingCache.get(1, force?: true, cache_name: test) == 22_000_000
assert SamplingCache.get(2, force?: true, cache_name: test) == 22_000_000
end
end
@ -59,6 +84,8 @@ defmodule Plausible.Stats.SamplingCacheTest do
defp start_test_cache(cache_name) do
%{start: {m, f, a}} = SamplingCache.child_spec(cache_name: cache_name)
apply(m, f, a)
:ok = SamplingCache.refresh_all(cache_name: cache_name)
end
end
end