try to revive dead mqtt connections every 30 seconds

Author: lolcatjpg

build.gradle

@@ -24,8 +24,8 @@ dependencies {
     // implementation 'org.springframework.boot:spring-boot-starter-jdbc'
     implementation 'org.springframework.boot:spring-boot-starter-web'
     implementation 'org.springframework.boot:spring-boot-starter-actuator'
-    implementation 'org.springframework.boot:spring-boot-starter-data-jdbc'// management stuff
-    runtimeOnly 'org.postgresql:postgresql'
+//    implementation 'org.springframework.boot:spring-boot-starter-data-jdbc'// management stuff
+//    runtimeOnly 'org.postgresql:postgresql'
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
     testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
 

src/main/kotlin/gent/zeus/guitar/mqtt/MqttCallbackClient.kt

@@ -11,8 +11,7 @@ import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence
 
 class MqttCallbackClient : MqttCallback {
 
-    private val trackStore = InMemoryTrackStore()
-    private val dataProvider = DataProvider(trackStore)
+    private val dataProvider = DataProvider()
 
     private var mqttClient: MqttClient = MqttClient(
         "tcp://${MqttEnv.URL}:${MqttEnv.PORT}",
@@ -30,13 +29,22 @@ class MqttCallbackClient : MqttCallback {
         connectionTimeout = 10
     }
 
+    init {
+        Thread(
+            MqttDefibrillator(this),
+            "mqtt-defibrillator"
+        ).start()
+    }
+
     fun connect() {
         Logging.log.info("mqtt: connecting...")
         mqttClient.connect(mqttOptions)
         mqttClient.subscribe(MqttEnv.LISTEN_TOPIC)
         Logging.log.info("mqtt: connected to ${MqttEnv.hostString} with id ${MqttEnv.clientId}")
     }
 
+    val isConnected get() = mqttClient.isConnected
+
     override fun connectionLost(cause: Throwable?) {
         Logging.log.warn("mqtt: connection lost, reconnecting...", cause)
         connect()

src/main/kotlin/gent/zeus/guitar/mqtt/MqttDefibrillator.kt

@@ -0,0 +1,34 @@
+package gent.zeus.guitar.mqtt
+
+import gent.zeus.guitar.Logging
+import org.apache.juli.logging.Log
+import org.springframework.boot.ApplicationArguments
+import org.springframework.boot.ApplicationRunner
+import org.springframework.scheduling.config.Task
+import java.net.ConnectException
+
+
+const val SLEEP_TIME: Long = 1000 * 30 * 1
+
+/**
+ * checks every few minutes if mqtt connection is dead and revives it if necessary
+ */
+class MqttDefibrillator(val client: MqttCallbackClient) : Runnable {
+
+    override fun run() {
+        Logging.log.info("defibrillator: looking for dead mqtt connections...")
+
+        while (true) {
+            Thread.sleep(SLEEP_TIME)
+
+            if (!client.isConnected) {
+                Logging.log.info("defibrillator: dead mqtt connection found!! :O reviving...")
+                try {
+                    client.connect()
+                } catch (_: Exception) {
+                    Logging.log.info("defibrillator: could not connect, trying again in ${SLEEP_TIME / 1000} seconds")
+                }
+            }
+        }
+    }
+}

…lin/gent/zeus/guitar/storage/Database.kt …zeus/guitar/storage/Database.kt.disabledsrc/main/kotlin/gent/zeus/guitar/storage/Database.kt renamed to src/main/kotlin/gent/zeus/guitar/storage/Database.kt.disabled src/main/kotlin/gent/zeus/guitar/storage/Database.kt renamed to src/main/kotlin/gent/zeus/guitar/storage/Database.kt.disabled

@@ -1,4 +1,5 @@
-create table guitar(
-    spotifyId varchar,
-
+create table tracks(
+    spotifyId varchar primary key ,
+    name varchar,
+    album varchar,
 )