Differential D16569 Diff 49662 chronik/chronik-http/src/handlers.rs

Changeset View

Standalone View

Show First 20 Lines • Show All 372 Lines • ▼ Show 20 Lines	Ok(proto::PluginGroups {
groups: groups		groups: groups
.groups		.groups
.into_iter()		.into_iter()
.map(\|group\| proto::PluginGroup { group })		.map(\|group\| proto::PluginGroup { group })
.collect(),		.collect(),
next_start: groups.next_start.unwrap_or_default(),		next_start: groups.next_start.unwrap_or_default(),
})		})
}		}

		/// Return a block header and optionally checkpoint data
		pub async fn handle_block_header(
		hash_or_height: String,
		query_params: &HashMap<String, String>,
		indexer: &ChronikIndexer,
		node: &Node,
		) -> Result<proto::BlockHeader> {
		let blocks = indexer.blocks(&node);
		let checkpoint_height: i32 =
		get_param(query_params, "checkpoint_height")?.unwrap_or(0);
		blocks.header(hash_or_height, checkpoint_height).await
		}

		/// Return block headers and optionally checkpoint data
		pub async fn handle_block_headers(
		start_height: i32,
		end_height: i32,
		query_params: &HashMap<String, String>,
		indexer: &ChronikIndexer,
		node: &Node,
		) -> Result<proto::BlockHeaders> {
		let blocks = indexer.blocks(&node);
		let checkpoint_height: i32 =
		get_param(query_params, "checkpoint_height")?.unwrap_or(0);
		blocks
		.headers_by_range(start_height, end_height, checkpoint_height)
		.await
		}