From e444fe9a98e712f24398c674471438e91ea3dc60 Mon Sep 17 00:00:00 2001
From: Konrad Stepniak <konrad@eiger.co>
Date: Thu, 28 Nov 2024 17:19:14 +0100
Subject: [PATCH] feat: add working demo

---
 cli/polka-storage-provider/server/src/main.rs         | 6 +++++-
 cli/polka-storage-provider/server/src/pipeline/mod.rs | 6 +++---
 examples/rpc_publish.sh                               | 3 ++-
 3 files changed, 10 insertions(+), 5 deletions(-)

diff --git a/cli/polka-storage-provider/server/src/main.rs b/cli/polka-storage-provider/server/src/main.rs
index f02f9769b..78075c653 100644
--- a/cli/polka-storage-provider/server/src/main.rs
+++ b/cli/polka-storage-provider/server/src/main.rs
@@ -10,7 +10,7 @@ mod storage;
 use std::{env::temp_dir, net::SocketAddr, path::PathBuf, sync::Arc, time::Duration};
 
 use clap::Parser;
-use pipeline::types::PipelineMessage;
+use pipeline::types::{PipelineMessage, SubmitWindowedPoStMessage};
 use polka_storage_proofs::{
     porep::{self, PoRepParameters},
     post::{self, PoStParameters},
@@ -419,6 +419,10 @@ impl ServerConfiguration {
 
         let (pipeline_tx, pipeline_rx) = tokio::sync::mpsc::unbounded_channel::<PipelineMessage>();
 
+        pipeline_tx.send(PipelineMessage::SubmitWindowedPoStMessage(SubmitWindowedPoStMessage {
+            deadline_index: 0
+        })).expect("it to work...");
+
         let storage_state = StorageServerState {
             car_piece_storage_dir: car_piece_storage_dir.clone(),
             deal_db: deal_database.clone(),
diff --git a/cli/polka-storage-provider/server/src/pipeline/mod.rs b/cli/polka-storage-provider/server/src/pipeline/mod.rs
index 42275f5cf..24133313b 100644
--- a/cli/polka-storage-provider/server/src/pipeline/mod.rs
+++ b/cli/polka-storage-provider/server/src/pipeline/mod.rs
@@ -14,16 +14,16 @@ use primitives_commitment::{CommD, CommP, CommR, Commitment};
 use primitives_proofs::{
     derive_prover_id,
     randomness::{draw_randomness, DomainSeparationTag},
-    SectorNumber, MAX_SECTORS_PER_PROOF,
+    SectorNumber,
 };
 use storagext::{
     types::{
         market::DealProposal,
         storage_provider::{PoStProof, ProveCommitSector, SectorPreCommitInfo, SubmitWindowedPoStParams},
-    }, IntoBoundedByteVec, RandomnessClientExt, StorageProviderClientExt, SystemClientExt
+    }, RandomnessClientExt, StorageProviderClientExt, SystemClientExt
 };
 use subxt::{
-    ext::{codec::Encode, sp_core::ConstU32},
+    ext::codec::Encode,
     tx::Signer,
 };
 use tokio::{
diff --git a/examples/rpc_publish.sh b/examples/rpc_publish.sh
index f2fcc0ed5..d06086184 100755
--- a/examples/rpc_publish.sh
+++ b/examples/rpc_publish.sh
@@ -1,4 +1,5 @@
 #!/usr/bin/env bash
+set -e
 
 if [ "$#" -ne 1 ]; then
     echo "$0: input file required"
@@ -58,7 +59,7 @@ DEAL_JSON=$(
 )
 SIGNED_DEAL_JSON="$(RUST_LOG=error target/release/polka-storage-provider-client sign-deal --sr25519-key "$CLIENT" "$DEAL_JSON")"
 
-(RUST_LOG=debug target/release/polka-storage-provider-server --sr25519-key "$PROVIDER" --seal-proof "2KiB" --post-proof "2KiB" --porep-parameters 2KiB.porep.params) &
+(RUST_LOG=debug target/release/polka-storage-provider-server --sr25519-key "$PROVIDER" --seal-proof "2KiB" --post-proof "2KiB" --porep-parameters 2KiB.porep.params --post-parameters 2KiB.post.params) &
 sleep 5 # gives time for the server to start
 
 DEAL_CID="$(RUST_LOG=error target/release/polka-storage-provider-client propose-deal "$DEAL_JSON")"