rustfmt
This commit is contained in:
parent
7f445a24e0
commit
9806a970da
@ -63,7 +63,5 @@ async fn main() {
|
|||||||
|
|
||||||
let worker = Worker { db, toggl_api };
|
let worker = Worker { db, toggl_api };
|
||||||
|
|
||||||
server::serve(
|
server::serve(worker).await.expect("Failed to start server")
|
||||||
worker
|
|
||||||
).await.expect("Failed to start server")
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -1,9 +1,13 @@
|
|||||||
use axum::{http::StatusCode, routing::{get, post}, Json, Router, Extension};
|
|
||||||
use axum::response::IntoResponse;
|
use axum::response::IntoResponse;
|
||||||
|
use axum::{
|
||||||
|
http::StatusCode,
|
||||||
|
routing::{get, post},
|
||||||
|
Extension, Json, Router,
|
||||||
|
};
|
||||||
use chrono::TimeDelta;
|
use chrono::TimeDelta;
|
||||||
|
|
||||||
use crate::AppError;
|
|
||||||
use crate::worker::Worker;
|
use crate::worker::Worker;
|
||||||
|
use crate::AppError;
|
||||||
|
|
||||||
async fn sync(Extension(worker): Extension<Worker>) -> Result<impl IntoResponse, AppError> {
|
async fn sync(Extension(worker): Extension<Worker>) -> Result<impl IntoResponse, AppError> {
|
||||||
worker.update(TimeDelta::days(30)).await?;
|
worker.update(TimeDelta::days(30)).await?;
|
||||||
|
|||||||
@ -143,10 +143,7 @@ impl Worker {
|
|||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
async fn update_time_entries_chunk(
|
async fn update_time_entries_chunk(&self, time_entries: &[TimeEntry]) -> Result<(), AppError> {
|
||||||
&self,
|
|
||||||
time_entries: &[TimeEntry],
|
|
||||||
) -> Result<(), AppError> {
|
|
||||||
let time_entries = Soa::from(time_entries);
|
let time_entries = Soa::from(time_entries);
|
||||||
|
|
||||||
sqlx::query!(
|
sqlx::query!(
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user