Merge pull request #21 from FeatureProbe/sync_once_func

feat: add sync_once func

Author: SSebo

Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 edition = "2021"
 name = "feature-probe-server-sdk"
-version = "1.2.7"
+version = "1.2.8"
 license = "Apache-2.0"
 authors = ["[email protected]"]
 description = "FeatureProbe Server Side SDK for Rust"

src/feature_probe.rs

@@ -7,6 +7,8 @@ use std::fmt::Debug;
 use std::sync::Arc;
 use tracing::trace;
 
+#[cfg(all(feature = "use_tokio", feature = "realtime"))]
+use crate::sync::SyncType;
 use crate::{
     config::Config,
     evaluate::{EvalDetail, Repository},
@@ -248,6 +250,18 @@ impl FeatureProbe {
         syncer.start_sync(self.config.start_wait, self.should_stop.clone());
     }
 
+    #[cfg(all(feature = "use_tokio", feature = "realtime"))]
+    pub fn sync_now(&self, t: SyncType) {
+        trace!("sync now url {}", &self.config.toggles_url);
+        let syncer = match &self.syncer {
+            Some(syncer) => syncer.clone(),
+            None => return,
+        };
+        tokio::spawn(async move {
+            syncer.sync_now(t).await.expect("sync once error");
+        });
+    }
+
     #[cfg(all(feature = "use_tokio", feature = "realtime"))]
     fn connect_socket(&mut self) {
         let mut slf = self.clone();
@@ -297,8 +311,6 @@ impl FeatureProbe {
 
     #[cfg(all(feature = "use_tokio", feature = "realtime"))]
     fn socket_on_update(slf: Self, payload: Option<socketio_rs::Payload>) -> SocketCallback {
-        use crate::sync::SyncType;
-
         trace!("socket_on_update: {:?}", payload);
         async move {
             if let Some(syncer) = &slf.syncer {

tests/integration_test.rs

@@ -35,7 +35,8 @@ async fn integration_test() {
     };
 
     let mut fp = FeatureProbe::new(config);
-
+    #[cfg(all(feature = "use_tokio", feature = "realtime"))]
+    fp.sync_now(SyncType::Polling);
     let did_update = {
         let did_update = Arc::new(Mutex::new((false, false)));
         let did_update_clone = did_update.clone();