chore: format better

rustfmt.toml

@@ -0,0 +1,3 @@
+unstable_features = true
+group_imports = "StdExternalCrate"
+imports_granularity = "Module"

shell.nix

@@ -1,4 +1,6 @@
-{ pkgs ? import (import ./npins).nixpkgs { } }:
+{
+  pkgs ? import (import ./npins).nixpkgs { },
+}:
 pkgs.mkShell {
   buildInputs = [
     pkgs.cargo
@@ -7,6 +9,6 @@ pkgs.mkShell {
     pkgs.signal-cli
     pkgs.rustc
     pkgs.rust-analyzer
-    pkgs.rustfmt
+    (pkgs.rustfmt.override { asNightly = true; })
   ];
 }

src/main.rs

@@ -1,20 +1,18 @@
 mod jsonrpc;
 mod transform;
 mod transports;
-use crate::jsonrpc::RpcClient;
-use irc::client::ClientStream;
-use jsonrpsee::core::client::SubscriptionClientT;
-use log;
-use serde_json::Value;
 use std::path::Path;
-use transform::Bridge;
-
-use jsonrpsee::core::client::Subscription;
-use pretty_env_logger;
 
 use futures::future::try_join;
 use futures::prelude::*;
 use irc::client::prelude::*;
+use irc::client::ClientStream;
+use jsonrpsee::core::client::{Subscription, SubscriptionClientT};
+use serde_json::Value;
+use transform::Bridge;
+use {log, pretty_env_logger};
+
+use crate::jsonrpc::RpcClient;
 
 const CHANNEL: &str = "#hackens-signal";
 const MEDIA_DIR: &str = "./www";
@@ -149,7 +147,11 @@ async fn handle_signal(
                         .map_err(|e| format!("error while sending to irc: {e}"))?;
                 }
             }
-            Some(Err(err)) => return Err(format!("error while retrieving messages from signal: {err}")),
+            Some(Err(err)) => {
+                return Err(format!(
+                    "error while retrieving messages from signal: {err}"
+                ))
+            }
         }
     }
 }

src/transform.rs

@@ -1,7 +1,7 @@
-use irc::client::prelude::*;
-use serde_json::Map;
-use serde_json::Value;
 use std::path::Path;
+
+use irc::client::prelude::*;
+use serde_json::{Map, Value};
 use tokio::fs::copy;
 
 #[derive(Default)]

src/transports/mod.rs

@@ -15,11 +15,10 @@
  * You should have received a copy of the GNU General Public License
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
-use futures_util::{stream::StreamExt, Sink, SinkExt, Stream};
+use futures_util::stream::StreamExt;
-use jsonrpsee::core::{
+use futures_util::{Sink, SinkExt, Stream};
-    async_trait,
+use jsonrpsee::core::async_trait;
-    client::{ReceivedMessage, TransportReceiverT, TransportSenderT},
+use jsonrpsee::core::client::{ReceivedMessage, TransportReceiverT, TransportSenderT};
-};
 use thiserror::Error;
 
 pub mod ipc;

src/transports/stream_codec.rs

@@ -15,8 +15,9 @@
  * You should have received a copy of the GNU General Public License
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
-use bytes::BytesMut;
 use std::{io, str};
+
+use bytes::BytesMut;
 use tokio_util::codec::{Decoder, Encoder};
 
 type Separator = u8;