added more functionality to module

Author: nagarajm22

lib/ain-ocean/src/data_acces/script_activity.rs

@@ -1 +1,33 @@
+use crate::database::db_manger::ColumnFamilyOperations;
+use crate::database::db_manger::RocksDB;
+use crate::model::script_activity::ScriptActivity;
+use anyhow::{anyhow, Error, Result};
+use serde::{Deserialize, Serialize};
+use serde_json;
 
+pub struct ScriptUnspentDB {
+    pub db: RocksDB,
+}
+
+impl ScriptUnspentDB {
+    pub async fn query(&self, limit: i32, lt: String) -> Result<Vec<ScriptActivity>> {
+        todo!()
+    }
+    pub async fn store(&self, unspent: ScriptActivity) -> Result<()> {
+        match serde_json::to_string(&unspent) {
+            Ok(value) => {
+                let key = unspent.id.clone();
+                self.db
+                    .put("script_activity", key.as_bytes(), value.as_bytes())?;
+                Ok(())
+            }
+            Err(e) => Err(anyhow!(e)),
+        }
+    }
+    pub async fn delete(&self, id: String) -> Result<()> {
+        match self.db.delete("script_activity", id.as_bytes()) {
+            Ok(_) => Ok(()),
+            Err(e) => Err(anyhow!(e)),
+        }
+    }
+}

lib/ain-ocean/src/data_acces/script_aggregation.rs

@@ -1 +1,44 @@
+use crate::database::db_manger::ColumnFamilyOperations;
+use crate::database::db_manger::RocksDB;
+use crate::model::script_aggregation::ScriptAggregation;
+use anyhow::{anyhow, Error, Result};
+use serde::{Deserialize, Serialize};
+use serde_json;
 
+pub struct ScriptAggretionDB {
+    pub db: RocksDB,
+}
+
+impl ScriptAggretionDB {
+    pub async fn query(&self, limit: i32, lt: String) -> Result<Vec<ScriptAggregation>> {
+        todo!()
+    }
+    pub async fn store(&self, aggregation: ScriptAggregation) -> Result<()> {
+        match serde_json::to_string(&aggregation) {
+            Ok(value) => {
+                let key = aggregation.id.clone();
+                self.db
+                    .put("script_aggregation", key.as_bytes(), value.as_bytes())?;
+                Ok(())
+            }
+            Err(e) => Err(anyhow!(e)),
+        }
+    }
+    pub async fn get(&self, id: String) -> Result<Option<ScriptAggregation>> {
+        match self.db.get("script_aggregation", id.as_bytes()) {
+            Ok(Some(value)) => {
+                let oracle: ScriptAggregation =
+                    serde_json::from_slice(&value).map_err(|e| anyhow!(e))?;
+                Ok(Some(oracle))
+            }
+            Ok(None) => Ok(None),
+            Err(e) => Err(anyhow!(e)),
+        }
+    }
+    pub async fn delete(&self, id: String) -> Result<()> {
+        match self.db.delete("script_aggregation", id.as_bytes()) {
+            Ok(_) => Ok(()),
+            Err(e) => Err(anyhow!(e)),
+        }
+    }
+}

lib/ain-ocean/src/data_acces/script_unspent.rs

@@ -1 +1,33 @@
+use crate::database::db_manger::ColumnFamilyOperations;
+use crate::database::db_manger::RocksDB;
+use crate::model::script_unspent::ScriptUnspent;
+use anyhow::{anyhow, Error, Result};
+use serde::{Deserialize, Serialize};
+use serde_json;
 
+pub struct ScriptUnspentDB {
+    pub db: RocksDB,
+}
+
+impl ScriptUnspentDB {
+    pub async fn query(&self, limit: i32, lt: String) -> Result<Vec<ScriptUnspent>> {
+        todo!()
+    }
+    pub async fn store(&self, unspent: ScriptUnspent) -> Result<()> {
+        match serde_json::to_string(&unspent) {
+            Ok(value) => {
+                let key = unspent.id.clone();
+                self.db
+                    .put("script_unspent", key.as_bytes(), value.as_bytes())?;
+                Ok(())
+            }
+            Err(e) => Err(anyhow!(e)),
+        }
+    }
+    pub async fn delete(&self, id: String) -> Result<()> {
+        match self.db.delete("script_unspent", id.as_bytes()) {
+            Ok(_) => Ok(()),
+            Err(e) => Err(anyhow!(e)),
+        }
+    }
+}

lib/ain-ocean/src/data_acces/vault_auction_batch_history.rs

@@ -1 +1,41 @@
+use crate::database::db_manger::ColumnFamilyOperations;
+use crate::database::db_manger::RocksDB;
+use crate::model::vault_auction_batch_history::VaultAuctionBatchHistory;
+use anyhow::{anyhow, Error, Result};
+use serde::{Deserialize, Serialize};
+use serde_json;
 
+pub struct VaultAuctionDB {
+    pub db: RocksDB,
+}
+
+impl VaultAuctionDB {
+    pub async fn store(&self, auction: VaultAuctionBatchHistory) -> Result<()> {
+        match serde_json::to_string(&auction) {
+            Ok(value) => {
+                let key = auction.id.clone();
+                self.db
+                    .put("vault_auction_history", key.as_bytes(), value.as_bytes())?;
+                Ok(())
+            }
+            Err(e) => Err(anyhow!(e)),
+        }
+    }
+    pub async fn get(&self, id: String) -> Result<Option<VaultAuctionBatchHistory>> {
+        match self.db.get("vault_auction_history", id.as_bytes()) {
+            Ok(Some(value)) => {
+                let oracle: VaultAuctionBatchHistory =
+                    serde_json::from_slice(&value).map_err(|e| anyhow!(e))?;
+                Ok(Some(oracle))
+            }
+            Ok(None) => Ok(None),
+            Err(e) => Err(anyhow!(e)),
+        }
+    }
+    pub async fn delete(&self, id: String) -> Result<()> {
+        match self.db.delete("vault_auction_history", id.as_bytes()) {
+            Ok(_) => Ok(()),
+            Err(e) => Err(anyhow!(e)),
+        }
+    }
+}