Move entire multiprovider downloader into an example.

This is a bit unfortunate, but there are major refactorings coming for the
store, and the current code has to fake a part of the functionality that
is needed from the store.

This way people can take a look at the code structure and also try it out.
Once the main store changes are merged, the multiprovider downloader will
move into the main crate.

Author: rklaehn

src/downloader2.rs renamed to examples/multiprovider/downloader2.rs

@@ -21,7 +21,7 @@ use std::{
     u64,
 };
 
-use crate::{
+use iroh_blobs::{
     get::{
         fsm::{BlobContentNext, ConnectedNext, EndBlobNext},
         Stats,
@@ -433,7 +433,7 @@ impl<S> SimpleBitfieldSubscription<S> {
 
 async fn get_valid_ranges_local<S: Store>(hash: &Hash, store: S) -> anyhow::Result<BitfieldEvent> {
     if let Some(entry) = store.get_mut(hash).await? {
-        let ranges = crate::get::db::valid_ranges::<S>(&entry).await?;
+        let ranges = iroh_blobs::get::db::valid_ranges::<S>(&entry).await?;
         let size = entry.size();
         let size = match size {
             size @ BaoBlobSize::Unverified(value) => {
@@ -462,8 +462,8 @@ async fn get_valid_ranges_remote(
     id: NodeId,
     hash: &Hash,
 ) -> anyhow::Result<BitfieldEvent> {
-    let conn = endpoint.connect(id, crate::ALPN).await?;
-    let (size, _) = crate::get::request::get_verified_size(&conn, hash).await?;
+    let conn = endpoint.connect(id, iroh_blobs::ALPN).await?;
+    let (size, _) = iroh_blobs::get::request::get_verified_size(&conn, hash).await?;
     let chunks = (size + 1023) / 1024;
     let ranges = ChunkRanges::from(ChunkNum(0)..ChunkNum(chunks));
     Ok(BitfieldState {

src/downloader2/actor.rs renamed to examples/multiprovider/downloader2/actor.rs

@@ -238,13 +238,13 @@ async fn peer_download<S: Store>(
     start: Instant,
 ) -> anyhow::Result<Stats> {
     info!("Connecting to peer {peer}");
-    let conn = endpoint.connect(peer, crate::ALPN).await?;
+    let conn = endpoint.connect(peer, iroh_blobs::ALPN).await?;
     info!("Got connection to peer {peer}");
     let spec = RangeSpec::new(ranges);
     let ranges = RangeSpecSeq::new([spec, RangeSpec::EMPTY]);
     info!("starting download from {peer} for {hash} {ranges:?}");
     let request = GetRequest::new(hash, ranges);
-    let initial = crate::get::fsm::start(conn, request);
+    let initial = iroh_blobs::get::fsm::start(conn, request);
     // connect
     let connected = initial.next().await?;
     // read the first bytes

src/downloader2/content_discovery.rs renamed to examples/multiprovider/downloader2/content_discovery.rs

@@ -4,11 +4,12 @@ use bao_tree::{ChunkNum, ChunkRanges};
 use clap::Parser;
 use console::Term;
 use iroh::{NodeId, SecretKey};
+mod downloader2;
+use downloader2::{
+    print_bitmap, BitfieldEvent, BitfieldState, BitfieldUpdate, DownloadRequest, Downloader,
+    ObserveRequest, StaticContentDiscovery,
+};
 use iroh_blobs::{
-    downloader2::{
-        print_bitmap, BitfieldEvent, BitfieldState, BitfieldUpdate, DownloadRequest, Downloader,
-        ObserveRequest, StaticContentDiscovery,
-    },
     store::Store,
     Hash,
 };

src/downloader2/planners.rs renamed to examples/multiprovider/downloader2/planners.rs

@@ -32,8 +32,6 @@
 pub mod cli;
 #[cfg(feature = "downloader")]
 pub mod downloader;
-#[cfg(feature = "downloader")]
-pub mod downloader2;
 pub mod export;
 pub mod format;
 pub mod get;