redb_store.rs 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386
  1. use std::collections::HashMap;
  2. use std::str::FromStr;
  3. use std::sync::Arc;
  4. use async_trait::async_trait;
  5. use cashu::nuts::{Id, KeySetInfo, Keys, MintInfo, Proofs};
  6. use cashu::types::{MeltQuote, MintQuote};
  7. use cashu::url::UncheckedUrl;
  8. use redb::{
  9. Database, MultimapTableDefinition, ReadableMultimapTable, ReadableTable, TableDefinition,
  10. };
  11. use tokio::sync::Mutex;
  12. use super::{Error, LocalStore};
  13. const MINTS_TABLE: TableDefinition<&str, &str> = TableDefinition::new("mints_table");
  14. const MINT_KEYSETS_TABLE: MultimapTableDefinition<&str, &str> =
  15. MultimapTableDefinition::new("mint_keysets");
  16. const MINT_QUOTES_TABLE: TableDefinition<&str, &str> = TableDefinition::new("mint_quotes");
  17. const MELT_QUOTES_TABLE: TableDefinition<&str, &str> = TableDefinition::new("melt_quotes");
  18. const MINT_KEYS_TABLE: TableDefinition<&str, &str> = TableDefinition::new("mint_keys");
  19. const PROOFS_TABLE: MultimapTableDefinition<&str, &str> = MultimapTableDefinition::new("proofs");
  20. const PENDING_PROOFS_TABLE: MultimapTableDefinition<&str, &str> =
  21. MultimapTableDefinition::new("pending_proofs");
  22. #[derive(Debug, Clone)]
  23. pub struct RedbLocalStore {
  24. db: Arc<Mutex<Database>>,
  25. }
  26. impl RedbLocalStore {
  27. pub fn new(path: &str) -> Result<Self, Error> {
  28. let db = Database::create(path)?;
  29. let write_txn = db.begin_write()?;
  30. {
  31. let _ = write_txn.open_table(MINTS_TABLE)?;
  32. let _ = write_txn.open_multimap_table(MINT_KEYSETS_TABLE)?;
  33. let _ = write_txn.open_table(MINT_QUOTES_TABLE)?;
  34. let _ = write_txn.open_table(MELT_QUOTES_TABLE)?;
  35. let _ = write_txn.open_table(MINT_KEYS_TABLE)?;
  36. let _ = write_txn.open_multimap_table(PROOFS_TABLE)?;
  37. }
  38. write_txn.commit()?;
  39. Ok(Self {
  40. db: Arc::new(Mutex::new(db)),
  41. })
  42. }
  43. }
  44. #[async_trait(?Send)]
  45. impl LocalStore for RedbLocalStore {
  46. async fn add_mint(
  47. &self,
  48. mint_url: UncheckedUrl,
  49. mint_info: Option<MintInfo>,
  50. ) -> Result<(), Error> {
  51. let db = self.db.lock().await;
  52. let write_txn = db.begin_write()?;
  53. {
  54. let mut table = write_txn.open_table(MINTS_TABLE)?;
  55. table.insert(
  56. mint_url.to_string().as_str(),
  57. serde_json::to_string(&mint_info)?.as_str(),
  58. )?;
  59. }
  60. write_txn.commit()?;
  61. Ok(())
  62. }
  63. async fn get_mint(&self, mint_url: UncheckedUrl) -> Result<Option<MintInfo>, Error> {
  64. let db = self.db.lock().await;
  65. let read_txn = db.begin_read()?;
  66. let table = read_txn.open_table(MINTS_TABLE)?;
  67. if let Some(mint_info) = table.get(mint_url.to_string().as_str())? {
  68. return Ok(serde_json::from_str(mint_info.value())?);
  69. }
  70. Ok(None)
  71. }
  72. async fn get_mints(&self) -> Result<HashMap<UncheckedUrl, Option<MintInfo>>, Error> {
  73. let db = self.db.lock().await;
  74. let read_txn = db.begin_read()?;
  75. let table = read_txn.open_table(MINTS_TABLE)?;
  76. let mints = table
  77. .iter()?
  78. .flatten()
  79. .map(|(mint, mint_info)| {
  80. (
  81. UncheckedUrl::from_str(mint.value()).unwrap(),
  82. serde_json::from_str(mint_info.value()).ok(),
  83. )
  84. })
  85. .collect();
  86. Ok(mints)
  87. }
  88. async fn add_mint_keysets(
  89. &self,
  90. mint_url: UncheckedUrl,
  91. keysets: Vec<KeySetInfo>,
  92. ) -> Result<(), Error> {
  93. let db = self.db.lock().await;
  94. let write_txn = db.begin_write()?;
  95. {
  96. let mut table = write_txn.open_multimap_table(MINT_KEYSETS_TABLE)?;
  97. for keyset in keysets {
  98. table.insert(
  99. mint_url.to_string().as_str(),
  100. serde_json::to_string(&keyset)?.as_str(),
  101. )?;
  102. }
  103. }
  104. write_txn.commit()?;
  105. Ok(())
  106. }
  107. async fn get_mint_keysets(
  108. &self,
  109. mint_url: UncheckedUrl,
  110. ) -> Result<Option<Vec<KeySetInfo>>, Error> {
  111. let db = self.db.lock().await;
  112. let read_txn = db.begin_read()?;
  113. let table = read_txn.open_multimap_table(MINT_KEYSETS_TABLE)?;
  114. let keysets = table
  115. .get(mint_url.to_string().as_str())?
  116. .flatten()
  117. .flat_map(|k| serde_json::from_str(k.value()))
  118. .collect();
  119. Ok(keysets)
  120. }
  121. async fn add_mint_quote(&self, quote: MintQuote) -> Result<(), Error> {
  122. let db = self.db.lock().await;
  123. let write_txn = db.begin_write()?;
  124. {
  125. let mut table = write_txn.open_table(MINT_QUOTES_TABLE)?;
  126. table.insert(quote.id.as_str(), serde_json::to_string(&quote)?.as_str())?;
  127. }
  128. write_txn.commit()?;
  129. Ok(())
  130. }
  131. async fn get_mint_quote(&self, quote_id: &str) -> Result<Option<MintQuote>, Error> {
  132. let db = self.db.lock().await;
  133. let read_txn = db.begin_read()?;
  134. let table = read_txn.open_table(MINT_QUOTES_TABLE)?;
  135. if let Some(mint_info) = table.get(quote_id)? {
  136. return Ok(serde_json::from_str(mint_info.value())?);
  137. }
  138. Ok(None)
  139. }
  140. async fn remove_mint_quote(&self, quote_id: &str) -> Result<(), Error> {
  141. let db = self.db.lock().await;
  142. let write_txn = db.begin_write()?;
  143. {
  144. let mut table = write_txn.open_table(MINT_QUOTES_TABLE)?;
  145. table.remove(quote_id)?;
  146. }
  147. write_txn.commit()?;
  148. Ok(())
  149. }
  150. async fn add_melt_quote(&self, quote: MeltQuote) -> Result<(), Error> {
  151. let db = self.db.lock().await;
  152. let write_txn = db.begin_write()?;
  153. {
  154. let mut table = write_txn.open_table(MELT_QUOTES_TABLE)?;
  155. table.insert(quote.id.as_str(), serde_json::to_string(&quote)?.as_str())?;
  156. }
  157. write_txn.commit()?;
  158. Ok(())
  159. }
  160. async fn get_melt_quote(&self, quote_id: &str) -> Result<Option<MeltQuote>, Error> {
  161. let db = self.db.lock().await;
  162. let read_txn = db.begin_read()?;
  163. let table = read_txn.open_table(MELT_QUOTES_TABLE)?;
  164. if let Some(mint_info) = table.get(quote_id)? {
  165. return Ok(serde_json::from_str(mint_info.value())?);
  166. }
  167. Ok(None)
  168. }
  169. async fn remove_melt_quote(&self, quote_id: &str) -> Result<(), Error> {
  170. let db = self.db.lock().await;
  171. let write_txn = db.begin_write()?;
  172. {
  173. let mut table = write_txn.open_table(MELT_QUOTES_TABLE)?;
  174. table.remove(quote_id)?;
  175. }
  176. write_txn.commit()?;
  177. Ok(())
  178. }
  179. async fn add_keys(&self, keys: Keys) -> Result<(), Error> {
  180. let db = self.db.lock().await;
  181. let write_txn = db.begin_write()?;
  182. {
  183. let mut table = write_txn.open_table(MINT_KEYS_TABLE)?;
  184. table.insert(
  185. Id::from(&keys).to_string().as_str(),
  186. serde_json::to_string(&keys)?.as_str(),
  187. )?;
  188. }
  189. write_txn.commit()?;
  190. Ok(())
  191. }
  192. async fn get_keys(&self, id: &Id) -> Result<Option<Keys>, Error> {
  193. let db = self.db.lock().await;
  194. let read_txn = db.begin_read()?;
  195. let table = read_txn.open_table(MINT_KEYS_TABLE)?;
  196. if let Some(mint_info) = table.get(id.to_string().as_str())? {
  197. return Ok(serde_json::from_str(mint_info.value())?);
  198. }
  199. Ok(None)
  200. }
  201. async fn remove_keys(&self, id: &Id) -> Result<(), Error> {
  202. let db = self.db.lock().await;
  203. let write_txn = db.begin_write()?;
  204. {
  205. let mut table = write_txn.open_table(MINT_KEYS_TABLE)?;
  206. table.remove(id.to_string().as_str())?;
  207. }
  208. write_txn.commit()?;
  209. Ok(())
  210. }
  211. async fn add_proofs(&self, mint_url: UncheckedUrl, proofs: Proofs) -> Result<(), Error> {
  212. let db = self.db.lock().await;
  213. let write_txn = db.begin_write()?;
  214. {
  215. let mut table = write_txn.open_multimap_table(PROOFS_TABLE)?;
  216. for proof in proofs {
  217. table.insert(
  218. mint_url.to_string().as_str(),
  219. serde_json::to_string(&proof)?.as_str(),
  220. )?;
  221. }
  222. }
  223. write_txn.commit()?;
  224. Ok(())
  225. }
  226. async fn get_proofs(&self, mint_url: UncheckedUrl) -> Result<Option<Proofs>, Error> {
  227. let db = self.db.lock().await;
  228. let read_txn = db.begin_read()?;
  229. let table = read_txn.open_multimap_table(PROOFS_TABLE)?;
  230. let proofs = table
  231. .get(mint_url.to_string().as_str())?
  232. .flatten()
  233. .flat_map(|k| serde_json::from_str(k.value()))
  234. .collect();
  235. Ok(proofs)
  236. }
  237. async fn remove_proofs(&self, mint_url: UncheckedUrl, proofs: &Proofs) -> Result<(), Error> {
  238. let db = self.db.lock().await;
  239. let write_txn = db.begin_write()?;
  240. {
  241. let mut table = write_txn.open_multimap_table(PROOFS_TABLE)?;
  242. for proof in proofs {
  243. table.remove(
  244. mint_url.to_string().as_str(),
  245. serde_json::to_string(&proof)?.as_str(),
  246. )?;
  247. }
  248. }
  249. write_txn.commit()?;
  250. Ok(())
  251. }
  252. async fn add_pending_proofs(
  253. &self,
  254. mint_url: UncheckedUrl,
  255. proofs: Proofs,
  256. ) -> Result<(), Error> {
  257. let db = self.db.lock().await;
  258. let write_txn = db.begin_write()?;
  259. {
  260. let mut table = write_txn.open_multimap_table(PENDING_PROOFS_TABLE)?;
  261. for proof in proofs {
  262. table.insert(
  263. mint_url.to_string().as_str(),
  264. serde_json::to_string(&proof)?.as_str(),
  265. )?;
  266. }
  267. }
  268. write_txn.commit()?;
  269. Ok(())
  270. }
  271. async fn get_pending_proofs(&self, mint_url: UncheckedUrl) -> Result<Option<Proofs>, Error> {
  272. let db = self.db.lock().await;
  273. let read_txn = db.begin_read()?;
  274. let table = read_txn.open_multimap_table(PENDING_PROOFS_TABLE)?;
  275. let proofs = table
  276. .get(mint_url.to_string().as_str())?
  277. .flatten()
  278. .flat_map(|k| serde_json::from_str(k.value()))
  279. .collect();
  280. Ok(proofs)
  281. }
  282. async fn remove_pending_proofs(
  283. &self,
  284. mint_url: UncheckedUrl,
  285. proofs: &Proofs,
  286. ) -> Result<(), Error> {
  287. let db = self.db.lock().await;
  288. let write_txn = db.begin_write()?;
  289. {
  290. let mut table = write_txn.open_multimap_table(PENDING_PROOFS_TABLE)?;
  291. for proof in proofs {
  292. table.remove(
  293. mint_url.to_string().as_str(),
  294. serde_json::to_string(&proof)?.as_str(),
  295. )?;
  296. }
  297. }
  298. write_txn.commit()?;
  299. Ok(())
  300. }
  301. }