Set host on Hop protocol in relay transport

set Connection attribute call fireActive in upgradeStream
Peergos · Dec 27, 2023 · c10d756 · c10d756
1 parent 4581381
commit c10d756
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/libp2p/src/main/java/io/libp2p/protocol/circuit/RelayTransport.java b/libp2p/src/main/java/io/libp2p/protocol/circuit/RelayTransport.java
@@ -43,6 +43,7 @@ public RelayTransport(
   @Override
   public void setHost(Host us) {
     this.us = us;
+    hop.setHost(us);
   }
 
   public static class CandidateRelay {
@@ -207,6 +208,7 @@ protected void initChannel(Channel channel) throws Exception {
             System.out.println(
                 "Upgrade " + (isInitiator ? "outgoing" : "incoming") + " relay to " + remote);
             channel.attr(AttributesKt.getREMOTE_PEER_ID()).set(remote);
+            channel.attr(AttributesKt.getCONNECTION()).set(conn);
             upgrader
                 .establishSecureChannel(conn)
                 .thenCompose(
@@ -230,6 +232,8 @@ protected void initChannel(Channel channel) throws Exception {
                       res.completeExceptionally(t);
                       return null;
                     });
+            System.out.println("Fire active");
+            channel.pipeline().fireChannelActive();
           }
         });
     return res;