Identify update

README.md

@@ -82,7 +82,7 @@ See for an in-depth description of libp2p, please see: https://libp2p.io/
     - [ ] Quic (planned)
 
 - Protocols
-    - [ ] Identify (planned)
+    - [X] Identify
     - [X] Ping
     - [ ] DHT/Kademlia (planned)
     - [ ] pubsub (planned)

libp2p-core/src/test/kotlin/org/erwinkok/libp2p/core/protocol/identify/IdServiceTest.kt

@@ -47,6 +47,7 @@ import org.junit.jupiter.api.Test
 import kotlin.time.Duration
 import kotlin.time.Duration.Companion.hours
 import kotlin.time.Duration.Companion.milliseconds
+import kotlin.time.Duration.Companion.minutes
 import kotlin.time.Duration.Companion.seconds
 
 class IdServiceTest {
@@ -315,7 +316,7 @@ class IdServiceTest {
     }
 
     @Test
-    fun largeIdentifyMessage() = runTest {
+    fun largeIdentifyMessage() = runTest(timeout = 1.minutes) {
         withContext(Dispatchers.Default) {
             val h1 = BlankHost.create(this, SwarmTestBuilder.create(this)).expectNoErrors()
             val h2 = BlankHost.create(this, SwarmTestBuilder.create(this)).expectNoErrors()

libp2p-testing/src/main/kotlin/org/erwinkok/libp2p/testing/testsuites/datastore/DatastoreTestSuite.kt

@@ -39,14 +39,15 @@ import org.junit.jupiter.api.DynamicTest
 import org.junit.jupiter.api.function.Executable
 import java.util.stream.Stream
 import kotlin.random.Random
+import kotlin.time.Duration.Companion.minutes
 
 class DatastoreTestSuite(private val dsName: String) {
     private class SubTestExecutable<T : Datastore>(
         private val create: (CoroutineScope) -> T,
         private val exec: suspend (CoroutineScope, T) -> Unit,
         private val cleanup: suspend (CoroutineScope, T) -> Unit,
     ) : Executable {
-        override fun execute() = runTest {
+        override fun execute() = runTest(timeout = 1.minutes) {
             val element = create(this)
             element.use {
                 exec(this, element)