Communication Protocols for Self-Sovereign Identity

app/src/main/java/nl/tudelft/trustchain/app/TrustChainApplication.kt

@@ -18,15 +18,18 @@ import nl.tudelft.ipv8.android.IPv8Android
 import nl.tudelft.ipv8.android.keyvault.AndroidCryptoProvider
 import nl.tudelft.ipv8.android.messaging.bluetooth.BluetoothLeDiscovery
 import nl.tudelft.ipv8.android.peerdiscovery.NetworkServiceDiscovery
-import nl.tudelft.ipv8.attestation.schema.SchemaManager
+import nl.tudelft.ipv8.attestation.common.AuthorityManager
+import nl.tudelft.ipv8.attestation.common.SchemaManager
+import nl.tudelft.ipv8.attestation.communication.CommunicationManager
+import nl.tudelft.ipv8.attestation.identity.store.IdentitySQLiteStore
+import nl.tudelft.ipv8.attestation.revocation.AuthoritySQLiteStore
 import nl.tudelft.ipv8.attestation.trustchain.*
 import nl.tudelft.ipv8.attestation.trustchain.store.TrustChainSQLiteStore
 import nl.tudelft.ipv8.attestation.trustchain.store.TrustChainStore
 import nl.tudelft.ipv8.attestation.trustchain.validation.TransactionValidator
 import nl.tudelft.ipv8.attestation.trustchain.validation.ValidationResult
-import nl.tudelft.ipv8.attestation.wallet.AttestationCommunity
-import nl.tudelft.ipv8.attestation.wallet.AttestationSQLiteStore
 import nl.tudelft.ipv8.attestation.wallet.cryptography.bonehexact.BonehPrivateKey
+import nl.tudelft.ipv8.attestation.wallet.store.AttestationSQLiteStore
 import nl.tudelft.ipv8.keyvault.PrivateKey
 import nl.tudelft.ipv8.keyvault.defaultCryptoProvider
 import nl.tudelft.ipv8.messaging.tftp.TFTPCommunity
@@ -48,6 +51,7 @@ import nl.tudelft.trustchain.gossipML.RecommenderCommunity
 import nl.tudelft.trustchain.gossipML.db.RecommenderStore
 import nl.tudelft.trustchain.peerchat.community.PeerChatCommunity
 import nl.tudelft.trustchain.peerchat.db.PeerChatStore
+import nl.tudelft.trustchain.ssi.Communication
 
 import nl.tudelft.trustchain.voting.VotingCommunity
 import nl.tudelft.gossipML.sqldelight.Database as MLDatabase
@@ -70,7 +74,6 @@ class TrustChainApplication : Application() {
                 createEuroTokenCommunity(),
                 createTFTPCommunity(),
                 createDemoCommunity(),
-                createWalletCommunity(),
                 createMarketCommunity(),
                 createCoinCommunity(),
                 createVotingCommunity(),
@@ -86,6 +89,7 @@ class TrustChainApplication : Application() {
             .setServiceClass(TrustChainService::class.java)
             .init()
 
+        initCommunicationManager()
         initWallet()
         initTrustChain()
     }
@@ -100,6 +104,26 @@ class TrustChainApplication : Application() {
         }
     }
 
+    private fun initCommunicationManager() {
+        val driver: SqlDriver = AndroidSqliteDriver(Database.Schema, this, "wallet.db")
+        val database = Database(driver)
+        val authorityStore = AuthoritySQLiteStore(database)
+        val attestationStore = AttestationSQLiteStore(database)
+        val identityStore = IdentitySQLiteStore(database)
+
+        val authorityManager = AuthorityManager(authorityStore)
+        val communicationManager = CommunicationManager(
+            IPv8Android.getInstance(),
+            attestationStore,
+            identityStore,
+            authorityManager,
+            ::storePseudonym,
+            ::loadPseudonym
+        )
+
+        Communication.Factory(communicationManager)
+    }
+
     private fun initTrustChain() {
         val ipv8 = IPv8Android.getInstance()
         val trustchain = ipv8.getOverlay<TrustChainCommunity>()!!
@@ -170,18 +194,6 @@ class TrustChainApplication : Application() {
         )
     }
 
-    private fun createWalletCommunity(): OverlayConfiguration<AttestationCommunity> {
-        val driver: SqlDriver = AndroidSqliteDriver(Database.Schema, this, "wallet.db")
-        val database = Database(driver)
-        val store = AttestationSQLiteStore(database)
-        val randomWalk = RandomWalk.Factory()
-
-        return OverlayConfiguration(
-            AttestationCommunity.Factory(store),
-            listOf(randomWalk)
-        )
-    }
-
     private fun createDiscoveryCommunity(): OverlayConfiguration<DiscoveryCommunity> {
         val randomWalk = RandomWalk.Factory()
         val randomChurn = RandomChurn.Factory()
@@ -339,6 +351,23 @@ class TrustChainApplication : Application() {
         }
     }
 
+    private fun loadPseudonym(name: String): PrivateKey? {
+        val prefs = PreferenceManager.getDefaultSharedPreferences(this)
+        val privateKey = prefs.getString(name, null)
+        return if (privateKey == null) {
+            null
+        } else {
+            AndroidCryptoProvider.keyFromPrivateBin(privateKey.hexToBytes())
+        }
+    }
+
+    private fun storePseudonym(name: String, privateKey: PrivateKey) {
+        val prefs = PreferenceManager.getDefaultSharedPreferences(this)
+        prefs.edit()
+            .putString(name, privateKey.keyToBin().toHex())
+            .apply()
+    }
+
     companion object {
         private const val PREF_PRIVATE_KEY = "private_key"
         private const val PREF_ID_METADATA_KEY = "id_metadata"

common/src/main/java/nl/tudelft/trustchain/common/BaseActivity.kt

@@ -1,6 +1,7 @@
 package nl.tudelft.trustchain.common
 
 import android.os.Bundle
+import android.view.View
 import androidx.annotation.MenuRes
 import androidx.appcompat.app.AppCompatActivity
 import androidx.core.view.isVisible
@@ -9,6 +10,7 @@ import androidx.navigation.ui.AppBarConfiguration
 import androidx.navigation.ui.navigateUp
 import androidx.navigation.ui.setupActionBarWithNavController
 import androidx.navigation.ui.setupWithNavController
+import com.google.android.material.bottomnavigation.BottomNavigationView
 import nl.tudelft.trustchain.common.databinding.ActivityBaseBinding
 import nl.tudelft.trustchain.common.util.viewBinding
 
@@ -19,6 +21,8 @@ abstract class BaseActivity : AppCompatActivity() {
         AppBarConfiguration(setOf())
     }
 
+    protected lateinit var bottomNavigation: BottomNavigationView
+
     /**
      * The resource ID of the navigation graph.
      */
@@ -39,6 +43,7 @@ abstract class BaseActivity : AppCompatActivity() {
 
         setContentView(binding.root)
 
+        bottomNavigation = binding.bottomNavigation
         navController.setGraph(navigationGraph)
 
         // Setup ActionBar

ig-ssi/build.gradle

@@ -74,15 +74,18 @@ dependencies {
 
     // Kotlin
     implementation "org.jetbrains.kotlin:kotlin-stdlib-jdk7:$kotlin_version"
-    implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core:1.3.3'
-    implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-android:1.3.3'
+    implementation "org.jetbrains.kotlinx:kotlinx-coroutines-core:$coroutines_version"
+    implementation "org.jetbrains.kotlinx:kotlinx-coroutines-android:$coroutines_version"
     implementation "org.jetbrains.kotlin:kotlin-reflect:$kotlin_version"
 
+    implementation 'androidmads.library.qrgenearator:QRGenearator:1.0.4'
+
     // Logging
     implementation 'io.github.microutils:kotlin-logging:1.7.7'
     implementation 'com.github.tony19:logback-android:2.0.0'
 
     implementation 'com.github.MattSkala:recyclerview-itemadapter:0.4'
+    implementation 'androidx.legacy:legacy-support-v4:1.0.0'
 
     // Testing
     testImplementation 'junit:junit:4.12'

ig-ssi/src/main/java/nl/tudelft/trustchain/ssi/Communication.kt

@@ -0,0 +1,69 @@
+package nl.tudelft.trustchain.ssi
+
+import nl.tudelft.ipv8.attestation.communication.CommunicationChannel
+import nl.tudelft.ipv8.attestation.communication.CommunicationManager
+
+const val DEFAULT_PSEUDONYM = "MY_PEER"
+val DEFAULT_RENDEZVOUS_TOKEN = null
+
+object Communication {
+
+    private var communicationManager: CommunicationManager? = null
+    private var activePseudonym: String? = null
+    private var activeRendezvousToken: String? = null
+
+    val pseudonymLock = Object()
+    val tokenLock = Object()
+
+    fun getInstance(): CommunicationManager {
+        return communicationManager
+            ?: throw IllegalStateException("CommunicationManager is not initialized.")
+    }
+
+    fun load(
+        pseudonym: String = getActivePseudonym(),
+        rendezvous: String? = getActiveRendezvousToken()
+    ): CommunicationChannel {
+        var rendezvousToken = rendezvous
+        if (rendezvousToken == "") {
+            rendezvousToken = DEFAULT_RENDEZVOUS_TOKEN
+        }
+        if (rendezvousToken != activeRendezvousToken) {
+            setActiveRendezvousToken(rendezvousToken)
+        }
+        return getInstance().load(pseudonym, rendezvousToken)
+    }
+
+    fun getActivePseudonym(): String {
+        return activePseudonym
+            ?: throw java.lang.IllegalStateException("ActivePseudonym is not initialized.")
+    }
+
+    fun getActiveRendezvousToken(): String? {
+        return activeRendezvousToken
+    }
+
+    fun setActivePseudonym(pseudonym: String) {
+        synchronized(pseudonymLock) {
+            this.activePseudonym = pseudonym
+        }
+    }
+
+    fun setActiveRendezvousToken(token: String?) {
+        if (activeRendezvousToken != token)
+        synchronized(tokenLock) {
+            val manager = getInstance()
+            manager.unload(getActivePseudonym())
+            this.activeRendezvousToken = token
+            this.load()
+        }
+    }
+
+    class Factory(communicationManager: CommunicationManager) {
+        init {
+            Communication.communicationManager = communicationManager
+            activePseudonym = DEFAULT_PSEUDONYM
+            communicationManager.load(getActivePseudonym())
+        }
+    }
+}