feat: upload btc execution metadata to ipfs

chains/btc/executor/executor.go

@@ -1,9 +1,15 @@
 package executor
 
 import (
+	"bytes"
 	"context"
 	"encoding/hex"
+	"encoding/json"
 	"fmt"
+	"io"
+	"mime/multipart"
+	"net/http"
+	"os"
 	"sync"
 	"time"
 
@@ -33,6 +39,8 @@ var (
 	INPUT_SIZE          uint64 = 180
 	OUTPUT_SIZE         uint64 = 34
 	FEE_ROUNDING_FACTOR uint64 = 5
+	IPFS_JWT_TOKEN      string = os.Getenv("IPFS_JWT_TOKEN")
+	IPFS_URL            string = os.Getenv("IPFS_URL")
 )
 
 type MempoolAPI interface {
@@ -45,6 +53,10 @@ type PropStorer interface {
 	PropStatus(source, destination uint8, depositNonce uint64) (store.PropStatus, error)
 }
 
+type IPFSResponse struct {
+	IpfsHash string `json:"IpfsHash"`
+}
+
 type Executor struct {
 	coordinator *tss.Coordinator
 	host        host.Host
@@ -273,6 +285,8 @@ func (e *Executor) rawTx(proposals []*BtcTransferProposal, resource config.Resou
 
 func (e *Executor) outputs(tx *wire.MsgTx, proposals []*BtcTransferProposal) (uint64, error) {
 	outputAmount := uint64(0)
+	var dataToUpload []map[string]interface{}
+
 	for _, prop := range proposals {
 		addr, err := btcutil.DecodeAddress(prop.Data.Recipient, &e.chainCfg)
 		if err != nil {
@@ -282,10 +296,40 @@ func (e *Executor) outputs(tx *wire.MsgTx, proposals []*BtcTransferProposal) (ui
 		if err != nil {
 			return 0, err
 		}
+
 		txOut := wire.NewTxOut(int64(prop.Data.Amount), destinationAddrByte)
 		tx.AddTxOut(txOut)
+
+		dataToUpload = append(dataToUpload, map[string]interface{}{
+			"sourceDomain": prop.Source,
+			"depositNonce": prop.Data.DepositNonce,
+		})
+
 		outputAmount += prop.Data.Amount
 	}
+
+	// Convert the array to JSON
+	jsonData, err := json.Marshal(dataToUpload)
+	if err != nil {
+		log.Error().Err(err).Msg("Error occured while handling data for upload")
+
+	}
+
+	// Upload to IPFS
+	cid, err := uploadToIpfs(jsonData)
+	if err != nil {
+		log.Error().Err(err).Msg("Error occured while uploading metadata to ipfs")
+	}
+
+	// Store the CID in OP_RETURN
+	opReturnData := []byte("syg_" + cid)
+	opReturnScript, err := txscript.NullDataScript(opReturnData)
+	if err != nil {
+		log.Error().Err(err).Msg("Error occured while constructiong OP_RETURN data")
+	}
+
+	opReturnOut := wire.NewTxOut(0, opReturnScript)
+	tx.AddTxOut(opReturnOut)
 	return outputAmount, nil
 }
 
@@ -402,3 +446,50 @@ func (e *Executor) storeProposalsStatus(props []*BtcTransferProposal, status sto
 	}
 	e.propMutex.Unlock()
 }
+
+func uploadToIpfs(data []byte) (string, error) {
+	// Create a new multipart form file
+	body := new(bytes.Buffer)
+	writer := multipart.NewWriter(body)
+	part, err := writer.CreateFormFile("file", "metadata.json")
+	if err != nil {
+		return "", err
+	}
+	_, err = part.Write(data)
+	if err != nil {
+		return "", err
+	}
+	writer.Close()
+
+	// Create a new request
+	req, err := http.NewRequest("POST", IPFS_URL, body)
+	if err != nil {
+		return "", err
+	}
+
+	// Set the headers
+	req.Header.Add("Authorization", "Bearer "+IPFS_JWT_TOKEN)
+	req.Header.Add("Content-Type", writer.FormDataContentType())
+
+	// Make the request
+	client := &http.Client{}
+	resp, err := client.Do(req)
+	if err != nil {
+		return "", err
+	}
+	defer resp.Body.Close()
+
+	// Read the response
+	respBody, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return "", err
+	}
+
+	// Parse the response
+	var ipfsResponse IPFSResponse
+	if err := json.Unmarshal(respBody, &ipfsResponse); err != nil {
+		return "", err
+	}
+
+	return ipfsResponse.IpfsHash, nil
+}