Ecosystem/serai
Ecosystem/serai
1
0
Fork 0
mirror of https://github.com/serai-dex/serai.git synced 2025-01-03 17:40:34 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Use pub(crate) for create_db items, not pub

Browse source
This commit is contained in:
Luke Parker 2023-12-18 11:09:16 -05:00
parent c8747e23c5
commit a4c82632fb
No known key found for this signature in database
2 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
common/db/src/create_db.rs
View file

@ -42,9 +42,9 @@ macro_rules! create_db {
}) => { }) => {
$( $(
#[derive(Clone, Debug)] #[derive(Clone, Debug)]
pub struct $field_name; pub(crate) struct $field_name;
impl $field_name { impl $field_name {
pub fn key($($arg: $arg_type),*) -> Vec<u8> { pub(crate) fn key($($arg: $arg_type),*) -> Vec<u8> {
use scale::Encode; use scale::Encode;
$crate::serai_db_key( $crate::serai_db_key(
stringify!($db_name).as_bytes(), stringify!($db_name).as_bytes(),
@ -52,17 +52,17 @@ macro_rules! create_db {
($($arg),*).encode() ($($arg),*).encode()
) )
} }
pub fn set(txn: &mut impl DbTxn $(, $arg: $arg_type)*, data: &$field_type) { pub(crate) fn set(txn: &mut impl DbTxn $(, $arg: $arg_type)*, data: &$field_type) {
let key = $field_name::key($($arg),*); let key = $field_name::key($($arg),*);
txn.put(&key, borsh::to_vec(data).unwrap()); txn.put(&key, borsh::to_vec(data).unwrap());
} }
pub fn get(getter: &impl Get, $($arg: $arg_type),*) -> Option<$field_type> { pub(crate) fn get(getter: &impl Get, $($arg: $arg_type),*) -> Option<$field_type> {
getter.get($field_name::key($($arg),*)).map(|data| { getter.get($field_name::key($($arg),*)).map(|data| {
borsh::from_slice(data.as_ref()).unwrap() borsh::from_slice(data.as_ref()).unwrap()
}) })
} }
#[allow(dead_code)] #[allow(dead_code)]
pub fn del(txn: &mut impl DbTxn $(, $arg: $arg_type)*) { pub(crate) fn del(txn: &mut impl DbTxn $(, $arg: $arg_type)*) {
txn.del(&$field_name::key($($arg),*)) txn.del(&$field_name::key($($arg),*))
} }
} }
@ -83,7 +83,7 @@ macro_rules! db_channel {
} }
impl $field_name { impl $field_name {
pub fn send(txn: &mut impl DbTxn $(, $arg: $arg_type)*, value: &$field_type) { pub(crate) fn send(txn: &mut impl DbTxn $(, $arg: $arg_type)*, value: &$field_type) {
// Use index 0 to store the amount of messages // Use index 0 to store the amount of messages
let messages_sent_key = $field_name::key($($arg),*, 0); let messages_sent_key = $field_name::key($($arg),*, 0);
let messages_sent = txn.get(&messages_sent_key).map(|counter| { let messages_sent = txn.get(&messages_sent_key).map(|counter| {
@ -98,7 +98,7 @@ macro_rules! db_channel {
$field_name::set(txn, $($arg),*, index_to_use, value); $field_name::set(txn, $($arg),*, index_to_use, value);
} }
pub fn try_recv(txn: &mut impl DbTxn $(, $arg: $arg_type)*) -> Option<$field_type> { pub(crate) fn try_recv(txn: &mut impl DbTxn $(, $arg: $arg_type)*) -> Option<$field_type> {
let messages_recvd_key = $field_name::key($($arg),*, 1); let messages_recvd_key = $field_name::key($($arg),*, 1);
let messages_recvd = txn.get(&messages_recvd_key).map(|counter| { let messages_recvd = txn.get(&messages_recvd_key).map(|counter| {
u32::from_le_bytes(counter.try_into().unwrap()) u32::from_le_bytes(counter.try_into().unwrap())

2
coordinator/src/substrate/db.rs
View file

@ -13,7 +13,7 @@ mod inner_db {
} }
); );
} }
pub use inner_db::{NextBlock, BatchInstructionsHashDb}; pub(crate) use inner_db::{NextBlock, BatchInstructionsHashDb};
pub struct HandledEvent; pub struct HandledEvent;
impl HandledEvent { impl HandledEvent {