Skip to content

Commit

Permalink
Added OCW activity logs (#415)
Browse files Browse the repository at this point in the history
## Description
<!-- Describe what change this PR is implementing -->

## Types of Changes
Please select the branch type you are merging and fill in the relevant
template.
<!--- Check the following box with an x if the following applies: -->
- [ ] Hotfix
- [ ] Release
- [ ] Fix or Feature

## Fix or Feature
<!--- Check the following box with an x if the following applies: -->

### Types of Changes
<!--- What types of changes does your code introduce? -->
- [ ] Tech Debt (Code improvements)
- [ ] Bug fix (non-breaking change which fixes an issue)
- [ ] New feature (non-breaking change which adds functionality)
- [ ] Breaking change (fix or feature that would cause existing
functionality to change)
- [ ] Dependency upgrade (A change in substrate or any 3rd party crate
version)

### Migrations and Hooks
<!--- Check the following box with an x if the following applies: -->
- [ ] This change requires a runtime migration.
- [ ] Modifies `on_initialize`
- [ ] Modifies `on_finalize`

### Checklist for Fix or Feature
<!--- All boxes need to be checked. Follow this checklist before
requiring PR review -->
- [ ] Change has been tested locally.
- [ ] Change adds / updates tests if applicable.
- [ ] Changelog doc updated.
- [ ] `spec_version` has been incremented.
- [ ] `network-relayer`'s
[events](https://github.com/Cerebellum-Network/network-relayer/blob/dev-cere/shared/substrate/events.go)
have been updated according to the blockchain events if applicable.
- [ ] All CI checks have been passed successfully

## Checklist for Hotfix
<!--- All boxes need to be checked. Follow this checklist before
requiring PR review -->
- [ ] Change has been deployed to Testnet.
- [ ] Change has been tested in Testnet.
- [ ] Changelog has been updated.
- [ ] Crate version has been updated.
- [ ] `spec_version` has been incremented.
- [ ] Transaction version has been updated if required.
- [ ] Pull Request to `dev` has been created.
- [ ] Pull Request to `staging` has been created.
- [ ] `network-relayer`'s
[events](https://github.com/Cerebellum-Network/network-relayer/blob/dev-cere/shared/substrate/events.go)
have been updated according to the blockchain events if applicable.
- [ ] All CI checks have been passed successfully

## Checklist for Release
<!--- All boxes need to be checked. Follow this checklist before
requiring PR review -->
- [ ] Change has been deployed to Devnet.
- [ ] Change has been tested in Devnet.
- [ ] Change has been deployed to Qanet.
- [ ] Change has been tested in Qanet.
- [ ] Change has been deployed to Testnet.
- [ ] Change has been tested in Testnet.
- [ ] Changelog has been updated.
- [ ] Crate version has been updated.
- [ ] Spec version has been updated.
- [ ] Transaction version has been updated if required.
- [ ] All CI checks have been passed successfully
  • Loading branch information
ayushmishra2005 authored Aug 12, 2024
1 parent 92e08a3 commit f164ec0
Show file tree
Hide file tree
Showing 3 changed files with 21 additions and 12 deletions.
29 changes: 19 additions & 10 deletions pallets/ddc-verification/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1226,11 +1226,14 @@ pub mod pallet {
.map(|c| c.hash::<T>())
.collect();

let customer_activity_hashes_string: Vec<String> =
customer_activity_hashes.clone().into_iter().map(hex::encode).collect();

log::info!(
"🧗‍ Customer Activity hashes for ClusterId: {:?} EraId: {:?} is: {:?}",
cluster_id,
era_activity.id,
customer_activity_hashes
customer_activity_hashes_string
);
let customers_activity_batch_roots = Self::convert_to_batch_merkle_roots(
cluster_id,
Expand All @@ -1247,9 +1250,9 @@ pub mod pallet {
"🧗‍ Customer Activity batches for ClusterId: {:?} EraId: {:?} is: batch {:?} with root {:?} for activities {:?}",
cluster_id,
era_activity.id,
pos,
pos + 1,
batch_root,
customer_activity_hashes
customer_activity_hashes_string
);
}

Expand Down Expand Up @@ -1279,11 +1282,14 @@ pub mod pallet {
let node_activity_hashes: Vec<ActivityHash> =
nodes_activity_in_consensus.clone().into_iter().map(|c| c.hash::<T>()).collect();

let node_activity_hashes_string: Vec<String> =
node_activity_hashes.clone().into_iter().map(hex::encode).collect();

log::info!(
"🧗‍ Node Activity hashes for ClusterId: {:?} EraId: {:?} is: {:?}",
cluster_id,
era_activity.id,
node_activity_hashes
node_activity_hashes_string
);

let nodes_activity_batch_roots = Self::convert_to_batch_merkle_roots(
Expand All @@ -1296,20 +1302,23 @@ pub mod pallet {
let nodes_activity_batch_roots_string: Vec<String> =
nodes_activity_batch_roots.clone().into_iter().map(hex::encode).collect();

log::info!(
"🧗‍ Node Activity batches for ClusterId: {:?} EraId: {:?} is: batch 1 with root {:?} for activities {:?}",
for (pos, batch_root) in nodes_activity_batch_roots_string.iter().enumerate() {
log::info!(
"🧗‍ Node Activity batches for ClusterId: {:?} EraId: {:?} is: batch {:?} with root {:?} for activities {:?}",
cluster_id,
era_activity.id,
nodes_activity_batch_roots_string,
node_activity_hashes
);
pos + 1,
batch_root,
node_activity_hashes_string
);
}

let nodes_activity_root =
Self::create_merkle_root(cluster_id, era_activity.id, &nodes_activity_batch_roots)
.map_err(|err| vec![err])?;

log::info!(
"🧗‍ Node Activity batches tree for ClusterId: {:?} EraId: {:?} is: batch 1 with root {:?} for activities {:?}",
"🧗‍ Node Activity batches tree for ClusterId: {:?} EraId: {:?} is: batch with root {:?} for activities {:?}",
cluster_id,
era_activity.id,
hex::encode(nodes_activity_root),
Expand Down
2 changes: 1 addition & 1 deletion runtime/cere-dev/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -149,7 +149,7 @@ pub const VERSION: RuntimeVersion = RuntimeVersion {
// and set impl_version to 0. If only runtime
// implementation changes and behavior does not, then leave spec_version as
// is and increment impl_version.
spec_version: 54114,
spec_version: 54115,
impl_version: 0,
apis: RUNTIME_API_VERSIONS,
transaction_version: 19,
Expand Down
2 changes: 1 addition & 1 deletion runtime/cere/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,7 @@ pub const VERSION: RuntimeVersion = RuntimeVersion {
// and set impl_version to 0. If only runtime
// implementation changes and behavior does not, then leave spec_version as
// is and increment impl_version.
spec_version: 54114,
spec_version: 54115,
impl_version: 0,
apis: RUNTIME_API_VERSIONS,
transaction_version: 19,
Expand Down

0 comments on commit f164ec0

Please sign in to comment.