pub type OwnedCreateBoardRequestView = ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::CreateBoardRequestView<'static>,
>;
pub type OwnedCreateBoardResponseView = ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::CreateBoardResponseView<'static>,
>;
pub type OwnedGetBoardRequestView = ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::GetBoardRequestView<'static>,
>;
pub type OwnedGetBoardResponseView = ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::GetBoardResponseView<'static>,
>;
pub type OwnedListBoardsRequestView = ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::ListBoardsRequestView<'static>,
>;
pub type OwnedListBoardsResponseView = ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::ListBoardsResponseView<'static>,
>;
pub type OwnedUpdateBoardRequestView = ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::UpdateBoardRequestView<'static>,
>;
pub type OwnedUpdateBoardResponseView = ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::UpdateBoardResponseView<'static>,
>;
pub type OwnedUpdateBoardAclRequestView = ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::UpdateBoardAclRequestView<'static>,
>;
pub type OwnedUpdateBoardAclResponseView = ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::UpdateBoardAclResponseView<'static>,
>;
pub type OwnedArchiveBoardRequestView = ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::ArchiveBoardRequestView<'static>,
>;
pub type OwnedArchiveBoardResponseView = ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::ArchiveBoardResponseView<'static>,
>;
pub type OwnedMintJoinTokenRequestView = ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::MintJoinTokenRequestView<'static>,
>;
pub type OwnedMintJoinTokenResponseView = ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::MintJoinTokenResponseView<'static>,
>;
impl ::connectrpc::Encodable<crate::proto::collab::v1::CreateBoardResponse>
for crate::proto::collab::v1::__buffa::view::CreateBoardResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::collab::v1::CreateBoardResponse>
for ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::CreateBoardResponseView<'static>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::collab::v1::GetBoardResponse>
for crate::proto::collab::v1::__buffa::view::GetBoardResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::collab::v1::GetBoardResponse>
for ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::GetBoardResponseView<'static>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::collab::v1::ListBoardsResponse>
for crate::proto::collab::v1::__buffa::view::ListBoardsResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::collab::v1::ListBoardsResponse>
for ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::ListBoardsResponseView<'static>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::collab::v1::UpdateBoardResponse>
for crate::proto::collab::v1::__buffa::view::UpdateBoardResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::collab::v1::UpdateBoardResponse>
for ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::UpdateBoardResponseView<'static>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::collab::v1::UpdateBoardAclResponse>
for crate::proto::collab::v1::__buffa::view::UpdateBoardAclResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::collab::v1::UpdateBoardAclResponse>
for ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::UpdateBoardAclResponseView<'static>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::collab::v1::ArchiveBoardResponse>
for crate::proto::collab::v1::__buffa::view::ArchiveBoardResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::collab::v1::ArchiveBoardResponse>
for ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::ArchiveBoardResponseView<'static>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::collab::v1::MintJoinTokenResponse>
for crate::proto::collab::v1::__buffa::view::MintJoinTokenResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::collab::v1::MintJoinTokenResponse>
for ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::MintJoinTokenResponseView<'static>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
pub const WHITEBOARD_SERVICE_SERVICE_NAME: &str = "collab.v1.WhiteboardService";
pub const WHITEBOARD_SERVICE_CREATE_BOARD_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/collab.v1.WhiteboardService/CreateBoard",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const WHITEBOARD_SERVICE_GET_BOARD_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/collab.v1.WhiteboardService/GetBoard",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const WHITEBOARD_SERVICE_LIST_BOARDS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/collab.v1.WhiteboardService/ListBoards",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const WHITEBOARD_SERVICE_UPDATE_BOARD_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/collab.v1.WhiteboardService/UpdateBoard",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const WHITEBOARD_SERVICE_UPDATE_BOARD_ACL_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/collab.v1.WhiteboardService/UpdateBoardAcl",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const WHITEBOARD_SERVICE_ARCHIVE_BOARD_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/collab.v1.WhiteboardService/ArchiveBoard",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const WHITEBOARD_SERVICE_MINT_JOIN_TOKEN_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/collab.v1.WhiteboardService/MintJoinToken",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
#[allow(clippy::type_complexity)]
pub trait WhiteboardService: Send + Sync + 'static {
fn create_board<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::collab::v1::CreateBoardRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::collab::v1::CreateBoardResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn get_board<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::collab::v1::GetBoardRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::collab::v1::GetBoardResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn list_boards<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::collab::v1::ListBoardsRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::collab::v1::ListBoardsResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn update_board<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::collab::v1::UpdateBoardRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::collab::v1::UpdateBoardResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn update_board_acl<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::collab::v1::UpdateBoardAclRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::collab::v1::UpdateBoardAclResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn archive_board<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::collab::v1::ArchiveBoardRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::collab::v1::ArchiveBoardResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn mint_join_token<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::collab::v1::MintJoinTokenRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::collab::v1::MintJoinTokenResponse,
> + Send + use<'a, Self>,
>,
> + Send;
}
pub trait WhiteboardServiceExt: WhiteboardService {
fn register(
self: ::std::sync::Arc<Self>,
router: ::connectrpc::Router,
) -> ::connectrpc::Router;
}
impl<S: WhiteboardService> WhiteboardServiceExt for S {
fn register(
self: ::std::sync::Arc<Self>,
router: ::connectrpc::Router,
) -> ::connectrpc::Router {
router
.route_view(
WHITEBOARD_SERVICE_SERVICE_NAME,
"CreateBoard",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::CreateBoardRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::collab::v1::CreateBoardRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.create_board(ctx, sreq)
.await?
.encode::<
crate::proto::collab::v1::CreateBoardResponse,
>(format)
}
})
},
)
.with_spec(WHITEBOARD_SERVICE_CREATE_BOARD_SPEC)
.route_view(
WHITEBOARD_SERVICE_SERVICE_NAME,
"GetBoard",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::GetBoardRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::collab::v1::GetBoardRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.get_board(ctx, sreq)
.await?
.encode::<
crate::proto::collab::v1::GetBoardResponse,
>(format)
}
})
},
)
.with_spec(WHITEBOARD_SERVICE_GET_BOARD_SPEC)
.route_view(
WHITEBOARD_SERVICE_SERVICE_NAME,
"ListBoards",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::ListBoardsRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::collab::v1::ListBoardsRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.list_boards(ctx, sreq)
.await?
.encode::<
crate::proto::collab::v1::ListBoardsResponse,
>(format)
}
})
},
)
.with_spec(WHITEBOARD_SERVICE_LIST_BOARDS_SPEC)
.route_view(
WHITEBOARD_SERVICE_SERVICE_NAME,
"UpdateBoard",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::UpdateBoardRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::collab::v1::UpdateBoardRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.update_board(ctx, sreq)
.await?
.encode::<
crate::proto::collab::v1::UpdateBoardResponse,
>(format)
}
})
},
)
.with_spec(WHITEBOARD_SERVICE_UPDATE_BOARD_SPEC)
.route_view(
WHITEBOARD_SERVICE_SERVICE_NAME,
"UpdateBoardAcl",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::UpdateBoardAclRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::collab::v1::UpdateBoardAclRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.update_board_acl(ctx, sreq)
.await?
.encode::<
crate::proto::collab::v1::UpdateBoardAclResponse,
>(format)
}
})
},
)
.with_spec(WHITEBOARD_SERVICE_UPDATE_BOARD_ACL_SPEC)
.route_view(
WHITEBOARD_SERVICE_SERVICE_NAME,
"ArchiveBoard",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::ArchiveBoardRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::collab::v1::ArchiveBoardRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.archive_board(ctx, sreq)
.await?
.encode::<
crate::proto::collab::v1::ArchiveBoardResponse,
>(format)
}
})
},
)
.with_spec(WHITEBOARD_SERVICE_ARCHIVE_BOARD_SPEC)
.route_view(
WHITEBOARD_SERVICE_SERVICE_NAME,
"MintJoinToken",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::MintJoinTokenRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::collab::v1::MintJoinTokenRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.mint_join_token(ctx, sreq)
.await?
.encode::<
crate::proto::collab::v1::MintJoinTokenResponse,
>(format)
}
})
},
)
.with_spec(WHITEBOARD_SERVICE_MINT_JOIN_TOKEN_SPEC)
}
}
#[doc(hidden)]
pub struct WhiteboardServiceRegisterMarker;
impl<S: WhiteboardService> ::connectrpc::ServiceRegister<WhiteboardServiceRegisterMarker>
for ::std::sync::Arc<S> {
fn register_service(self, router: ::connectrpc::Router) -> ::connectrpc::Router {
<S as WhiteboardServiceExt>::register(self, router)
}
}
pub struct WhiteboardServiceServer<T> {
inner: ::std::sync::Arc<T>,
}
impl<T: WhiteboardService> WhiteboardServiceServer<T> {
pub fn new(service: T) -> Self {
Self {
inner: ::std::sync::Arc::new(service),
}
}
pub fn from_arc(inner: ::std::sync::Arc<T>) -> Self {
Self { inner }
}
}
impl<T> Clone for WhiteboardServiceServer<T> {
fn clone(&self) -> Self {
Self {
inner: ::std::sync::Arc::clone(&self.inner),
}
}
}
impl<T: WhiteboardService> ::connectrpc::Dispatcher for WhiteboardServiceServer<T> {
#[inline]
fn lookup(
&self,
path: &str,
) -> Option<::connectrpc::dispatcher::codegen::MethodDescriptor> {
let method = path.strip_prefix("collab.v1.WhiteboardService/")?;
match method {
"CreateBoard" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(WHITEBOARD_SERVICE_CREATE_BOARD_SPEC),
)
}
"GetBoard" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(WHITEBOARD_SERVICE_GET_BOARD_SPEC),
)
}
"ListBoards" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(WHITEBOARD_SERVICE_LIST_BOARDS_SPEC),
)
}
"UpdateBoard" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(WHITEBOARD_SERVICE_UPDATE_BOARD_SPEC),
)
}
"UpdateBoardAcl" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(WHITEBOARD_SERVICE_UPDATE_BOARD_ACL_SPEC),
)
}
"ArchiveBoard" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(WHITEBOARD_SERVICE_ARCHIVE_BOARD_SPEC),
)
}
"MintJoinToken" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(WHITEBOARD_SERVICE_MINT_JOIN_TOKEN_SPEC),
)
}
_ => None,
}
}
fn call_unary(
&self,
path: &str,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::Payload,
format: ::connectrpc::CodecFormat,
) -> ::connectrpc::dispatcher::codegen::UnaryResult {
let Some(method) = path.strip_prefix("collab.v1.WhiteboardService/") else {
return ::connectrpc::dispatcher::codegen::unimplemented_unary(path);
};
let _ = (&ctx, &request, &format);
match method {
"CreateBoard" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::collab::v1::CreateBoardRequest,
>(request.encoded()?, format)?;
let req: crate::proto::collab::v1::__buffa::view::CreateBoardRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::collab::v1::CreateBoardRequest,
>::from_parts(&req, &body);
svc.create_board(ctx, req)
.await?
.encode::<crate::proto::collab::v1::CreateBoardResponse>(format)
})
}
"GetBoard" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::collab::v1::GetBoardRequest,
>(request.encoded()?, format)?;
let req: crate::proto::collab::v1::__buffa::view::GetBoardRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::collab::v1::GetBoardRequest,
>::from_parts(&req, &body);
svc.get_board(ctx, req)
.await?
.encode::<crate::proto::collab::v1::GetBoardResponse>(format)
})
}
"ListBoards" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::collab::v1::ListBoardsRequest,
>(request.encoded()?, format)?;
let req: crate::proto::collab::v1::__buffa::view::ListBoardsRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::collab::v1::ListBoardsRequest,
>::from_parts(&req, &body);
svc.list_boards(ctx, req)
.await?
.encode::<crate::proto::collab::v1::ListBoardsResponse>(format)
})
}
"UpdateBoard" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::collab::v1::UpdateBoardRequest,
>(request.encoded()?, format)?;
let req: crate::proto::collab::v1::__buffa::view::UpdateBoardRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::collab::v1::UpdateBoardRequest,
>::from_parts(&req, &body);
svc.update_board(ctx, req)
.await?
.encode::<crate::proto::collab::v1::UpdateBoardResponse>(format)
})
}
"UpdateBoardAcl" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::collab::v1::UpdateBoardAclRequest,
>(request.encoded()?, format)?;
let req: crate::proto::collab::v1::__buffa::view::UpdateBoardAclRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::collab::v1::UpdateBoardAclRequest,
>::from_parts(&req, &body);
svc.update_board_acl(ctx, req)
.await?
.encode::<
crate::proto::collab::v1::UpdateBoardAclResponse,
>(format)
})
}
"ArchiveBoard" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::collab::v1::ArchiveBoardRequest,
>(request.encoded()?, format)?;
let req: crate::proto::collab::v1::__buffa::view::ArchiveBoardRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::collab::v1::ArchiveBoardRequest,
>::from_parts(&req, &body);
svc.archive_board(ctx, req)
.await?
.encode::<crate::proto::collab::v1::ArchiveBoardResponse>(format)
})
}
"MintJoinToken" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::collab::v1::MintJoinTokenRequest,
>(request.encoded()?, format)?;
let req: crate::proto::collab::v1::__buffa::view::MintJoinTokenRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::collab::v1::MintJoinTokenRequest,
>::from_parts(&req, &body);
svc.mint_join_token(ctx, req)
.await?
.encode::<
crate::proto::collab::v1::MintJoinTokenResponse,
>(format)
})
}
_ => ::connectrpc::dispatcher::codegen::unimplemented_unary(path),
}
}
fn call_server_streaming(
&self,
path: &str,
ctx: ::connectrpc::RequestContext,
request: ::buffa::bytes::Bytes,
format: ::connectrpc::CodecFormat,
) -> ::connectrpc::dispatcher::codegen::StreamingResult {
let Some(method) = path.strip_prefix("collab.v1.WhiteboardService/") else {
return ::connectrpc::dispatcher::codegen::unimplemented_streaming(path);
};
let _ = (&ctx, &request, &format);
match method {
_ => ::connectrpc::dispatcher::codegen::unimplemented_streaming(path),
}
}
fn call_client_streaming(
&self,
path: &str,
ctx: ::connectrpc::RequestContext,
requests: ::connectrpc::dispatcher::codegen::RequestStream,
format: ::connectrpc::CodecFormat,
) -> ::connectrpc::dispatcher::codegen::UnaryResult {
let Some(method) = path.strip_prefix("collab.v1.WhiteboardService/") else {
return ::connectrpc::dispatcher::codegen::unimplemented_unary(path);
};
let _ = (&ctx, &requests, &format);
match method {
_ => ::connectrpc::dispatcher::codegen::unimplemented_unary(path),
}
}
fn call_bidi_streaming(
&self,
path: &str,
ctx: ::connectrpc::RequestContext,
requests: ::connectrpc::dispatcher::codegen::RequestStream,
format: ::connectrpc::CodecFormat,
) -> ::connectrpc::dispatcher::codegen::StreamingResult {
let Some(method) = path.strip_prefix("collab.v1.WhiteboardService/") else {
return ::connectrpc::dispatcher::codegen::unimplemented_streaming(path);
};
let _ = (&ctx, &requests, &format);
match method {
_ => ::connectrpc::dispatcher::codegen::unimplemented_streaming(path),
}
}
}
#[derive(Clone)]
pub struct WhiteboardServiceClient<T> {
transport: T,
config: ::connectrpc::client::ClientConfig,
}
impl<T> WhiteboardServiceClient<T>
where
T: ::connectrpc::client::ClientTransport,
<T::ResponseBody as ::connectrpc::http_body::Body>::Error: ::std::fmt::Display,
{
pub fn new(transport: T, config: ::connectrpc::client::ClientConfig) -> Self {
Self { transport, config }
}
pub fn config(&self) -> &::connectrpc::client::ClientConfig {
&self.config
}
pub fn config_mut(&mut self) -> &mut ::connectrpc::client::ClientConfig {
&mut self.config
}
pub async fn create_board(
&self,
request: crate::proto::collab::v1::CreateBoardRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::CreateBoardResponseView<'static>,
>,
>,
::connectrpc::ConnectError,
> {
self.create_board_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn create_board_with_options(
&self,
request: crate::proto::collab::v1::CreateBoardRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::CreateBoardResponseView<'static>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
WHITEBOARD_SERVICE_SERVICE_NAME,
"CreateBoard",
request,
options,
)
.await
}
pub async fn get_board(
&self,
request: crate::proto::collab::v1::GetBoardRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::GetBoardResponseView<'static>,
>,
>,
::connectrpc::ConnectError,
> {
self.get_board_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn get_board_with_options(
&self,
request: crate::proto::collab::v1::GetBoardRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::GetBoardResponseView<'static>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
WHITEBOARD_SERVICE_SERVICE_NAME,
"GetBoard",
request,
options,
)
.await
}
pub async fn list_boards(
&self,
request: crate::proto::collab::v1::ListBoardsRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::ListBoardsResponseView<'static>,
>,
>,
::connectrpc::ConnectError,
> {
self.list_boards_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn list_boards_with_options(
&self,
request: crate::proto::collab::v1::ListBoardsRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::ListBoardsResponseView<'static>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
WHITEBOARD_SERVICE_SERVICE_NAME,
"ListBoards",
request,
options,
)
.await
}
pub async fn update_board(
&self,
request: crate::proto::collab::v1::UpdateBoardRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::UpdateBoardResponseView<'static>,
>,
>,
::connectrpc::ConnectError,
> {
self.update_board_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn update_board_with_options(
&self,
request: crate::proto::collab::v1::UpdateBoardRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::UpdateBoardResponseView<'static>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
WHITEBOARD_SERVICE_SERVICE_NAME,
"UpdateBoard",
request,
options,
)
.await
}
pub async fn update_board_acl(
&self,
request: crate::proto::collab::v1::UpdateBoardAclRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::UpdateBoardAclResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.update_board_acl_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn update_board_acl_with_options(
&self,
request: crate::proto::collab::v1::UpdateBoardAclRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::UpdateBoardAclResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
WHITEBOARD_SERVICE_SERVICE_NAME,
"UpdateBoardAcl",
request,
options,
)
.await
}
pub async fn archive_board(
&self,
request: crate::proto::collab::v1::ArchiveBoardRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::ArchiveBoardResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.archive_board_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn archive_board_with_options(
&self,
request: crate::proto::collab::v1::ArchiveBoardRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::ArchiveBoardResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
WHITEBOARD_SERVICE_SERVICE_NAME,
"ArchiveBoard",
request,
options,
)
.await
}
pub async fn mint_join_token(
&self,
request: crate::proto::collab::v1::MintJoinTokenRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::MintJoinTokenResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.mint_join_token_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn mint_join_token_with_options(
&self,
request: crate::proto::collab::v1::MintJoinTokenRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::collab::v1::__buffa::view::MintJoinTokenResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
WHITEBOARD_SERVICE_SERVICE_NAME,
"MintJoinToken",
request,
options,
)
.await
}
}