summaryrefslogtreecommitdiff
path: root/test-runner/src/test
diff options
context:
space:
mode:
Diffstat (limited to 'test-runner/src/test')
-rw-r--r--test-runner/src/test/kotlin/org/terst/nav/data/model/GribFileTest.kt63
-rw-r--r--test-runner/src/test/kotlin/org/terst/nav/data/model/GribRegionTest.kt36
-rw-r--r--test-runner/src/test/kotlin/org/terst/nav/data/storage/GribFileManagerTest.kt100
3 files changed, 199 insertions, 0 deletions
diff --git a/test-runner/src/test/kotlin/org/terst/nav/data/model/GribFileTest.kt b/test-runner/src/test/kotlin/org/terst/nav/data/model/GribFileTest.kt
new file mode 100644
index 0000000..ef8bf7f
--- /dev/null
+++ b/test-runner/src/test/kotlin/org/terst/nav/data/model/GribFileTest.kt
@@ -0,0 +1,63 @@
+package org.terst.nav.data.model
+
+import org.junit.Assert.*
+import org.junit.Test
+import java.time.Instant
+
+class GribFileTest {
+
+ private val region = GribRegion(
+ name = "Test Region",
+ latMin = 40.0,
+ latMax = 60.0,
+ lonMin = -10.0,
+ lonMax = 10.0
+ )
+
+ private val modelRun = Instant.parse("2026-03-15T00:00:00Z")
+ private val downloadedAt = Instant.parse("2026-03-15T01:00:00Z")
+
+ private fun makeFile(forecastHours: Int = 48) = GribFile(
+ region = region,
+ modelRunTime = modelRun,
+ forecastHours = forecastHours,
+ downloadedAt = downloadedAt,
+ filePath = "/data/grib/test.grib2",
+ sizeBytes = 1_000_000L
+ )
+
+ @Test
+ fun `validUntil_equalsModelRunPlusForecastHours`() {
+ val file = makeFile(forecastHours = 48)
+ val expected = modelRun.plusSeconds(48L * 3600)
+ assertEquals(expected, file.validUntil())
+ }
+
+ @Test
+ fun `isStale_returnsFalse_whenNowBeforeValidUntil`() {
+ val file = makeFile(forecastHours = 48)
+ val now = modelRun.plusSeconds(24L * 3600) // 24h in, still 24h to go
+ assertFalse(file.isStale(now))
+ }
+
+ @Test
+ fun `isStale_returnsTrue_whenNowAfterValidUntil`() {
+ val file = makeFile(forecastHours = 48)
+ val now = modelRun.plusSeconds(49L * 3600) // 1h past expiry
+ assertTrue(file.isStale(now))
+ }
+
+ @Test
+ fun `isStale_returnsFalse_whenNowExactlyAtValidUntil`() {
+ val file = makeFile(forecastHours = 48)
+ val now = file.validUntil() // exactly at boundary — not yet stale
+ assertFalse(file.isStale(now))
+ }
+
+ @Test
+ fun `ageSeconds_computesElapsedTime`() {
+ val file = makeFile()
+ val now = downloadedAt.plusSeconds(3600) // 1h after download
+ assertEquals(3600L, file.ageSeconds(now))
+ }
+}
diff --git a/test-runner/src/test/kotlin/org/terst/nav/data/model/GribRegionTest.kt b/test-runner/src/test/kotlin/org/terst/nav/data/model/GribRegionTest.kt
new file mode 100644
index 0000000..a9a0334
--- /dev/null
+++ b/test-runner/src/test/kotlin/org/terst/nav/data/model/GribRegionTest.kt
@@ -0,0 +1,36 @@
+package org.terst.nav.data.model
+
+import org.junit.Assert.*
+import org.junit.Test
+
+class GribRegionTest {
+
+ private val region = GribRegion(
+ name = "Test Region",
+ latMin = 40.0,
+ latMax = 60.0,
+ lonMin = -10.0,
+ lonMax = 10.0
+ )
+
+ @Test
+ fun `contains_returnsTrue_whenPointInsideBounds`() {
+ assertTrue(region.contains(50.0, 0.0))
+ }
+
+ @Test
+ fun `contains_returnsFalse_whenLatOutOfRange`() {
+ assertFalse(region.contains(70.0, 0.0))
+ }
+
+ @Test
+ fun `contains_returnsFalse_whenLonOutOfRange`() {
+ assertFalse(region.contains(50.0, 20.0))
+ }
+
+ @Test
+ fun `areaDegrees_computesCorrectly`() {
+ val area = region.areaDegrees()
+ assertEquals(400.0, area, 0.0001)
+ }
+}
diff --git a/test-runner/src/test/kotlin/org/terst/nav/data/storage/GribFileManagerTest.kt b/test-runner/src/test/kotlin/org/terst/nav/data/storage/GribFileManagerTest.kt
new file mode 100644
index 0000000..95ca546
--- /dev/null
+++ b/test-runner/src/test/kotlin/org/terst/nav/data/storage/GribFileManagerTest.kt
@@ -0,0 +1,100 @@
+package org.terst.nav.data.storage
+
+import org.junit.Assert.*
+import org.junit.Test
+import org.terst.nav.data.model.GribFile
+import org.terst.nav.data.model.GribRegion
+import java.time.Instant
+
+private fun makeGribFile(
+ region: GribRegion,
+ downloadedAt: Instant,
+ sizeBytes: Long = 1024L
+): GribFile = GribFile(
+ region = region,
+ modelRunTime = downloadedAt.minusSeconds(6 * 3600),
+ forecastHours = 48,
+ downloadedAt = downloadedAt,
+ filePath = "/tmp/grib_${region.name}_${downloadedAt.epochSecond}.grb2",
+ sizeBytes = sizeBytes
+)
+
+class GribFileManagerTest {
+ private val manager = InMemoryGribFileManager()
+ private val regionA = GribRegion("Atlantic", 30.0, 60.0, -50.0, 0.0)
+ private val regionB = GribRegion("Pacific", 20.0, 50.0, -160.0, -100.0)
+ private val baseTime = Instant.parse("2026-01-01T12:00:00Z")
+
+ @Test
+ fun saveMetadata_addsFileToList() {
+ val file = makeGribFile(regionA, baseTime)
+ manager.saveMetadata(file)
+ assertEquals(listOf(file), manager.listFiles(regionA))
+ }
+
+ @Test
+ fun listFiles_returnsOnlyFilesForRegion() {
+ val fileA = makeGribFile(regionA, baseTime)
+ val fileB = makeGribFile(regionB, baseTime)
+ manager.saveMetadata(fileA)
+ manager.saveMetadata(fileB)
+ assertEquals(listOf(fileA), manager.listFiles(regionA))
+ assertEquals(listOf(fileB), manager.listFiles(regionB))
+ }
+
+ @Test
+ fun listFiles_returnsNewestFirst() {
+ val older = makeGribFile(regionA, baseTime)
+ val newer = makeGribFile(regionA, baseTime.plusSeconds(3600))
+ manager.saveMetadata(older)
+ manager.saveMetadata(newer)
+ assertEquals(listOf(newer, older), manager.listFiles(regionA))
+ }
+
+ @Test
+ fun latestFile_returnsNull_whenNoFiles() {
+ assertNull(manager.latestFile(regionA))
+ }
+
+ @Test
+ fun latestFile_returnsMostRecent() {
+ val older = makeGribFile(regionA, baseTime)
+ val newer = makeGribFile(regionA, baseTime.plusSeconds(3600))
+ manager.saveMetadata(older)
+ manager.saveMetadata(newer)
+ assertEquals(newer, manager.latestFile(regionA))
+ }
+
+ @Test
+ fun delete_removesFile_returnsTrue() {
+ val file = makeGribFile(regionA, baseTime)
+ manager.saveMetadata(file)
+ assertTrue(manager.delete(file))
+ assertTrue(manager.listFiles(regionA).isEmpty())
+ }
+
+ @Test
+ fun delete_returnsFalse_whenNotPresent() {
+ val file = makeGribFile(regionA, baseTime)
+ assertFalse(manager.delete(file))
+ }
+
+ @Test
+ fun purgeOlderThan_removesOldFiles_returnsCount() {
+ val old = makeGribFile(regionA, baseTime)
+ val recent = makeGribFile(regionA, baseTime.plusSeconds(7200))
+ manager.saveMetadata(old)
+ manager.saveMetadata(recent)
+ val cutoff = baseTime.plusSeconds(3600)
+ val deleted = manager.purgeOlderThan(cutoff)
+ assertEquals(1, deleted)
+ assertEquals(listOf(recent), manager.listFiles(regionA))
+ }
+
+ @Test
+ fun totalSizeBytes_sumsAllFiles() {
+ manager.saveMetadata(makeGribFile(regionA, baseTime, sizeBytes = 1000L))
+ manager.saveMetadata(makeGribFile(regionB, baseTime, sizeBytes = 2000L))
+ assertEquals(3000L, manager.totalSizeBytes())
+ }
+}