stop using NativeDateTime

This is an ambiguous way to deal with time, DateTime<Utc> should be
prefered.

Author: MarinPostma

libsql-server/src/http/admin/mod.rs

@@ -4,7 +4,7 @@ use axum::extract::{FromRef, Path, State};
 use axum::middleware::Next;
 use axum::routing::delete;
 use axum::Json;
-use chrono::NaiveDateTime;
+use chrono::{DateTime, Utc};
 use futures::{SinkExt, StreamExt, TryStreamExt};
 use hyper::{Body, Request, StatusCode};
 use metrics_exporter_prometheus::{PrometheusBuilder, PrometheusHandle};
@@ -427,7 +427,7 @@ async fn handle_create_namespace<C: Connector>(
 
 #[derive(Debug, Deserialize)]
 struct ForkNamespaceReq {
-    timestamp: NaiveDateTime,
+    timestamp: DateTime<Utc>,
 }
 
 async fn handle_fork_namespace<C>(

libsql-server/src/namespace/configurator/libsql_primary.rs

@@ -3,6 +3,7 @@ use std::pin::Pin;
 use std::sync::atomic::{AtomicBool, Ordering};
 use std::sync::Arc;
 
+use chrono::{DateTime, Utc};
 use futures::prelude::Future;
 use libsql_sys::name::NamespaceResolver;
 use libsql_wal::io::StdIO;
@@ -267,7 +268,7 @@ impl ConfigureNamespace for LibsqlPrimaryConfigurator {
         _from_config: MetaStoreHandle,
         _to_ns: NamespaceName,
         _to_config: MetaStoreHandle,
-        _timestamp: Option<chrono::prelude::NaiveDateTime>,
+        timestamp: Option<DateTime<Utc>>,
         _store: NamespaceStore,
     ) -> Pin<Box<dyn Future<Output = crate::Result<Namespace>> + Send + 'a>> {
         unimplemented!()

libsql-server/src/namespace/configurator/libsql_replica.rs

@@ -2,6 +2,7 @@ use std::future::Future;
 use std::pin::Pin;
 use std::sync::Arc;
 
+use chrono::{DateTime, Utc};
 use hyper::Uri;
 use libsql_replication::injector::LibsqlInjector;
 use libsql_replication::replicator::Replicator;
@@ -265,7 +266,7 @@ impl ConfigureNamespace for LibsqlReplicaConfigurator {
         _from_config: MetaStoreHandle,
         _to_ns: NamespaceName,
         _to_config: MetaStoreHandle,
-        _timestamp: Option<chrono::prelude::NaiveDateTime>,
+        _timestamp: Option<DateTime<Utc>>,
         _store: NamespaceStore,
     ) -> Pin<Box<dyn Future<Output = crate::Result<Namespace>> + Send + 'a>> {
         Box::pin(std::future::ready(Err(crate::Error::Fork(

libsql-server/src/namespace/configurator/libsql_schema.rs

@@ -1,6 +1,7 @@
 use std::path::Path;
 use std::sync::Arc;
 
+use chrono::{DateTime, Utc};
 use futures::prelude::Future;
 use libsql_sys::name::NamespaceResolver;
 use libsql_wal::io::StdIO;
@@ -159,22 +160,13 @@ impl ConfigureNamespace for LibsqlSchemaConfigurator {
 
     fn fork<'a>(
         &'a self,
-        from_ns: &'a Namespace,
-        from_config: MetaStoreHandle,
-        to_ns: NamespaceName,
-        to_config: MetaStoreHandle,
-        timestamp: Option<chrono::prelude::NaiveDateTime>,
-        store: NamespaceStore,
+        _from_ns: &'a Namespace,
+        _from_config: MetaStoreHandle,
+        _to_ns: NamespaceName,
+        _to_config: MetaStoreHandle,
+        _timestamp: Option<DateTime<Utc>>,
+        _store: NamespaceStore,
     ) -> std::pin::Pin<Box<dyn Future<Output = crate::Result<Namespace>> + Send + 'a>> {
-        Box::pin(super::fork::fork(
-            from_ns,
-            from_config,
-            to_ns,
-            to_config,
-            timestamp,
-            store,
-            &self.primary_config,
-            self.base.base_path.clone(),
-        ))
+        todo!()
     }
 }

libsql-server/src/namespace/configurator/mod.rs

@@ -3,7 +3,7 @@ use std::pin::Pin;
 use std::sync::Arc;
 use std::time::Duration;
 
-use chrono::NaiveDateTime;
+use chrono::{DateTime, Utc};
 use futures::Future;
 use libsql_sys::EncryptionConfig;
 use tokio::sync::Semaphore;
@@ -139,7 +139,7 @@ pub trait ConfigureNamespace {
         from_config: MetaStoreHandle,
         to_ns: NamespaceName,
         to_config: MetaStoreHandle,
-        timestamp: Option<NaiveDateTime>,
+        timestamp: Option<DateTime<Utc>>,
         store: NamespaceStore,
     ) -> Pin<Box<dyn Future<Output = crate::Result<Namespace>> + Send + 'a>>;
 }

libsql-server/src/namespace/configurator/primary.rs

@@ -3,6 +3,7 @@ use std::pin::Pin;
 use std::sync::atomic::{AtomicBool, Ordering};
 use std::sync::Arc;
 
+use chrono::{DateTime, Utc};
 use futures::prelude::Future;
 use libsql_sys::EncryptionConfig;
 use tokio::task::JoinSet;
@@ -184,15 +185,15 @@ impl ConfigureNamespace for PrimaryConfigurator {
         from_config: MetaStoreHandle,
         to_ns: NamespaceName,
         to_config: MetaStoreHandle,
-        timestamp: Option<chrono::prelude::NaiveDateTime>,
+        timestamp: Option<DateTime<Utc>>,
         store: NamespaceStore,
     ) -> Pin<Box<dyn Future<Output = crate::Result<Namespace>> + Send + 'a>> {
         Box::pin(super::fork::fork(
             from_ns,
             from_config,
             to_ns,
             to_config,
-            timestamp,
+            timestamp.map(|d| d.naive_utc()),
             store,
             &self.primary_config,
             self.base.base_path.clone(),

libsql-server/src/namespace/configurator/schema.rs

@@ -1,5 +1,6 @@
 use std::sync::{atomic::AtomicBool, Arc};
 
+use chrono::{DateTime, Utc};
 use futures::prelude::Future;
 use tokio::task::JoinSet;
 
@@ -120,15 +121,15 @@ impl ConfigureNamespace for SchemaConfigurator {
         from_config: MetaStoreHandle,
         to_ns: NamespaceName,
         to_config: MetaStoreHandle,
-        timestamp: Option<chrono::prelude::NaiveDateTime>,
+        timestamp: Option<DateTime<Utc>>,
         store: NamespaceStore,
     ) -> std::pin::Pin<Box<dyn Future<Output = crate::Result<Namespace>> + Send + 'a>> {
         Box::pin(super::fork::fork(
             from_ns,
             from_config,
             to_ns,
             to_config,
-            timestamp,
+            timestamp.map(|ts| ts.naive_utc()),
             store,
             &self.primary_config,
             self.base.base_path.clone(),

libsql-server/src/namespace/store.rs

@@ -2,7 +2,7 @@ use std::sync::atomic::{AtomicBool, Ordering};
 use std::sync::Arc;
 
 use async_lock::RwLock;
-use chrono::NaiveDateTime;
+use chrono::{DateTime, Utc};
 use futures::TryFutureExt;
 use moka::future::Cache;
 use once_cell::sync::OnceCell;
@@ -219,7 +219,7 @@ impl NamespaceStore {
         from: NamespaceName,
         to: NamespaceName,
         to_config: DatabaseConfig,
-        timestamp: Option<NaiveDateTime>,
+        timestamp: Option<DateTime<Utc>>,
     ) -> crate::Result<()> {
         if self.inner.has_shutdown.load(Ordering::Relaxed) {
             return Err(Error::NamespaceStoreShutdown);