use tetsy_jsonrpc_derive::rpc;
use serde::{Serialize, Deserialize};

use std::sync::Arc;
use tetsy_jsonrpc_core::Result;
use tetsy_jsonrpc_pubsub::{typed::Subscriber, SubscriptionId, Session, PubSubHandler};

#[derive(Serialize, Deserialize)]
pub struct Wrapper<T, U> {
	inner: T,
	inner2: U,
}

#[rpc]
pub trait Rpc<T, U> {
	type Metadata;

	/// Hello subscription
	#[pubsub(subscription = "hello", subscribe, name = "hello_subscribe", alias("hello_sub"))]
	fn subscribe(&self, _: Self::Metadata, _: Subscriber<Wrapper<T, U>>);

	/// Unsubscribe from hello subscription.
	#[pubsub(subscription = "hello", unsubscribe, name = "hello_unsubscribe")]
	fn unsubscribe(&self, a: Option<Self::Metadata>, b: SubscriptionId) -> Result<bool>;
}

#[derive(Serialize, Deserialize)]
struct SerializeAndDeserialize {
	foo: String,
}

struct RpcImpl;
impl Rpc<SerializeAndDeserialize, SerializeAndDeserialize> for RpcImpl {
	type Metadata = Arc<Session>;

	fn subscribe(&self, _: Self::Metadata, _: Subscriber<Wrapper<SerializeAndDeserialize, SerializeAndDeserialize>>) {
		unimplemented!();
	}

	fn unsubscribe(&self, _: Option<Self::Metadata>, _: SubscriptionId) -> Result<bool> {
		unimplemented!();
	}
}

fn main() {
	let mut io = PubSubHandler::default();
	let rpc = RpcImpl;
	io.extend_with(rpc.to_delegate());
}