fixes formatting

Author: budde25

src/daemon.rs

@@ -2,12 +2,12 @@ use super::http;
 use job_scheduler::Job;
 use job_scheduler::JobScheduler;
 use log::{debug, error};
-use std::{thread, time};
 use std::str::FromStr;
+use std::{thread, time};
 
+use super::db;
 use super::file;
 use super::util;
-use super::db;
 
 pub fn start() -> anyhow::Result<()> {
     db::create_db()?;
@@ -36,7 +36,10 @@ fn schedule_tasks(mut sched: JobScheduler) -> anyhow::Result<JobScheduler> {
     let schedule: Vec<db::Schedule> = db::get_schedule()?;
     for item in schedule {
         match file::create_file_for_user(Some(&item.user)) {
-            Ok(_) => debug!("authorized keys file for {} exists or was created", &item.user),
+            Ok(_) => debug!(
+                "authorized keys file for {} exists or was created",
+                &item.user
+            ),
             Err(e) => {
                 error!(
                     "Unable to create authorized keys file for user {}. {}",
@@ -46,9 +49,10 @@ fn schedule_tasks(mut sched: JobScheduler) -> anyhow::Result<JobScheduler> {
             }
         }
 
-        sched.add(Job::new(cron::Schedule::from_str(&item.cron).unwrap(), move || {
-            run_job(item.user.to_owned(), item.url.to_owned())
-        }));
+        sched.add(Job::new(
+            cron::Schedule::from_str(&item.cron).unwrap(),
+            move || run_job(item.user.to_owned(), item.url.to_owned()),
+        ));
         println!("Scheduled item");
     }
 
@@ -84,4 +88,4 @@ fn run_job(user: String, url: String) {
         ),
         Err(e) => eprint!("failed to write keys to file. {}", e),
     };
-}
+}

src/db.rs

@@ -1,12 +1,12 @@
+use anyhow::anyhow;
+use cron;
+use log::{info, warn};
 use rusqlite::NO_PARAMS;
 use rusqlite::{params, Connection};
-use std::path::PathBuf;
 use std::fs;
-use url::Url;
-use cron;
+use std::path::PathBuf;
 use std::str::FromStr;
-use log::{warn, info};
-use anyhow::anyhow;
+use url::Url;
 
 use super::file;
 
@@ -19,7 +19,6 @@ pub struct Schedule {
     pub url: String,
 }
 
-
 /// Creates the db and path to it if it doesn't already exist
 pub fn create_db() -> anyhow::Result<()> {
     let path = file::get_schedule_path();
@@ -32,10 +31,10 @@ pub fn create_db() -> anyhow::Result<()> {
     if !parent.is_dir() {
         fs::create_dir_all(parent)?;
     }
-    
+
     let conn: Connection = Connection::open(path)?;
     conn.execute(
-    "create table if not exists Schedule (
+        "create table if not exists Schedule (
             id integer primary key,
             user text not null,
             cron text not null,
@@ -51,16 +50,18 @@ pub fn delete_schedule(id: i32) -> anyhow::Result<()> {
     let path: PathBuf = file::get_schedule_path();
     let conn: Connection = Connection::open(path)?;
 
-    conn.execute(
-        "DELETE FROM Schedule WHERE ID = ?1",
-        params![id],
-    )?;
+    conn.execute("DELETE FROM Schedule WHERE ID = ?1", params![id])?;
     Ok(())
 }
 
 /// Adds a new schedule to the database
 pub fn add_schedule(user: String, cron: String, url: String) -> anyhow::Result<()> {
-    let schedule: Schedule = validate_schdule(Schedule{id: 0, user, cron, url})?;
+    let schedule: Schedule = validate_schdule(Schedule {
+        id: 0,
+        user,
+        cron,
+        url,
+    })?;
 
     create_db()?;
     let path: PathBuf = file::get_schedule_path();
@@ -77,9 +78,9 @@ pub fn add_schedule(user: String, cron: String, url: String) -> anyhow::Result<(
 pub fn get_schedule() -> anyhow::Result<Vec<Schedule>> {
     let path = file::get_schedule_path();
     let conn: Connection = Connection::open(path)?;
-    
+
     let mut stmt = conn.prepare("SELECT id, user, cron, url FROM Schedule")?;
-    let schedule_iter =stmt.query_map(params![], |row| {
+    let schedule_iter = stmt.query_map(params![], |row| {
         Ok(Schedule {
             id: row.get(0)?,
             user: row.get(1)?,
@@ -99,14 +100,14 @@ pub fn get_schedule() -> anyhow::Result<Vec<Schedule>> {
                     Err(e) => warn!("Database has invalid data, {} for ID {}", e, id),
                 }
             }
-            Err(e) => warn!("Invaid result from database, {}", e)
+            Err(e) => warn!("Invaid result from database, {}", e),
         }
     }
     Ok(schedules)
 }
 
 // Returns a Schedule if its valid, None if its not
-fn validate_schdule(schedule: Schedule) -> anyhow::Result<Schedule>{
+fn validate_schdule(schedule: Schedule) -> anyhow::Result<Schedule> {
     if Url::parse(&schedule.url).is_err() {
         return Err(anyhow!("Invalid schedule"));
     }

src/main.rs

@@ -301,8 +301,11 @@ fn jobs() -> anyhow::Result<()> {
     if total_jobs > 0 {
         println!("{:<5}{:<15}{:<25}{:<45}", "ID", "User", "Cron", "Url");
         println!("{:-<90}", "");
-        for job  in jobs {
-            println!("{:<5}{:<15}{:<25}{:<40}", job.id, job.user, job.cron, job.url);
+        for job in jobs {
+            println!(
+                "{:<5}{:<15}{:<25}{:<40}",
+                job.id, job.user, job.cron, job.url
+            );
         }
     }
     Ok(())