content: bounded provider recovery and joined browser/Weather proof harnesses

.github/workflows/alpha-topology.yml

@@ -180,6 +180,16 @@ jobs:
           sh -n tests/integration/content-provider-filter-smoke.sh
           python3 -B tests/integration/test-content-provider-filter-smoke.py
           python3 -B tests/integration/test-content-provider-smoke.py
+          python3 -B tests/integration/test-content-provider-worker-budget.py
+          python3 -B tests/integration/test-content-provider-resource-ready.py
+          python3 -B tests/integration/test-content-provider-pressure.py
+          python3 -B tests/integration/test-content-provider-pressure-smoke.py
+          python3 -B tests/integration/test-content-provider-pressure-shell.py
+          python3 -B tests/integration/test-content-provider-pressure-wiring.py
+          sh -n tests/integration/content-provider-pressure-smoke.sh
+          python3 -B tests/integration/test-content-cancellation-smoke.py
+          sh -n tests/integration/content-provider-late-recovery.sh
+          python3 -B tests/integration/test-content-provider-late-recovery.py
           sh -n tests/integration/content-provider-https-smoke.sh
           python3 -B tests/integration/test-content-provider-https-smoke.py
           sh -n tests/integration/content-mailbox-smoke.sh

.github/workflows/quality.yml

@@ -71,6 +71,22 @@ jobs:
           python3 -B tests/integration/transaction-abci-contract-tests.py
           python3 -B tests/integration/transaction-abci-wiring-tests.py
 
+      - name: Check closed provider and Weather diagnostics without network access
+        run: |
+          python3 -B tests/integration/test-content-provider-worker-budget.py
+          python3 -B tests/integration/test-content-provider-resource-ready.py
+          python3 -B tests/integration/test-content-provider-pressure.py
+          python3 -B tests/integration/test-content-provider-pressure-smoke.py
+          python3 -B tests/integration/test-content-provider-pressure-shell.py
+          python3 -B tests/integration/test-content-provider-pressure-wiring.py
+          sh -n tests/integration/content-provider-pressure-smoke.sh
+          node --version
+          node -e 'if (Number(process.versions.node.split(".")[0]) < 22) process.exit(1)'
+          node --test tests/integration/test-weather-source-observer.mjs
+          python3 -B tests/integration/test-weather-products-delivery.py
+          python3 -B tests/integration/test-weather-products-delivery-shell.py
+          python3 -B tests/integration/test-weather-client-runner.py
+
       - name: Check formatting and shell sources
         run: |
           cargo fmt --all -- --check

README.md

@@ -281,6 +281,7 @@ and compute coordination belongs in the core.
 | [Weather](https://github.com/VOLPAROSSA/volparossa-weather) | Direct public model data | Shared weather processing and measured forecast improvement. |
 | [Cloud](https://github.com/VOLPAROSSA/volparossa-cloud) | OpenCloud | Private files, synchronization and server-independent access. |
 | [Bank](https://github.com/VOLPAROSSA/volparossa-bank) | Financial protocol research | Participant-owned portfolios, payments and auditable corrections; no real-money service. |
+| [Citizen](https://github.com/VOLPAROSSA/volparossa-citizen) | Participation and voting research | Proposals and referenda alongside existing institutions; synthetic procedure simulation first. |
 
 [Application scope and current boundaries](docs/applications/APPLICATIONS.md)
 

crates/volparossa-agent/src/content.rs

@@ -20,6 +20,7 @@ mod object_policy;
 mod parallel;
 mod private_storage;
 mod recent;
+mod rediscovery;
 #[cfg(test)]
 mod refresh_tests;
 mod replication;
@@ -759,68 +760,7 @@ impl ContentRuntime {
         policy: &volparossa_policy::VerifiedManifest,
         control_peer: libp2p::PeerId,
     ) -> Result<(Vec<String>, u64), ContentError> {
-        if complete(manifest, store)? {
-            return Ok((Vec::new(), 0));
-        }
-        let mut used = std::collections::BTreeSet::new();
-        let mut attempted = std::collections::BTreeSet::new();
-        let mut bytes = 0_u64;
-        if let Some(scope) = recent::RecentProviderScope::for_route(context, policy).await {
-            let recent = context
-                .content
-                .refresh_recent_provider_hints(scope, &context.discovery, Duration::from_secs(1))
-                .await;
-            attempted.extend(recent.iter().map(|provider| provider.peer_id));
-            let (providers, received) =
-                Self::pull_providers(context, manifest, store, policy, recent).await?;
-            used.extend(providers);
-            bytes = received;
-            if complete(manifest, store)? {
-                return Ok((used.into_iter().collect(), bytes));
-            }
-        }
-        let discovered = context
-            .discovery
-            .discover_content_providers(control_peer, 16)
-            .await;
-        let state = context.state.read().await;
-        if !state.roles().client
-            || state
-                .active_policy(unix_millis())
-                .as_ref()
-                .map(volparossa_policy::VerifiedManifest::policy_hash)
-                != Some(policy.policy_hash())
-        {
-            return Err(ContentError::Policy);
-        }
-        drop(state);
-        let providers = match discovered {
-            Ok(providers) => providers,
-            Err(DiscoveryError::Invalid) => return Err(ContentError::Invalid),
-            Err(DiscoveryError::Invalidated) => return Err(ContentError::Policy),
-            Err(
-                DiscoveryError::Busy
-                | DiscoveryError::Closed
-                | DiscoveryError::Timeout
-                | DiscoveryError::Unavailable,
-            ) => {
-                // A later unavailable capability search cannot erase verified earlier bytes.
-                // Native callers still require complete reconstruction; HTTPS fills only gaps.
-                if bytes > 0 {
-                    return Ok((used.into_iter().collect(), bytes));
-                }
-                return Err(ContentError::Unavailable);
-            }
-        };
-        let providers = providers
-            .into_iter()
-            .filter(|provider| !attempted.contains(&provider.peer_id))
-            .collect();
-        let (providers, received) =
-            Self::pull_providers(context, manifest, store, policy, providers).await?;
-        used.extend(providers);
-        bytes = bytes.checked_add(received).ok_or(ContentError::Invalid)?;
-        Ok((used.into_iter().collect(), bytes))
+        rediscovery::pull(context, manifest, store, policy, control_peer).await
     }
 
     /// Reuse the same bounded provider set after a name-metadata round; no second discovery.