chore: resolve advisory that backoff is unmaintained

driver/kasa/Cargo.toml

@@ -4,7 +4,7 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
-backoff = { workspace = true, features = ["tokio"] }
+backon = { workspace = true }
 deranged = { workspace = true }
 mac_address = { version = "1.1.8", features = ["serde"] }
 protocol = { path = "../../protocol" }

driver/kasa/src/connection.rs

@@ -1,17 +1,15 @@
-use std::{convert::Infallible, io, net::SocketAddr, num::NonZero, time::Duration};
-
-use backoff::{ExponentialBackoff, ExponentialBackoffBuilder};
+use crate::messages::{GetSysInfo, GetSysInfoResponse, LB130USSys, SysInfo};
+use backon::{FibonacciBuilder, Retryable};
 use protocol::light::{Kelvin, KelvinLight, Light, Rgb, RgbLight};
 use snafu::{ResultExt, Snafu};
+use std::{convert::Infallible, io, net::SocketAddr, num::NonZero, time::Duration};
 use tokio::{
     io::{AsyncReadExt, AsyncWriteExt, BufReader, BufWriter},
-    net::{TcpListener, TcpSocket, TcpStream},
-    sync::{mpsc, oneshot, OnceCell},
+    net::TcpStream,
+    sync::{mpsc, oneshot},
     time::timeout,
 };
 
-use crate::messages::{GetSysInfo, GetSysInfoResponse, LB130USSys, SysInfo};
-
 struct XorEncryption<const INITIAL_KEY: u8>;
 
 impl<const INITIAL_KEY: u8> XorEncryption<INITIAL_KEY> {
@@ -90,21 +88,19 @@ async fn lb130us_actor(
                     "connecting for a first time / reconnecting after having gone idle..."
                 );
 
-                match backoff::future::retry_notify(
-                    ExponentialBackoff::default(),
-                    || async {
-                        let stream = TcpStream::connect(addr).await?;
-                        let (reader, writer) = stream.into_split();
+                match (|| async {
+                    let stream = TcpStream::connect(addr).await?;
+                    let (reader, writer) = stream.into_split();
 
-                        let buf_reader = BufReader::new(reader);
-                        let buf_writer = BufWriter::new(writer);
+                    let buf_reader = BufReader::new(reader);
+                    let buf_writer = BufWriter::new(writer);
 
-                        Ok((buf_reader, buf_writer))
-                    },
-                    |err, duration| {
-                        tracing::error!(?err, ?duration);
-                    },
-                )
+                    Ok((buf_reader, buf_writer))
+                })
+                .retry(FibonacciBuilder::default())
+                .notify(|err: &io::Error, duration| {
+                    tracing::error!(?err, ?duration);
+                })
                 .await
                 {
                     Ok(connection) => (connection_cell.insert(connection), message),