use async_trait::async_trait;
use serde::{Deserialize, Serialize};
use to_url::ToUrl;
use serde_json::Value;
use crate::client::{CLIENT, REQ_CLIENT};
use crate::parse_url::ParseUrl;
use crate::result::Result;
const REGISTER: &str = "/nacos/v1/ns/instance";
#[allow(non_snake_case)]
#[derive(Debug, Default, Clone, Deserialize, Serialize, ToUrl)]
pub struct Register {
pub serviceName: String,
pub ip: String,
pub port: String,
pub namespaceId: Option<String>,
pub weight: Option<f64>,
pub enabled: Option<bool>,
pub healthy: Option<bool>,
pub metadata: Option<String>,
pub clusterName: Option<String>,
pub groupName: Option<String>,
pub ephemeral: Option<bool>,
}
#[async_trait]
impl ParseUrl for Register{}
impl Register {
pub async fn register(&self) -> Result<String> {
let url = self.parse_url(REGISTER).await;
let ok = REQ_CLIENT.post(url).send().await?.text().await?;
let read = CLIENT.read().await;
let ins = read.get_instance().get_instance().await?;
let beat = read.get_beat(&ins.instanceId);
beat.beat().await?;
Ok(ok)
}
}