Version 1.0.0 PoC

Author: rmeissner

.gitignore

@@ -1,2 +1,60 @@
+# Built application files
+*.apk
+*.ap_
+
+# Files for the ART/Dalvik VM
+*.dex
+
+# Java class files
+*.class
+
+# Generated files
+bin/
+gen/
+out/
+
+# Gradle files
+.gradle/
 build/
-out/
+
+# Local configuration file (sdk path, etc)
+local.properties
+
+# Fabric plugin
+fabric.properties
+
+# Proguard folder generated by Eclipse
+proguard/
+
+# Log Files
+*.log
+
+# Android Studio Navigation editor temp files
+.navigation/
+
+# Android Studio captures folder
+captures/
+
+*.iml
+.idea
+
+# Keystore files
+*.jks
+
+# External native build folder generated in Android Studio 2.2 and later
+.externalNativeBuild
+
+# Google Services (e.g. APIs or Firebase)
+google-services.json
+
+# Coverage reports
+jacoco.exec
+
+# Freeline
+freeline.py
+freeline/
+freeline_project_description.json
+
+secrets.tar
+project_keys
+.DS_STORE

build.gradle

@@ -1,13 +1,17 @@
 buildscript {
     ext {
-        KOTLIN_VERSION = "1.3.21"
+        versions = [
+                kotlin: "1.3.21",
+                moshi : '1.8.0',
+                okhttp: '3.11.0',
+        ]
     }
 
     repositories {
         mavenCentral()
     }
 
     dependencies {
-        classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:${KOTLIN_VERSION}"
+        classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$versions.kotlin"
     }
 }

lib/build.gradle

@@ -6,19 +6,18 @@ repositories {
 }
 
 dependencies {
-    implementation "org.jetbrains.kotlin:kotlin-stdlib:${KOTLIN_VERSION}"
-
-    implementation "com.github.walleth.kethereum:erc55:0.70"
-    implementation "com.github.walleth.kethereum:erc1328:0.70"
+    implementation "org.jetbrains.kotlin:kotlin-stdlib:$versions.kotlin"
 
     implementation "com.github.walleth:khex:0.6"
 
     implementation 'org.bouncycastle:bcprov-jdk15on:1.60'
 
     implementation 'com.squareup.moshi:moshi:1.8.0'
+    // TODO: it would be better to use the generated adapter by moshi
+    // but for that we should move the implementations in different modules
+    //kapt "com.squareup.moshi:moshi-kotlin-codegen:$versions.moshi"
 
-    def okhttpVersion = '3.12.0'
-    implementation 'com.squareup.okhttp3:okhttp:' + okhttpVersion
+    implementation "com.squareup.okhttp3:okhttp:$versions.okhttp"
 
     implementation group: 'org.slf4j', name: 'slf4j-log4j12', version: "1.7.25"
 
@@ -28,9 +27,9 @@ dependencies {
     testRuntime 'org.junit.jupiter:junit-jupiter-engine:5.3.2'
 
 
-    testImplementation 'com.squareup.okhttp3:mockwebserver:' + okhttpVersion
+    testImplementation "com.squareup.okhttp3:mockwebserver:$versions.okhttp"
 }
 
 test {
     useJUnitPlatform()
-}
+}

lib/src/main/kotlin/org/walletconnect/Session.kt

@@ -0,0 +1,149 @@
+package org.walletconnect
+
+import java.net.URLDecoder
+
+interface Session {
+    fun init()
+    fun approve(accounts: List<String>, chainId: Long)
+    fun reject()
+    fun update(accounts: List<String>, chainId: Long)
+    fun kill()
+
+    fun peerMeta(): PayloadAdapter.PeerMeta?
+    fun approvedAccounts(): List<String>?
+
+    fun approveRequest(id: Long, response: Any)
+    fun rejectRequest(id: Long, errorCode: Long, errorMsg: String)
+
+    fun addCallback(cb: Session.Callback)
+    fun removeCallback(cb: Session.Callback)
+
+    data class Config(
+        val handshakeTopic: String,
+        val bridge: String,
+        val key: String,
+        val protocol: String = "wc",
+        val version: Int = 1
+    ) {
+        companion object {
+            fun fromWCUri(uri: String): Config {
+                val protocolSeparator = uri.indexOf(':')
+                val handshakeTopicSeparator = uri.indexOf('@', startIndex = protocolSeparator)
+                val versionSeparator = uri.indexOf('?')
+                val protocol = uri.substring(0, protocolSeparator)
+                val handshakeTopic = uri.substring(protocolSeparator + 1, handshakeTopicSeparator)
+                val version = Integer.valueOf(uri.substring(handshakeTopicSeparator + 1, versionSeparator))
+                val params = uri.substring(versionSeparator + 1).split("&").associate {
+                    it.split("=").let { param -> param.first() to URLDecoder.decode(param[1], "UTF-8") }
+                }
+                val bridge = params["bridge"] ?: throw IllegalArgumentException("Missing bridge param in URI")
+                val key = params["key"] ?: throw IllegalArgumentException("Missing key param in URI")
+                return Config(handshakeTopic, bridge, key, protocol, version)
+            }
+        }
+    }
+
+    interface Callback {
+
+        fun sendTransaction(
+            id: Long,
+            from: String,
+            to: String,
+            nonce: String?,
+            gasPrice: String?,
+            gasLimit: String?,
+            value: String,
+            data: String
+        )
+
+        fun signMessage(id: Long, address: String, message: String)
+
+        fun sessionRequest(peer: PayloadAdapter.PeerData)
+
+        fun sessionApproved()
+
+        fun sessionClosed(msg: String?)
+    }
+
+    interface PayloadAdapter {
+        fun parse(payload: String, key: String): MethodCall
+        fun prepare(data: MethodCall, key: String): String
+
+        sealed class MethodCall(private val internalId: Long) {
+            fun id() = internalId
+
+            data class SessionRequest(val id: Long, val peer: PeerData) : MethodCall(id)
+
+            data class SessionUpdate(val id: Long, val params: SessionParams) : MethodCall(id)
+
+            data class ExchangeKey(val id: Long, val nextKey: String, val peer: PeerData) : MethodCall(id)
+
+            data class SendTransaction(
+                val id: Long,
+                val from: String,
+                val to: String,
+                val nonce: String?,
+                val gasPrice: String?,
+                val gasLimit: String?,
+                val value: String,
+                val data: String
+            ) : MethodCall(id)
+
+            data class SignMessage(val id: Long, val address: String, val message: String) : MethodCall(id)
+
+            data class Response(val id: Long, val result: Any?, val error: Error? = null) : MethodCall(id)
+        }
+
+        data class PeerData(val id: String, val meta: PeerMeta?)
+        data class PeerMeta(
+            val url: String? = null,
+            val name: String? = null,
+            val description: String? = null,
+            val icons: List<String>? = null,
+            val ssl: Boolean? = null
+        )
+
+        data class SessionParams(val approved: Boolean, val chainId: Long?, val accounts: List<String>?, val message: String?)
+
+        data class Error(val code: Long, val message: String)
+
+    }
+
+    interface Transport {
+
+        fun connect(): Boolean
+
+        fun send(message: Message)
+
+        fun status(): Status
+
+        fun close()
+
+        enum class Status {
+            CONNECTED,
+            DISCONNECTED
+        }
+
+        data class Message(
+            val topic: String,
+            val type: String,
+            val payload: String
+        )
+
+        interface Builder {
+            fun build(
+                url: String,
+                statusHandler: (Session.Transport.Status) -> Unit,
+                messageHandler: (Session.Transport.Message) -> Unit
+            ): Transport
+        }
+
+    }
+
+    sealed class MethodCallException(val id: Long, val code: Long, message: String) : IllegalArgumentException(message) {
+        // TODO define proper error codes
+        class InvalidMethod(id: Long, method: String) : MethodCallException(id, 42, "Unknown method: $method")
+        class InvalidRequest(id: Long, request: String) : MethodCallException(id, 23, "Invalid request: $request")
+        class InvalidAccount(id: Long, account: String) : MethodCallException(id, 3141, "Invalid account request: $account")
+    }
+}

lib/src/main/kotlin/org/walletconnect/Utils.kt

@@ -0,0 +1,36 @@
+package org.walletconnect
+
+import kotlin.experimental.and
+
+//Map functions that throw exceptions into optional types
+fun <T> nullOnThrow(func: () -> T): T? = try {
+    func.invoke()
+} catch (e: Exception) {
+    null
+}
+
+// TODO: Use khex
+
+private val hexArray = "0123456789abcdef".toCharArray()
+
+fun ByteArray.toHexString(): String {
+    val hexChars = CharArray(this.size * 2)
+    for (j in this.indices) {
+        val v = ((this[j] and 0xFF.toByte()).toInt() + 256) % 256
+        hexChars[j * 2] = hexArray[v ushr 4]
+        hexChars[j * 2 + 1] = hexArray[v and 0x0F]
+    }
+    return String(hexChars)
+}
+
+fun String.hexToByteArray(): ByteArray {
+    val s = this.removePrefix("0x")
+    val len = s.length
+    val data = ByteArray(len / 2)
+    var i = 0
+    while (i < len) {
+        data[i / 2] = ((Character.digit(s[i], 16) shl 4) + Character.digit(s[i + 1], 16)).toByte()
+        i += 2
+    }
+    return data
+}