openiap_proto/
workitem.rs#![warn(missing_docs)]
use super::protos::{
Envelope, PushWorkitemRequest, PushWorkitemsRequest, PopWorkitemRequest, UpdateWorkitemRequest, DeleteWorkitemRequest,
AddWorkItemQueueRequest, UpdateWorkItemQueueRequest, DeleteWorkItemQueueRequest
};
impl PushWorkitemRequest {
pub fn to_envelope(&self) -> Envelope {
let any_message = prost_types::Any {
type_url: "type.googleapis.com/openiap.PushWorkitemRequest".to_string(),
value: {
let mut buf = Vec::new();
prost::Message::encode(self, &mut buf).unwrap_or(());
buf
},
};
Envelope {
command: "pushworkitem".into(),
data: Some(any_message.clone()),
..Default::default()
}
}
}
impl PushWorkitemsRequest {
pub fn to_envelope(&self) -> Envelope {
let any_message = prost_types::Any {
type_url: "type.googleapis.com/openiap.PushWorkitemsRequest".to_string(),
value: {
let mut buf = Vec::new();
prost::Message::encode(self, &mut buf).unwrap_or(());
buf
},
};
Envelope {
command: "pushworkitems".into(),
data: Some(any_message.clone()),
..Default::default()
}
}
}
impl PopWorkitemRequest {
pub fn bywiq(wiq: &str) -> Self {
Self {
wiq: wiq.to_string(),
compressed: false,
includefiles: false,
wiqid: "".to_string(),
}
}
pub fn bywiqid(wiqid: &str) -> Self {
Self {
wiqid: wiqid.to_string(),
compressed: false,
includefiles: false,
wiq: "".to_string(),
}
}
pub fn to_envelope(&self) -> Envelope {
let any_message = prost_types::Any {
type_url: "type.googleapis.com/openiap.PopWorkitemRequest".to_string(),
value: {
let mut buf = Vec::new();
prost::Message::encode(self, &mut buf).unwrap_or(());
buf
},
};
Envelope {
command: "popworkitem".into(),
data: Some(any_message.clone()),
..Default::default()
}
}
}
impl UpdateWorkitemRequest {
pub fn to_envelope(&self) -> Envelope {
let any_message = prost_types::Any {
type_url: "type.googleapis.com/openiap.UpdateWorkitemRequest".to_string(),
value: {
let mut buf = Vec::new();
prost::Message::encode(self, &mut buf).unwrap_or(());
buf
},
};
Envelope {
command: "updateworkitem".into(),
data: Some(any_message.clone()),
..Default::default()
}
}
}
impl DeleteWorkitemRequest {
pub fn to_envelope(&self) -> Envelope {
let any_message = prost_types::Any {
type_url: "type.googleapis.com/openiap.DeleteWorkitemRequest".to_string(),
value: {
let mut buf = Vec::new();
prost::Message::encode(self, &mut buf).unwrap_or(());
buf
},
};
Envelope {
command: "deleteworkitem".into(),
data: Some(any_message.clone()),
..Default::default()
}
}
}
impl AddWorkItemQueueRequest {
pub fn to_envelope(&self) -> Envelope {
let any_message = prost_types::Any {
type_url: "type.googleapis.com/openiap.AddWorkItemQueueRequest".to_string(),
value: {
let mut buf = Vec::new();
prost::Message::encode(self, &mut buf).unwrap_or(());
buf
},
};
Envelope {
command: "addworkitemqueue".into(),
data: Some(any_message.clone()),
..Default::default()
}
}
}
impl UpdateWorkItemQueueRequest {
pub fn to_envelope(&self) -> Envelope {
let any_message = prost_types::Any {
type_url: "type.googleapis.com/openiap.UpdateWorkItemQueueRequest".to_string(),
value: {
let mut buf = Vec::new();
prost::Message::encode(self, &mut buf).unwrap_or(());
buf
},
};
Envelope {
command: "updateworkitemqueue".into(),
data: Some(any_message.clone()),
..Default::default()
}
}
}
impl DeleteWorkItemQueueRequest {
pub fn to_envelope(&self) -> Envelope {
let any_message = prost_types::Any {
type_url: "type.googleapis.com/openiap.DeleteWorkItemQueueRequest".to_string(),
value: {
let mut buf = Vec::new();
prost::Message::encode(self, &mut buf).unwrap_or(());
buf
},
};
Envelope {
command: "deleteworkitemqueue".into(),
data: Some(any_message.clone()),
..Default::default()
}
}
}