11use crate :: analyser:: core:: Analyser ;
2- use crate :: command:: push:: data_type_client_impl:: SagittariusDataTypeServiceClient ;
3- use crate :: command:: push:: flow_type_client_impl:: SagittariusFlowTypeServiceClient ;
4- use crate :: command:: push:: function_client_impl:: SagittariusRuntimeFunctionServiceClient ;
52
63mod auth;
7- mod data_type_client_impl;
8- mod flow_type_client_impl;
9- mod function_client_impl;
104
115pub async fn push (
126 token : String ,
@@ -22,51 +16,6 @@ pub async fn push(
2216 } ;
2317
2418 let mut analyzer = Analyser :: new ( dir_path. as_str ( ) ) ;
25- let mut data_type_client =
26- SagittariusDataTypeServiceClient :: new ( url. clone ( ) , token. clone ( ) ) . await ;
27- let mut flow_type_client =
28- SagittariusFlowTypeServiceClient :: new ( url. clone ( ) , token. clone ( ) ) . await ;
29- let mut function_client = SagittariusRuntimeFunctionServiceClient :: new ( url, token) . await ;
30-
3119 analyzer. report ( false , true ) ;
32-
33- data_type_client
34- . update_data_types (
35- analyzer
36- . data_types
37- . iter ( )
38- . map ( |d| {
39- let mut def = d. definition_data_type . clone ( ) ;
40- def. version = version. clone ( ) ;
41- return def;
42- } )
43- . collect ( ) ,
44- )
45- . await ;
46- flow_type_client
47- . update_flow_types (
48- analyzer
49- . flow_types
50- . iter ( )
51- . map ( |d| {
52- let mut def = d. flow_type . clone ( ) ;
53- def. version = version. clone ( ) ;
54- return def;
55- } )
56- . collect ( ) ,
57- )
58- . await ;
59- function_client
60- . update_runtime_function_definitions (
61- analyzer
62- . functions
63- . iter ( )
64- . map ( |d| {
65- let mut def = d. function . clone ( ) ;
66- def. version = version. clone ( ) ;
67- return def;
68- } )
69- . collect ( ) ,
70- )
71- . await ;
20+ todo ! ( "Implement Sagittarius Module Service Client Endpoint!" )
7221}
0 commit comments