fix: increase proposal channel to 4096, restore direct writes for startup sync

Author: echobt

bins/validator-node/src/main.rs

@@ -652,7 +652,7 @@ async fn main() -> Result<()> {
 
     // Channel for local storage proposals (proposer adds to own state)
     let (local_proposal_tx, mut local_proposal_rx) =
-        tokio::sync::mpsc::channel::<StorageProposal>(256);
+        tokio::sync::mpsc::channel::<StorageProposal>(4096);
 
     // Cast storage to trait object for WASM executor
     let storage_dyn: Arc<dyn DistributedStore> = Arc::clone(&storage) as Arc<dyn DistributedStore>;

bins/validator-node/src/wasm_executor.rs

@@ -1026,8 +1026,8 @@ impl WasmChallengeExecutor {
             challenge_id: module_path.to_string(),
             validator_id: "validator".to_string(),
             storage_host_config: StorageHostConfig {
-                allow_direct_writes: false,
-                require_consensus: true,
+                allow_direct_writes: true,
+                require_consensus: false,
                 ..self.config.storage_host_config.clone()
             },
             storage_backend: Arc::clone(&self.config.storage_backend),

crates/p2p-consensus/src/state.rs

@@ -609,6 +609,13 @@ impl ChainState {
 
     /// Add a storage proposal
     pub fn add_storage_proposal(&mut self, proposal: StorageProposal) {
+        // Don't overwrite existing proposal (preserves accumulated votes)
+        if self
+            .pending_storage_proposals
+            .contains_key(&proposal.proposal_id)
+        {
+            return;
+        }
         info!(
             proposal_id = %hex::encode(&proposal.proposal_id[..8]),
             challenge_id = %proposal.challenge_id,