Features/android js develop

GaiaXAndroidClientToStudio/src/main/java/com/alibaba/gaiax/studio/GXClientToStudio.kt → GaiaXAndroidClientToStudio/src/main/java/com/alibaba/gaiax/studio/GXClientToStudioMultiType.kt

@@ -9,17 +9,32 @@ import java.io.UnsupportedEncodingException
 import java.net.URLDecoder
 import java.util.regex.Pattern
 
-class GXClientToStudio {
-
+/**
+ * @author: shisan.lms
+ * @date: 2023-02-02
+ * Description: Studio扫码三合一通道
+ */
+class GXClientToStudioMultiType {
  interface GXSocketToStudioListener {
  fun onAddData(templateId: String, templateData: JSONObject)
  fun onUpdate(templateId: String, templateData: JSONObject)
  }
 
+ interface GXSocketJSReceiveListener {
+ fun onCallSyncFromStudioWorker(socketId: Int, params: JSONObject)
+
+ fun onCallAsyncFromStudioWorker(socketId: Int, params: JSONObject)
+
+ fun onCallPromiseFromStudioWorker(socketId: Int, params: JSONObject)
+
+ fun onCallGetLibraryFromStudioWorker(socketId: Int, methodName: String)
+ }
+
  var applicationContext: Context? = null
 
  var gxSocketToStudioListener: GXSocketToStudioListener? = null
 
+
  private var socketHelper: GXSocket? = null
  private var currentAddress: String? = null
  private var currentTemplateId: String? = null
@@ -29,21 +44,26 @@ class GXClientToStudio {
  private val gxSocketListener: GXSocket.GXSocketListener = object : GXSocket.GXSocketListener {
 
  override fun onSocketConnected() {
- sendInitMsg(currentType)
+ sendInitMsg()
+
  }
 
  override fun onSocketDisconnected() {
  if (isWaitDisconnectMsgThenConnectGaiaStudio) {
+ //ip改变时的断开重连
  isWaitDisconnectMsgThenConnectGaiaStudio = false
  toConnectGaiaStudio()
  }
+ socketHelper?.devTools?.changeDevToolsConnectedStateView()
  }
 
  override fun onStudioConnected() {
+
  Log.d(TAG, "onStudioConnected() called currentTemplateId = $currentTemplateId")
  if (currentTemplateId != null) {
- socketHelper?.sendGetTemplateData103(currentTemplateId)
+ socketHelper?.sendGetTemplateData(currentTemplateId)
  }
+ socketHelper?.devTools?.changeDevToolsConnectedStateView()
  }
 
  override fun onStudioAddData(templateId: String, templateData: JSONObject) {
@@ -67,7 +87,7 @@ class GXClientToStudio {
  socketHelper = null
  }
 
- fun manualConnect(context: Context, params: JSONObject) {
+ fun manualConnect1(context: Context, params: JSONObject) {
  if (isConnectVpn(context)) {
  Log.e(TAG, "manualConnect: 请断开手机VPN后重试")
  return
@@ -90,6 +110,17 @@ class GXClientToStudio {
  tryToConnectGaiaStudio(targetUrl, templateId, type)
  }
 
+ fun manualConnect(context: Context, params: JSONObject) {
+ if (isConnectVpn(context)) {
+ Log.e(TAG, "manualConnect: 请断开手机VPN后重试")
+ return
+ }
+ Log.e(TAG, "onlyConnect() called with: params = [$params]")
+ val targetUrl = params.getString("URL")
+ val type = params.getString("TYPE")
+ tryToConnectGaiaStudio(targetUrl, null, type)
+ }
+
  fun getParams(url: String?): JSONObject? {
  if (url == null || TextUtils.isEmpty(url)) {
  return null
@@ -107,12 +138,12 @@ class GXClientToStudio {
  if (matcher.find()) {
  //局域网下IP
  val targetUrl = matcher.group()
- val templateId = parseTemplateId(finalUrl)
+// val templateId = parseTemplateId(finalUrl)
  val type = parseConnectType(finalUrl)
  val result = JSONObject()
  result["URL"] = targetUrl
  result["TYPE"] = type
- result["TEMPLATE_ID"] = templateId
+// result["TEMPLATE_ID"] = templateId
  Log.e(TAG, "getParams() called with: result = [$result]")
  return result
  } else {
@@ -121,16 +152,16 @@ class GXClientToStudio {
  return null
  }
 
- private fun parseConnectType(url: String): String {
- try {
- return url.split("&".toRegex()).toTypedArray()[2].split("=".toRegex()).toTypedArray()[1]
- } catch (e: Exception) {
- e.printStackTrace()
- }
- return ""
- }
+// private fun parseConnectType(url: String): String {
+// try {
+// return url.split("&".toRegex()).toTypedArray()[2].split("=".toRegex()).toTypedArray()[1]
+// } catch (e: Exception) {
+// e.printStackTrace()
+// }
+// return ""
+// }
 
- private fun parseTemplateId(url: String): String {
+ private fun parseConnectType(url: String): String {
  try {
  return url.split("&".toRegex()).toTypedArray()[1].split("=".toRegex()).toTypedArray()[1]
  } catch (e: Exception) {
@@ -152,10 +183,7 @@ class GXClientToStudio {
  }
 
  private fun tryToConnectGaiaStudio(address: String, templateId: String?, type: String) {
- Log.e(
- TAG,
- "tryToConnectGaiaStudio() called with: address = [$address], templateId = [$templateId], type = [$type]"
- )
+ Log.e(TAG, "tryToConnectGaiaStudio() called with: address = [$address], templateId = [$templateId], type = [$type]")
  val tmpAddress = currentAddress
  currentType = type
  currentAddress = address
@@ -175,28 +203,74 @@ class GXClientToStudio {
  socketHelper?.gxSocketListener = gxSocketListener
  socketHelper?.connectToServer(currentAddress)
  } else {
- sendInitMsg(currentType)
+ sendInitMsg()
  }
  }
 
- private fun sendInitMsg(type: String) {
- if (socketHelper?.isManualPush(type) == true) {
- socketHelper?.sendMsgWithManualPushInit()
- } else if (socketHelper?.isFastPreview(type) == true) {
- socketHelper?.sendMsgWithFastPreviewInit()
- }
+ private fun sendInitMsg() {
+ socketHelper?.sendMsgWithMultiTypeInit()
  }
 
  fun sendMessage(data: JSONObject) {
  socketHelper?.sendMessage(data)
  }
 
+
+ fun sendMsgForObtainMode() {
+ Log.d(GXSocket.TAG, "sendMsgForObtainMode() called ")
+ val data = JSONObject()
+ data["jsonrpc"] = "2.0"
+ data["method"] = "mode/get"
+ data["id"] = 302
+ socketHelper?.sendMessage(data)
+ }
+
+ fun sendMsgForDisconnect() {
+ val data = JSONObject()
+ data["jsonrpc"] = "2.0"
+ data["method"] = "close"
+ socketHelper?.sendMessage(data)
+ }
+
+ fun sendMsgForGetTemplateData(templateId: String?) {
+ socketHelper?.sendGetTemplateData(templateId)
+ }
+
+ fun sendMsgForJSLog(logLevel: String, logContent: String) {
+ val data = JSONObject()
+ data["jsonrpc"] = "2.0"
+ data["method"] = "js/console"
+ val params = JSONObject()
+ params["level"] = logLevel
+ params["data"] = logContent
+ data["params"] = params
+ socketHelper?.sendMessage(data)
+ }
+
+ fun setDevTools(dev: IDevTools) {
+ socketHelper?.devTools = dev
+ }
+
+ fun setJSReceiverListener(listener: GXSocketJSReceiveListener) {
+ socketHelper?.gxSocketJSReceiveListener = listener
+ }
+
+ fun isGaiaStudioConnected(): Boolean? {
+ return socketHelper?.gxSocketIsConnected
+ }
+
  companion object {
- const val TAG = "[GaiaX][GXStudio]"
+ const val TAG = "[GXStudioMulti]"
+
+ const val PREVIEW_AUTO = "auto"
+ const val PREVIEW_MANUAL = "manual"
+ const val PREVIEW_NONE = "none"
+
+ const val JS_DEFAULT = "default"
+ const val JS_BREAKPOINT = "breakpoint"
 
  val instance by lazy {
- GXClientToStudio()
+ GXClientToStudioMultiType()
  }
  }
-
 }