ipfs, sia: broadcast pinned CIDs

ipfs/node.go

@@ -117,6 +117,11 @@ func mustParsePeer(s string) peer.AddrInfo {
 	return *info
 }
 
+// Provide broadcasts a CID to the network
+func (n *Node) Provide(c cid.Cid) error {
+	return n.provider.Provide(c)
+}
+
 // NewNode creates a new IPFS node
 func NewNode(ctx context.Context, privateKey crypto.PrivKey, cfg config.IPFS, ds datastore.Batching, bs blockstore.Blockstore) (*Node, error) {
 	cmgr, err := connmgr.NewConnManager(600, 900)

sia/sia.go

@@ -29,10 +29,16 @@ type (
 		AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)
 	}
 
+	// An IPFSProvider broadcasts CIDs to the IPFS network
+	IPFSProvider interface {
+		Provide(cid.Cid) error
+	}
+
 	// A Node is a specialized IPFS gateway that retrieves data from a renterd
 	// node
 	Node struct {
 		store Store
+		ipfs  IPFSProvider
 		log   *zap.Logger
 
 		renterd config.Renterd
@@ -107,10 +113,20 @@ func (n *Node) UploadCID(ctx context.Context, c cid.Cid, r io.Reader) error {
 	default:
 	}
 
+	blocks := dagSvc.Blocks()
+
 	if rootNode.Cid().Hash().B58String() != c.Hash().B58String() {
 		return fmt.Errorf("unexpected root cid: %s", rootNode.Cid().Hash().B58String())
+	} else if err := n.store.AddBlocks(ctx, blocks); err != nil {
+		return fmt.Errorf("failed to add blocks to store: %w", err)
 	}
-	return n.store.AddBlocks(ctx, dagSvc.Blocks())
+
+	for _, b := range blocks {
+		if err := n.ipfs.Provide(b.CID); err != nil {
+			return fmt.Errorf("failed to provide block: %w", err)
+		}
+	}
+	return nil
 }
 
 // ProxyHTTPDownload proxies an http download request to the renterd node