stuff

llarp/exit/endpoint.cpp

@@ -119,7 +119,7 @@ namespace llarp
         if (not quic)
           return false;
         quic->receive_packet(tag, buf.underlying);
-        return false;
+        return true;
       }
       // queue overflow
       if (m_UpstreamQueue.size() > MaxUpstreamQueueSize)

llarp/handlers/null.hpp

@@ -26,7 +26,6 @@ namespace llarp
           service::ProtocolType t,
           uint64_t) override
       {
-
         if (t == service::ProtocolType::Control)
           return true;
 

llarp/rpc/rpc_server.cpp

@@ -170,7 +170,7 @@ namespace llarp::rpc
                 SockAddr laddr{};
                 laddr.fromString(bindAddr);
 
-                r->loop()->call([reply, endpoint, r, remoteHost, port, closeID]() {
+                r->loop()->call([reply, endpoint, r, remoteHost, port, closeID, laddr]() {
                   auto ep = GetEndpointByName(r, endpoint);
                   if (not ep)
                   {
@@ -190,11 +190,19 @@ namespace llarp::rpc
                     return;
                   }
 
-                  auto [addr, id] = quic->open(remoteHost, port);
-                  util::StatusObject status;
-                  status["addr"] = addr.toString();
-                  status["id"] = id;
-                  reply(CreateJSONResponse(status));
+                  try
+                  {
+                    auto [addr, id] = quic->open(
+                        remoteHost, port, [](auto&&) {}, laddr);
+                    util::StatusObject status;
+                    status["addr"] = addr.toString();
+                    status["id"] = id;
+                    reply(CreateJSONResponse(status));
+                  }
+                  catch (std::exception& ex)
+                  {
+                    reply(CreateJSONError(ex.what()));
+                  }
                 });
               });
             })