From ec940bb0681f1cd8ad6b2ee0acb20eed30a49013 Mon Sep 17 00:00:00 2001
From: naskya <m@naskya.net>
Date: Sun, 21 Apr 2024 22:43:09 +0900
Subject: [PATCH] chore (backend-rs): publish -> publish_to_stream
---
packages/backend-rs/src/service/add_note_to_antenna.rs | 4 ++--
packages/backend-rs/src/service/stream.rs | 8 ++++++--
2 files changed, 8 insertions(+), 4 deletions(-)
diff --git a/packages/backend-rs/src/service/add_note_to_antenna.rs b/packages/backend-rs/src/service/add_note_to_antenna.rs
index 4ba8856dc4..0509db9ccb 100644
--- a/packages/backend-rs/src/service/add_note_to_antenna.rs
+++ b/packages/backend-rs/src/service/add_note_to_antenna.rs
@@ -1,5 +1,5 @@
use crate::database::{redis_conn, redis_key};
-use crate::service::stream::{publish, Error, Stream};
+use crate::service::stream::{publish_to_stream, Error, Stream};
use crate::util::id::get_timestamp;
use redis::{streams::StreamMaxlen, Commands};
@@ -15,7 +15,7 @@ pub fn add_note_to_antenna(antenna_id: &str, note_id: &str) -> Result<(), Error>
let stream = Stream::Antenna {
id: antenna_id.to_string(),
};
- publish(
+ publish_to_stream(
&stream,
Some("note"),
Some(format!("{{ \"id\": \"{}\" }}", note_id)),
diff --git a/packages/backend-rs/src/service/stream.rs b/packages/backend-rs/src/service/stream.rs
index 6fbe699f44..e7d0cce628 100644
--- a/packages/backend-rs/src/service/stream.rs
+++ b/packages/backend-rs/src/service/stream.rs
@@ -42,7 +42,11 @@ pub enum Error {
ValueError(String),
}
-pub fn publish(channel: &Stream, kind: Option<&str>, value: Option<String>) -> Result<(), Error> {
+pub fn publish_to_stream(
+ stream: &Stream,
+ kind: Option<&str>,
+ value: Option<String>,
+) -> Result<(), Error> {
let message = if let Some(kind) = kind {
format!(
"{{ \"type\": \"{}\", \"body\": {} }}",
@@ -60,7 +64,7 @@ pub fn publish(channel: &Stream, kind: Option<&str>, value: Option<String>) -> R
&CONFIG.host,
format!(
"{{ \"channel\": \"{}\", \"message\": {} }}",
- channel, message,
+ stream, message,
),
)?;