1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
| class WalletConnectBridgeRepositoryIntegrationTest {
/**
* Integration test that can be used with the wallet connect example dapp
*/
@Test
fun approveSession() {
val client = OkHttpClient.Builder().pingInterval(1000, TimeUnit.MILLISECONDS).build()
val moshi = Moshi.Builder().build()
val sessionDir = File("build/tmp/").apply { mkdirs() }
val sessionStore = FileWCSessionStore(File(sessionDir, "test_store.json").apply { createNewFile() }, moshi)
//wc:33...为扫码扫出来的结果
val config = Session.Config.fromWCUri("wc:79870fae-c04f-479e-8241-085e96603f2b@1?bridge=http%3A%2F%2F192.168.20.18%3A8000%2Fapi%2Fv1%2Fws&key=db8147b92d96a62cb1a2181dd3f9076cfd8eceaeba01feb8becfb965754e6f3e")
val session = WCSession(
config,
MoshiPayloadAdapter(moshi),
sessionStore,
OkHttpTransport.Builder(client, moshi),
Session.PeerMeta(name = "WC Unit Test")
)
session.addCallback(object : Session.Callback {
//相关的状态会回调，如建立连接，连接断掉
override fun onStatus(status: Session.Status) {
System.out.println("onStatus: $status")
}
//网页有请求，会接收到回调
override fun onMethodCall(call: Session.MethodCall) {
if (call is Session.MethodCall.SessionRequest) {
//Session.MethodCall.SessionRequest授权请求
//回复账户地址，代表授权此账户地址
session.approve(listOf("0x32C772DCCF8DCddd3e271B213a0027c22C98Fd1e"), 1L)
} else if (call is Session.MethodCall.SendTransaction) {
//Session.MethodCall.SessionRequest发送交易请求
// 可拿到call.to, call.from, call.data 等信息，后进行签名交易，并发送，然后回复处理成功
session.approveRequest(call.id, "ok")
} else if(call is Session.MethodCall.Custom) {
//自定义方法和参数
//根据call.params call.method进行处理后签名交易，并发送，然后回复处理成功
session.approveRequest(call.id, "ok")
}
}
})
//创建连接
session.init()
Thread.sleep(2000000)
}
@Test
fun approveSession1() {
val client = OkHttpClient.Builder().pingInterval(1000, TimeUnit.MILLISECONDS).build()
val moshi = Moshi.Builder().build()
val sessionDir = File("build/tmp/").apply { mkdirs() }
val sessionStore = FileWCSessionStore(File(sessionDir, "test_store.json").apply { createNewFile() }, moshi)
val key = ByteArray(32).also { Random().nextBytes(it) }.toNoPrefixHexString()
val topic = ByteArray(32).also { Random().nextBytes(it) }.toNoPrefixHexString()
println("topic: " + topic)
println("key : $key")
val config = Session.Config(topic, "http://192.168.20.18:5000", key)
val session = WCSession(
config,
MoshiPayloadAdapter(moshi),
sessionStore,
OkHttpTransport.Builder(client, moshi),
Session.PeerMeta(name = "WC Unit Test")
)
session.addCallback(object : Session.Callback {
override fun onStatus(status: Session.Status) {
System.out.println("onStatus: $status")
}
override fun onMethodCall(call: Session.MethodCall) {
System.out.println("onMethodCall: $call")
}
})
session.offer()
Thread.sleep(5000)
println("==========================")
val id = Random().nextLong()
println("id: "+ id)
val p = session.performMethodCall(Session.MethodCall.Custom(id, "tttt", listOf(1,2,"3",4,"5")), callback = { resp ->
println(resp)
})
println(p)
Thread.sleep(100000)
session.kill()
Thread.sleep(200000)
}
}
|