点赞和改造开关加入后台配置

server-rs/crates/api-server/src/state.rs

@@ -559,6 +559,44 @@ impl AppState {
         }
     }
 
+    /// 通过 SpacetimeDB 保存公开作品互动配置，并同步测试缓存。
+    pub async fn upsert_public_work_interaction_config(
+        &self,
+        input: module_runtime::PublicWorkInteractionConfigAdminUpsertInput,
+    ) -> Result<CreationEntryConfigResponse, SpacetimeClientError> {
+        #[cfg(test)]
+        let test_interactions_json = input.public_work_interactions_json.clone();
+        match self
+            .spacetime_client
+            .upsert_public_work_interaction_config(input)
+            .await
+        {
+            Ok(config) => {
+                #[cfg(test)]
+                self.cache_test_creation_entry_config(config.clone());
+                Ok(config)
+            }
+            #[cfg(test)]
+            Err(_) => {
+                let mut config = self.read_test_creation_entry_config();
+                if let Ok(interactions) =
+                    module_runtime::decode_public_work_interaction_config_snapshots(
+                        test_interactions_json.as_str(),
+                    )
+                {
+                    config.public_work_interactions = interactions
+                        .into_iter()
+                        .map(module_runtime::build_public_work_interaction_config_response)
+                        .collect();
+                    self.cache_test_creation_entry_config(config.clone());
+                }
+                Ok(config)
+            }
+            #[cfg(not(test))]
+            Err(error) => Err(error),
+        }
+    }
+
     pub async fn get_creation_entry_config(
         &self,
     ) -> Result<CreationEntryConfigResponse, SpacetimeClientError> {
@@ -619,6 +657,53 @@ impl AppState {
             .unwrap_or(true))
     }
 
+    pub async fn is_public_work_interaction_enabled(
+        &self,
+        source_type: &str,
+        action: crate::creation_entry_config::PublicWorkInteractionAction,
+    ) -> Result<bool, SpacetimeClientError> {
+        let config = self.get_creation_entry_config().await?;
+        Ok(config
+            .public_work_interactions
+            .iter()
+            .find(|item| item.source_type == source_type)
+            .map(|item| match action {
+                crate::creation_entry_config::PublicWorkInteractionAction::Like => {
+                    item.like_enabled
+                }
+                crate::creation_entry_config::PublicWorkInteractionAction::Remix => {
+                    item.remix_enabled
+                }
+            })
+            .unwrap_or(true))
+    }
+
+    #[cfg(test)]
+    pub(crate) fn set_test_public_work_interaction_enabled(
+        &self,
+        source_type: impl AsRef<str>,
+        action: crate::creation_entry_config::PublicWorkInteractionAction,
+        enabled: bool,
+    ) {
+        let source_type = source_type.as_ref();
+        let mut config = self.read_test_creation_entry_config();
+        if let Some(item) = config
+            .public_work_interactions
+            .iter_mut()
+            .find(|item| item.source_type == source_type)
+        {
+            match action {
+                crate::creation_entry_config::PublicWorkInteractionAction::Like => {
+                    item.like_enabled = enabled;
+                }
+                crate::creation_entry_config::PublicWorkInteractionAction::Remix => {
+                    item.remix_enabled = enabled;
+                }
+            }
+        }
+        self.cache_test_creation_entry_config(config);
+    }
+
     #[cfg(test)]
     pub(crate) fn set_test_creation_entry_route_enabled(
         &self,