Expire channels that have been unused for too long

Expire unused channels based on the discussion in issue #41 (closed) .

crates/arti-client/src/client.rs

@@ -355,6 +355,11 @@ impl<R: Runtime> TorClient<R> {
             Arc::downgrade(&dirmgr),
         ))?;
 
+        runtime.spawn(continually_expire_channels(
+            runtime.clone(),
+            Arc::downgrade(&chanmgr),
+        ))?;
+
         let client_isolation = IsolationToken::new();
 
         Ok(TorClient {
@@ -800,6 +805,24 @@ async fn continually_preemptively_build_circuits<R: Runtime>(
         rt.sleep(Duration::from_secs(10)).await;
     }
 }
+/// Periodically expire any channels that have been unused beyond
+/// the maximum duration allowed.
+///
+/// Exist when we find that `chanmgrq is dropped
+///
+/// This is a daemon task that runs indefinitely in the background
+async fn continually_expire_channels<R: Runtime>(rt: R, chanmgr: Weak<tor_chanmgr::ChanMgr<R>>) {
+    loop {
+        let delay = if let Some(cm) = Weak::upgrade(&chanmgr) {
+            cm.expire_channels(coarsetime::Instant::now())
+        } else {
+            // channel manager is closed.
+            return;
+        };
+        // This will sometimes be an underestimate, but it's no big deal; we just sleep some more.
+        rt.sleep(Duration::from_secs(delay.as_secs())).await;
+    }
+}
 
 impl<R: Runtime> Drop for TorClient<R> {
     // TODO: Consider moving this into tor-circmgr after we have more