Sqlite database now gets the session_timestamp from the history sessi…

…on id

examples/demo.rs

@@ -37,7 +37,6 @@ fn main() -> std::io::Result<()> {
         reedline::SqliteBackedHistory::with_file(
             "history.sqlite3".into(),
             history_session_id,
-            Some(chrono::Utc::now()),
         )
         .map_err(|e| std::io::Error::new(std::io::ErrorKind::Other, e))?,
     );

src/history/base.rs

@@ -218,6 +218,9 @@ pub trait History: Send {
     fn sync(&mut self) -> std::io::Result<()>;
     /// get the history session id
     fn session(&self) -> Option<HistorySessionId>;
+    // Dev comment: This has been implemented due to the `history session --set` command which couldn't get done so this is commented
+    // /// updates the history session id
+    // fn update_session(&mut self, history_session: Option<HistorySessionId>);
 }
 
 #[cfg(test)]
@@ -395,7 +398,7 @@ mod test {
         #[cfg(any(feature = "sqlite", feature = "sqlite-dynlib"))]
         fn open_history() -> Box<dyn History> {
             Box::new(
-                crate::SqliteBackedHistory::with_file("target/test-history.db".into(), None, None)
+                crate::SqliteBackedHistory::with_file("target/test-history.db".into(), None)
                     .unwrap(),
             )
         }

src/history/file_backed.rs

@@ -278,6 +278,10 @@ impl History for FileBackedHistory {
     fn session(&self) -> Option<HistorySessionId> {
         self.session
     }
+
+    // fn update_session(&mut self, history_session: Option<HistorySessionId>) {
+    //     self.session = history_session
+    // }
 }
 
 impl FileBackedHistory {

src/history/sqlite_backed.rs

@@ -176,6 +176,11 @@ impl History for SqliteBackedHistory {
     fn session(&self) -> Option<HistorySessionId> {
         self.session
     }
+
+    // fn update_session(&mut self, history_session: Option<HistorySessionId>) {
+    //     self.session = history_session;
+    //     self.session_timestamp = history_session.map(|hs| chrono::Utc.timestamp_nanos(hs.0))
+    // }
 }
 fn map_sqlite_err(err: rusqlite::Error) -> ReedlineError {
     // TODO: better error mapping
@@ -195,15 +200,14 @@ impl SqliteBackedHistory {
     pub fn with_file(
         file: PathBuf,
         session: Option<HistorySessionId>,
-        session_timestamp: Option<chrono::DateTime<Utc>>,
     ) -> Result<Self> {
         if let Some(base_dir) = file.parent() {
             std::fs::create_dir_all(base_dir).map_err(|e| {
                 ReedlineError(ReedlineErrorVariants::HistoryDatabaseError(format!("{e}")))
             })?;
         }
         let db = Connection::open(&file).map_err(map_sqlite_err)?;
-        Self::from_connection(db, session, session_timestamp)
+        Self::from_connection(db, session, session.map(|s| chrono::Utc.timestamp_nanos(s.0)))
     }
     /// Creates a new history in memory
     pub fn in_memory() -> Result<Self> {
@@ -357,6 +361,7 @@ impl SqliteBackedHistory {
                 wheres.push("exit_status != 0");
             }
         }
+
         if let (Some(session_id), Some(session_timestamp)) =
             (query.filter.session, self.session_timestamp)
         {
@@ -374,6 +379,7 @@ impl SqliteBackedHistory {
         if wheres.is_empty() {
             wheres = "true".to_string();
         }
+
         let query = format!(
             "SELECT {select_expression} \
              FROM history \