Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 6 additions & 7 deletions src/api/handlers.rs
Original file line number Diff line number Diff line change
@@ -1,16 +1,15 @@
use std::{collections::HashMap, sync::atomic::Ordering};

use axum::{
Json, Router,
Json,
extract::{Path, State},
http::StatusCode,
routing::{get, post},
};
use log::{error, info};
use log::info;
use serde::{Deserialize, Serialize};

use crate::{api::state::AppState, job::get::get_jobs};
use crate::{job::JobScheme, status::JobStatusEnum};
use crate::job::JobScheme;
use crate::{
job::set::{add_job, remove_job},
status::get::get_status_log,
Expand Down Expand Up @@ -41,7 +40,7 @@ pub async fn jobs_status(State(state): State<AppState>) -> Json<JobsStatus> {

pub async fn jobs_start(
State(state): State<AppState>,
Json(payload): Json<Option<StartConfig>>,
Json(_payload): Json<Option<StartConfig>>,
) -> Result<Json<serde_json::Value>, StatusCode> {
// Prevent double-start
if state.started.swap(true, Ordering::Relaxed) {
Expand Down Expand Up @@ -147,7 +146,7 @@ impl From<&crate::status::JobStatusStruct> for JobResponse {
pub async fn jobs_list(
State(state): State<AppState>,
) -> Result<Json<Vec<JobResponse>>, StatusCode> {
let ap = state.auto_pilot.read().await;
let _ap = state.auto_pilot.read().await;

// ۱. تبدیل live_jobs به HashMap با کلیدِ id
// این‌ها اولویت بالاتری دارن (نسخه‌های زنده)
Expand Down Expand Up @@ -242,7 +241,7 @@ pub async fn jobs_delete(Path(id): Path<String>) -> Result<Json<serde_json::Valu

/// PUT /jobs/{id} - Update job by ID
pub async fn jobs_update(
State(state): State<AppState>,
State(_state): State<AppState>,
Path(id): Path<String>,
Json(payload): Json<JobScheme>,
) -> Result<Json<serde_json::Value>, StatusCode> {
Expand Down
1 change: 0 additions & 1 deletion src/api/state.rs
Original file line number Diff line number Diff line change
@@ -1,4 +1,3 @@
use axum::{Json, Router, extract::State, http::StatusCode, routing::get};
use serde::Serialize;
use std::sync::{Arc, atomic::AtomicBool};
use tokio::sync::RwLock;
Expand Down
3 changes: 1 addition & 2 deletions src/autopilot/mod.rs
Original file line number Diff line number Diff line change
@@ -1,5 +1,4 @@
use colored::Colorize;
use futures::future::join_all;
use log::{error, info, warn};
use tokio::task::JoinHandle;
use tokio_cron_scheduler::JobScheduler;
Expand Down Expand Up @@ -52,7 +51,7 @@ impl AutoPilot {

info!("{}", "Autopilot reloaded successfully!".green())
}
pub fn start(&mut self, verbose: bool) {
pub fn start(&mut self, _verbose: bool) {
// Self::prepare_logging(verbose);
if Self::check_instance() {
return;
Expand Down
2 changes: 1 addition & 1 deletion src/cli/list.rs
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ use crate::{
error::AutoPilotError,
fs::get_autopilot_path,
job::set::remove_job,
status::{get::get_status_log, set::set_status_initial},
status::get::get_status_log,
};

pub fn list() {
Expand Down
8 changes: 2 additions & 6 deletions src/cli/serve.rs
Original file line number Diff line number Diff line change
@@ -1,15 +1,11 @@
use std::{
sync::{Arc, atomic::AtomicBool},
thread::sleep,
time::Duration,
};
use std::sync::{Arc, atomic::AtomicBool};

use crate::{
api::{routes::start_api, state::AppState},
autopilot::AutoPilot,
status::set::set_status_initial,
};
use log::{error, info, warn};
use log::{error, warn};
use tokio::{self, signal, sync::RwLock};

pub async fn serve(verbose: bool, api: bool) {
Expand Down
4 changes: 2 additions & 2 deletions src/job/mod.rs
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
use std::{sync::Arc, thread::sleep, time::Duration};
use std::{thread::sleep, time::Duration};

use colored::Colorize;
use futures::future::join_all;
use log::{error, info};
use serde::{Deserialize, Serialize};
use tokio::{sync::RwLock, task::JoinHandle};
use tokio::task::JoinHandle;
use tokio_cron_scheduler::JobScheduler;

use crate::{
Expand Down
1 change: 0 additions & 1 deletion src/job/set.rs
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
use std::{collections::HashMap, path::PathBuf};

use serde_json::de;

use crate::{
conditions::ConditionScheme,
Expand Down
1 change: 0 additions & 1 deletion src/task/runner.rs
Original file line number Diff line number Diff line change
@@ -1,4 +1,3 @@
use log::error;

use crate::error::AutoPilotError;

Expand Down
1 change: 0 additions & 1 deletion src/time/add.rs
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@ use tokio_cron_scheduler::JobScheduler;
use crate::{
error::AutoPilotError,
job::Job,
status::JobStatusEnum,
time::{When, to_cron_expression},
};

Expand Down
Loading