mod.rs

use crate::analyser::core::Analyser;
use crate::command::push::data_type_client_impl::SagittariusDataTypeServiceClient;
use crate::command::push::flow_type_client_impl::SagittariusFlowTypeServiceClient;
use crate::command::push::function_client_impl::SagittariusRuntimeFunctionServiceClient;

mod auth;
mod data_type_client_impl;
mod flow_type_client_impl;
mod function_client_impl;

pub async fn push(token: String, url: String, path: Option<String>) {
    let dir_path = path.unwrap_or_else(|| "./definitions".to_string());

    let mut analyzer = Analyser::new(dir_path.as_str());
    let mut data_type_client =
        SagittariusDataTypeServiceClient::new(url.clone(), token.clone()).await;
    let mut flow_type_client =
        SagittariusFlowTypeServiceClient::new(url.clone(), token.clone()).await;
    let mut function_client = SagittariusRuntimeFunctionServiceClient::new(url, token).await;

    analyzer.report(false, true);

    data_type_client
        .update_data_types(
            analyzer
                .data_types
                .iter()
                .map(|d| d.definition_data_type.clone())
                .collect(),
        )
        .await;
    flow_type_client
        .update_flow_types(
            analyzer
                .flow_types
                .iter()
                .map(|d| d.flow_type.clone())
                .collect(),
        )
        .await;
    function_client
        .update_runtime_function_definitions(
            analyzer
                .functions
                .iter()
                .map(|d| d.function.clone())
                .collect(),
        )
        .await;
}