fix lints

src/cursor/file.rs

@@ -11,11 +11,10 @@ fn breadcrumbs_to_data(crumbs: &Breadcrumbs) -> Vec<(u64, String)> {
     crumbs
         .points()
         .into_iter()
-        .map(|p| match p {
+        .filter_map(|p| match p {
             Point::Origin => None,
             Point::Specific(slot, hash) => Some((slot, hex::encode(hash))),
         })
-        .flatten()
         .collect()
 }
 
@@ -124,10 +123,7 @@ impl Config {
     pub fn initial_load(&self) -> Result<Breadcrumbs, Error> {
         let path = self.define_path()?;
 
-        let max_breadcrumbs = self
-            .max_breadcrumbs
-            .clone()
-            .unwrap_or(DEFAULT_MAX_BREADCRUMBS);
+        let max_breadcrumbs = self.max_breadcrumbs.unwrap_or(DEFAULT_MAX_BREADCRUMBS);
 
         if path.is_file() {
             let file = std::fs::File::open(&path).map_err(|err| Error::Custom(err.to_string()))?;
@@ -141,10 +137,7 @@ impl Config {
     }
 
     pub fn bootstrapper(self, ctx: &Context) -> Result<Stage, Error> {
-        let flush_interval = self
-            .flush_interval
-            .clone()
-            .unwrap_or(DEFAULT_FLUSH_INTERVAL as u64);
+        let flush_interval = self.flush_interval.unwrap_or(DEFAULT_FLUSH_INTERVAL as u64);
 
         let stage = Stage {
             path: self.define_path()?,

src/sinks/aws_lambda.rs

@@ -78,7 +78,7 @@ pub struct Config {
 }
 
 impl Config {
-    pub fn bootstrapper(self, ctx: &Context) -> Result<Stage, Error> {
+    pub fn bootstrapper(self, _ctx: &Context) -> Result<Stage, Error> {
         let stage = Stage {
             config: self,
             ops_count: Default::default(),

src/sinks/aws_s3.rs

@@ -99,7 +99,7 @@ pub struct Config {
 }
 
 impl Config {
-    pub fn bootstrapper(self, ctx: &Context) -> Result<Stage, Error> {
+    pub fn bootstrapper(self, _ctx: &Context) -> Result<Stage, Error> {
         let stage = Stage {
             config: self,
             ops_count: Default::default(),

src/sinks/aws_sqs.rs

@@ -97,7 +97,7 @@ pub struct Config {
 }
 
 impl Config {
-    pub fn bootstrapper(self, ctx: &Context) -> Result<Stage, Error> {
+    pub fn bootstrapper(self, _ctx: &Context) -> Result<Stage, Error> {
         let stage = Stage {
             config: self,
             ops_count: Default::default(),

src/sinks/gcp_cloudfunction.rs

@@ -253,7 +253,7 @@ pub struct Config {
 }
 
 impl Config {
-    pub fn bootstrapper(self, ctx: &Context) -> Result<Stage, Error> {
+    pub fn bootstrapper(self, _ctx: &Context) -> Result<Stage, Error> {
         let stage = Stage {
             config: self,
             ops_count: Default::default(),

src/sinks/gcp_pubsub.rs

@@ -79,7 +79,7 @@ pub struct Config {
 }
 
 impl Config {
-    pub fn bootstrapper(self, ctx: &Context) -> Result<Stage, Error> {
+    pub fn bootstrapper(self, _ctx: &Context) -> Result<Stage, Error> {
         let stage = Stage {
             config: self,
             ops_count: Default::default(),

src/sinks/kafka.rs

@@ -105,7 +105,7 @@ pub struct Config {
 }
 
 impl Config {
-    pub fn bootstrapper(self, ctx: &Context) -> Result<Stage, Error> {
+    pub fn bootstrapper(self, _ctx: &Context) -> Result<Stage, Error> {
         let stage = Stage {
             config: self,
             ops_count: Default::default(),

src/sinks/rabbitmq.rs

@@ -82,7 +82,7 @@ pub struct Config {
 }
 
 impl Config {
-    pub fn bootstrapper(self, ctx: &Context) -> Result<Stage, Error> {
+    pub fn bootstrapper(self, _ctx: &Context) -> Result<Stage, Error> {
         let stage = Stage {
             config: self,
             ops_count: Default::default(),

src/sinks/redis.rs

@@ -106,7 +106,7 @@ pub struct Config {
 }
 
 impl Config {
-    pub fn bootstrapper(self, ctx: &Context) -> Result<Stage, Error> {
+    pub fn bootstrapper(self, _ctx: &Context) -> Result<Stage, Error> {
         let stage = Stage {
             config: self,
             ops_count: Default::default(),

src/sinks/webhook.rs

@@ -109,7 +109,7 @@ pub struct Config {
 }
 
 impl Config {
-    pub fn bootstrapper(self, ctx: &Context) -> Result<Stage, Error> {
+    pub fn bootstrapper(self, _ctx: &Context) -> Result<Stage, Error> {
         let stage = Stage {
             config: self,
             ops_count: Default::default(),

src/sources/utxorpc.rs

@@ -193,8 +193,7 @@ impl gasket::framework::Worker<Stage> for Worker {
 
         let intersect = intersect
             .into_iter()
-            .map(point_to_blockref)
-            .flatten()
+            .filter_map(point_to_blockref)
             .collect::<Vec<_>>()
             .pop();