Make IPFS url configurable (#669)

Author: mangas

crates/config/default_values.toml

@@ -9,6 +9,7 @@ recently_closed_allocation_buffer_secs = 3600
 syncing_interval_secs = 60
 
 [service]
+ipfs_url = "https://api.thegraph.com/ipfs/"
 serve_network_subgraph = false
 serve_escrow_subgraph = false
 host_and_port = "0.0.0.0:7600"
@@ -26,4 +27,3 @@ trigger_value_divisor = 10
 timestamp_buffer_secs = 60
 request_timeout_secs = 5
 max_receipts_per_request = 10000
-

crates/config/maximal-config-example.toml

@@ -102,6 +102,7 @@ serve_escrow_subgraph = false
 # serve_auth_token = "token"
 ## allow queries using this token
 # free_query_auth_token = "i-am-authorized-right?"
+ipfs_url = "https://api.thegraph.com/ipfs/"
 
 
 [service.tap]

crates/config/src/config.rs

@@ -353,6 +353,7 @@ pub struct BlockchainConfig {
 #[derive(Debug, Deserialize)]
 #[cfg_attr(test, derive(PartialEq))]
 pub struct ServiceConfig {
+    pub ipfs_url: Url,
     pub serve_network_subgraph: bool,
     pub serve_escrow_subgraph: bool,
     pub serve_auth_token: Option<String>,

crates/service/src/service.rs

@@ -102,6 +102,7 @@ pub async fn run() -> anyhow::Result<()> {
 
     let host_and_port = config.service.host_and_port;
     let indexer_address = config.indexer.indexer_address;
+    let ipfs_url = config.service.ipfs_url.clone();
 
     let router = ServiceRouter::builder()
         .database(database.clone())
@@ -135,7 +136,7 @@ pub async fn run() -> anyhow::Result<()> {
             .expect("invalid dips host port");
 
         let ipfs_fetcher: Arc<dyn IpfsFetcher> =
-            Arc::new(IpfsClient::new("https://api.thegraph.com/ipfs/").unwrap());
+            Arc::new(IpfsClient::new(ipfs_url.as_str()).unwrap());
 
         // TODO: Try to re-use the same watcher for both DIPS and TAP
         let watcher = escrow_accounts_v1(

crates/service/tests/router_test.rs

@@ -84,6 +84,7 @@ async fn full_integration_test(database: PgPool) {
                 max_receipt_value_grt: NonZeroGRT::new(1000000000000).unwrap(),
             },
             free_query_auth_token: None,
+            ipfs_url: "http://localhost:5001".parse().unwrap(),
         })
         .blockchain(BlockchainConfig {
             chain_id: indexer_config::TheGraphChainId::Test,