removing exchange currencies system, cos new one going in place now
This commit is contained in:
2
client
2
client
Submodule client updated: 213500f425...0fd324cf74
@@ -216,7 +216,6 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
|
|||||||
.compile_protos(
|
.compile_protos(
|
||||||
&[
|
&[
|
||||||
"proto/common.proto",
|
"proto/common.proto",
|
||||||
"proto/currency_conversion.proto",
|
|
||||||
"proto/document_data.proto",
|
"proto/document_data.proto",
|
||||||
"proto/adresar.proto",
|
"proto/adresar.proto",
|
||||||
"proto/analytics.proto",
|
"proto/analytics.proto",
|
||||||
@@ -243,7 +242,6 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
|
|||||||
println!("cargo:rerun-if-changed=build.rs");
|
println!("cargo:rerun-if-changed=build.rs");
|
||||||
for proto in [
|
for proto in [
|
||||||
"proto/common.proto",
|
"proto/common.proto",
|
||||||
"proto/currency_conversion.proto",
|
|
||||||
"proto/document_data.proto",
|
"proto/document_data.proto",
|
||||||
"proto/adresar.proto",
|
"proto/adresar.proto",
|
||||||
"proto/analytics.proto",
|
"proto/analytics.proto",
|
||||||
|
|||||||
@@ -1,53 +0,0 @@
|
|||||||
syntax = "proto3";
|
|
||||||
package komp_ac.currency_conversion;
|
|
||||||
|
|
||||||
service CurrencyConversion {
|
|
||||||
rpc ConvertCurrency(ConvertCurrencyRequest) returns (ConvertCurrencyResponse);
|
|
||||||
rpc ResolveRate(ResolveRateRequest) returns (ResolvedFxRate);
|
|
||||||
rpc ListRequiredCurrencies(ListRequiredCurrenciesRequest)
|
|
||||||
returns (ListRequiredCurrenciesResponse);
|
|
||||||
}
|
|
||||||
|
|
||||||
message ConvertCurrencyRequest {
|
|
||||||
string amount = 1;
|
|
||||||
string source_currency = 2;
|
|
||||||
string target_currency = 3;
|
|
||||||
string source = 4;
|
|
||||||
string as_of_date = 5;
|
|
||||||
}
|
|
||||||
|
|
||||||
message ResolveRateRequest {
|
|
||||||
string source_currency = 1;
|
|
||||||
string target_currency = 2;
|
|
||||||
string source = 3;
|
|
||||||
string as_of_date = 4;
|
|
||||||
}
|
|
||||||
|
|
||||||
message FxRateComponent {
|
|
||||||
string currency = 1;
|
|
||||||
string units_per_base = 2;
|
|
||||||
}
|
|
||||||
|
|
||||||
message ResolvedFxRate {
|
|
||||||
string source_currency = 1;
|
|
||||||
string target_currency = 2;
|
|
||||||
string rate = 3;
|
|
||||||
string effective_date = 4;
|
|
||||||
string source = 5;
|
|
||||||
int64 rate_set_id = 6;
|
|
||||||
int32 revision = 7;
|
|
||||||
string base_currency = 8;
|
|
||||||
repeated FxRateComponent components = 9;
|
|
||||||
}
|
|
||||||
|
|
||||||
message ConvertCurrencyResponse {
|
|
||||||
string amount = 1;
|
|
||||||
string currency = 2;
|
|
||||||
ResolvedFxRate resolved_rate = 3;
|
|
||||||
}
|
|
||||||
|
|
||||||
message ListRequiredCurrenciesRequest {}
|
|
||||||
|
|
||||||
message ListRequiredCurrenciesResponse {
|
|
||||||
repeated string currencies = 1;
|
|
||||||
}
|
|
||||||
@@ -185,14 +185,6 @@ message ScriptDependency {
|
|||||||
string operation = 5;
|
string operation = 5;
|
||||||
// Relationship table used to match the owner row to the related collection.
|
// Relationship table used to match the owner row to the related collection.
|
||||||
string via_table = 6;
|
string via_table = 6;
|
||||||
// Source currency for an fx_conversion dependency.
|
|
||||||
string from_currency = 7;
|
|
||||||
// Target currency for an fx_conversion dependency.
|
|
||||||
string to_currency = 8;
|
|
||||||
// Persisted exchange-rate provider/source identifier.
|
|
||||||
string source = 9;
|
|
||||||
// Requested YYYY-MM-DD date, or empty for the latest stored snapshot.
|
|
||||||
string as_of_date = 10;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Identifies the active form row whose external Steel inputs must be hydrated.
|
// Identifies the active form row whose external Steel inputs must be hydrated.
|
||||||
@@ -251,18 +243,4 @@ message HydrateScriptDependenciesResponse {
|
|||||||
repeated HydratedColumnValue columns = 1;
|
repeated HydratedColumnValue columns = 1;
|
||||||
// Exact related aggregate inputs declared by stored scripts.
|
// Exact related aggregate inputs declared by stored scripts.
|
||||||
repeated HydratedAggregateValue aggregates = 2;
|
repeated HydratedAggregateValue aggregates = 2;
|
||||||
// Exact resolved rates declared by the table's stored scripts.
|
|
||||||
repeated HydratedFxRate fx_rates = 3;
|
|
||||||
}
|
|
||||||
|
|
||||||
message HydratedFxRate {
|
|
||||||
string from_currency = 1;
|
|
||||||
string to_currency = 2;
|
|
||||||
string source = 3;
|
|
||||||
string requested_as_of_date = 4;
|
|
||||||
string rate = 5;
|
|
||||||
string effective_date = 6;
|
|
||||||
int64 rate_set_id = 7;
|
|
||||||
int32 revision = 8;
|
|
||||||
string base_currency = 9;
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -20,9 +20,6 @@ pub mod proto {
|
|||||||
pub mod common {
|
pub mod common {
|
||||||
include!("proto/komp_ac.common.rs");
|
include!("proto/komp_ac.common.rs");
|
||||||
}
|
}
|
||||||
pub mod currency_conversion {
|
|
||||||
include!("proto/komp_ac.currency_conversion.rs");
|
|
||||||
}
|
|
||||||
pub mod document_data {
|
pub mod document_data {
|
||||||
include!("proto/komp_ac.document_data.rs");
|
include!("proto/komp_ac.document_data.rs");
|
||||||
}
|
}
|
||||||
|
|||||||
Binary file not shown.
@@ -1,535 +0,0 @@
|
|||||||
// This file is @generated by prost-build.
|
|
||||||
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
|
|
||||||
pub struct ConvertCurrencyRequest {
|
|
||||||
#[prost(string, tag = "1")]
|
|
||||||
pub amount: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "2")]
|
|
||||||
pub source_currency: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "3")]
|
|
||||||
pub target_currency: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "4")]
|
|
||||||
pub source: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "5")]
|
|
||||||
pub as_of_date: ::prost::alloc::string::String,
|
|
||||||
}
|
|
||||||
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
|
|
||||||
pub struct ResolveRateRequest {
|
|
||||||
#[prost(string, tag = "1")]
|
|
||||||
pub source_currency: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "2")]
|
|
||||||
pub target_currency: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "3")]
|
|
||||||
pub source: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "4")]
|
|
||||||
pub as_of_date: ::prost::alloc::string::String,
|
|
||||||
}
|
|
||||||
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
|
|
||||||
pub struct FxRateComponent {
|
|
||||||
#[prost(string, tag = "1")]
|
|
||||||
pub currency: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "2")]
|
|
||||||
pub units_per_base: ::prost::alloc::string::String,
|
|
||||||
}
|
|
||||||
#[derive(Clone, PartialEq, ::prost::Message)]
|
|
||||||
pub struct ResolvedFxRate {
|
|
||||||
#[prost(string, tag = "1")]
|
|
||||||
pub source_currency: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "2")]
|
|
||||||
pub target_currency: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "3")]
|
|
||||||
pub rate: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "4")]
|
|
||||||
pub effective_date: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "5")]
|
|
||||||
pub source: ::prost::alloc::string::String,
|
|
||||||
#[prost(int64, tag = "6")]
|
|
||||||
pub rate_set_id: i64,
|
|
||||||
#[prost(int32, tag = "7")]
|
|
||||||
pub revision: i32,
|
|
||||||
#[prost(string, tag = "8")]
|
|
||||||
pub base_currency: ::prost::alloc::string::String,
|
|
||||||
#[prost(message, repeated, tag = "9")]
|
|
||||||
pub components: ::prost::alloc::vec::Vec<FxRateComponent>,
|
|
||||||
}
|
|
||||||
#[derive(Clone, PartialEq, ::prost::Message)]
|
|
||||||
pub struct ConvertCurrencyResponse {
|
|
||||||
#[prost(string, tag = "1")]
|
|
||||||
pub amount: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "2")]
|
|
||||||
pub currency: ::prost::alloc::string::String,
|
|
||||||
#[prost(message, optional, tag = "3")]
|
|
||||||
pub resolved_rate: ::core::option::Option<ResolvedFxRate>,
|
|
||||||
}
|
|
||||||
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
|
|
||||||
pub struct ListRequiredCurrenciesRequest {}
|
|
||||||
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
|
|
||||||
pub struct ListRequiredCurrenciesResponse {
|
|
||||||
#[prost(string, repeated, tag = "1")]
|
|
||||||
pub currencies: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
|
|
||||||
}
|
|
||||||
/// Generated client implementations.
|
|
||||||
pub mod currency_conversion_client {
|
|
||||||
#![allow(
|
|
||||||
unused_variables,
|
|
||||||
dead_code,
|
|
||||||
missing_docs,
|
|
||||||
clippy::wildcard_imports,
|
|
||||||
clippy::let_unit_value,
|
|
||||||
)]
|
|
||||||
use tonic::codegen::*;
|
|
||||||
use tonic::codegen::http::Uri;
|
|
||||||
#[derive(Debug, Clone)]
|
|
||||||
pub struct CurrencyConversionClient<T> {
|
|
||||||
inner: tonic::client::Grpc<T>,
|
|
||||||
}
|
|
||||||
impl CurrencyConversionClient<tonic::transport::Channel> {
|
|
||||||
/// Attempt to create a new client by connecting to a given endpoint.
|
|
||||||
pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
|
|
||||||
where
|
|
||||||
D: TryInto<tonic::transport::Endpoint>,
|
|
||||||
D::Error: Into<StdError>,
|
|
||||||
{
|
|
||||||
let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
|
|
||||||
Ok(Self::new(conn))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
impl<T> CurrencyConversionClient<T>
|
|
||||||
where
|
|
||||||
T: tonic::client::GrpcService<tonic::body::Body>,
|
|
||||||
T::Error: Into<StdError>,
|
|
||||||
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
|
|
||||||
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
|
|
||||||
{
|
|
||||||
pub fn new(inner: T) -> Self {
|
|
||||||
let inner = tonic::client::Grpc::new(inner);
|
|
||||||
Self { inner }
|
|
||||||
}
|
|
||||||
pub fn with_origin(inner: T, origin: Uri) -> Self {
|
|
||||||
let inner = tonic::client::Grpc::with_origin(inner, origin);
|
|
||||||
Self { inner }
|
|
||||||
}
|
|
||||||
pub fn with_interceptor<F>(
|
|
||||||
inner: T,
|
|
||||||
interceptor: F,
|
|
||||||
) -> CurrencyConversionClient<InterceptedService<T, F>>
|
|
||||||
where
|
|
||||||
F: tonic::service::Interceptor,
|
|
||||||
T::ResponseBody: Default,
|
|
||||||
T: tonic::codegen::Service<
|
|
||||||
http::Request<tonic::body::Body>,
|
|
||||||
Response = http::Response<
|
|
||||||
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
|
|
||||||
>,
|
|
||||||
>,
|
|
||||||
<T as tonic::codegen::Service<
|
|
||||||
http::Request<tonic::body::Body>,
|
|
||||||
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
|
|
||||||
{
|
|
||||||
CurrencyConversionClient::new(InterceptedService::new(inner, interceptor))
|
|
||||||
}
|
|
||||||
/// Compress requests with the given encoding.
|
|
||||||
///
|
|
||||||
/// This requires the server to support it otherwise it might respond with an
|
|
||||||
/// error.
|
|
||||||
#[must_use]
|
|
||||||
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
|
|
||||||
self.inner = self.inner.send_compressed(encoding);
|
|
||||||
self
|
|
||||||
}
|
|
||||||
/// Enable decompressing responses.
|
|
||||||
#[must_use]
|
|
||||||
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
|
|
||||||
self.inner = self.inner.accept_compressed(encoding);
|
|
||||||
self
|
|
||||||
}
|
|
||||||
/// Limits the maximum size of a decoded message.
|
|
||||||
///
|
|
||||||
/// Default: `4MB`
|
|
||||||
#[must_use]
|
|
||||||
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
|
|
||||||
self.inner = self.inner.max_decoding_message_size(limit);
|
|
||||||
self
|
|
||||||
}
|
|
||||||
/// Limits the maximum size of an encoded message.
|
|
||||||
///
|
|
||||||
/// Default: `usize::MAX`
|
|
||||||
#[must_use]
|
|
||||||
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
|
|
||||||
self.inner = self.inner.max_encoding_message_size(limit);
|
|
||||||
self
|
|
||||||
}
|
|
||||||
pub async fn convert_currency(
|
|
||||||
&mut self,
|
|
||||||
request: impl tonic::IntoRequest<super::ConvertCurrencyRequest>,
|
|
||||||
) -> std::result::Result<
|
|
||||||
tonic::Response<super::ConvertCurrencyResponse>,
|
|
||||||
tonic::Status,
|
|
||||||
> {
|
|
||||||
self.inner
|
|
||||||
.ready()
|
|
||||||
.await
|
|
||||||
.map_err(|e| {
|
|
||||||
tonic::Status::unknown(
|
|
||||||
format!("Service was not ready: {}", e.into()),
|
|
||||||
)
|
|
||||||
})?;
|
|
||||||
let codec = tonic_prost::ProstCodec::default();
|
|
||||||
let path = http::uri::PathAndQuery::from_static(
|
|
||||||
"/komp_ac.currency_conversion.CurrencyConversion/ConvertCurrency",
|
|
||||||
);
|
|
||||||
let mut req = request.into_request();
|
|
||||||
req.extensions_mut()
|
|
||||||
.insert(
|
|
||||||
GrpcMethod::new(
|
|
||||||
"komp_ac.currency_conversion.CurrencyConversion",
|
|
||||||
"ConvertCurrency",
|
|
||||||
),
|
|
||||||
);
|
|
||||||
self.inner.unary(req, path, codec).await
|
|
||||||
}
|
|
||||||
pub async fn resolve_rate(
|
|
||||||
&mut self,
|
|
||||||
request: impl tonic::IntoRequest<super::ResolveRateRequest>,
|
|
||||||
) -> std::result::Result<tonic::Response<super::ResolvedFxRate>, tonic::Status> {
|
|
||||||
self.inner
|
|
||||||
.ready()
|
|
||||||
.await
|
|
||||||
.map_err(|e| {
|
|
||||||
tonic::Status::unknown(
|
|
||||||
format!("Service was not ready: {}", e.into()),
|
|
||||||
)
|
|
||||||
})?;
|
|
||||||
let codec = tonic_prost::ProstCodec::default();
|
|
||||||
let path = http::uri::PathAndQuery::from_static(
|
|
||||||
"/komp_ac.currency_conversion.CurrencyConversion/ResolveRate",
|
|
||||||
);
|
|
||||||
let mut req = request.into_request();
|
|
||||||
req.extensions_mut()
|
|
||||||
.insert(
|
|
||||||
GrpcMethod::new(
|
|
||||||
"komp_ac.currency_conversion.CurrencyConversion",
|
|
||||||
"ResolveRate",
|
|
||||||
),
|
|
||||||
);
|
|
||||||
self.inner.unary(req, path, codec).await
|
|
||||||
}
|
|
||||||
pub async fn list_required_currencies(
|
|
||||||
&mut self,
|
|
||||||
request: impl tonic::IntoRequest<super::ListRequiredCurrenciesRequest>,
|
|
||||||
) -> std::result::Result<
|
|
||||||
tonic::Response<super::ListRequiredCurrenciesResponse>,
|
|
||||||
tonic::Status,
|
|
||||||
> {
|
|
||||||
self.inner
|
|
||||||
.ready()
|
|
||||||
.await
|
|
||||||
.map_err(|e| {
|
|
||||||
tonic::Status::unknown(
|
|
||||||
format!("Service was not ready: {}", e.into()),
|
|
||||||
)
|
|
||||||
})?;
|
|
||||||
let codec = tonic_prost::ProstCodec::default();
|
|
||||||
let path = http::uri::PathAndQuery::from_static(
|
|
||||||
"/komp_ac.currency_conversion.CurrencyConversion/ListRequiredCurrencies",
|
|
||||||
);
|
|
||||||
let mut req = request.into_request();
|
|
||||||
req.extensions_mut()
|
|
||||||
.insert(
|
|
||||||
GrpcMethod::new(
|
|
||||||
"komp_ac.currency_conversion.CurrencyConversion",
|
|
||||||
"ListRequiredCurrencies",
|
|
||||||
),
|
|
||||||
);
|
|
||||||
self.inner.unary(req, path, codec).await
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
/// Generated server implementations.
|
|
||||||
pub mod currency_conversion_server {
|
|
||||||
#![allow(
|
|
||||||
unused_variables,
|
|
||||||
dead_code,
|
|
||||||
missing_docs,
|
|
||||||
clippy::wildcard_imports,
|
|
||||||
clippy::let_unit_value,
|
|
||||||
)]
|
|
||||||
use tonic::codegen::*;
|
|
||||||
/// Generated trait containing gRPC methods that should be implemented for use with CurrencyConversionServer.
|
|
||||||
#[async_trait]
|
|
||||||
pub trait CurrencyConversion: std::marker::Send + std::marker::Sync + 'static {
|
|
||||||
async fn convert_currency(
|
|
||||||
&self,
|
|
||||||
request: tonic::Request<super::ConvertCurrencyRequest>,
|
|
||||||
) -> std::result::Result<
|
|
||||||
tonic::Response<super::ConvertCurrencyResponse>,
|
|
||||||
tonic::Status,
|
|
||||||
>;
|
|
||||||
async fn resolve_rate(
|
|
||||||
&self,
|
|
||||||
request: tonic::Request<super::ResolveRateRequest>,
|
|
||||||
) -> std::result::Result<tonic::Response<super::ResolvedFxRate>, tonic::Status>;
|
|
||||||
async fn list_required_currencies(
|
|
||||||
&self,
|
|
||||||
request: tonic::Request<super::ListRequiredCurrenciesRequest>,
|
|
||||||
) -> std::result::Result<
|
|
||||||
tonic::Response<super::ListRequiredCurrenciesResponse>,
|
|
||||||
tonic::Status,
|
|
||||||
>;
|
|
||||||
}
|
|
||||||
#[derive(Debug)]
|
|
||||||
pub struct CurrencyConversionServer<T> {
|
|
||||||
inner: Arc<T>,
|
|
||||||
accept_compression_encodings: EnabledCompressionEncodings,
|
|
||||||
send_compression_encodings: EnabledCompressionEncodings,
|
|
||||||
max_decoding_message_size: Option<usize>,
|
|
||||||
max_encoding_message_size: Option<usize>,
|
|
||||||
}
|
|
||||||
impl<T> CurrencyConversionServer<T> {
|
|
||||||
pub fn new(inner: T) -> Self {
|
|
||||||
Self::from_arc(Arc::new(inner))
|
|
||||||
}
|
|
||||||
pub fn from_arc(inner: Arc<T>) -> Self {
|
|
||||||
Self {
|
|
||||||
inner,
|
|
||||||
accept_compression_encodings: Default::default(),
|
|
||||||
send_compression_encodings: Default::default(),
|
|
||||||
max_decoding_message_size: None,
|
|
||||||
max_encoding_message_size: None,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
pub fn with_interceptor<F>(
|
|
||||||
inner: T,
|
|
||||||
interceptor: F,
|
|
||||||
) -> InterceptedService<Self, F>
|
|
||||||
where
|
|
||||||
F: tonic::service::Interceptor,
|
|
||||||
{
|
|
||||||
InterceptedService::new(Self::new(inner), interceptor)
|
|
||||||
}
|
|
||||||
/// Enable decompressing requests with the given encoding.
|
|
||||||
#[must_use]
|
|
||||||
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
|
|
||||||
self.accept_compression_encodings.enable(encoding);
|
|
||||||
self
|
|
||||||
}
|
|
||||||
/// Compress responses with the given encoding, if the client supports it.
|
|
||||||
#[must_use]
|
|
||||||
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
|
|
||||||
self.send_compression_encodings.enable(encoding);
|
|
||||||
self
|
|
||||||
}
|
|
||||||
/// Limits the maximum size of a decoded message.
|
|
||||||
///
|
|
||||||
/// Default: `4MB`
|
|
||||||
#[must_use]
|
|
||||||
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
|
|
||||||
self.max_decoding_message_size = Some(limit);
|
|
||||||
self
|
|
||||||
}
|
|
||||||
/// Limits the maximum size of an encoded message.
|
|
||||||
///
|
|
||||||
/// Default: `usize::MAX`
|
|
||||||
#[must_use]
|
|
||||||
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
|
|
||||||
self.max_encoding_message_size = Some(limit);
|
|
||||||
self
|
|
||||||
}
|
|
||||||
}
|
|
||||||
impl<T, B> tonic::codegen::Service<http::Request<B>> for CurrencyConversionServer<T>
|
|
||||||
where
|
|
||||||
T: CurrencyConversion,
|
|
||||||
B: Body + std::marker::Send + 'static,
|
|
||||||
B::Error: Into<StdError> + std::marker::Send + 'static,
|
|
||||||
{
|
|
||||||
type Response = http::Response<tonic::body::Body>;
|
|
||||||
type Error = std::convert::Infallible;
|
|
||||||
type Future = BoxFuture<Self::Response, Self::Error>;
|
|
||||||
fn poll_ready(
|
|
||||||
&mut self,
|
|
||||||
_cx: &mut Context<'_>,
|
|
||||||
) -> Poll<std::result::Result<(), Self::Error>> {
|
|
||||||
Poll::Ready(Ok(()))
|
|
||||||
}
|
|
||||||
fn call(&mut self, req: http::Request<B>) -> Self::Future {
|
|
||||||
match req.uri().path() {
|
|
||||||
"/komp_ac.currency_conversion.CurrencyConversion/ConvertCurrency" => {
|
|
||||||
#[allow(non_camel_case_types)]
|
|
||||||
struct ConvertCurrencySvc<T: CurrencyConversion>(pub Arc<T>);
|
|
||||||
impl<
|
|
||||||
T: CurrencyConversion,
|
|
||||||
> tonic::server::UnaryService<super::ConvertCurrencyRequest>
|
|
||||||
for ConvertCurrencySvc<T> {
|
|
||||||
type Response = super::ConvertCurrencyResponse;
|
|
||||||
type Future = BoxFuture<
|
|
||||||
tonic::Response<Self::Response>,
|
|
||||||
tonic::Status,
|
|
||||||
>;
|
|
||||||
fn call(
|
|
||||||
&mut self,
|
|
||||||
request: tonic::Request<super::ConvertCurrencyRequest>,
|
|
||||||
) -> Self::Future {
|
|
||||||
let inner = Arc::clone(&self.0);
|
|
||||||
let fut = async move {
|
|
||||||
<T as CurrencyConversion>::convert_currency(&inner, request)
|
|
||||||
.await
|
|
||||||
};
|
|
||||||
Box::pin(fut)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
let accept_compression_encodings = self.accept_compression_encodings;
|
|
||||||
let send_compression_encodings = self.send_compression_encodings;
|
|
||||||
let max_decoding_message_size = self.max_decoding_message_size;
|
|
||||||
let max_encoding_message_size = self.max_encoding_message_size;
|
|
||||||
let inner = self.inner.clone();
|
|
||||||
let fut = async move {
|
|
||||||
let method = ConvertCurrencySvc(inner);
|
|
||||||
let codec = tonic_prost::ProstCodec::default();
|
|
||||||
let mut grpc = tonic::server::Grpc::new(codec)
|
|
||||||
.apply_compression_config(
|
|
||||||
accept_compression_encodings,
|
|
||||||
send_compression_encodings,
|
|
||||||
)
|
|
||||||
.apply_max_message_size_config(
|
|
||||||
max_decoding_message_size,
|
|
||||||
max_encoding_message_size,
|
|
||||||
);
|
|
||||||
let res = grpc.unary(method, req).await;
|
|
||||||
Ok(res)
|
|
||||||
};
|
|
||||||
Box::pin(fut)
|
|
||||||
}
|
|
||||||
"/komp_ac.currency_conversion.CurrencyConversion/ResolveRate" => {
|
|
||||||
#[allow(non_camel_case_types)]
|
|
||||||
struct ResolveRateSvc<T: CurrencyConversion>(pub Arc<T>);
|
|
||||||
impl<
|
|
||||||
T: CurrencyConversion,
|
|
||||||
> tonic::server::UnaryService<super::ResolveRateRequest>
|
|
||||||
for ResolveRateSvc<T> {
|
|
||||||
type Response = super::ResolvedFxRate;
|
|
||||||
type Future = BoxFuture<
|
|
||||||
tonic::Response<Self::Response>,
|
|
||||||
tonic::Status,
|
|
||||||
>;
|
|
||||||
fn call(
|
|
||||||
&mut self,
|
|
||||||
request: tonic::Request<super::ResolveRateRequest>,
|
|
||||||
) -> Self::Future {
|
|
||||||
let inner = Arc::clone(&self.0);
|
|
||||||
let fut = async move {
|
|
||||||
<T as CurrencyConversion>::resolve_rate(&inner, request)
|
|
||||||
.await
|
|
||||||
};
|
|
||||||
Box::pin(fut)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
let accept_compression_encodings = self.accept_compression_encodings;
|
|
||||||
let send_compression_encodings = self.send_compression_encodings;
|
|
||||||
let max_decoding_message_size = self.max_decoding_message_size;
|
|
||||||
let max_encoding_message_size = self.max_encoding_message_size;
|
|
||||||
let inner = self.inner.clone();
|
|
||||||
let fut = async move {
|
|
||||||
let method = ResolveRateSvc(inner);
|
|
||||||
let codec = tonic_prost::ProstCodec::default();
|
|
||||||
let mut grpc = tonic::server::Grpc::new(codec)
|
|
||||||
.apply_compression_config(
|
|
||||||
accept_compression_encodings,
|
|
||||||
send_compression_encodings,
|
|
||||||
)
|
|
||||||
.apply_max_message_size_config(
|
|
||||||
max_decoding_message_size,
|
|
||||||
max_encoding_message_size,
|
|
||||||
);
|
|
||||||
let res = grpc.unary(method, req).await;
|
|
||||||
Ok(res)
|
|
||||||
};
|
|
||||||
Box::pin(fut)
|
|
||||||
}
|
|
||||||
"/komp_ac.currency_conversion.CurrencyConversion/ListRequiredCurrencies" => {
|
|
||||||
#[allow(non_camel_case_types)]
|
|
||||||
struct ListRequiredCurrenciesSvc<T: CurrencyConversion>(pub Arc<T>);
|
|
||||||
impl<
|
|
||||||
T: CurrencyConversion,
|
|
||||||
> tonic::server::UnaryService<super::ListRequiredCurrenciesRequest>
|
|
||||||
for ListRequiredCurrenciesSvc<T> {
|
|
||||||
type Response = super::ListRequiredCurrenciesResponse;
|
|
||||||
type Future = BoxFuture<
|
|
||||||
tonic::Response<Self::Response>,
|
|
||||||
tonic::Status,
|
|
||||||
>;
|
|
||||||
fn call(
|
|
||||||
&mut self,
|
|
||||||
request: tonic::Request<super::ListRequiredCurrenciesRequest>,
|
|
||||||
) -> Self::Future {
|
|
||||||
let inner = Arc::clone(&self.0);
|
|
||||||
let fut = async move {
|
|
||||||
<T as CurrencyConversion>::list_required_currencies(
|
|
||||||
&inner,
|
|
||||||
request,
|
|
||||||
)
|
|
||||||
.await
|
|
||||||
};
|
|
||||||
Box::pin(fut)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
let accept_compression_encodings = self.accept_compression_encodings;
|
|
||||||
let send_compression_encodings = self.send_compression_encodings;
|
|
||||||
let max_decoding_message_size = self.max_decoding_message_size;
|
|
||||||
let max_encoding_message_size = self.max_encoding_message_size;
|
|
||||||
let inner = self.inner.clone();
|
|
||||||
let fut = async move {
|
|
||||||
let method = ListRequiredCurrenciesSvc(inner);
|
|
||||||
let codec = tonic_prost::ProstCodec::default();
|
|
||||||
let mut grpc = tonic::server::Grpc::new(codec)
|
|
||||||
.apply_compression_config(
|
|
||||||
accept_compression_encodings,
|
|
||||||
send_compression_encodings,
|
|
||||||
)
|
|
||||||
.apply_max_message_size_config(
|
|
||||||
max_decoding_message_size,
|
|
||||||
max_encoding_message_size,
|
|
||||||
);
|
|
||||||
let res = grpc.unary(method, req).await;
|
|
||||||
Ok(res)
|
|
||||||
};
|
|
||||||
Box::pin(fut)
|
|
||||||
}
|
|
||||||
_ => {
|
|
||||||
Box::pin(async move {
|
|
||||||
let mut response = http::Response::new(
|
|
||||||
tonic::body::Body::default(),
|
|
||||||
);
|
|
||||||
let headers = response.headers_mut();
|
|
||||||
headers
|
|
||||||
.insert(
|
|
||||||
tonic::Status::GRPC_STATUS,
|
|
||||||
(tonic::Code::Unimplemented as i32).into(),
|
|
||||||
);
|
|
||||||
headers
|
|
||||||
.insert(
|
|
||||||
http::header::CONTENT_TYPE,
|
|
||||||
tonic::metadata::GRPC_CONTENT_TYPE,
|
|
||||||
);
|
|
||||||
Ok(response)
|
|
||||||
})
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
impl<T> Clone for CurrencyConversionServer<T> {
|
|
||||||
fn clone(&self) -> Self {
|
|
||||||
let inner = self.inner.clone();
|
|
||||||
Self {
|
|
||||||
inner,
|
|
||||||
accept_compression_encodings: self.accept_compression_encodings,
|
|
||||||
send_compression_encodings: self.send_compression_encodings,
|
|
||||||
max_decoding_message_size: self.max_decoding_message_size,
|
|
||||||
max_encoding_message_size: self.max_encoding_message_size,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
/// Generated gRPC service name
|
|
||||||
pub const SERVICE_NAME: &str = "komp_ac.currency_conversion.CurrencyConversion";
|
|
||||||
impl<T> tonic::server::NamedService for CurrencyConversionServer<T> {
|
|
||||||
const NAME: &'static str = SERVICE_NAME;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -133,18 +133,6 @@ pub struct ScriptDependency {
|
|||||||
/// Relationship table used to match the owner row to the related collection.
|
/// Relationship table used to match the owner row to the related collection.
|
||||||
#[prost(string, tag = "6")]
|
#[prost(string, tag = "6")]
|
||||||
pub via_table: ::prost::alloc::string::String,
|
pub via_table: ::prost::alloc::string::String,
|
||||||
/// Source currency for an fx_conversion dependency.
|
|
||||||
#[prost(string, tag = "7")]
|
|
||||||
pub from_currency: ::prost::alloc::string::String,
|
|
||||||
/// Target currency for an fx_conversion dependency.
|
|
||||||
#[prost(string, tag = "8")]
|
|
||||||
pub to_currency: ::prost::alloc::string::String,
|
|
||||||
/// Persisted exchange-rate provider/source identifier.
|
|
||||||
#[prost(string, tag = "9")]
|
|
||||||
pub source: ::prost::alloc::string::String,
|
|
||||||
/// Requested YYYY-MM-DD date, or empty for the latest stored snapshot.
|
|
||||||
#[prost(string, tag = "10")]
|
|
||||||
pub as_of_date: ::prost::alloc::string::String,
|
|
||||||
}
|
}
|
||||||
/// Identifies the active form row whose external Steel inputs must be hydrated.
|
/// Identifies the active form row whose external Steel inputs must be hydrated.
|
||||||
#[derive(Clone, PartialEq, ::prost::Message)]
|
#[derive(Clone, PartialEq, ::prost::Message)]
|
||||||
@@ -225,30 +213,6 @@ pub struct HydrateScriptDependenciesResponse {
|
|||||||
/// Exact related aggregate inputs declared by stored scripts.
|
/// Exact related aggregate inputs declared by stored scripts.
|
||||||
#[prost(message, repeated, tag = "2")]
|
#[prost(message, repeated, tag = "2")]
|
||||||
pub aggregates: ::prost::alloc::vec::Vec<HydratedAggregateValue>,
|
pub aggregates: ::prost::alloc::vec::Vec<HydratedAggregateValue>,
|
||||||
/// Exact resolved rates declared by the table's stored scripts.
|
|
||||||
#[prost(message, repeated, tag = "3")]
|
|
||||||
pub fx_rates: ::prost::alloc::vec::Vec<HydratedFxRate>,
|
|
||||||
}
|
|
||||||
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
|
|
||||||
pub struct HydratedFxRate {
|
|
||||||
#[prost(string, tag = "1")]
|
|
||||||
pub from_currency: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "2")]
|
|
||||||
pub to_currency: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "3")]
|
|
||||||
pub source: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "4")]
|
|
||||||
pub requested_as_of_date: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "5")]
|
|
||||||
pub rate: ::prost::alloc::string::String,
|
|
||||||
#[prost(string, tag = "6")]
|
|
||||||
pub effective_date: ::prost::alloc::string::String,
|
|
||||||
#[prost(int64, tag = "7")]
|
|
||||||
pub rate_set_id: i64,
|
|
||||||
#[prost(int32, tag = "8")]
|
|
||||||
pub revision: i32,
|
|
||||||
#[prost(string, tag = "9")]
|
|
||||||
pub base_currency: ::prost::alloc::string::String,
|
|
||||||
}
|
}
|
||||||
/// Generated client implementations.
|
/// Generated client implementations.
|
||||||
pub mod table_script_client {
|
pub mod table_script_client {
|
||||||
|
|||||||
2
server
2
server
Submodule server updated: 86e8b04ca9...0635958988
Reference in New Issue
Block a user