feat: Initialize Channel storage logic

3 files changed, 127 insertions, 3 deletions

diff --git a/platform-paper/src/main/kotlin/dev/m1sk9/lunaticChat/paper/LunaticChat.kt b/platform-paper/src/main/kotlin/dev/m1sk9/lunaticChat/paper/LunaticChat.kt
index 6525b55..dd6d618 100644
--- a/platform-paper/src/main/kotlin/dev/m1sk9/lunaticChat/paper/LunaticChat.kt
+++ b/platform-paper/src/main/kotlin/dev/m1sk9/lunaticChat/paper/LunaticChat.kt
@@ -113,7 +113,7 @@ class LunaticChat :
         )
 
         // Conditionally register /reply command if quick replies are enabled
-        if (configuration.features.quickRepliesEnabled.enabled) {
+        if (configuration.features.quickReplies.enabled) {
             commandRegistry.registerAll(
                 ReplyCommand(this, services.directMessageHandler, services.languageManager),
             )
diff --git a/platform-paper/src/main/kotlin/dev/m1sk9/lunaticChat/paper/ServiceInitializer.kt b/platform-paper/src/main/kotlin/dev/m1sk9/lunaticChat/paper/ServiceInitializer.kt
index e39f04f..96dea1d 100644
--- a/platform-paper/src/main/kotlin/dev/m1sk9/lunaticChat/paper/ServiceInitializer.kt
+++ b/platform-paper/src/main/kotlin/dev/m1sk9/lunaticChat/paper/ServiceInitializer.kt
@@ -1,6 +1,7 @@
 package dev.m1sk9.lunaticChat.paper
 
 import dev.m1sk9.lunaticChat.engine.converter.GoogleIMEClient
+import dev.m1sk9.lunaticChat.paper.channel.storage.ChannelStorage
 import dev.m1sk9.lunaticChat.paper.command.handler.DirectMessageHandler
 import dev.m1sk9.lunaticChat.paper.config.LunaticChatConfiguration
 import dev.m1sk9.lunaticChat.paper.converter.ConversionCache
@@ -34,7 +35,8 @@ class ServiceInitializer(
      * 1. LanguageManager (required by all features)
      * 2. PlayerSettingsManager (required for DM notifications)
      * 3. Japanese Conversion (optional, config-dependent)
-     * 4. DirectMessageHandler (depends on settings manager and romaji converter)
+     * 4. ChannelStorage
+     * 5. DirectMessageHandler (depends on settings manager and romaji converter)
      *
      * @return ServiceContainer with all initialized services
      */
@@ -60,7 +62,12 @@ class ServiceInitializer(
                 null
             }
 
-        // 4. Initialize handlers
+        // 4. Initialize channel storage
+        if (configuration.features.channelChat.enabled) {
+            initializeChannelStorage()
+        }
+
+        // 5. Initialize handlers
         val directMessageHandler =
             DirectMessageHandler(
                 settingsManager = playerSettingsManager,
@@ -136,6 +143,24 @@ class ServiceInitializer(
     }
 
     /**
+     * Initializes channel storage by loading existing data or creating new storage.
+     */
+    private fun initializeChannelStorage() {
+        val channelsFile = plugin.dataFolder.resolve("channels.json").toPath()
+        val storage =
+            ChannelStorage(
+                channelsFile = channelsFile,
+                plugin = plugin,
+                logger = logger,
+            )
+
+        val channelData = storage.loadFromDisk()
+        storage.saveToDisk(channelData)
+
+        logger.info("Channels storage loaded successfully.")
+    }
+
+    /**
      * Schedules periodic tasks such as cache saving.
      */
     fun schedulePeriodicTasks() {
diff --git a/platform-paper/src/main/kotlin/dev/m1sk9/lunaticChat/paper/channel/storage/ChannelStorage.kt b/platform-paper/src/main/kotlin/dev/m1sk9/lunaticChat/paper/channel/storage/ChannelStorage.kt
new file mode 100644
index 0000000..7b85703
--- /dev/null
+++ b/platform-paper/src/main/kotlin/dev/m1sk9/lunaticChat/paper/channel/storage/ChannelStorage.kt
@@ -0,0 +1,99 @@
+package dev.m1sk9.lunaticChat.paper.channel.storage
+
+import dev.m1sk9.lunaticChat.engine.channel.modal.ChannelData
+import dev.m1sk9.lunaticChat.engine.exception.ChannelStorageLoadException
+import dev.m1sk9.lunaticChat.engine.exception.ChannelStorageSaveException
+import kotlinx.serialization.json.Json
+import org.bukkit.plugin.java.JavaPlugin
+import java.nio.file.Path
+import java.util.logging.Logger
+import kotlin.io.path.bufferedReader
+import kotlin.io.path.exists
+import kotlin.io.path.writeText
+
+/**
+ * Manages the storage of channel data on disk.
+ *
+ * @property channelsFile The path to the file where channel data is stored.
+ * @property plugin The JavaPlugin instance for accessing plugin resources.
+ * @property logger The logger for logging messages.
+ */
+class ChannelStorage(
+    private val channelsFile: Path,
+    private val plugin: JavaPlugin,
+    private val logger: Logger,
+) {
+    private val json =
+        Json {
+            prettyPrint = true
+            ignoreUnknownKeys = true
+        }
+
+    /**
+     * Loads channel data from disk.
+     *
+     * @return The loaded ChannelData.
+     * @throws ChannelStorageLoadException if there is an error loading the data.
+     */
+    fun loadFromDisk(): ChannelData {
+        if (!channelsFile.exists()) {
+            logger.warning("Channel storage not found, will create a new one.")
+            return ChannelData()
+        }
+
+        return try {
+            val jsonContent =
+                channelsFile.bufferedReader().use {
+                    it.readText()
+                }
+            json.decodeFromString(ChannelData.serializer(), jsonContent).also {
+                logger.info("Successfully loaded channels from ${channelsFile.fileName}.")
+            }
+        } catch (e: Exception) {
+            throw ChannelStorageLoadException(
+                "Failed to load channels from ${channelsFile.fileName}: ${e.message}",
+                e,
+            )
+        }
+    }
+
+    /**
+     * Saves channel data to disk.
+     *
+     * @param data The ChannelData to save.
+     * @throws ChannelStorageSaveException if there is an error saving the data.
+     */
+    fun saveToDisk(data: ChannelData) {
+        try {
+            val jsonContent = json.encodeToString(ChannelData.serializer(), data)
+            channelsFile.writeText(jsonContent).also {
+                logger.fine("Successfully saved channels from ${channelsFile.fileName}.")
+            }
+        } catch (e: Exception) {
+            throw ChannelStorageSaveException(
+                "Failed to save channels to ${channelsFile.fileName}: ${e.message}",
+                e,
+            )
+        }
+    }
+
+    /**
+     * Queues an asynchronous save of channel data to disk.
+     *
+     * @param data The ChannelData to save.
+     * @throws ChannelStorageSaveException if there is an error saving the data.
+     */
+    fun queueAsyncSave(data: ChannelData) {
+        plugin.server.scheduler.runTaskAsynchronously(
+            plugin,
+            Runnable {
+                try {
+                    saveToDisk(data)
+                } catch (e: ChannelStorageSaveException) {
+                    logger.severe("Error saving channel data asynchronously: ${e.message}")
+                    e.printStackTrace()
+                }
+            },
+        )
+    }
+}