try to implement runtime apis

cli/polka-storage-provider/client/src/commands/proofs.rs

@@ -380,6 +380,10 @@ impl ProofsCommand {
                 // need to be able to calculate deadline info and challenge
                 // I'll hardcode it for now
                 let randomness: [u8; 32] = if let Some(randomness) = randomness {
+                    // 1. We need to know deadline_index as an input, which was assigned on ProveCommit, treat it as an index
+                    // 2. We can impl_runtime_apis for current_deadline info, if it matches the index, if not, just wait another proving window.
+                    // 3. Then get randomness for this current_deadline info block
+                    // 4. Make the proof work.
                     hex::decode(randomness).unwrap().try_into().unwrap()
                 } else {
                     [1u8; 32]

cli/polka-storage/storagext/Cargo.toml

@@ -21,7 +21,7 @@ frame-support = { workspace = true, features = ["std"] }
 futures.workspace = true
 hex = { workspace = true, features = ["serde"] }
 itertools = { workspace = true }
-primitives-proofs = { workspace = true, features = ["serde"] }
+primitives-proofs = { workspace = true, features = ["std", "serde"] }
 serde = { workspace = true, features = ["derive"] }
 serde_json = { workspace = true }
 sha2 = { workspace = true }

cli/polka-storage/storagext/src/clients/storage_provider.rs

@@ -98,9 +98,19 @@ pub trait StorageProviderClientExt {
     fn retrieve_registered_storage_providers(
         &self,
     ) -> impl Future<Output = Result<Vec<String>, subxt::Error>>;
+
+
+    fn current_deadline(&self, account_id: &AccountId32) -> impl Future<Output = Result<u64, subxt::Error>>;
 }
 
 impl StorageProviderClientExt for crate::runtime::client::Client {
+    async fn current_deadline(&self, account_id: &AccountId32) -> Result<u64, subxt::Error> {
+        // let _ = runtime::apis().storage_provider_api().current_deadline(account_id);
+        // let _ = runtime::apis().account_nonce_api().account_nonce(account_id);
+
+        Ok(0)
+    }
+
     #[tracing::instrument(
         level = "debug",
         skip_all,

pallets/storage-provider/src/lib.rs

@@ -729,10 +729,6 @@ pub mod pallet {
                 )
                 .map_err(|e| Error::<T>::GeneralPalletError(e))?;
 
-            // TODO:
-            // - generate a windowed post proof for this shit (by hand)
-            // - generate it automatically in the pipeline
-
             // TODO(@th7nder,#592, 19/11/2024): handle faulty and recovered sectors, we don't take them into account now
             let deadlines = &sp.deadlines;
             let mut replicas = BoundedBTreeMap::new();
@@ -766,7 +762,7 @@ pub mod pallet {
                 replicas
             );
 
-            // let entropy = owner.encode();
+            let entropy = owner.encode();
             // The `chain_commit_epoch` should be `current_deadline.challenge` as per:
             //
             // These issues that were filed against the original implementation:
@@ -792,10 +788,6 @@ pub mod pallet {
                 &entropy,
             )?;
 
-            let randomness = [1u8; 32];
-
-            // Questions:
-            // * How do we know the partition the sector was assigned to (as a caller) ?
             T::ProofVerification::verify_post(
                 windowed_post.proof.post_proof,
                 randomness,

primitives/proofs/Cargo.toml

@@ -14,6 +14,7 @@ scale-decode = { workspace = true, default-features = false, features = ["derive
 scale-encode = { workspace = true, default-features = false, features = ["derive"] }
 scale-info = { workspace = true, default-features = false, features = ["derive"] }
 
+sp-api = { workspace = true, default-features = false }
 sp-core = { workspace = true, default-features = false }
 sp-runtime = { workspace = true, default-features = false }
 sp-std = { workspace = true, default-features = false }
@@ -31,4 +32,4 @@ workspace = true
 [features]
 clap = ["dep:clap", "std"]
 default = ["std"]
-std = ["cid/scale-codec", "codec/std", "dep:storage-proofs-core", "scale-info/std", "sp-core/std", "sp-runtime/std", "sp-std/std"]
+std = ["cid/scale-codec", "codec/std", "dep:storage-proofs-core", "sp-api/std", "scale-info/std", "sp-core/std", "sp-runtime/std", "sp-std/std"]

primitives/proofs/src/lib.rs

@@ -4,7 +4,7 @@ pub mod randomness;
 mod traits;
 mod types;
 
-use codec::Encode;
+use codec::{Codec, Encode};
 pub use traits::*;
 pub use types::*;
 
@@ -23,3 +23,10 @@ where
     encoded[31] &= 0x3f;
     encoded
 }
+
+sp_api::decl_runtime_apis! {
+    pub trait StorageProviderApi<AccountId> where AccountId: Codec
+    {
+        fn current_deadline(storage_provider: AccountId) -> u64;
+    }
+}

primitives/proofs/src/traits.rs

@@ -163,4 +163,4 @@ pub struct ActiveDeal<AccountId> {
     pub piece_cid: Cid,
     /// Real size of the data
     pub piece_size: u64,
-}
+}

runtime/Cargo.toml

@@ -26,6 +26,8 @@ pallet-proofs = { workspace = true, default-features = false }
 pallet-randomness = { workspace = true, default-features = false }
 pallet-storage-provider = { workspace = true, default-features = false }
 
+primitives-proofs = { workspace = true, default-features = false }
+
 codec = { workspace = true, default-features = false, features = ["chain-error", "derive"] }
 docify = { workspace = true }
 hex-literal = { workspace = true, optional = true }
@@ -128,6 +130,7 @@ std = [
   "parachains-common/std",
   "polkadot-parachain-primitives/std",
   "polkadot-runtime-common/std",
+  "primitives-proofs/std",
   "scale-info/std",
   "sp-api/std",
   "sp-block-builder/std",

runtime/src/apis.rs

@@ -65,6 +65,12 @@ impl Runtime {
 }
 
 impl_runtime_apis! {
+    impl primitives_proofs::StorageProviderApi<Block, AccountId> for Runtime {
+        fn current_deadline(storage_provider: AccountId) -> u64 {
+            0
+        }
+    }
+
     impl sp_consensus_aura::AuraApi<Block, AuraId> for Runtime {
         fn slot_duration() -> sp_consensus_aura::SlotDuration {
             Runtime::impl_slot_duration()