testonly

package
v1.3.11 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 6, 2020 License: Apache-2.0 Imports: 32 Imported by: 26

Documentation

Overview

Package testonly holds test-specific code for Trillian storage layers.

Index

Constants

View Source
const (

	// PublicKeyPEM is the public key for: LogTree and PreorderedLogTree
	PublicKeyPEM = `` /* 178-byte string literal not displayed */

)

Variables

View Source
var (
	// LogTree is a valid, LOG-type trillian.Tree for tests.
	LogTree = &trillian.Tree{
		TreeState:          trillian.TreeState_ACTIVE,
		TreeType:           trillian.TreeType_LOG,
		HashStrategy:       trillian.HashStrategy_RFC6962_SHA256,
		HashAlgorithm:      spb.DigitallySigned_SHA256,
		SignatureAlgorithm: spb.DigitallySigned_ECDSA,
		DisplayName:        "Llamas Log",
		Description:        "Registry of publicly-owned llamas",
		PrivateKey: mustMarshalAny(&keyspb.PrivateKey{
			Der: ktestonly.MustMarshalPrivatePEMToDER(privateKeyPEM, privateKeyPass),
		}),
		PublicKey: &keyspb.PublicKey{
			Der: ktestonly.MustMarshalPublicPEMToDER(PublicKeyPEM),
		},
		MaxRootDuration: ptypes.DurationProto(0 * time.Millisecond),
	}

	// PreorderedLogTree is a valid, PREORDERED_LOG-type trillian.Tree for tests.
	PreorderedLogTree = &trillian.Tree{
		TreeState:          trillian.TreeState_ACTIVE,
		TreeType:           trillian.TreeType_PREORDERED_LOG,
		HashStrategy:       trillian.HashStrategy_RFC6962_SHA256,
		HashAlgorithm:      spb.DigitallySigned_SHA256,
		SignatureAlgorithm: spb.DigitallySigned_ECDSA,
		DisplayName:        "Pre-ordered Log",
		Description:        "Mirror registry of publicly-owned llamas",
		PrivateKey: mustMarshalAny(&keyspb.PrivateKey{
			Der: ktestonly.MustMarshalPrivatePEMToDER(privateKeyPEM, privateKeyPass),
		}),
		PublicKey: &keyspb.PublicKey{
			Der: ktestonly.MustMarshalPublicPEMToDER(PublicKeyPEM),
		},
		MaxRootDuration: ptypes.DurationProto(0 * time.Millisecond),
	}

	// MapTree is a valid, MAP-type trillian.Tree for tests.
	MapTree = &trillian.Tree{
		TreeState:          trillian.TreeState_ACTIVE,
		TreeType:           trillian.TreeType_MAP,
		HashStrategy:       trillian.HashStrategy_TEST_MAP_HASHER,
		HashAlgorithm:      spb.DigitallySigned_SHA256,
		SignatureAlgorithm: spb.DigitallySigned_ECDSA,
		DisplayName:        "Llamas Map",
		Description:        "Key Transparency map for all your digital llama needs.",
		PrivateKey: mustMarshalAny(&keyspb.PrivateKey{
			Der: ktestonly.MustMarshalPrivatePEMToDER(testonly.DemoPrivateKey, testonly.DemoPrivateKeyPass),
		}),
		PublicKey: &keyspb.PublicKey{
			Der: ktestonly.MustMarshalPublicPEMToDER(testonly.DemoPublicKey),
		},
		MaxRootDuration: ptypes.DurationProto(0 * time.Millisecond),
	}
)
View Source
var ErrNotImplemented = errors.New("not implemented")

ErrNotImplemented is returned by unimplemented methods on the storage fakes.

Functions

func MustCreateNodeIDForTreeCoords

func MustCreateNodeIDForTreeCoords(depth, index int64, maxPathBits int) tree.NodeID

MustCreateNodeIDForTreeCoords creates a NodeID for the given position in the tree.

func NodeIDEq

func NodeIDEq(n tree.NodeID) gomock.Matcher

NodeIDEq returns a matcher that expects the specified NodeID.

func NodeSet

func NodeSet(nodes []tree.Node) gomock.Matcher

NodeSet returns a matcher that expects the given set of Nodes.

func RunOnAdminTX added in v1.0.7

func RunOnAdminTX(tx storage.AdminTX) func(ctx context.Context, f storage.AdminTXFunc) error

RunOnAdminTX is a helper for mocking out the AdminStorage.ReadWriteTransaction method.

func RunOnLogTX added in v1.0.7

func RunOnLogTX(tx storage.LogTreeTX) func(ctx context.Context, treeID int64, f storage.LogTXFunc) error

RunOnLogTX is a helper for mocking out the LogStorage.ReadWriteTransaction method.

func RunOnMapTX added in v1.0.7

func RunOnMapTX(tx storage.MapTreeTX) func(ctx context.Context, treeID int64, f storage.MapTXFunc) error

RunOnMapTX is a helper for mocking out the MapStorage.ReadWriteTransaction method.

Types

type AdminStorageTester

type AdminStorageTester struct {
	// NewAdminStorage returns an AdminStorage instance pointing to a clean
	// test database.
	NewAdminStorage func() storage.AdminStorage
}

AdminStorageTester runs a suite of tests against AdminStorage implementations.

func (*AdminStorageTester) RunAllTests

func (tester *AdminStorageTester) RunAllTests(t *testing.T)

RunAllTests runs all AdminStorage tests.

func (*AdminStorageTester) TestAdminTXReadWriteTransaction added in v1.0.7

func (tester *AdminStorageTester) TestAdminTXReadWriteTransaction(t *testing.T)

TestAdminTXReadWriteTransaction tests the ReadWriteTransaction method on AdminStorage.

func (*AdminStorageTester) TestCreateTree

func (tester *AdminStorageTester) TestCreateTree(t *testing.T)

TestCreateTree tests AdminStorage Tree creation.

func (*AdminStorageTester) TestHardDeleteTree

func (tester *AdminStorageTester) TestHardDeleteTree(t *testing.T)

TestHardDeleteTree tests success scenarios of HardDeleteTree.

func (*AdminStorageTester) TestHardDeleteTreeErrors

func (tester *AdminStorageTester) TestHardDeleteTreeErrors(t *testing.T)

TestHardDeleteTreeErrors tests error scenarios of HardDeleteTree.

func (*AdminStorageTester) TestListTrees

func (tester *AdminStorageTester) TestListTrees(t *testing.T)

TestListTrees tests both ListTreeIDs and ListTrees.

func (*AdminStorageTester) TestSoftDeleteTree

func (tester *AdminStorageTester) TestSoftDeleteTree(t *testing.T)

TestSoftDeleteTree tests success scenarios of SoftDeleteTree.

func (*AdminStorageTester) TestSoftDeleteTreeErrors

func (tester *AdminStorageTester) TestSoftDeleteTreeErrors(t *testing.T)

TestSoftDeleteTreeErrors tests error scenarios of SoftDeleteTree.

func (*AdminStorageTester) TestUndeleteTree

func (tester *AdminStorageTester) TestUndeleteTree(t *testing.T)

TestUndeleteTree tests success scenarios of UndeleteTree.

func (*AdminStorageTester) TestUndeleteTreeErrors

func (tester *AdminStorageTester) TestUndeleteTreeErrors(t *testing.T)

TestUndeleteTreeErrors tests error scenarios of UndeleteTree.

func (*AdminStorageTester) TestUpdateTree

func (tester *AdminStorageTester) TestUpdateTree(t *testing.T)

TestUpdateTree tests AdminStorage Tree updates.

type FakeAdminStorage added in v1.0.7

type FakeAdminStorage struct {
	TX          []storage.AdminTX
	ReadOnlyTX  []storage.ReadOnlyAdminTX
	TXErr       []error
	SnapshotErr []error
}

FakeAdminStorage is a AdminStorage implementation which is used for testing.

func (*FakeAdminStorage) Begin added in v1.0.7

Begin implements AdminStorage.Begin

func (*FakeAdminStorage) CheckDatabaseAccessible added in v1.0.7

func (f *FakeAdminStorage) CheckDatabaseAccessible(ctx context.Context) error

CheckDatabaseAccessible implements AdminStorage.CheckDatabaseAccessible

func (*FakeAdminStorage) ReadWriteTransaction added in v1.0.7

func (f *FakeAdminStorage) ReadWriteTransaction(ctx context.Context, fn storage.AdminTXFunc) error

ReadWriteTransaction implements AdminStorage.ReadWriteTransaction

func (*FakeAdminStorage) Snapshot added in v1.0.7

Snapshot implements AdminStorage.Snapshot

type FakeLogStorage added in v1.0.7

type FakeLogStorage struct {
	TX         storage.LogTreeTX
	ReadOnlyTX storage.ReadOnlyLogTreeTX

	TXErr                 error
	QueueLeavesErr        error
	AddSequencedLeavesErr error
}

FakeLogStorage is a LogStorage implementation which is used for testing.

func (*FakeLogStorage) AddSequencedLeaves added in v1.0.7

func (f *FakeLogStorage) AddSequencedLeaves(ctx context.Context, tree *trillian.Tree, leaves []*trillian.LogLeaf, timestamp time.Time) ([]*trillian.QueuedLogLeaf, error)

AddSequencedLeaves implements LogStorage.AddSequencedLeaves.

func (*FakeLogStorage) CheckDatabaseAccessible added in v1.0.7

func (f *FakeLogStorage) CheckDatabaseAccessible(ctx context.Context) error

CheckDatabaseAccessible implements LogStorage.CheckDatabaseAccessible

func (*FakeLogStorage) QueueLeaves added in v1.0.7

func (f *FakeLogStorage) QueueLeaves(ctx context.Context, tree *trillian.Tree, leaves []*trillian.LogLeaf, queueTimestamp time.Time) ([]*trillian.QueuedLogLeaf, error)

QueueLeaves implements LogStorage.QueueLeaves.

func (*FakeLogStorage) ReadWriteTransaction added in v1.0.7

func (f *FakeLogStorage) ReadWriteTransaction(ctx context.Context, tree *trillian.Tree, fn storage.LogTXFunc) error

ReadWriteTransaction implements LogStorage.ReadWriteTransaction

func (*FakeLogStorage) Snapshot added in v1.0.7

Snapshot implements LogStorage.Snapshot

func (*FakeLogStorage) SnapshotForTree added in v1.0.7

func (f *FakeLogStorage) SnapshotForTree(ctx context.Context, _ *trillian.Tree) (storage.ReadOnlyLogTreeTX, error)

SnapshotForTree implements LogStorage.SnapshotForTree

type FakeMapStorage added in v1.0.7

type FakeMapStorage struct {
	TX          storage.MapTreeTX
	ReadOnlyTX  storage.ReadOnlyMapTreeTX
	SnapshotErr error
}

FakeMapStorage is a MapStorage implementation which is used for testing.

func (*FakeMapStorage) CheckDatabaseAccessible added in v1.0.7

func (f *FakeMapStorage) CheckDatabaseAccessible(ctx context.Context) error

CheckDatabaseAccessible implements MapStorage.CheckDatabaseAccessible

func (*FakeMapStorage) Layout added in v1.3.6

func (f *FakeMapStorage) Layout(*trillian.Tree) (*tree.Layout, error)

Layout is not implemented.

func (*FakeMapStorage) ReadWriteTransaction added in v1.0.7

func (f *FakeMapStorage) ReadWriteTransaction(ctx context.Context, tree *trillian.Tree, fn storage.MapTXFunc) error

ReadWriteTransaction implements MapStorage.ReadWriteTransaction

func (*FakeMapStorage) Snapshot added in v1.0.7

Snapshot implements MapStorage.Snapshot

func (*FakeMapStorage) SnapshotForTree added in v1.0.7

func (f *FakeMapStorage) SnapshotForTree(ctx context.Context, _ *trillian.Tree) (storage.ReadOnlyMapTreeTX, error)

SnapshotForTree implements MapStorage.SnapshotForTree

type FakeNodeReader

type FakeNodeReader struct {
	// contains filtered or unexported fields
}

FakeNodeReader is an implementation of storage.NodeReader that's preloaded with a set of NodeID -> Node mappings and will return only those. Requesting any other nodes results in an error. For use in tests only, does not implement any other storage APIs.

func NewFakeNodeReader

func NewFakeNodeReader(nodes []tree.Node, treeRevision int64) *FakeNodeReader

NewFakeNodeReader creates and returns a FakeNodeReader with the supplied nodes assuming that all the nodes are at a specified tree revision. All the node IDs must be distinct.

func (FakeNodeReader) GetMerkleNodes

func (f FakeNodeReader) GetMerkleNodes(treeRevision int64, NodeIDs []tree.NodeID) ([]tree.Node, error)

GetMerkleNodes implements the corresponding NodeReader API.

type LeafBatch

type LeafBatch struct {
	TreeRevision int64
	Leaves       []string
	ExpectedRoot []byte
}

LeafBatch describes a set of leaves to be loaded into a MultiFakeNodeReader via a compact merkle tree. As each batch is added to the tree a set of node updates are collected and recorded in a FakeNodeReader for that revision. The expected root should be the result of calling CurrentRoot() on the compact Merkle tree encoded by hex.EncodeToString().

type MultiFakeNodeReader

type MultiFakeNodeReader struct {
	// contains filtered or unexported fields
}

MultiFakeNodeReader can provide nodes at multiple revisions. It delegates to a number of FakeNodeReaders, each set up to handle one revision.

func NewMultiFakeNodeReader

func NewMultiFakeNodeReader(readers []FakeNodeReader) *MultiFakeNodeReader

NewMultiFakeNodeReader creates a MultiFakeNodeReader delegating to a number of FakeNodeReaders

func NewMultiFakeNodeReaderFromLeaves

func NewMultiFakeNodeReaderFromLeaves(batches []LeafBatch) *MultiFakeNodeReader

NewMultiFakeNodeReaderFromLeaves uses a compact Merkle tree to set up the nodes at various revisions. It collates all node updates from a batch of leaf data into one FakeNodeReader. This has the advantage of not needing to manually create all the data structures but the disadvantage is that a bug in the compact tree could be reflected in test using this code. To help guard against this we check the tree root hash after each batch has been processed. The supplied batches should be in ascending order of tree revision.

func (MultiFakeNodeReader) GetMerkleNodes

func (m MultiFakeNodeReader) GetMerkleNodes(ctx context.Context, treeRevision int64, NodeIDs []tree.NodeID) ([]tree.Node, error)

GetMerkleNodes implements the corresponding NodeReader API.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL