Skip to content

Commit

Permalink
Playground bindings
Browse files Browse the repository at this point in the history
  • Loading branch information
Mikhail Sozin committed Oct 8, 2024
1 parent 7606ccb commit fb388f9
Show file tree
Hide file tree
Showing 3 changed files with 14 additions and 18 deletions.
7 changes: 4 additions & 3 deletions core/src/generator/networks_bindings.rs
Original file line number Diff line number Diff line change
Expand Up @@ -92,7 +92,7 @@ pub fn generate_networks_code(networks: &[Network]) -> Code {
use ethers::types::U64;
use rindexer::{
lazy_static,
provider::{create_client, JsonRpcCachedProvider, RetryClientError},
provider::{create_jsonrpc_client, JsonRpcCachedProvider, ProviderInterface, RetryClientError},
public_read_env_value, HeaderMap,
};
use std::sync::Arc;
Expand All @@ -102,13 +102,14 @@ pub fn generate_networks_code(networks: &[Network]) -> Code {
rpc_url: &str,
compute_units_per_second: Option<u64>,
max_block_range: Option<U64>,
) -> Result<Arc<JsonRpcCachedProvider>, RetryClientError> {
) -> Result<Arc<dyn ProviderInterface>, RetryClientError> {
let mut header = HeaderMap::new();
header.insert(
"X-SHADOW-API-KEY",
public_read_env_value("RINDEXER_PHANTOM_API_KEY").unwrap().parse().unwrap(),
);
create_client(rpc_url, compute_units_per_second, max_block_range, header)
create_jsonrpc_client(rpc_url.parse().unwrap(), compute_units_per_second, max_block_range, header)
.and_then(|client| Ok(client as Arc<dyn ProviderInterface>))
}
lazy_static! {
Expand Down
15 changes: 3 additions & 12 deletions rindexer_rust_playground/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -83,21 +83,15 @@ async fn main() {

#[allow(dead_code)]
fn generate() {
let path = PathBuf::from_str(
"./rindexer.yaml",
)
.expect("Invalid path");
let path = PathBuf::from_str("./rindexer.yaml").expect("Invalid path");
let manifest = read_manifest(&path).expect("Failed to read manifest");
rindexer::generator::build::generate_rindexer_typings(&manifest, &path, true)
.expect("Failed to generate typings");
}

#[allow(dead_code)]
fn generate_code_test() {
let path = PathBuf::from_str(
"./rindexer.yaml",
)
.expect("Invalid path");
let path = PathBuf::from_str("./rindexer.yaml").expect("Invalid path");
let manifest = read_manifest(&path).expect("Failed to read manifest");

rindexer::generator::build::generate_rindexer_handlers(manifest, &path, true)
Expand All @@ -106,10 +100,7 @@ fn generate_code_test() {

#[allow(dead_code)]
fn generate_all() {
let path = PathBuf::from_str(
"./rindexer.yaml",
)
.expect("Invalid path");
let path = PathBuf::from_str("./rindexer.yaml").expect("Invalid path");
rindexer::generator::build::generate_rindexer_typings_and_handlers(&path)
.expect("Failed to generate typings and handlers");
}
Expand Down
10 changes: 7 additions & 3 deletions rindexer_rust_playground/src/rindexer_lib/typings/networks.rs
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@ use ethers::providers::{Http, Provider, RetryClient};
use ethers::types::U64;
use rindexer::{
lazy_static,
manifest::network::ProviderType,
provider::{create_jsonrpc_client, JsonRpcCachedProvider, ProviderInterface, RetryClientError},
public_read_env_value, HeaderMap,
};
Expand All @@ -24,8 +23,13 @@ fn create_shadow_client(
"X-SHADOW-API-KEY",
public_read_env_value("RINDEXER_PHANTOM_API_KEY").unwrap().parse().unwrap(),
);
create_jsonrpc_client(rpc_url.parse().unwrap(), compute_units_per_second, max_block_range, header)
.and_then(|client| Ok(client as Arc<dyn ProviderInterface>))
create_jsonrpc_client(
rpc_url.parse().unwrap(),
compute_units_per_second,
max_block_range,
header,
)
.and_then(|client| Ok(client as Arc<dyn ProviderInterface>))
}

lazy_static! {
Expand Down

0 comments on commit fb388f9

Please sign in to comment.