create CallbackInfo and its tests

src/db/callback_info.rs

@@ -0,0 +1,57 @@
+use crate::query_call;
+use crate::CallDB;
+use bson::oid::ObjectId;
+use serde::{Deserialize, Serialize};
+
+use super::DbResult;
+use bson::doc;
+
+#[derive(Serialize, Deserialize, Default)]
+pub struct CallbackInfo<C>
+where
+    C: Serialize,
+{
+    pub _id: bson::oid::ObjectId,
+    #[serde(flatten)]
+    pub callback: C,
+}
+
+impl<C> CallbackInfo<C>
+where
+    C: Serialize + for<'a> Deserialize<'a> + Send + Sync,
+{
+    pub fn new(callback: C) -> Self {
+        Self {
+            _id: Default::default(),
+            callback,
+        }
+    }
+
+    pub fn get_id(&self) -> String {
+        self._id.to_hex()
+    }
+
+    query_call!(store, self, db, (), {
+        let db = db.get_database().await;
+        let ci = db.collection::<Self>("callback_info");
+
+        ci.insert_one(self).await?;
+
+        Ok(())
+    });
+
+    pub async fn get<D: CallDB>(db: &mut D, id: &str) -> DbResult<Option<Self>> {
+        let db = db.get_database().await;
+        let ci = db.collection::<Self>("callback_info");
+
+        let id = match ObjectId::parse_str(id) {
+            Ok(id) => id,
+            Err(_) => return Ok(None),
+        };
+
+        ci.find_one(doc! {
+            "_id": id
+        })
+        .await
+    }
+}

src/db/mod.rs

@@ -1,3 +1,5 @@
+pub mod callback_info;
+
 use async_trait::async_trait;
 use chrono::{DateTime, Utc};
 use enum_stringify::EnumStringify;

src/db/tests/callback_info_tests.rs

@@ -0,0 +1,28 @@
+use super::super::{callback_info::CallbackInfo, CallDB, DB};
+use super::setup_db;
+
+use serde::{Deserialize, Serialize};
+
+#[derive(Serialize, Deserialize, Default)]
+#[serde(tag = "type")]
+#[serde(rename = "snake_case")]
+pub enum Callback {
+    #[default]
+    MoreInfo,
+    NextPage,
+}
+
+type CI = CallbackInfo<Callback>;
+
+#[tokio::test]
+async fn test_store() {
+    let mut db = setup_db().await;
+
+    let ci = CI::new(Default::default());
+
+    ci.store(&mut db).await.unwrap();
+
+    let ci = CI::get(&mut db, &ci.get_id()).await.unwrap();
+
+    assert!(ci.is_some());
+}

src/db/tests/mod.rs

@@ -1,5 +1,6 @@
 #![allow(clippy::unwrap_used)]
 
+mod callback_info_tests;
 use dotenvy;
 
 use super::CallDB;