do not reply with nats
This commit is contained in:
parent
6c3942e37d
commit
fad27b6792
@ -2,7 +2,7 @@
|
|||||||
// to perform the operation, not necessarily the over-the-wire format
|
// to perform the operation, not necessarily the over-the-wire format
|
||||||
|
|
||||||
// Requests are sent from maps-service to validator
|
// Requests are sent from maps-service to validator
|
||||||
// Responses are sent from validator to maps-service
|
// Validation invokes the REST api to update the submissions
|
||||||
|
|
||||||
#[derive(serde::Deserialize)]
|
#[derive(serde::Deserialize)]
|
||||||
pub struct ValidateRequest{
|
pub struct ValidateRequest{
|
||||||
@ -12,18 +12,6 @@ pub struct ValidateRequest{
|
|||||||
pub model_version:u64,
|
pub model_version:u64,
|
||||||
}
|
}
|
||||||
|
|
||||||
pub struct ValidateResponse{
|
|
||||||
pub submission_id:u64,
|
|
||||||
// model id will be changed if scripts were replaced
|
|
||||||
pub model_id:u64,
|
|
||||||
pub model_version:u64,
|
|
||||||
}
|
|
||||||
|
|
||||||
// an invalidate is sent instead if validation fails
|
|
||||||
pub struct InvalidateResponse{
|
|
||||||
pub submission_id:u64,
|
|
||||||
}
|
|
||||||
|
|
||||||
// Create a new map
|
// Create a new map
|
||||||
pub struct PublishNewRequest{
|
pub struct PublishNewRequest{
|
||||||
pub submission_id:u64,
|
pub submission_id:u64,
|
||||||
@ -40,8 +28,3 @@ pub struct PublishFixRequest{
|
|||||||
pub model_version:u64,
|
pub model_version:u64,
|
||||||
pub target_asset_id:u64,
|
pub target_asset_id:u64,
|
||||||
}
|
}
|
||||||
|
|
||||||
pub struct PublishResponse{
|
|
||||||
pub submission_id:u64,
|
|
||||||
pub success:bool,
|
|
||||||
}
|
|
||||||
|
@ -51,7 +51,7 @@ impl Validator{
|
|||||||
match self.validate(message).await{
|
match self.validate(message).await{
|
||||||
Ok(valid)=>{
|
Ok(valid)=>{
|
||||||
unimplemented!();
|
unimplemented!();
|
||||||
// self.nats.publish("validated","yo it validated".into()).await.unwrap();
|
// self.api.validate(validate_response).await.unwrap();
|
||||||
},
|
},
|
||||||
Err(e)=>{
|
Err(e)=>{
|
||||||
println!("there was an error, oopsie! {e}");
|
println!("there was an error, oopsie! {e}");
|
||||||
|
Loading…
Reference in New Issue
Block a user