spacebar/rust-nex
Watch
14
1
Fork
You've already forked rust-nex
 1
Code Issues Pull requests Projects Releases Packages 60 Wiki Activity Actions

fix datastore

Browse source
This commit is contained in:
Maple Nebel 2026-07-14 20:26:41 +02:00
commit 055b2e196a
2 changed files with 8 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

10
rnex-server-nex-modules/rnex-ds/src/datastore.rs
View file

@ -348,7 +348,11 @@ impl DatastoreUser {
} }
#[instrument] #[instrument]
async fn init_object_rating_slot(&self, data_id: i64, rating_param: RatingInitParamWithSlot) { async fn init_object_rating_slot(
&self,
data_id: i64,
rating_param: RatingInitParamWithSlot,
) -> Result<(), ErrorCode> {
info!("running init object rating slot"); info!("running init object rating slot");
sqlx::query!( sqlx::query!(
r#" r#"
@ -843,7 +847,7 @@ impl DataStore for DatastoreUser {
for rating_param in &postparam.rating_init_params { for rating_param in &postparam.rating_init_params {
info!("running init params"); info!("running init params");
self.init_object_rating_slot(data_id, rating_param.clone()) self.init_object_rating_slot(data_id, rating_param.clone())
.await .await?;
} }
let key = format!("data/{}.bin", data_id); let key = format!("data/{}.bin", data_id);
@ -1299,7 +1303,7 @@ impl DataStore for DatastoreUser {
for rating_param in &param.post_param.rating_init_params { for rating_param in &param.post_param.rating_init_params {
info!("running init params"); info!("running init params");
self.init_object_rating_slot(data_id, rating_param.clone()) self.init_object_rating_slot(data_id, rating_param.clone())
.await .await?;
} }
let key = format!("data/{}.jpg", data_id); let key = format!("data/{}.jpg", data_id);

2
rnex-server/src/lib.rs
View file

@ -353,7 +353,7 @@ pub async fn with_setup(f: impl AsyncFnOnce() -> anyhow::Result<()>) {
.with(tracing_subscriber::fmt::layer().with_filter( .with(tracing_subscriber::fmt::layer().with_filter(
tracing_subscriber::filter::FilterFn::new(|m| { tracing_subscriber::filter::FilterFn::new(|m| {
!m.module_path().is_some_and(|m| { !m.module_path().is_some_and(|m| {
(m.starts_with("h2") | m.starts_with("reqwest") | m.starts_with("hyper_util")) m.starts_with("h2") | m.starts_with("reqwest") | m.starts_with("hyper_util")
}) || (*m.level() <= Level::INFO) }) || (*m.level() <= Level::INFO)
}), }),
)) ))