添加socket的初始化成功判断

Author: mdddj

src/main/kotlin/shop/itbug/fluttercheckversionx/form/socket/LeftActionTools.kt

@@ -165,4 +165,5 @@ class ViewGetQueryParamsAction(private val request: Request?, private val projec
 
 fun Any.mylogger() : org.slf4j.Logger {
    return LoggerFactory.getLogger(this::class.java)
-}
+}
+

src/main/kotlin/shop/itbug/fluttercheckversionx/form/socket/SocketRequestForm.kt

@@ -262,6 +262,13 @@ class SocketRequestForm(val project: Project) : ListSelectionListener { /// 表
             ) {
                 RewardDialog(project).show()
             }
+            val socketIsInited = service.socketIsInit;
+            if(socketIsInited.not()){
+                appendLine("")
+                appendText("Socket(端口9999)没有正常启动,请检查网络连接或者本地代理,点我重连",SimpleTextAttributes(SimpleTextAttributes.STYLE_CLICKABLE,JBUI.CurrentTheme.Link.Foreground.ENABLED)){
+                    service.initSocketService(project)
+                }
+            }
         }
     }
 

src/main/kotlin/shop/itbug/fluttercheckversionx/linemark/PluginDartIconLineMark.kt

@@ -34,14 +34,12 @@ class PluginDartIconLineMark : LineMarkerProvider {
 
 ///处理点击
 class PluginDartIconLineMarkNavHandler(val element: YAMLKeyValueImpl) : GutterIconNavigationHandler<PsiElement> {
-
     override fun navigate(e: MouseEvent?, elt: PsiElement?) {
         if (e != null && e.clickCount == 1) {
             JBPopupFactory.getInstance().createListPopup(PluginDartIconActioinMenuList(element = element))
                 .show(RelativePoint(e.locationOnScreen))
         }
     }
-
 }
 
 data class PluginDartIconActionMenuItem(val title: String, val type: String, val icon: Icon)
@@ -58,13 +56,12 @@ class PluginDartIconActioinMenuList(val element: YAMLKeyValueImpl) : BaseListPop
     }
 
 
-
     override fun getTextFor(value: PluginDartIconActionMenuItem?): String {
         return value?.title ?: "未知选项"
     }
 
     override fun onChosen(selectedValue: PluginDartIconActionMenuItem?, finalChoice: Boolean): PopupStep<*>? {
-        when(selectedValue?.type){
+        when (selectedValue?.type) {
             menus[0].type -> {
                 BrowserUtil.browse("$PUB_URL${element.keyText}")
             }

src/main/kotlin/shop/itbug/fluttercheckversionx/socket/service/AppService.kt

@@ -3,6 +3,7 @@ package shop.itbug.fluttercheckversionx.socket.service
 import cn.hutool.core.lang.Console
 import cn.hutool.http.HttpUtil
 import com.google.gson.Gson
+import com.intellij.notification.NotificationType
 import com.intellij.openapi.application.ApplicationManager
 import com.intellij.openapi.project.Project
 import kotlinx.coroutines.DelicateCoroutinesApi
@@ -14,6 +15,7 @@ import org.smartboot.socket.StateMachineEnum
 import org.smartboot.socket.transport.AioQuickServer
 import org.smartboot.socket.transport.AioSession
 import shop.itbug.fluttercheckversionx.form.socket.Request
+import shop.itbug.fluttercheckversionx.form.socket.mylogger
 import shop.itbug.fluttercheckversionx.model.example.ExampleResult
 import shop.itbug.fluttercheckversionx.model.example.ResourceModel
 import shop.itbug.fluttercheckversionx.services.SocketMessageBus
@@ -25,11 +27,16 @@ class AppService {
 
 
     lateinit var project: Project
+
     /**
      * 全局的socket监听服务
      */
     private var server: AioQuickServer? = null
 
+
+    /**
+     * 组件示例
+     */
     var examples = emptyList<ResourceModel>()
 
     /**
@@ -41,6 +48,12 @@ class AppService {
     private var flutterProjects = mutableMapOf<String, List<ProjectSocketService.SocketResponseModel>>()
 
 
+    /**
+     * socket服务是否已经正常运行
+     */
+     var socketIsInit = false
+
+
 //    init {
 //        setTestData()
 //    }
@@ -64,18 +77,26 @@ class AppService {
                     ) {
                         super.stateEvent(session, stateMachineEnum, throwable)
                         println("状态机:${stateMachineEnum}")
-                        when(stateMachineEnum){
+                        when (stateMachineEnum) {
                             StateMachineEnum.NEW_SESSION -> {
                                 newSessionHandle(session)
                             }
+
                             else -> {}
                         }
                     }
                 })
                 server!!.setReadBufferSize(10485760) // 10m
                 try {
                     server!!.start()
-                } catch (_: Exception) {
+                    socketIsInit = true
+                } catch (e: Exception) {
+                    socketIsInit = false
+                    mylogger().error("启动socket服务失败:${e.localizedMessage}")
+                    MyNotifactionUtil.socketNotif(
+                        message = "启动dio监听模块失败,异常:${e.localizedMessage}", project = project,
+                        NotificationType.ERROR
+                    )
                 }
             }
         }
@@ -85,7 +106,10 @@ class AppService {
      * 当有新连接进来的时候处理函数
      */
     private fun newSessionHandle(session: AioSession?) {
-        MyNotifactionUtil.socketNotif("梁典典: 检测到APP连接成功,现在可以在底部工具栏监听dio请求了", project = project)
+        MyNotifactionUtil.socketNotif(
+            "梁典典: 检测到APP连接成功,现在可以在底部工具栏监听dio请求了,${session?.sessionID}",
+            project = project
+        )
     }
 
     @OptIn(DelicateCoroutinesApi::class)
@@ -160,10 +184,11 @@ class AppService {
     }
 
 
-    fun setTestData(){
+    fun setTestData() {
         flutterProjects = mutableMapOf(
             Pair(
-                "test",ProjectSocketService.genList()
-        ))
+                "test", ProjectSocketService.genList()
+            )
+        )
     }
 }