fix issue with Daemon when no file present for a given IPFS hash

README.md

@@ -234,6 +234,7 @@ see [rate limiting configuration](./ratelimit/README.md)
 
 * **heartbeat_svc_end_point** (optional; default: `""`) - It must be a valid URL. if it is empty, then service state always assumed as SERVING, and same will be wrapped in Daemon Heartbeat. see [daemon heartbeats configuration](./metrics/README.md)
 
+* **ipfs_timeout** (optional; default: `30`) - All IPFS read/writes timeout if the operations doesnt complete in 30 sec or set duration in this config entry.
 
 #### Environment variables and CLI parameters
 

config/config.go

@@ -30,6 +30,7 @@ const (
 	HdwalletIndexKey               = "hdwallet_index"
 	HdwalletMnemonicKey            = "hdwallet_mnemonic"
 	IpfsEndPoint                   = "ipfs_end_point"
+	IpfsTimeout                    = "ipfs_timeout"
 	LogKey                         = "log"
 	MonitoringEnabled              = "monitoring_enabled"
 	MonitoringServiceEndpoint      = "monitoring_svc_end_point"
@@ -62,6 +63,7 @@ const (
 	"hdwallet_index": 0,
 	"hdwallet_mnemonic": "",
 	"ipfs_end_point": "http://localhost:5002/", 
+	"ipfs_timeout" : 30,
 	"monitoring_enabled": true,
 	"monitoring_svc_end_point": "https://n4rzw9pu76.execute-api.us-east-1.amazonaws.com/beta",
 	"organization_id": "ExampleOrganizationId", 

ipfsutils/ipfsutils.go

@@ -6,6 +6,7 @@ import (
 	log "github.com/sirupsen/logrus"
 	"io/ioutil"
 	"strings"
+	"time"
 )
 
 func GetIpfsFile(hash string) string {
@@ -43,5 +44,7 @@ func GetIpfsFile(hash string) string {
 
 func GetIpfsShell() *shell.Shell {
 	sh := shell.NewShell(config.GetString(config.IpfsEndPoint))
+	// sets the timeout for accessing the ipfs content
+	sh.SetTimeout(time.Duration(config.GetInt(config.IpfsTimeout)) * time.Second)
 	return sh
 }