#![allow(unused_imports, clippy::ptr_arg, clippy::needless_lifetimes)]
use async_trait::async_trait;
use serde::{Deserialize, Serialize};
use std::{borrow::Cow, io::Write, string::ToString};
use wasmbus_rpc::{
deserialize, serialize, Context, Message, MessageDispatch, RpcError, RpcResult, SendOpts,
Timestamp, Transport,
};
pub const SMITHY_VERSION: &str = "1.0";
#[derive(Clone, Debug, Default, Deserialize, Eq, PartialEq, Serialize)]
pub struct Column {
pub ordinal: u32,
#[serde(default)]
pub name: String,
#[serde(rename = "dbType")]
#[serde(default)]
pub db_type: String,
}
pub type Columns = Vec<Column>;
#[derive(Clone, Debug, Default, Deserialize, Eq, PartialEq, Serialize)]
pub struct ExecuteResult {
#[serde(rename = "rowsAffected")]
pub rows_affected: u64,
#[serde(default, skip_serializing_if = "Option::is_none")]
pub error: Option<SqlDbError>,
}
#[derive(Clone, Debug, Default, Deserialize, Eq, PartialEq, Serialize)]
pub struct FetchResult {
#[serde(rename = "numRows")]
pub num_rows: u64,
pub columns: Columns,
#[serde(with = "serde_bytes")]
#[serde(default)]
pub rows: Vec<u8>,
#[serde(default, skip_serializing_if = "Option::is_none")]
pub error: Option<SqlDbError>,
}
pub type Query = String;
#[derive(Clone, Debug, Default, Deserialize, Eq, PartialEq, Serialize)]
pub struct SqlDbError {
#[serde(default)]
pub code: String,
#[serde(default)]
pub message: String,
}
#[async_trait]
pub trait SqlDb {
fn contract_id() -> &'static str {
"wasmcloud:sqldb"
}
async fn execute(&self, ctx: &Context, arg: &Query) -> RpcResult<ExecuteResult>;
async fn fetch(&self, ctx: &Context, arg: &Query) -> RpcResult<FetchResult>;
}
#[doc(hidden)]
#[async_trait]
pub trait SqlDbReceiver: MessageDispatch + SqlDb {
async fn dispatch(&self, ctx: &Context, message: &Message<'_>) -> RpcResult<Message<'_>> {
match message.method {
"Execute" => {
let value: Query = deserialize(message.arg.as_ref())
.map_err(|e| RpcError::Deser(format!("message '{}': {}", message.method, e)))?;
let resp = SqlDb::execute(self, ctx, &value).await?;
let buf = serialize(&resp)?;
Ok(Message {
method: "SqlDb.Execute",
arg: Cow::Owned(buf),
})
}
"Fetch" => {
let value: Query = deserialize(message.arg.as_ref())
.map_err(|e| RpcError::Deser(format!("message '{}': {}", message.method, e)))?;
let resp = SqlDb::fetch(self, ctx, &value).await?;
let buf = serialize(&resp)?;
Ok(Message {
method: "SqlDb.Fetch",
arg: Cow::Owned(buf),
})
}
_ => Err(RpcError::MethodNotHandled(format!(
"SqlDb::{}",
message.method
))),
}
}
}
#[derive(Debug)]
pub struct SqlDbSender<T: Transport> {
transport: T,
}
impl<T: Transport> SqlDbSender<T> {
pub fn via(transport: T) -> Self {
Self { transport }
}
pub fn set_timeout(&self, interval: std::time::Duration) {
self.transport.set_timeout(interval);
}
}
#[cfg(target_arch = "wasm32")]
impl SqlDbSender<wasmbus_rpc::actor::prelude::WasmHost> {
pub fn new() -> Self {
let transport =
wasmbus_rpc::actor::prelude::WasmHost::to_provider("wasmcloud:sqldb", "default")
.unwrap();
Self { transport }
}
pub fn new_with_link(link_name: &str) -> wasmbus_rpc::RpcResult<Self> {
let transport =
wasmbus_rpc::actor::prelude::WasmHost::to_provider("wasmcloud:sqldb", link_name)?;
Ok(Self { transport })
}
}
#[async_trait]
impl<T: Transport + std::marker::Sync + std::marker::Send> SqlDb for SqlDbSender<T> {
#[allow(unused)]
async fn execute(&self, ctx: &Context, arg: &Query) -> RpcResult<ExecuteResult> {
let buf = serialize(arg)?;
let resp = self
.transport
.send(
ctx,
Message {
method: "SqlDb.Execute",
arg: Cow::Borrowed(&buf),
},
None,
)
.await?;
let value = deserialize(&resp)
.map_err(|e| RpcError::Deser(format!("response to {}: {}", "Execute", e)))?;
Ok(value)
}
#[allow(unused)]
async fn fetch(&self, ctx: &Context, arg: &Query) -> RpcResult<FetchResult> {
let buf = serialize(arg)?;
let resp = self
.transport
.send(
ctx,
Message {
method: "SqlDb.Fetch",
arg: Cow::Borrowed(&buf),
},
None,
)
.await?;
let value = deserialize(&resp)
.map_err(|e| RpcError::Deser(format!("response to {}: {}", "Fetch", e)))?;
Ok(value)
}
}