use config object instead of single val (#181)

Author: nikitos

Cargo.lock

@@ -70,11 +70,7 @@ impl Service {
                 None
             } else {
                 Some(Arc::new(HttpNotifier::new(
-                    httpnotifier.on_publish.clone(),
-                    httpnotifier.on_unpublish.clone(),
-                    httpnotifier.on_play.clone(),
-                    httpnotifier.on_stop.clone(),
-                    httpnotifier.on_hls.clone(),
+                    httpnotifier.clone(),
                     event_producer.clone(),
                 )))
             }

application/xiu/src/service.rs

@@ -26,6 +26,7 @@ serde_json = { version = "1", default-features = false, features = [
     "std",
 ] }
 serde = { version = "1.0", features = ["derive", "rc"] }
+config = { path = "../../library/config/" }
 
 bytesio = { path = "../../library/bytesio/" }
 xflv = { path = "../../library/container/flv/" }

library/streamhub/Cargo.toml

@@ -1,7 +1,8 @@
 use crate::notify::Notifier;
 use reqwest::Client;
 use async_trait::async_trait;
-use crate::define::{PublisherInfo, StreamHubEventMessage, StreamHubEventSender, StreamHubEvent};
+use crate::define::{StreamHubEventMessage, StreamHubEventSender, StreamHubEvent};
+use config::HttpNotifierConfig;
 
 macro_rules! serialize_event {
     ($message:expr) => {{
@@ -29,21 +30,16 @@ pub struct HttpNotifier {
 
 impl HttpNotifier {
     pub fn new(
-        on_publish_url: Option<String>,
-        on_unpublish_url: Option<String>,
-        on_play_url: Option<String>,
-        on_stop_url: Option<String>,
-        on_hls_url: Option<String>,
+        config: HttpNotifierConfig,
         event_producer: StreamHubEventSender,
-
     ) -> Self {
         Self {
             request_client: reqwest::Client::new(),
-            on_publish_url,
-            on_unpublish_url,
-            on_play_url,
-            on_stop_url,
-            on_hls_url,
+            on_publish_url: config.on_publish,
+            on_unpublish_url: config.on_unpublish,
+            on_play_url: config.on_play,
+            on_stop_url: config.on_stop,
+            on_hls_url: config.on_hls,
             event_producer,
         }
     }