hancock

// Copyright (C) 2019  David N. Cohen

// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU Affero General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.

// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU Affero General Public License for more details.

// You should have received a copy of the GNU Affero General Public License
// along with this program.  If not, see <https://www.gnu.org/licenses/>.

package main

import (
	"bytes"
	"fmt"
	"io/ioutil"
	"mime/multipart"
	"net/http"
)

// IPFS helper functions

// https://docs.ipfs.io/reference/api/http/#api-v0-add
func ipfsAdd(ipfs string, b []byte, name string) error {
	buf := &bytes.Buffer{}
	mp := multipart.NewWriter(buf)
	part, err := mp.CreateFormFile("path", name)
	if err != nil {
		return err
	}
	_, err = part.Write(b)
	if err != nil {
		return err
	}
	err = mp.Close()
	if err != nil {
		return err
	}

	uri := ipfs + "/api/v0/add?raw-leaves=true&pin=false" // TODO(dnc) pin by default
	req, err := http.NewRequest("POST", uri, buf)
	req.Header.Set("Content-Type", mp.FormDataContentType())

	resp, err := http.DefaultClient.Do(req)
	if err != nil {
		return err
	}
	defer resp.Body.Close()
	body, err := ioutil.ReadAll(resp.Body)
	if err != nil {
		return err
	}
	if resp.StatusCode != http.StatusOK {
		err = fmt.Errorf("%s %s", uri, resp.Status)
	}
	//command.Debug(uri, resp.Status)
	//command.Debug(string(body))
	_ = body

	return err
}