Merge pull request #389 from majestrate/staging

unbreak

docs/proto_v0.txt

@@ -656,6 +656,7 @@ start a new session
   A: "H",
   C: "<1048 bytes ciphertext block>",
   D: "<N bytes encrypted HSD>",
+  F: "<16 bytes source path_id>",
   N: "<32 bytes nonce for key exchange>",
   V: 0,
   Z: "<64 bytes signature of entire message using sender's signing key>"
@@ -691,6 +692,8 @@ C, K = PQKE_A(I_B.k)
 N = RAND(32)
 D = SE(X, K, N)
 
+path = PickSendPath()
+
 M = {
   A: "T",
   P: I_B.P,
@@ -699,6 +702,7 @@ M = {
     A: "H",
     C: C,
     D: D,
+    F: path.lastHop.txID,
     N: N,
     V: 0,
     Z: "\x00" * 64
@@ -711,6 +715,8 @@ Z = S(A_sk, BE(M))
 alice transmits a TDFM to router with public key I_B.K via her path that ends 
 with router with public key I_B.k
 
+path = PickSendPath()
+
 {
   A: "T",
   P: I_B.P,
@@ -719,6 +725,7 @@ with router with public key I_B.k
     A: "H",
     C: C,
     D: D,
+    F: path.lastHop.txID,
     N: N,
     V: 0,
     Z: Z
@@ -744,6 +751,7 @@ transfer data on a session previously made
 {
   A: "H",
   D: "<N bytes encrypted HSD>",
+  F: "<16 bytes path id of soruce>",
   N: "<32 bytes nonce for symettric cipher>",
   T: "<16 bytes converstation tag>",
   V: 0,

llarp/path/path.cpp

@@ -172,8 +172,7 @@ namespace llarp
     IHopHandler*
     PathContext::GetByUpstream(const RouterID& remote, const PathID_t& id)
     {
-      auto own = MapGet(
+      auto own = MapGet(m_OurPaths, id,
-          m_OurPaths, id,
                         [](__attribute__((unused)) const PathSet* s) -> bool {
                           // TODO: is this right?
                           return true;
@@ -184,8 +183,7 @@ namespace llarp
       if(own)
         return own;
 
-      return MapGet(
+      return MapGet(m_TransitPaths, id,
-          m_TransitPaths, id,
                     [remote](const std::shared_ptr< TransitHop >& hop) -> bool {
                       return hop->info.upstream == remote;
                     },
@@ -208,8 +206,7 @@ namespace llarp
     IHopHandler*
     PathContext::GetByDownstream(const RouterID& remote, const PathID_t& id)
     {
-      return MapGet(
+      return MapGet(m_TransitPaths, id,
-          m_TransitPaths, id,
                     [remote](const std::shared_ptr< TransitHop >& hop) -> bool {
                       return hop->info.downstream == remote;
                     },
@@ -440,6 +437,13 @@ namespace llarp
       return intro.latency > 0 && _status == ePathEstablished;
     }
 
+    bool
+    Path::IsEndpoint(const RouterID& r, const PathID_t& id) const
+    {
+      return hops[hops.size() - 1].rc.pubkey == r
+          && hops[hops.size() - 1].txID == id;
+    }
+
     RouterID
     Path::Upstream() const
     {

llarp/path/pathset.cpp

@@ -156,6 +156,22 @@ namespace llarp
       return chosen;
     }
 
+    Path*
+    PathSet::GetByEndpointWithID(RouterID ep, PathID_t id) const
+    {
+      Lock_t l(&m_PathsMutex);
+      auto itr = m_Paths.begin();
+      while(itr != m_Paths.end())
+      {
+        if(itr->second->IsEndpoint(ep, id))
+        {
+          return itr->second;
+        }
+        ++itr;
+      }
+      return nullptr;
+    }
+
     Path*
     PathSet::GetPathByID(PathID_t id) const
     {

llarp/path/pathset.hpp

@@ -176,6 +176,9 @@ namespace llarp
       Path*
       GetPathByID(PathID_t id) const;
 
+      Path*
+      GetByEndpointWithID(RouterID router, PathID_t id) const;
+
       bool
       GetCurrentIntroductionsWithFilter(
           std::set< service::Introduction >& intros,

llarp/service/endpoint.cpp

@@ -998,6 +998,7 @@ namespace llarp
         if(!frame->Verify(Crypto(), si))
           return false;
         // remove convotag it doesn't exist
+        LogWarn("remove convotag T=", frame->T);
         RemoveConvoTag(frame->T);
         return true;
       }
@@ -1027,6 +1028,7 @@ namespace llarp
         , m_Endpoint(ep)
     {
       createdAt = ep->Now();
+      currentConvoTag.Zero();
     }
 
     void
@@ -1583,6 +1585,7 @@ namespace llarp
         self->handler->PutCachedSessionKeyFor(self->msg.tag, self->sharedKey);
         self->handler->PutIntroFor(self->msg.tag, self->remoteIntro);
         self->handler->PutSenderFor(self->msg.tag, self->remote);
+        self->handler->PutReplyIntroFor(self->msg.tag, self->msg.introReply);
         self->hook(self->frame);
         delete self;
       }
@@ -1669,24 +1672,22 @@ namespace llarp
 
       ex->msg.PutBuffer(payload);
       ex->msg.introReply = path->intro;
-      m_DataHandler->PutReplyIntroFor(currentConvoTag, path->intro);
+      ex->frame.F        = ex->msg.introReply.pathID;
       llarp_threadpool_queue_job(m_Endpoint->Worker(),
                                  {ex, &AsyncKeyExchange::Encrypt});
     }
 
     bool
-    Endpoint::SendContext::Send(ProtocolFrame& msg)
+    Endpoint::SendContext::Send(const ProtocolFrame& msg)
     {
-      auto path = m_PathSet->GetPathByRouter(remoteIntro.router);
+      auto path = m_PathSet->GetByEndpointWithID(remoteIntro.router, msg.F);
-      if(path == nullptr)
-        path = m_Endpoint->GetPathByRouter(remoteIntro.router);
       if(path)
       {
-        routing::PathTransferMessage transfer(msg, remoteIntro.pathID);
+        const routing::PathTransferMessage transfer(msg, remoteIntro.pathID);
         if(path->SendRoutingMessage(&transfer, m_Endpoint->Router()))
         {
-          llarp::LogDebug("sent data to ", remoteIntro.pathID, " on ",
+          llarp::LogInfo("sent intro to ", remoteIntro.pathID, " on ",
-                          remoteIntro.router);
+                         remoteIntro.router, " seqno=", sequenceNo);
           lastGoodSend = m_Endpoint->Now();
           ++sequenceNo;
           return true;
@@ -1798,6 +1799,8 @@ namespace llarp
           ++itr;
       }
       // send control message if we look too quiet
+      if(lastGoodSend)
+      {
         if(now - lastGoodSend > (sendTimeout / 2))
         {
           if(!GetNewestPathByRouter(remoteIntro.router))
@@ -1808,6 +1811,11 @@ namespace llarp
           tmp.Randomize();
           llarp_buffer_t buf(tmp.data(), tmp.size());
           AsyncEncryptAndSendTo(buf, eProtocolControl);
+          SharedSecret k;
+          if(currentConvoTag.IsZero())
+            return false;
+          return !m_DataHandler->HasConvoTag(currentConvoTag);
+        }
       }
       // if we are dead return true so we are removed
       return lastGoodSend
@@ -1815,6 +1823,12 @@ namespace llarp
           : (now >= createdAt && now - createdAt > connectTimeout);
     }
 
+    bool
+    Endpoint::HasConvoTag(const ConvoTag& t) const
+    {
+      return m_Sessions.find(t) != m_Sessions.end();
+    }
+
     bool
     Endpoint::OutboundContext::SelectHop(llarp_nodedb* db,
                                          const RouterContact& prev,

llarp/service/endpoint.hpp

@@ -222,7 +222,7 @@ namespace llarp
         /// send a fully encrypted hidden service frame
         /// via a path on our pathset with path id p
         bool
-        Send(ProtocolFrame& f);
+        Send(const ProtocolFrame& f);
 
         llarp::SharedSecret sharedKey;
         ServiceInfo remoteIdent;
@@ -261,6 +261,9 @@ namespace llarp
       static void
       HandlePathDead(void*);
 
+      bool
+      HasConvoTag(const ConvoTag& t) const override;
+
       bool
       ShouldBuildMore(llarp_time_t now) const override;
 

llarp/service/handler.hpp

@@ -28,6 +28,9 @@ namespace llarp
       virtual void
       RemoveConvoTag(const ConvoTag& remote) = 0;
 
+      virtual bool
+      HasConvoTag(const ConvoTag& remote) const = 0;
+
       virtual void
       PutSenderFor(const ConvoTag& remote, const ServiceInfo& si) = 0;