From 42c318a1b84710df7dc6a7cfcd7878c08d2d966e Mon Sep 17 00:00:00 2001
From: Yannik <>
Date: Thu, 27 Oct 2022 12:01:01 +0200
Subject: [PATCH] style

---
 src/main.rs | 27 ++++++++++++++-------------
 1 file changed, 14 insertions(+), 13 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index 2b25120..2fe1484 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -112,19 +112,20 @@ async fn handle_peer(
     let ip = peer.ip();
 
     let mut lines = FramedRead::new(stream, LinesCodec::new());
-    loop {
-        match lines.next().await.transpose()? {
-            Some(line) => {
-                let (prio, now, date, service, log) = parse_line(&line)?;
-                if !blacklist.contains(service) {
-                    db.execute(
-                        &insert_statement,
-                        &[&prio, &ip, &now, &date, &service, &log],
-                    )
-                    .await?;
-                }
-            }
-            None => break,
+    while let Some(line) = lines.next().await.transpose()? {
+        let ParsedLine {
+            prio,
+            rcvtime,
+            logtime,
+            service,
+            entry,
+        } = parse_line(&line)?;
+        if !blacklist.contains(service) {
+            db.execute(
+                &insert_statement,
+                &[&prio, &ip, &rcvtime, &logtime, &service, &entry],
+            )
+            .await?;
         }
     }
     Ok(())