Add one more test for self-connect-open-accept-stream.

libp2p/daemon/daemonapi.nim

@@ -96,7 +96,7 @@ type
 
   PeerInfo* = object
     peer*: PeerID
-    addresses: seq[MultiAddress]
+    addresses*: seq[MultiAddress]
 
   P2PStreamCallback* = proc(api: DaemonAPI,
                             stream: P2PStream): Future[void] {.gcsafe.}

tests/testdaemon.nim

@@ -8,8 +8,36 @@ proc identitySpawnTest(): Future[bool] {.async.} =
   await api.close()
   result = true
 
+proc connectStreamTest(): Future[bool] {.async.} =
+  var api1 = await newDaemonApi(sockpath = "/tmp/p2pd-1.sock")
+  var api2 = await newDaemonApi(sockpath = "/tmp/p2pd-2.sock")
+
+  var id1 = await api1.identity()
+  var id2 = await api2.identity()
+
+  var protos = @["/test-stream"]
+  var test = "TEST STRING"
+
+  var testFuture = newFuture[string]("test.future")
+
+  proc streamHandler(api: DaemonAPI, stream: P2PStream) {.async.} =
+    var line = await stream.transp.readLine()
+    testFuture.complete(line)
+
+  await api2.addHandler(protos, streamHandler)
+  await api1.connect(id2.peer, id2.addresses)
+  var stream = await api1.openStream(id2.peer, protos)
+  let sent = await stream.transp.write(test & "\r\n")
+  doAssert(sent == len(test) + 2)
+  var check = await wait(testFuture, 10000)
+  doAssert(check == test)
+  result = true
+
 when isMainModule:
   suite "libp2p-daemon test suite":
     test "Simple spawn and get identity test":
       check:
         waitFor(identitySpawnTest()) == true
+    test "Connect/Accept peer/stream test":
+      check:
+        waitFor(connectStreamTest()) == true