Skeleton

.gitignore

@@ -15,3 +15,5 @@ index.html
 
 # Test data
 test-data
+
+Cargo.lock

Cargo.toml

@@ -1,11 +1,4 @@
-[package]
-authors     = ["Xavier Lau <[email protected]>"]
-build       = "build.rs"
-description = "<DESCRIPTION>"
-edition     = "2021"
-homepage    = "https://<NAME>.hack.ink"
-license     = "GPL-3.0"
-name        = "<NAME>"
-readme      = "README.md"
-repository  = "https://github.com/hack-ink/<NAME>"
-version     = "0.1.0"
+[workspace]
+members = [
+	"subapeye"
+]

subapeye/Cargo.toml

@@ -0,0 +1,31 @@
+[package]
+authors     = ["Xavier Lau <[email protected]>"]
+description = "subapeye"
+edition     = "2021"
+homepage    = "https://github.com/darwinia-network/subxt"
+license     = "GPL-3.0"
+name        = "subapeye"
+readme      = "README.md"
+repository  = "https://github.com/darwinia-network/subxt"
+version     = "0.1.0"
+
+[dependencies]
+
+thiserror         = "1"
+async-trait       = "0.1"
+tokio-tungstenite = { optional = true, version = "0.18" }
+reqwest           = { optional = true, version = "0.11" }
+
+subcryptor        = { branch = "main", git = "https://github.com/hack-ink/subalfred" }
+subgrandpa        = { branch = "main", git = "https://github.com/hack-ink/subalfred" }
+subhasher         = { branch = "main", git = "https://github.com/hack-ink/subalfred" }
+subrpcer          = { branch = "main", git = "https://github.com/hack-ink/subalfred" }
+subruntimer       = { branch = "main", git = "https://github.com/hack-ink/subalfred" }
+subspector        = { branch = "main", git = "https://github.com/hack-ink/subalfred" }
+substorager       = { branch = "main", git = "https://github.com/hack-ink/subalfred" }
+subversioner      = { branch = "main", git = "https://github.com/hack-ink/subalfred" }
+
+[features]
+default       = ["provider-http", "provider-ws"]
+provider-http = ["reqwest"]
+provider-ws   = ["tokio-tungstenite"]

subapeye/src/error.rs

@@ -0,0 +1,11 @@
+use thiserror::Error as ThisError;
+
+pub type SubapeyeResult<T> = Result<T, SubapeyeError>;
+
+
+/// Subapeye error
+#[derive(ThisError, Debug)]
+pub enum SubapeyeError {
+	#[error("Unsupported: {0}")]
+	Unsupported(String),
+}

subapeye/src/lib.rs

@@ -0,0 +1,5 @@
+pub use self::subapeye::*;
+
+pub mod provider;
+
+mod subapeye;

subapeye/src/provider/common.rs

@@ -0,0 +1,23 @@
+
+/// provider config
+#[derive(Clone, Debug)]
+pub struct Config {
+	pub endpoint: String,
+	pub timeout: Option<u64>,
+}
+
+impl Config {
+	pub fn simple(endpoint: impl AsRef<str>) -> Self {
+		Self {
+			endpoint: endpoint.as_ref().to_string(),
+			timeout: None,
+		}
+	}
+}
+
+#[async_trait::async_trait]
+pub trait ApeyeProvider: Clone + std::fmt::Debug {
+
+}
+
+

subapeye/src/provider/http.rs

@@ -0,0 +1,15 @@
+use crate::provider::{ApeyeProvider, Config};
+
+#[derive(Clone, Debug)]
+pub struct HttpProvider {
+	config: Config,
+}
+
+impl HttpProvider {
+	pub fn new(config: Config) -> Self {
+		Self { config }
+	}
+}
+
+#[async_trait::async_trait]
+impl ApeyeProvider for HttpProvider {}

subapeye/src/provider/mod.rs

@@ -0,0 +1,15 @@
+
+#[cfg(any(feature = "provider-http", feature = "provider-ws"))]
+pub use self::common::*;
+#[cfg(feature = "provider-http")]
+pub use self::http::*;
+#[cfg(feature = "provider-ws")]
+pub use self::websocket::*;
+
+#[cfg(feature = "provider-http")]
+mod http;
+#[cfg(feature = "provider-ws")]
+mod websocket;
+
+#[cfg(any(feature = "provider-http", feature = "provider-ws"))]
+mod common;

subapeye/src/provider/websocket.rs

@@ -0,0 +1,15 @@
+use crate::provider::{ApeyeProvider, Config};
+
+#[derive(Clone, Debug)]
+pub struct WsProvider {
+	config: Config,
+}
+
+impl WsProvider {
+	pub fn new(config: Config) -> Self {
+		Self { config }
+	}
+}
+
+#[async_trait::async_trait]
+impl ApeyeProvider for WsProvider {}

subapeye/src/subapeye.rs

@@ -0,0 +1,15 @@
+use crate::provider::ApeyeProvider;
+
+/// Subapeye
+#[derive(Clone, Debug)]
+pub struct Subapeye<P: ApeyeProvider> {
+	provider: P,
+}
+
+impl<P: ApeyeProvider> Subapeye<P> {
+	/// New subapeye instance
+	pub fn new(provider: P) -> Self {
+		Self { provider }
+	}
+}
+