smeb_y/0g-storage-node
1
0
Fork 0
mirror of https://github.com/0glabs/0g-storage-node.git synced 2025-01-23 21:46:17 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Check the contract version

Browse Source
This commit is contained in:
Bruno Valente 2024-12-27 17:20:07 +08:00
parent ab6a4e8120
commit a584596bac
2 changed files with 41 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

63
node/miner/src/watcher.rs
View File

@ -28,6 +28,8 @@ lazy_static! {
H256::from_str("c5d2460186f7233c927e7db2dcc703c0e500b653ca82273b7bfad8045d85a470").unwrap();
}
const PORA_VERSION: u64 = 1;
pub struct MineContextWatcher {
provider: Arc<Provider<RetryClient<Http>>>,
flow_contract: ZgsFlow<Provider<RetryClient<Http>>>,
@ -108,29 +110,7 @@ impl MineContextWatcher {
}
async fn query_recent_context(&mut self) -> Result<(), String> {
let miner_id = self.miner_id.0;
let WorkerContext {
context,
pora_target,
subtask_digest,
max_shards,
} = self
.mine_contract
.compute_worker_context(miner_id)
.call()
.await
.map_err(|e| format!("Failed to query mining context: {:?}", e))?;
let report = if pora_target > U256::zero() && context.digest != EMPTY_HASH.0 {
Some(PoraPuzzle::new(
context,
pora_target,
max_shards,
H256(subtask_digest),
))
} else {
None
};
let report = self.fetch_pora_puzzle().await?;
if report == self.last_report {
return Ok(());
@ -145,4 +125,41 @@ impl MineContextWatcher {
Ok(())
}
async fn fetch_pora_puzzle(&self) -> Result<Option<PoraPuzzle>, String> {
let pora_version = self
.mine_contract
.pora_version()
.call()
.await
.map_err(|e| format!("Failed to query mining version: {:?}", e))?;
if pora_version != PORA_VERSION {
return Ok(None);
}
let miner_id = self.miner_id.0;
let WorkerContext {
context,
pora_target,
subtask_digest,
max_shards,
} = self
.mine_contract
.compute_worker_context(miner_id)
.call()
.await
.map_err(|e| format!("Failed to query mining context: {:?}", e))?;
if pora_target.is_zero() || context.digest == EMPTY_HASH.0 {
return Ok(None);
}
Ok(Some(PoraPuzzle::new(
context,
pora_target,
max_shards,
H256(subtask_digest),
)))
}
}