Graham McIntire
fd976b0cd5
- Add jump_credo_checks ~> 0.4 with all 20 checks enabled - Fix all standard Credo issues: 139 @spec (113 done, 26 remain), 4 refactoring, 3 alias usage, 9 System.cmd env, 5 unsafe_to_atom, 2 max line length, 9 assert_receive timeout - Fix 170+ jump_credo_checks warnings: - 117 TopLevelAliasImportRequire: move nested alias/import to module top - 32 UseObanProWorker: switch to Oban.Pro.Worker - 4 DoctestIExExamples: add doctests / create test file - ~20 WeakAssertion: strengthen type-check assertions - Various ConditionalAssertion, AssertReceiveTimeout fixes - Exclude vendor/ from Credo analysis - Remaining: 175 warnings (mostly opinionated WeakAssertion, AvoidSocketAssignsInTest), 26 @spec annotations
67 lines
1.7 KiB
Elixir
67 lines
1.7 KiB
Elixir
defmodule Mix.Tasks.ResetEnrichmentTest do
|
|
use Microwaveprop.DataCase, async: true
|
|
|
|
import Ecto.Query
|
|
|
|
alias Microwaveprop.Radio.Contact
|
|
alias Mix.Tasks.ResetEnrichment
|
|
|
|
defp create_queued_qso do
|
|
default = %{
|
|
station1: "W5XD",
|
|
station2: "K5TR",
|
|
qso_timestamp: ~U[2026-03-28 18:00:00Z],
|
|
mode: "CW",
|
|
band: Decimal.new("1296"),
|
|
grid1: "EM12",
|
|
grid2: "EM00",
|
|
pos1: %{"lat" => 32.9, "lon" => -97.0},
|
|
pos2: %{"lat" => 30.3, "lon" => -97.7},
|
|
distance_km: Decimal.new("295")
|
|
}
|
|
|
|
{:ok, contact} =
|
|
%Contact{}
|
|
|> Contact.changeset(default)
|
|
|> Repo.insert()
|
|
|
|
# Set all queued flags to true (not in changeset cast)
|
|
Contact
|
|
|> where([q], q.id == ^contact.id)
|
|
|> Repo.update_all(
|
|
set: [weather_status: "queued", hrrr_status: "queued", iemre_status: "queued", terrain_status: "queued"]
|
|
)
|
|
|
|
Repo.get!(Contact, contact.id)
|
|
end
|
|
|
|
describe "run/1" do
|
|
test "resets weather, hrrr, and iemre status to pending" do
|
|
contact = create_queued_qso()
|
|
|
|
assert contact.weather_status == :queued
|
|
assert contact.hrrr_status == :queued
|
|
assert contact.iemre_status == :queued
|
|
|
|
ResetEnrichment.run([])
|
|
|
|
updated = Repo.get!(Contact, contact.id)
|
|
assert updated.weather_status == :pending
|
|
assert updated.hrrr_status == :pending
|
|
assert updated.iemre_status == :pending
|
|
end
|
|
|
|
test "does not reset terrain status" do
|
|
contact = create_queued_qso()
|
|
|
|
ResetEnrichment.run([])
|
|
|
|
updated = Repo.get!(Contact, contact.id)
|
|
assert updated.terrain_status == :queued
|
|
end
|
|
|
|
test "handles empty database" do
|
|
assert :ok = ResetEnrichment.run([])
|
|
end
|
|
end
|
|
end
|