validator: grpc

validation/src/grpc/mapfixes.rs

@@ -0,0 +1,23 @@
+use crate::endpoint;
+use rust_grpc::validator::*;
+pub type ValidatorMapfixesServiceClient=rust_grpc::validator::validator_mapfix_service_client::ValidatorMapfixServiceClient<tonic::transport::channel::Channel>;
+#[derive(Clone)]
+pub struct Service{
+	client:ValidatorMapfixesServiceClient,
+}
+impl Service{
+	pub fn new(
+		client:ValidatorMapfixesServiceClient,
+	)->Self{
+		Self{client}
+	}
+	endpoint!(create,MapfixCreate,MapfixId);
+	endpoint!(create_audit_error,AuditErrorRequest,NullResponse);
+	endpoint!(create_audit_checklist,AuditChecklistRequest,NullResponse);
+	endpoint!(set_validated_model,ValidatedModelRequest,NullResponse);
+	endpoint!(set_status_submitted,SubmittedRequest,NullResponse);
+	endpoint!(set_status_request_changes,MapfixId,NullResponse);
+	endpoint!(set_status_validated,MapfixId,NullResponse);
+	endpoint!(set_status_failed,MapfixId,NullResponse);
+	endpoint!(set_status_uploaded,MapfixId,NullResponse);
+}

validation/src/grpc/mod.rs

@@ -0,0 +1,15 @@
+
+pub mod mapfixes;
+pub mod operations;
+pub mod scripts;
+pub mod script_policy;
+pub mod submissions;
+
+#[macro_export]
+macro_rules! endpoint{
+	($fn:ident,$in:ident,$out:ident)=>{
+		pub async fn $fn(&self,request:$in)->Result<$out,tonic::Status>{
+			Ok(self.client.clone().$fn(request).await?.into_inner())
+		}
+	};
+}

validation/src/grpc/operations.rs

@@ -0,0 +1,15 @@
+use crate::endpoint;
+use rust_grpc::validator::*;
+pub type ValidatorOperationsServiceClient=rust_grpc::validator::validator_operation_service_client::ValidatorOperationServiceClient<tonic::transport::channel::Channel>;
+#[derive(Clone)]
+pub struct Service{
+	client:ValidatorOperationsServiceClient,
+}
+impl Service{
+	pub fn new(
+		client:ValidatorOperationsServiceClient,
+	)->Self{
+		Self{client}
+	}
+	endpoint!(fail,OperationFailRequest,NullResponse);
+}

validation/src/grpc/script_policy.rs

@@ -0,0 +1,16 @@
+use crate::endpoint;
+use rust_grpc::validator::*;
+pub type ValidatorScriptPolicyServiceClient=rust_grpc::validator::validator_script_policy_service_client::ValidatorScriptPolicyServiceClient<tonic::transport::channel::Channel>;
+#[derive(Clone)]
+pub struct Service{
+	client:ValidatorScriptPolicyServiceClient,
+}
+impl Service{
+	pub fn new(
+		client:ValidatorScriptPolicyServiceClient,
+	)->Self{
+		Self{client}
+	}
+	endpoint!(create,ScriptPolicyCreate,ScriptPolicyId);
+	endpoint!(list,ScriptPolicyListRequest,ScriptPolicyListResponse);
+}

validation/src/grpc/scripts.rs

@@ -0,0 +1,17 @@
+use crate::endpoint;
+use rust_grpc::validator::*;
+pub type ValidatorScriptsServiceClient=rust_grpc::validator::validator_script_service_client::ValidatorScriptServiceClient<tonic::transport::channel::Channel>;
+#[derive(Clone)]
+pub struct Service{
+	client:ValidatorScriptsServiceClient,
+}
+impl Service{
+	pub fn new(
+		client:ValidatorScriptsServiceClient,
+	)->Self{
+		Self{client}
+	}
+	endpoint!(create,ScriptCreate,ScriptId);
+	endpoint!(get,ScriptId,Script);
+	endpoint!(list,ScriptListRequest,ScriptListResponse);
+}

validation/src/grpc/submissions.rs

@@ -0,0 +1,23 @@
+use crate::endpoint;
+use rust_grpc::validator::*;
+pub type ValidatorSubmissionsServiceClient=rust_grpc::validator::validator_submission_service_client::ValidatorSubmissionServiceClient<tonic::transport::channel::Channel>;
+#[derive(Clone)]
+pub struct Service{
+	client:ValidatorSubmissionsServiceClient,
+}
+impl Service{
+	pub fn new(
+		client:ValidatorSubmissionsServiceClient,
+	)->Self{
+		Self{client}
+	}
+	endpoint!(create,SubmissionCreate,SubmissionId);
+	endpoint!(create_audit_error,AuditErrorRequest,NullResponse);
+	endpoint!(create_audit_checklist,AuditChecklistRequest,NullResponse);
+	endpoint!(set_validated_model,ValidatedModelRequest,NullResponse);
+	endpoint!(set_status_submitted,SubmittedRequest,NullResponse);
+	endpoint!(set_status_request_changes,SubmissionId,NullResponse);
+	endpoint!(set_status_validated,SubmissionId,NullResponse);
+	endpoint!(set_status_failed,SubmissionId,NullResponse);
+	endpoint!(set_status_uploaded,StatusUploadedRequest,NullResponse);
+}

validation/src/main.rs

@@ -1,5 +1,6 @@
 use futures::StreamExt;
 
+mod grpc;
 mod rbx_util;
 mod message_handler;
 mod nats_types;