worker: write deploy-confs to file

land-worker/Cargo.toml

@@ -14,6 +14,7 @@ land-worker-server = { workspace = true }
 once_cell = { workspace = true }
 reqwest = { workspace = true }
 serde = { workspace = true }
+serde_json = { workspace = true }
 serde_yaml = "0.9.33"
 tokio = { workspace = true }
 tracing = { workspace = true }

land-worker/src/agent/sync.rs

@@ -6,7 +6,7 @@ use reqwest::header::AUTHORIZATION;
 use serde::{Deserialize, Serialize};
 use std::collections::HashMap;
 use tokio::sync::Mutex;
-use tracing::{info, instrument, warn};
+use tracing::{debug, info, instrument, warn};
 
 #[derive(Debug, Serialize, Deserialize)]
 pub struct Request {
@@ -39,9 +39,9 @@ pub async fn start(interval: u64, addr: String, token: String, dir: String) {
     info!("Center addr:{}", addr);
 
     // mkdir traefik yaml dir
-    let traefik_yaml_dir = format!("{}/traefik",dir);
+    let traefik_yaml_dir = format!("{}/traefik", dir);
     std::fs::create_dir_all(traefik_yaml_dir).unwrap();
-    
+
     tokio::spawn(async move {
         let mut ticker = tokio::time::interval(tokio::time::Duration::from_secs(interval));
         loop {
@@ -80,10 +80,15 @@ async fn sync(addr: String, token: String, dir: String) -> Result<()> {
         warn!("Bad status code: {}", status);
         return Err(anyhow!("Bad status code: {}", status));
     }
-    let value: Response = resp.json().await?;
+    let content = resp.text().await?;
+    let value: Response = serde_json::from_str(&content)?;
     *data = value.data;
     info!("Sync success, checksum: {}", data.checksum);
 
+    let confs_file = format!("{}/deploy-confs.json", dir);
+    debug!("Write to file: {}", confs_file);
+    std::fs::write(confs_file, content).unwrap();
+
     tokio::spawn(async move {
         super::deploys::build(dir).await;
     });