extra closure methods

include/quic/connection.hpp

@@ -116,6 +116,8 @@ namespace oxen::quic
         virtual int last_cleared() const = 0;
         virtual int datagram_bufsize() const = 0;
 
+        virtual void close_connection() = 0;
+
         virtual ~connection_interface() = default;
 
 #ifndef NDEBUG
@@ -189,6 +191,8 @@ namespace oxen::quic
 
         void send_datagram(bstring_view data, std::shared_ptr<void> keep_alive = nullptr) override;
 
+        void close_connection() override;
+
       private:
         // private Constructor (publicly construct via `make_conn` instead, so that we can properly
         // set up the shared_from_this shenanigans).

include/quic/endpoint.hpp

@@ -171,6 +171,8 @@ namespace oxen::quic
 
         void close_connection(Connection& conn, int code = NGTCP2_NO_ERROR, std::string_view msg = "NO_ERROR"sv);
 
+        void close_connection(ConnectionID cid, int code = NGTCP2_NO_ERROR, std::string_view msg = "NO_ERROR"sv);
+
         const Address& local() { return _local; }
 
         bool is_accepting() const { return _accepting_inbound; }

src/connection.cpp

@@ -234,6 +234,11 @@ namespace oxen::quic
         event_active(packet_io_trigger.get(), 0, 0);
     }
 
+    void Connection::close_connection()
+    {
+        _endpoint.call([this]() { _endpoint.close_connection(*this); });
+    }
+
     void Connection::handle_conn_packet(const Packet& pkt)
     {
         if (auto rv = ngtcp2_conn_in_closing_period(*this); rv != 0)

src/endpoint.cpp

@@ -154,6 +154,17 @@ namespace oxen::quic
         return;
     }
 
+    void Endpoint::close_connection(ConnectionID cid, int code, std::string_view msg)
+    {
+        for (auto& [scid, conn] : conns)
+        {
+            if (scid == cid)
+                return close_connection(*conn, code, msg);
+        }
+
+        log::warning(log_cat, "Could not find connection (CID: {}) for closure", cid);
+    }
+
     void Endpoint::close_connection(Connection& conn, int code, std::string_view msg)
     {
         log::debug(log_cat, "Closing connection (CID: {})", *conn.scid().data);