Save running animations to files to read in on restart

Author: maxnz

src/main/java/animatedledstrip/server/AnimatedLEDStripServer.kt

@@ -34,6 +34,7 @@ import animatedledstrip.utils.delayBlocking
 import org.apache.commons.cli.DefaultParser
 import org.tinylog.Logger
 import org.tinylog.configuration.Configuration
+import java.io.File
 import java.io.FileInputStream
 import java.io.FileNotFoundException
 import java.util.*
@@ -126,6 +127,10 @@ class AnimatedLEDStripServer<T : AnimatedLEDStrip>(
     /* Start and stop methods */
 
     fun start(): AnimatedLEDStripServer<T> {
+        val dir = File(".animations")
+        if (!dir.isDirectory)
+            dir.mkdirs()
+
         running = true
         Logger.debug { "Ports: $ports" }
         ports.forEach {

src/main/java/animatedledstrip/server/AnimationHandler.kt

@@ -31,6 +31,9 @@ import kotlinx.coroutines.GlobalScope
 import kotlinx.coroutines.launch
 import kotlinx.coroutines.newFixedThreadPoolContext
 import org.tinylog.Logger
+import java.io.File
+import java.io.FileInputStream
+import java.io.ObjectInputStream
 import java.lang.Math.random
 
 
@@ -52,6 +55,21 @@ internal class AnimationHandler(private val leds: AnimatedLEDStrip, threadCount:
     val continuousAnimations = mutableMapOf<String, ContinuousRunAnimation>()
 
 
+    init {
+        GlobalScope.launch {
+            File(".animations/").walk().forEach {
+                if (!it.isDirectory && it.name.endsWith(".anim")) try {
+                    ObjectInputStream(FileInputStream(it)).apply {
+                        val obj = readObject() as AnimationData
+                        addAnimation(obj)
+                        close()
+                    }
+                } catch (e: ClassCastException) {
+                }
+            }
+        }
+    }
+
     /**
      * Adds a new animation.
      *

src/main/java/animatedledstrip/server/ContinuousRunAnimation.kt

@@ -26,10 +26,13 @@ package animatedledstrip.server
 import animatedledstrip.animationutils.Animation
 import animatedledstrip.animationutils.AnimationData
 import animatedledstrip.leds.AnimatedLEDStrip
-import kotlinx.coroutines.GlobalScope
-import kotlinx.coroutines.Job
-import kotlinx.coroutines.launch
+import kotlinx.coroutines.*
 import org.tinylog.Logger
+import java.io.File
+import java.io.FileOutputStream
+import java.io.ObjectOutputStream
+import java.nio.file.Files
+import java.nio.file.Paths
 
 /**
  * Class for running an animation that repeats until stopped.
@@ -52,6 +55,8 @@ internal class ContinuousRunAnimation(
 
     private var job: Job? = null
 
+    private val fileName = "$id.anim"
+
 
     init {
         sendStartAnimation()                 // Send animation to GUI
@@ -63,6 +68,14 @@ internal class ContinuousRunAnimation(
      */
     fun runAnimation() {
         job = GlobalScope.launch(handler.animationThreadPool) {
+            launch {
+                withContext(Dispatchers.IO) {
+                    ObjectOutputStream(FileOutputStream(".animations/$fileName")).apply {
+                        writeObject(params)
+                        close()
+                    }
+                }
+            }
             Logger.trace { "params: $params" }
             while (continueAnimation) leds.run(params)
             sendEndAnimation()
@@ -78,6 +91,8 @@ internal class ContinuousRunAnimation(
         Logger.debug { "Animation $id ending" }
         if (continueAnimation) continueAnimation = false
         else job?.cancel()
+        if (File(".animations/$id").exists())
+            Files.delete(Paths.get(".animations/$fileName"))
     }
 
 

src/main/java/animatedledstrip/server/SocketConnections.kt

@@ -77,7 +77,6 @@ object SocketConnections {
         var connected = false
             private set
         private var socOut: ObjectOutputStream? = null
-        var textBased = false
 
         /**
          * Open the connection