summaryrefslogtreecommitdiff
path: root/test-runner/src/main
diff options
context:
space:
mode:
Diffstat (limited to 'test-runner/src/main')
-rw-r--r--test-runner/src/main/kotlin/org/terst/nav/ais/CpaAlert.kt23
-rw-r--r--test-runner/src/main/kotlin/org/terst/nav/ais/CpaCalculator.kt1
-rw-r--r--test-runner/src/main/kotlin/org/terst/nav/settings/HardwareSource.kt23
-rw-r--r--test-runner/src/main/kotlin/org/terst/nav/track/TrackRepository.kt28
-rw-r--r--test-runner/src/main/kotlin/org/terst/nav/track/TrackStats.kt15
-rw-r--r--test-runner/src/main/kotlin/org/terst/nav/vessel/CrewMember.kt15
-rw-r--r--test-runner/src/main/kotlin/org/terst/nav/vessel/Vessel.kt22
-rw-r--r--test-runner/src/main/kotlin/org/terst/nav/vessel/VesselRepository.kt55
8 files changed, 181 insertions, 1 deletions
diff --git a/test-runner/src/main/kotlin/org/terst/nav/ais/CpaAlert.kt b/test-runner/src/main/kotlin/org/terst/nav/ais/CpaAlert.kt
new file mode 100644
index 0000000..1d635c0
--- /dev/null
+++ b/test-runner/src/main/kotlin/org/terst/nav/ais/CpaAlert.kt
@@ -0,0 +1,23 @@
+package org.terst.nav.ais
+
+enum class CpaSeverity { CAUTION, WARNING, DANGER }
+
+data class CpaAlert(
+ val mmsi: Int,
+ val vesselName: String,
+ val cpaNm: Double,
+ val tcpaMin: Double,
+ val severity: CpaSeverity
+)
+
+object CpaThresholds {
+ const val DANGER_CPA_NM = 0.5
+ const val WARNING_CPA_NM = 1.0
+ const val CAUTION_CPA_NM = 2.0
+ const val MAX_TCPA_MIN = 30.0 // ignore contacts closing in > 30 min
+}
+
+fun CpaAlert.label(): String {
+ val name = if (vesselName.isNotBlank()) vesselName else "MMSI $mmsi"
+ return "%-12s CPA %.1fnm T+%.0fmin".format(name.take(12), cpaNm, tcpaMin)
+}
diff --git a/test-runner/src/main/kotlin/org/terst/nav/ais/CpaCalculator.kt b/test-runner/src/main/kotlin/org/terst/nav/ais/CpaCalculator.kt
index 7e98451..298af59 100644
--- a/test-runner/src/main/kotlin/org/terst/nav/ais/CpaCalculator.kt
+++ b/test-runner/src/main/kotlin/org/terst/nav/ais/CpaCalculator.kt
@@ -2,7 +2,6 @@ package org.terst.nav.ais
import kotlin.math.cos
import kotlin.math.sqrt
-import kotlin.math.PI
object CpaCalculator {
fun compute(
diff --git a/test-runner/src/main/kotlin/org/terst/nav/settings/HardwareSource.kt b/test-runner/src/main/kotlin/org/terst/nav/settings/HardwareSource.kt
new file mode 100644
index 0000000..b44cb66
--- /dev/null
+++ b/test-runner/src/main/kotlin/org/terst/nav/settings/HardwareSource.kt
@@ -0,0 +1,23 @@
+package org.terst.nav.settings
+
+enum class HardwareSource(val prefKey: String, val label: String) {
+ AIS_RECEIVER("hw_ais_receiver", "AIS Receiver"),
+ NMEA_INSTRUMENTS("hw_nmea_instruments", "NMEA Instruments")
+}
+
+/** Minimal in-memory implementation for JVM tests. */
+class InMemoryFeatureFlags {
+ private val state = mutableMapOf<HardwareSource, Boolean>()
+
+ fun isEnabled(source: HardwareSource): Boolean = state[source] ?: false
+
+ fun setEnabled(source: HardwareSource, enabled: Boolean) {
+ state[source] = enabled
+ }
+
+ fun toggle(source: HardwareSource): Boolean {
+ val next = !isEnabled(source)
+ setEnabled(source, next)
+ return next
+ }
+}
diff --git a/test-runner/src/main/kotlin/org/terst/nav/track/TrackRepository.kt b/test-runner/src/main/kotlin/org/terst/nav/track/TrackRepository.kt
index 85dd2dd..98d0bf3 100644
--- a/test-runner/src/main/kotlin/org/terst/nav/track/TrackRepository.kt
+++ b/test-runner/src/main/kotlin/org/terst/nav/track/TrackRepository.kt
@@ -1,5 +1,10 @@
package org.terst.nav.track
+import kotlin.math.atan2
+import kotlin.math.cos
+import kotlin.math.sin
+import kotlin.math.sqrt
+
class TrackRepository {
var isRecording: Boolean = false
@@ -29,4 +34,27 @@ class TrackRepository {
fun getPoints(): List<TrackPoint> = activePoints.toList()
fun getPastTracks(): List<List<TrackPoint>> = pastTracks.toList()
+
+ fun computeStats(): TrackStats? {
+ if (activePoints.size < 2) return null
+ var distNm = 0.0
+ for (i in 1 until activePoints.size) {
+ distNm += haversineNm(activePoints[i - 1].lat, activePoints[i - 1].lon, activePoints[i].lat, activePoints[i].lon)
+ }
+ val durationMs = activePoints.last().timestampMs - activePoints.first().timestampMs
+ val avgSog = if (durationMs > 0) activePoints.map { it.sogKnots }.average() else 0.0
+ return TrackStats(distNm, durationMs, avgSog)
+ }
+
+ companion object {
+ fun haversineNm(lat1: Double, lon1: Double, lat2: Double, lon2: Double): Double {
+ val r = 3440.065
+ val dLat = Math.toRadians(lat2 - lat1)
+ val dLon = Math.toRadians(lon2 - lon1)
+ val a = sin(dLat / 2) * sin(dLat / 2) +
+ cos(Math.toRadians(lat1)) * cos(Math.toRadians(lat2)) *
+ sin(dLon / 2) * sin(dLon / 2)
+ return r * 2 * atan2(sqrt(a), sqrt(1 - a))
+ }
+ }
}
diff --git a/test-runner/src/main/kotlin/org/terst/nav/track/TrackStats.kt b/test-runner/src/main/kotlin/org/terst/nav/track/TrackStats.kt
new file mode 100644
index 0000000..39153c6
--- /dev/null
+++ b/test-runner/src/main/kotlin/org/terst/nav/track/TrackStats.kt
@@ -0,0 +1,15 @@
+package org.terst.nav.track
+
+data class TrackStats(
+ val distanceNm: Double,
+ val durationMs: Long,
+ val avgSogKnots: Double
+) {
+ val durationFormatted: String get() {
+ val totalSec = durationMs / 1000
+ val h = totalSec / 3600
+ val m = (totalSec % 3600) / 60
+ val s = totalSec % 60
+ return if (h > 0) "%d:%02d:%02d".format(h, m, s) else "%d:%02d".format(m, s)
+ }
+}
diff --git a/test-runner/src/main/kotlin/org/terst/nav/vessel/CrewMember.kt b/test-runner/src/main/kotlin/org/terst/nav/vessel/CrewMember.kt
new file mode 100644
index 0000000..0df8cb9
--- /dev/null
+++ b/test-runner/src/main/kotlin/org/terst/nav/vessel/CrewMember.kt
@@ -0,0 +1,15 @@
+package org.terst.nav.vessel
+
+data class CrewMember(
+ val id: String,
+ val name: String,
+ val role: CrewRole = CrewRole.CREW,
+ val emergencyContact: String = "",
+ val emergencyPhone: String = "",
+ val certifications: List<String> = emptyList(),
+ val notes: String = ""
+)
+
+enum class CrewRole {
+ SKIPPER, FIRST_MATE, WATCH_CAPTAIN, CREW, GUEST
+}
diff --git a/test-runner/src/main/kotlin/org/terst/nav/vessel/Vessel.kt b/test-runner/src/main/kotlin/org/terst/nav/vessel/Vessel.kt
new file mode 100644
index 0000000..b7c0eaf
--- /dev/null
+++ b/test-runner/src/main/kotlin/org/terst/nav/vessel/Vessel.kt
@@ -0,0 +1,22 @@
+package org.terst.nav.vessel
+
+data class Vessel(
+ val id: String,
+ val name: String,
+ val mmsi: String = "",
+ val callsign: String = "",
+ val flag: String = "",
+ val homePort: String = "",
+ val hullType: HullType = HullType.MONOHULL,
+ val loaMeters: Double = 0.0,
+ val beamMeters: Double = 0.0,
+ val draftMeters: Double = 0.0,
+ val displacementKg: Double = 0.0,
+ val engineHp: Int = 0,
+ val notes: String = "",
+ val isOwnVessel: Boolean = false
+)
+
+enum class HullType {
+ MONOHULL, CATAMARAN, TRIMARAN, POWERBOAT, OTHER
+}
diff --git a/test-runner/src/main/kotlin/org/terst/nav/vessel/VesselRepository.kt b/test-runner/src/main/kotlin/org/terst/nav/vessel/VesselRepository.kt
new file mode 100644
index 0000000..fe4c44d
--- /dev/null
+++ b/test-runner/src/main/kotlin/org/terst/nav/vessel/VesselRepository.kt
@@ -0,0 +1,55 @@
+package org.terst.nav.vessel
+
+import java.util.UUID
+
+class VesselRepository {
+
+ private val vessels = mutableListOf<Vessel>()
+ private val crew = mutableListOf<CrewMember>()
+
+ fun addVessel(vessel: Vessel): Vessel {
+ val v = if (vessel.id.isBlank()) vessel.copy(id = UUID.randomUUID().toString()) else vessel
+ vessels.removeAll { it.id == v.id }
+ vessels.add(v)
+ return v
+ }
+
+ fun updateVessel(vessel: Vessel): Boolean {
+ val idx = vessels.indexOfFirst { it.id == vessel.id }
+ if (idx < 0) return false
+ vessels[idx] = vessel
+ return true
+ }
+
+ fun removeVessel(id: String): Boolean = vessels.removeAll { it.id == id }
+
+ fun getVessel(id: String): Vessel? = vessels.find { it.id == id }
+
+ fun getVessels(): List<Vessel> = vessels.toList()
+
+ fun getOwnVessel(): Vessel? = vessels.find { it.isOwnVessel }
+
+ fun addCrewMember(member: CrewMember): CrewMember {
+ val m = if (member.id.isBlank()) member.copy(id = UUID.randomUUID().toString()) else member
+ crew.removeAll { it.id == m.id }
+ crew.add(m)
+ return m
+ }
+
+ fun updateCrewMember(member: CrewMember): Boolean {
+ val idx = crew.indexOfFirst { it.id == member.id }
+ if (idx < 0) return false
+ crew[idx] = member
+ return true
+ }
+
+ fun removeCrewMember(id: String): Boolean = crew.removeAll { it.id == id }
+
+ fun getCrewMember(id: String): CrewMember? = crew.find { it.id == id }
+
+ fun getCrew(): List<CrewMember> = crew.toList()
+
+ fun getCrewByRole(role: CrewRole): List<CrewMember> = crew.filter { it.role == role }
+
+ fun getSkipper(): CrewMember? = crew.find { it.role == CrewRole.SKIPPER }
+}