replace OffsetDateTime with chrono

Cargo.toml

@@ -50,7 +50,7 @@ abi_stable = "0.11.1"
 activitypub_federation = "0.4.6"
 async-trait = "0.1.73"
 axum = { version = "0.6.20", features = ["ws", "headers"] }
-axum-test = "12.1.0"
+axum-test = "13.0.1"
 anyhow = "1.0.72"
 
 bytes = "1.4.0"

crates/common/Cargo.toml

@@ -25,6 +25,8 @@ axum.workspace = true
 http.workspace = true
 photos_network_plugin = { path = "../plugin_interface" }
 
+sqlx.workspace = true
+
 serde = { workspace = true, features = ["derive"] }
 serde_json.workspace = true
 serde_with.workspace = true

crates/common/src/auth/user.rs

@@ -16,19 +16,21 @@
  */
 
 use std::fmt;
-use time::OffsetDateTime;
+
+use sqlx::types::chrono::DateTime;
+use sqlx::types::chrono::Utc;
 
 #[derive(Clone, Debug, Eq, PartialEq)]
 pub struct User {
-    pub uuid: String, //Uuid,
+    pub uuid: String,
     pub email: String,
     pub password: Option<String>,
     pub lastname: Option<String>,
     pub firstname: Option<String>,
     pub is_locked: bool,
-    pub created_at: OffsetDateTime,
-    pub updated_at: Option<OffsetDateTime>,
-    pub last_login: Option<OffsetDateTime>,
+    pub created_at: DateTime<Utc>,
+    pub updated_at: Option<DateTime<Utc>>,
+    pub last_login: Option<DateTime<Utc>>,
 }
 
 impl fmt::Display for User {
@@ -50,7 +52,7 @@ impl User {
             lastname: Option::None,
             firstname: Option::None,
             is_locked: false,
-            created_at: OffsetDateTime::now_utc(),
+            created_at: Utc::now(),
             updated_at: Option::None,
             last_login: Option::None,
         }

crates/common/src/database/mod.rs

@@ -19,7 +19,9 @@ use std::sync::Arc;
 
 use anyhow::Result;
 use async_trait::async_trait;
-use time::OffsetDateTime;
+use sqlx::types::chrono::DateTime;
+
+use sqlx::types::chrono::Utc;
 
 use crate::auth::user::User;
 
@@ -59,7 +61,7 @@ pub trait Database {
         &self,
         user_id: &str,
         name: &str,
-        date_taken: OffsetDateTime,
+        date_taken: DateTime<Utc>,
     ) -> Result<String>;
     async fn get_media_item(&self, media_id: &str) -> Result<MediaItem>;
     async fn add_reference(

crates/common/src/database/reference.rs

@@ -15,14 +15,14 @@
  * along with this program.  If not, see <https://www.gnu.org/licenses/>.
  */
 
-use time::OffsetDateTime;
+use sqlx::types::chrono::{DateTime, Utc};
 
 pub struct Reference {
     pub uuid: String,
     pub filepath: String,
     pub filename: String,
     pub size: u64,
     pub description: &'static str,
-    pub last_modified: OffsetDateTime,
+    pub last_modified: DateTime<Utc>,
     pub is_missing: bool,
 }

crates/database/Cargo.toml

@@ -22,7 +22,7 @@ async-trait.workspace = true
 tracing.workspace = true
 uuid.workspace = true
 tokio.workspace = true
-sqlx = { workspace = true, features = ["runtime-tokio", "tls-native-tls", "postgres", "mysql", "sqlite", "any", "macros", "migrate", "time" ] }
+sqlx = { workspace = true, features = ["runtime-tokio", "tls-native-tls", "postgres", "mysql", "sqlite", "any", "macros", "migrate", "time", "chrono" ] }
 
 [dev-dependencies]
 pretty_assertions.workspace = true

crates/database/src/postgres.rs

@@ -23,7 +23,7 @@ use common::auth::user::User;
 use common::database::media_item::MediaItem;
 use common::database::reference::Reference;
 use common::database::Database;
-use sqlx::types::time::OffsetDateTime;
+use sqlx::types::chrono::{DateTime, Utc};
 use sqlx::PgPool;
 use sqlx::Row;
 use tracing::info;
@@ -63,7 +63,7 @@ impl Database for PostgresDatabase {
                 lastname: row.get("lastname"),
                 firstname: row.get("firstname"),
                 is_locked: false,
-                created_at: OffsetDateTime::now_utc(),
+                created_at: Utc::now(),
                 updated_at: None,
                 last_login: None,
             })
@@ -128,7 +128,7 @@ impl Database for PostgresDatabase {
         &self,
         user_id: &str,
         name: &str,
-        date_taken: OffsetDateTime,
+        date_taken: DateTime<Utc>,
     ) -> Result<String> {
         let query = "SELECT COUNT(*) FROM media WHERE owner is $1 and taken_at like $2";
         let res = sqlx::query(query).bind(user_id).bind(date_taken);
@@ -147,7 +147,7 @@ impl Database for PostgresDatabase {
                 .bind(user_id)
                 .bind(name)
                 .bind(false)
-                .bind(OffsetDateTime::now_utc())
+                .bind(Utc::now())
                 .bind(date_taken)
                 .execute(&self.pool)
                 .await?;

crates/database/src/sqlite.rs

@@ -24,7 +24,8 @@ use common::database::media_item::MediaItem;
 use common::database::reference::Reference;
 use common::database::Database;
 use sqlx::sqlite::SqliteQueryResult;
-use sqlx::types::time::OffsetDateTime;
+use sqlx::types::chrono::DateTime;
+use sqlx::types::chrono::Utc;
 use sqlx::Row;
 use sqlx::SqlitePool;
 use std::i64;
@@ -66,7 +67,7 @@ impl Database for SqliteDatabase {
                 lastname: row.get("lastname"),
                 firstname: row.get("firstname"),
                 is_locked: false,
-                created_at: OffsetDateTime::now_utc(),
+                created_at: Utc::now(),
                 updated_at: None,
                 last_login: None,
             })
@@ -128,7 +129,7 @@ impl Database for SqliteDatabase {
         &self,
         user_id: &str,
         name: &str,
-        date_taken: OffsetDateTime,
+        date_taken: DateTime<Utc>,
     ) -> Result<String> {
         struct Item {
             uuid: String,
@@ -159,7 +160,7 @@ impl Database for SqliteDatabase {
                     .bind(&user_id.to_string())
                     .bind(&name.to_string())
                     .bind(false)
-                    .bind(OffsetDateTime::now_utc())
+                    .bind(Utc::now())
                     .bind(date_taken)
                     .execute(&self.pool)
                     .await;
@@ -217,7 +218,6 @@ mod tests {
     use super::*;
     use std::path::PathBuf;
     use testdir::testdir;
-    use time::format_description::well_known::Rfc3339;
 
     #[sqlx::test]
     async fn create_user_should_succeed(pool: SqlitePool) -> Result<()> {
@@ -236,7 +236,7 @@ mod tests {
                 lastname: Some("Stuermer".into()),
                 firstname: Some("Benjamin".into()),
                 is_locked: false,
-                created_at: OffsetDateTime::now_utc(),
+                created_at: Utc::now(),
                 updated_at: None,
                 last_login: None,
             };
@@ -271,7 +271,7 @@ mod tests {
             lastname: Some("Stuermer".into()),
             firstname: Some("Benjamin".into()),
             is_locked: false,
-            created_at: OffsetDateTime::now_utc(),
+            created_at: Utc::now(),
             updated_at: None,
             last_login: None,
         };
@@ -415,7 +415,7 @@ mod tests {
         .await?;
 
         let name = "DSC_1234";
-        let date_taken = OffsetDateTime::now_utc();
+        let date_taken = Utc::now();
 
         // when
         let media_item_result = db.create_media_item(user_id, name, date_taken).await;
@@ -430,11 +430,14 @@ mod tests {
     #[sqlx::test]
     async fn create_media_item_should_return_existing_uuid(pool: SqlitePool) -> Result<()> {
         // given
-
         let user_id = "570DC079-664A-4496-BAA3-668C445A447";
         let media_id = "ef9ac799-02f3-4b3f-9d96-7576be0434e6";
-        let added_at = OffsetDateTime::parse("2023-02-03T13:37:01.234567Z", &Rfc3339).unwrap();
-        let taken_at = OffsetDateTime::parse("2023-01-01T13:37:01.234567Z", &Rfc3339).unwrap();
+        let added_at = "2023-02-03T13:37:01.234567Z"
+            .parse::<DateTime<Utc>>()
+            .unwrap();
+        let taken_at = "2023-01-01T13:37:01.234567Z"
+            .parse::<DateTime<Utc>>()
+            .unwrap();
         let name = "DSC_1234";
 
         // create fake user - used as FOREIGN KEY in media
@@ -477,8 +480,12 @@ mod tests {
         let user_id = "570DC079-664A-4496-BAA3-668C445A447";
         let media_id = "ef9ac799-02f3-4b3f-9d96-7576be0434e6";
         let reference_id = "ef9ac799-02f3-4b3f-9d96-7576be0434e6";
-        let added_at = OffsetDateTime::parse("2023-02-03T13:37:01.234567Z", &Rfc3339).unwrap();
-        let taken_at = OffsetDateTime::parse("2023-01-01T13:37:01.234567Z", &Rfc3339).unwrap();
+        let added_at = "2023-02-03T13:37:01.234567Z"
+            .parse::<DateTime<Utc>>()
+            .unwrap();
+        let taken_at = "2023-01-01T13:37:01.234567Z"
+            .parse::<DateTime<Utc>>()
+            .unwrap();
         // create fake user - used as FOREIGN KEY in reference
         sqlx::query("INSERT INTO users (uuid, email, password, lastname, firstname) VALUES ($1, $2, $3, $4, $5)")
             .bind(user_id)
@@ -514,7 +521,9 @@ mod tests {
             filename: filename.to_string(),
             size: metadata.len(),
             description: "",
-            last_modified: OffsetDateTime::parse("2023-02-03T13:37:01.234567Z", &Rfc3339).unwrap(),
+            last_modified: "2023-02-03T13:37:01.234567Z"
+                .parse::<DateTime<Utc>>()
+                .unwrap(),
             is_missing: false,
         };
 

crates/media/src/api/routes/post_media.rs

@@ -25,8 +25,7 @@ use axum::{
 };
 use common::auth::user::User;
 use serde::{Deserialize, Serialize};
-use time::format_description::well_known::Rfc3339;
-use time::OffsetDateTime;
+use sqlx::types::chrono::{DateTime, Utc};
 use tracing::{debug, info};
 use uuid::Uuid;
 
@@ -61,7 +60,7 @@ pub(crate) async fn post_media(
         return Err(StatusCode::BAD_REQUEST);
     }
 
-    let date = OffsetDateTime::parse(date_taken.unwrap().as_str(), &Rfc3339);
+    let date = date_taken.unwrap().parse::<DateTime<Utc>>();
     if date.is_err() {
         return Err(StatusCode::BAD_REQUEST);
     }