update function

src/main/scala/com/chain33/builder/Builder.scala

@@ -3,11 +3,18 @@ package com.chain33.builder
 import link.luyu.protocol.link._
 
 import java.util
+import com.chain33.driver
+import com.chain33.connection
 
+@LuyuPlugin("chain33")
 class Builder extends PluginBuilder {
 
-  override def newConnection(properties: util.Map[String, AnyRef]): Connection = ???
-
-  override def newDriver(connection: Connection, properties: util.Map[String, AnyRef]): Driver = ???
+  override def newConnection(properties: util.Map[String, AnyRef]): Connection = {
+    // TODO
+    val url = properties.get("chainUrl").toString
+    new connection.Connection(url)
+  }
 
+  override def newDriver(connection: Connection, properties: util.Map[String, AnyRef]): Driver =
+    driver.Driver(connection)
 }

src/main/scala/com/chain33/connection/Connection.scala

 package com.chain33.connection
 
 import link.luyu.protocol.link
+import cn.chain33.javasdk.client._
 
-class Connection extends link.Connection {
-  override def start(): Unit = ???
+import com.chain33.constant.Constant._
 
-  override def stop(): Unit = ???
+class Connection(val url: String) extends link.Connection {
+  private var client = new RpcClient(url)
+  client.setUrl(url)
+
+  override def start(): Unit = {}
+
+  override def stop(): Unit = {}
 
   override def asyncSend(
       path: String,
@@ -14,6 +20,17 @@ class Connection extends link.Connection {
       callback: link.Connection.Callback
   ): Unit = ???
 
-  override def subscribe(`type`: Int, data: Array[Byte], callback: link.Connection.Callback): Unit =
-    ???
+  override def subscribe(
+      `type`: Int,
+      data: Array[Byte],
+      callback: link.Connection.Callback
+  ): Unit = {
+    `type` match {
+      case Event.EVENT_NEW_BLOCK =>
+
+      case Event.EVENT_RESOURCES_CHANGED =>
+
+      case _ =>
+    }
+  }
 }

src/main/scala/com/chain33/driver/Driver.scala

 package com.chain33.driver
 
+import com.fasterxml.jackson.databind.ObjectMapper
 import link.luyu.protocol.link.{Driver => BaseDriver, _}
 import link.luyu.protocol.network.{Account, CallRequest, Events, Transaction}
 
-class Driver extends BaseDriver {
-  override def start(): Unit = ???
+case class Driver(val connection: Connection) extends BaseDriver {
+  override def start(): Unit = {}
 
-  override def stop(): Unit = ???
+  override def stop(): Unit = {}
 
-  override def getType: String = ???
+  override def getType: String = "chain33"
 
   override def listResources(callback: BaseDriver.ResourcesCallback): Unit = ???
 
-  override def registerEvents(events: Events): Unit = ???
+  override def registerEvents(events: Events): Unit = {}
 
   override def call(
       account: Account,
@@ -20,7 +21,7 @@ class Driver extends BaseDriver {
       callback: BaseDriver.CallResponseCallback
   ): Unit = ???
 
-  override def getSignatureType: String = ???
+  override def getSignatureType: String = "SM2_WITH_SM3"
 
   override def getBlockByHash(blockHash: String, callback: BaseDriver.BlockCallback): Unit = ???
 
@@ -37,3 +38,7 @@ class Driver extends BaseDriver {
       callback: BaseDriver.ReceiptCallback
   ): Unit = ???
 }
+
+object Driver {
+  private val objectMapper = new ObjectMapper
+}