hancock

// Publish signed testimony to an index with:
//    hancock publish
//
// This operation published the files produced by `hancock testimony`.
package main

import (
	"bytes"
	"fmt"
	"io/ioutil"
	"log"
	"net/http"
	"net/url"
	"os"
	"path/filepath"

	"github.com/pkg/errors"
	"src.d10.dev/command"
	"src.d10.dev/hancock/model"
	"src.d10.dev/hancock/store"
)

................................................................................
	// defaults
	cfgTop := cfg.Section("")
	cfgOp := cfg.Section("publish")

	defaultStore := cfgOp.Key("store").MustString(cfgTop.Key("store").MustString("https://hancock.beyondcentral.com"))

	// args
	storeFlag := command.OperationFlagSet.String("store", "defaultStore", fmt.Sprintf("URL of remote testimony store (default %q)", defaultStore))

	// parse flags
	err = command.ParseOperationFlagSet()
	if err != nil {
		return err
	}

................................................................................

			// publish testimony from local to remote
			k, err := remote.PutTestimony(testimony)
			if err != nil {
				return err
			}

			command.V(1).Infof("published %v to %v", k, remote)
			pubs++
			return nil
		})
		if err != nil {
			command.Error(err)
		}
	}

	command.Infof("published %d items to %q", pubs, remote)

	return nil
}

// publish testimony either to local filesystem or via POST to online index.
func XXXpublishTestimonyToStore(storeURL string, ft fileTestimony) error {
	log.Panic("replace calls to publishTestimonyToStore() with store.Store interface!")
	u, err := url.Parse(storeURL)
	if err != nil {
		return err
	}

	err = ft.Check()
	if err != nil {
		return err
	}

	switch u.Scheme {
	case "http", "https":
		// post to URL
		urlPath := storeURL + "/testimony"
		resp, err := http.Post(urlPath, "application/json", bytes.NewBuffer(ft.Bytes()))
		if err != nil {
			return err
		}
		defer resp.Body.Close()
		switch resp.StatusCode {
		case http.StatusOK, http.StatusCreated, http.StatusAccepted:
			// success
			if command.V(2) {
				command.Infof("posted testimony to %q", urlPath)
				b, _ := ioutil.ReadAll(resp.Body)
				command.Info(resp.StatusCode)
				command.Info(string(b))
			}
		default:
			command.V(1).Infof("Failed to post testimony: %s", string(ft.Bytes()))
			b, _ := ioutil.ReadAll(resp.Body)
			return fmt.Errorf("failed to publish testimony (%q) to index (%s): %s %q", ft.Path, storeURL, resp.Status, string(b))
		}

	case "file":
		// save to directory
		key, err := model.IndexKey(ft.Testimony.Content, ft.Authority)
		if err != nil {
			return err
		}

		// filepath.Join() turns the key values into directories.  If we
		// used flat file names, we might exceed filesystem limits for
		// number of files.
		path := filepath.Join(u.Path, filepath.Join(key...))
		err = os.MkdirAll(filepath.Dir(path), os.ModePerm)
		if err != nil {
			return fmt.Errorf("failed to store testimony file (%q): %w", path, err)
		}
		err = ioutil.WriteFile(path, ft.Bytes(), 0644)
		if err != nil {
			return fmt.Errorf("failed to store testimony file (%q): %w", path, err)
		} else {
			command.V(2).Infof("wrote testimony (%q) to file (%q)", ft.Path, path)
		}

	default:
		return fmt.Errorf("unexpected index URL scheme (%q)", u.Scheme)
	}
	return nil
}

// Publish signed testimony to an index with:
//    hancock publish
//
// This operation published the files produced by `hancock testimony`.
package main

import (

	"fmt"







	"github.com/pkg/errors"
	"src.d10.dev/command"
	"src.d10.dev/hancock/model"
	"src.d10.dev/hancock/store"
)

................................................................................
	// defaults
	cfgTop := cfg.Section("")
	cfgOp := cfg.Section("publish")

	defaultStore := cfgOp.Key("store").MustString(cfgTop.Key("store").MustString("https://hancock.beyondcentral.com"))

	// args
	storeFlag := command.OperationFlagSet.String("store", defaultStore, "URL of remote testimony store (default %q)")

	// parse flags
	err = command.ParseOperationFlagSet()
	if err != nil {
		return err
	}

................................................................................

			// publish testimony from local to remote
			k, err := remote.PutTestimony(testimony)
			if err != nil {
				return err
			}

			command.V(1).Infof("published %v to %q", k, *storeFlag)
			pubs++
			return nil
		})
		if err != nil {
			command.Error(err)
		}
	}

	command.Infof("published %d items to %q", pubs, *storeFlag)

	return nil
}