steffo/todocolors
steffo/todocolors
1
Fork 0
mirror of https://github.com/Steffo99/todocolors.git synced 2024-11-25 01:34:18 +00:00
Code Activity

Implement BoardOperation::store_or_500

Browse source
This commit is contained in:
Steffo 2023-07-31 12:32:55 +02:00
parent 93a0dc65b6
commit 345d59268d
Signed by: steffo
GPG key ID: 2A24051445686895
1 changed files with 14 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
todored/src/op.rs
View file

@ -27,22 +27,27 @@ impl ClientOperation {
} }
impl BoardOperation { impl BoardOperation {
fn store(&self, rconn: redis::aio::Connection, board: &str) -> Result<()> { /// Store this in Redis.
pub(crate) async fn store_or_500(&self, rconn: &mut redis::aio::Connection, board: &str) -> Result<String> {
log::debug!("Storing BoardOperation in Redis: {:?}", &self); log::debug!("Storing BoardOperation in Redis: {:?}", &self);
log::trace!("Serializing BoardOperation to JSON...");
let data = serde_json::ser::to_string(self)
.expect_or_500_and_log("Failed to serialize BoardOperation");
log::trace!("Computing Redis key..."); log::trace!("Computing Redis key...");
let stream_key = format!("board:{{{board}}}:stream"); let stream_key = format!("board:{{{board}}}:stream");
log::trace!("Serializing BoardOperation to JSON...");
let operation = serde_json::ser::to_string(self)
.expect_or_500_and_log("Failed to serialize BoardOperation")?;
log::trace!("Adding to the Redis stream {stream_key:?}..."); log::trace!("Adding to the Redis stream {stream_key:?}...");
let response = redis::cmd("XADD") let id = redis::cmd("XADD")
.arg(stream_key) .arg(stream_key)
.arg() .arg("*")
.arg("operation")
.arg(operation)
.query_async::<redis::aio::Connection, String>(rconn).await
.expect_or_500_and_log("Failed to XADD to Redis")?;
log::trace!("Added to Redis stream with id {id:?}!");
Ok(()) Ok(id)
} }
} }