From 20df2e3c6648832ddf2b88008b1f77c67274c5e2 Mon Sep 17 00:00:00 2001 From: KX Date: Tue, 23 Apr 2024 12:34:09 +0200 Subject: [PATCH] vicky: rust fmt and optimize imports --- vicky/src/bin/vicky/events.rs | 7 +++---- vicky/src/lib/logs/mod.rs | 13 +++---------- 2 files changed, 6 insertions(+), 14 deletions(-) diff --git a/vicky/src/bin/vicky/events.rs b/vicky/src/bin/vicky/events.rs index 6dda1c2..0cc1d3f 100644 --- a/vicky/src/bin/vicky/events.rs +++ b/vicky/src/bin/vicky/events.rs @@ -1,9 +1,8 @@ -use rocket::{get, State}; +use rocket::response::stream::{Event, EventStream}; +use rocket::{get, post, serde::json::Json, State}; use serde::{Deserialize, Serialize}; -use rocket::response::stream::{EventStream, Event}; use std::time; -use tokio::sync::broadcast::{error::{TryRecvError}, self}; - +use tokio::sync::broadcast::{self, error::TryRecvError}; #[derive(Debug, Clone, PartialEq, Serialize, Deserialize)] #[serde(tag = "type")] diff --git a/vicky/src/lib/logs/mod.rs b/vicky/src/lib/logs/mod.rs index 3e16bdf..39d0acd 100644 --- a/vicky/src/lib/logs/mod.rs +++ b/vicky/src/lib/logs/mod.rs @@ -2,16 +2,9 @@ use std::collections::{HashMap, VecDeque}; use std::time; use rocket::futures::lock::Mutex; -use tokio::sync::broadcast::{ - self, - error::TryRecvError, - Sender, -}; - -use crate::{ - errors::VickyError, - s3::client::S3Client, -}; +use tokio::sync::broadcast::{self, error::TryRecvError, Sender}; + +use crate::{errors::VickyError, s3::client::S3Client}; const LOG_BUFFER: usize = 10000;