hancock

//
// Provides a consistent naming convention for index files.  Multiple
// commands may create and inspect indexes, so we define the common
// conventions in this package.
package model

import (
	"encoding/hex"
	"errors"
	"fmt"
	"log"

	"golang.org/x/crypto/ssh"
)

// We use Keys to store/lookup content.  A Key is really a special
// case of Content, so each Key has its own CID.  We define a KID type
// so that our source code can be explicit and avoid confusion when
// working with Keys.
type KID CID
................................................................................
	this.kid = &id
	return this.kid
}

func (this *TestimonyKey) Split() []string {
	return []string{this.Content.String(), this.Authority.String()}
}

// deprecated, use TestimonyKey.Split
func IndexKey(source CID, authority interface{}) (key []string, err error) {
	var public ssh.PublicKey
	switch pub := authority.(type) {
	case Authority:
		// use hex of ssh encoding of public key
		public, _, _, _, err = ssh.ParseAuthorizedKey([]byte(pub))
		if err != nil {
			return
		}
	case ssh.PublicKey:
		public = pub
	default:
		return nil, fmt.Errorf("unexpected authority (%T %#v) not a public key", authority, authority)
	}
	return []string{
		source.String(),
		hex.EncodeToString(public.Marshal()),
	}, nil
}

//
// Provides a consistent naming convention for index files.  Multiple
// commands may create and inspect indexes, so we define the common
// conventions in this package.
package model

import (

	"errors"

	"log"


)

// We use Keys to store/lookup content.  A Key is really a special
// case of Content, so each Key has its own CID.  We define a KID type
// so that our source code can be explicit and avoid confusion when
// working with Keys.
type KID CID
................................................................................
	this.kid = &id
	return this.kid
}

func (this *TestimonyKey) Split() []string {
	return []string{this.Content.String(), this.Authority.String()}
}

}

func (this Authority) String() string { return string(this) }

// Type Testimony, when produced by a trusted authority, allows a
// verifier to authenticate a source file.
type Testimony struct {

	// The signer's public key.
	Authority Authority `json:"authority"`

	// The data or source file which is the object of attestation.
	Content CID `json:"content,omitempty"`

	// The encoded bytes that were signed.  May be decoded into a manifest.

}

func (this Authority) String() string { return string(this) }

// Type Testimony, when produced by a trusted authority, allows a
// verifier to authenticate a source file.
type Testimony struct {

	// The signer's public key.
	Authority Authority `json:"authority"`

	// The data or source file which is the object of attestation.
	Content CID `json:"content,omitempty"`

	// The encoded bytes that were signed.  May be decoded into a manifest.

		_, err := tx.CreateBucketIfNotExists(this.bucket)
		return err
	})
	return this, err
}

func (this *boltStore) PutTestimony(testimony model.Testimony) (*model.TestimonyKey, error) {
	//log.Println("boltStore.PutTestimony()") // troubleshoot

	// use key format consistent with kademlia
	tkey := testimony.Key()
	key := tkey.KID().Sum()

	value, err := model.Encode(testimony)
	if err != nil {
................................................................................
	}

	// persist to underlying db
	err = this.DB.Batch(func(tx *bolt.Tx) error {
		b := tx.Bucket(this.bucket)
		return b.Put(key, value)
	})

	return tkey, err
}

func (this *boltStore) GetTestimony(tkey model.TestimonyKey) (testimony *model.Testimony, err error) {
	//log.Println("boltStore.FindTestimony()", this) // troubleshoot

	key := tkey.KID().Sum()
	err = this.DB.View(func(tx *bolt.Tx) (err error) {
		b := tx.Bucket(this.bucket)
		v := b.Get(key)
		if v != nil {
			testimony = new(model.Testimony)

		_, err := tx.CreateBucketIfNotExists(this.bucket)
		return err
	})
	return this, err
}

func (this *boltStore) PutTestimony(testimony model.Testimony) (*model.TestimonyKey, error) {


	// use key format consistent with kademlia
	tkey := testimony.Key()
	key := tkey.KID().Sum()

	value, err := model.Encode(testimony)
	if err != nil {
................................................................................
	}

	// persist to underlying db
	err = this.DB.Batch(func(tx *bolt.Tx) error {
		b := tx.Bucket(this.bucket)
		return b.Put(key, value)
	})

	return tkey, err
}

func (this *boltStore) GetTestimony(tkey model.TestimonyKey) (testimony *model.Testimony, err error) {


	key := tkey.KID().Sum()
	err = this.DB.View(func(tx *bolt.Tx) (err error) {
		b := tx.Bucket(this.bucket)
		v := b.Get(key)
		if v != nil {
			testimony = new(model.Testimony)