Cleanup

src/asyncutil/lsg.rs

@@ -3,12 +3,9 @@ use std::future::Future;
 use std::pin::Pin;
 use std::sync::{Arc, Mutex, PoisonError};
 use std::task::{Context, Poll};
-use tokio::{
-    sync::{
-        mpsc::{channel, Receiver, Sender},
-        Semaphore,
-    },
-    time::timeout,
+use tokio::sync::{
+    mpsc::{channel, Receiver, Sender},
+    Semaphore,
 };
 use tokio_util::sync::CancellationToken;
 

src/main.rs

@@ -1,6 +1,3 @@
-#![allow(dead_code)] // XXX
-#![allow(unused_imports)] // XXX
-#![allow(clippy::todo)] // XXX
 mod asyncutil;
 mod inventory;
 mod manifest;

src/s3/mod.rs

@@ -168,7 +168,6 @@ impl S3Client {
             self.make_dl_tempfile(&PathBuf::from(format!("data/{fname}.csv.gz")), &url)?;
         self.download_object(&url, Some(&fspec.md5_checksum), &outfile)
             .await?;
-        // TODO: Verify file size?
         Ok(InventoryList::from_gzip_csv_file(url, outfile))
     }
 

src/syncer.rs

@@ -3,7 +3,7 @@ use crate::inventory::InventoryItem;
 use crate::manifest::CsvManifest;
 use crate::s3::S3Client;
 use anyhow::Context;
-use futures_util::{stream::select, StreamExt};
+use futures_util::StreamExt;
 use std::fmt;
 use std::fs::File;
 use std::num::NonZeroUsize;

src/timestamps/util.rs

@@ -1,6 +1,3 @@
-use std::num::ParseIntError;
-use thiserror::Error;
-
 #[derive(Copy, Clone, Debug, Eq, PartialEq)]
 pub(super) struct Scanner<'a, E> {
     s: &'a str,