✨ feat(client): 增加Websocket支持

Author: 892768447

build.gradle.kts

@@ -14,6 +14,10 @@ repositories {
     mavenCentral()
 }
 
+dependencies {
+    implementation("org.java-websocket:Java-WebSocket:1.5.6")
+}
+
 // Configure Gradle IntelliJ Plugin
 // Read more: https://plugins.jetbrains.com/docs/intellij/tools-gradle-intellij-plugin.html
 intellij {

src/main/kotlin/irony/pycharm/qsseditor/QSSAction.kt

@@ -10,6 +10,7 @@ import com.intellij.openapi.project.Project
 class QSSAction : AnAction(QSSBundle.message("action.apply.title", "Apply Style")) {
 
     override fun update(e: AnActionEvent) {
+        // 默认菜单不可用，需要判断当前文件类型
         e.presentation.isEnabledAndVisible = false
         val project: Project = e.project ?: return
         val editor: Editor = e.getData(CommonDataKeys.EDITOR) ?: return

src/main/kotlin/irony/pycharm/qsseditor/QSSClient.kt

@@ -0,0 +1,46 @@
+package irony.pycharm.qsseditor
+
+import com.intellij.openapi.application.ApplicationManager
+import org.java_websocket.client.WebSocketClient
+import org.java_websocket.handshake.ServerHandshake
+import java.net.URI
+
+class QSSClient(serverUri: URI?) : WebSocketClient(serverUri) {
+
+    override fun onOpen(handshakedata: ServerHandshake?) {
+        println("onOpen");
+    }
+
+    override fun onMessage(message: String?) {
+        println("onMessage: $message")
+    }
+
+    override fun onClose(code: Int, reason: String?, remote: Boolean) {
+        println("onClose: code=$code, remote=$remote, reason=$reason")
+    }
+
+    override fun onError(ex: Exception?) {
+        System.err.println("onError: $ex")
+    }
+
+    companion object {
+        private var client : QSSClient? = null
+
+        fun connect(host: String, port: Int) {
+            disconnect()
+            if (client == null) {
+                client = QSSClient(URI("ws://$host:$port"))
+                client!!.connect()
+            }
+        }
+
+        fun reconnect() {
+            client?.reconnect()
+        }
+
+        fun disconnect() {
+            client?.close()
+            client = null
+        }
+    }
+}

src/main/kotlin/irony/pycharm/qsseditor/QSSConfigurable.kt

@@ -16,13 +16,13 @@ class QSSConfigurable : BoundSearchableConfigurable(
     override fun createPanel() : DialogPanel {
         return panel {
             row(QSSBundle.message("setting.host.title", "Host")) {
-                textField().bindText(QSSService.instance::host)
+                textField().bindText(QSSState.instance::host)
             }
             row(QSSBundle.message("setting.port.title", "Port")) {
-                textField().bindIntText(QSSService.instance::port)
+                intTextField(IntRange(1000, 65535)).bindIntText(QSSState.instance::port)
             }
             row(QSSBundle.message("setting.auto.title","Auto Apply")) {
-                checkBox("").bindSelected(QSSService.instance::auto)
+                checkBox("").bindSelected(QSSState.instance::auto)
             }
         }
     }

src/main/kotlin/irony/pycharm/qsseditor/QSSService.kt

@@ -0,0 +1,12 @@
+package irony.pycharm.qsseditor
+
+import com.intellij.openapi.project.Project
+import com.intellij.openapi.startup.StartupActivity
+
+internal class QSSStartup : StartupActivity {
+
+    override fun runActivity(project: Project) {
+        // 启动客户端连接
+        QSSClient.connect(QSSState.instance.host, QSSState.instance.port)
+    }
+}

src/main/kotlin/irony/pycharm/qsseditor/QSSStartup.kt

@@ -0,0 +1,40 @@
+package irony.pycharm.qsseditor
+
+import com.intellij.openapi.application.ApplicationManager
+import com.intellij.openapi.components.*
+import com.intellij.util.xmlb.XmlSerializerUtil
+
+class ConfigState : BaseState() {
+    var auto: Boolean by property(true)
+    var host: String? by string("localhost")
+    var port: Int by property(61052)
+}
+
+@State(name = "irony.pycharm.qsseditor.QSSState", storages = [Storage("QSSEditorSetting.xml", roamingType = RoamingType.DEFAULT)])
+internal class QSSState() : SimplePersistentStateComponent<ConfigState>(ConfigState()) {
+
+    var auto: Boolean
+        get() = state.auto
+        set(value) {
+            state.auto = value
+        }
+
+    var host: String
+        get() = state.host ?: "localhost"
+        set(value) {
+            state.host = value
+        }
+
+    var port: Int
+        get() = state.port
+        set(value) {
+            state.port = value
+        }
+
+    companion object {
+        val instance: QSSState
+            get() = ApplicationManager.getApplication().getService(
+                QSSState::class.java
+            )
+    }
+}

src/main/kotlin/irony/pycharm/qsseditor/QSSState.kt

@@ -25,14 +25,15 @@
     <!-- Extension points defined by the plugin.
          Read more: https://plugins.jetbrains.com/docs/intellij/plugin-extension-points.html -->
     <extensions defaultExtensionNs="com.intellij">
+        <backgroundPostStartupActivity implementation="irony.pycharm.qsseditor.QSSStartup"/>
         <applicationService
-                serviceImplementation="irony.pycharm.qsseditor.QSSService"/>
+                serviceImplementation="irony.pycharm.qsseditor.QSSState"/>
         <applicationConfigurable
             parentId="language"
             groupWeight="-500"
             instance="irony.pycharm.qsseditor.QSSConfigurable"
             id="irony.pycharm.qsseditor.QSSConfigurable"
-            displayName="QSS"/>
+            displayName="QSS Editor"/>
     </extensions>
     <actions>
         <action id="ApplyAction" class="irony.pycharm.qsseditor.QSSAction">