package storage
import (
"context"
"github.com/google/trillian"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
"google.golang.org/protobuf/proto"
)
func ValidateTreeForCreation(ctx context.Context, tree *trillian.Tree) error {
switch {
case tree == nil:
return status.Error(codes.InvalidArgument, "a tree is required")
case tree.TreeState != trillian.TreeState_ACTIVE:
return status.Errorf(codes.InvalidArgument, "invalid tree_state: %s", tree.TreeState)
case tree.TreeType == trillian.TreeType_UNKNOWN_TREE_TYPE:
return status.Errorf(codes.InvalidArgument, "invalid tree_type: %s", tree.TreeType)
case tree.Deleted:
return status.Errorf(codes.InvalidArgument, "invalid deleted: %v", tree.Deleted)
case tree.DeleteTime != nil:
return status.Errorf(codes.InvalidArgument, "invalid delete_time: %+v (must be nil)", tree.DeleteTime)
}
return validateMutableTreeFields(ctx, tree)
}
func validateTreeTypeUpdate(oldTree, newTree *trillian.Tree) error {
const prefix = "can't change tree_type"
const wantState = trillian.TreeState_FROZEN
if oldState := oldTree.TreeState; oldState != wantState {
return status.Errorf(codes.InvalidArgument, "%s: tree_state=%v, want %v", prefix, oldState, wantState)
} else if newTree.TreeState != wantState {
return status.Errorf(codes.InvalidArgument, "%s: tree_state should stay %v", prefix, wantState)
}
if oldTree.TreeType != trillian.TreeType_PREORDERED_LOG || newTree.TreeType != trillian.TreeType_LOG {
return status.Errorf(codes.InvalidArgument, "%s: %v->%v", prefix, oldTree.TreeType, newTree.TreeType)
}
return nil
}
func ValidateTreeForUpdate(ctx context.Context, storedTree, newTree *trillian.Tree) error {
switch {
case storedTree.TreeId != newTree.TreeId:
return status.Error(codes.InvalidArgument, "readonly field changed: tree_id")
case storedTree.TreeType != newTree.TreeType:
if err := validateTreeTypeUpdate(storedTree, newTree); err != nil {
return err
}
case !proto.Equal(storedTree.CreateTime, newTree.CreateTime):
return status.Error(codes.InvalidArgument, "readonly field changed: create_time")
case !proto.Equal(storedTree.UpdateTime, newTree.UpdateTime):
return status.Error(codes.InvalidArgument, "readonly field changed: update_time")
case storedTree.Deleted != newTree.Deleted:
return status.Error(codes.InvalidArgument, "readonly field changed: deleted")
case !proto.Equal(storedTree.DeleteTime, newTree.DeleteTime):
return status.Error(codes.InvalidArgument, "readonly field changed: delete_time")
}
return validateMutableTreeFields(ctx, newTree)
}
func validateMutableTreeFields(ctx context.Context, tree *trillian.Tree) error {
if tree.TreeState == trillian.TreeState_UNKNOWN_TREE_STATE {
return status.Errorf(codes.InvalidArgument, "invalid tree_state: %v", tree.TreeState)
}
if err := tree.MaxRootDuration.CheckValid(); err != nil {
return status.Errorf(codes.InvalidArgument, "max_root_duration malformed: %v", err)
} else if duration := tree.MaxRootDuration.AsDuration(); duration < 0 {
return status.Errorf(codes.InvalidArgument, "max_root_duration negative: %v", tree.MaxRootDuration)
}
if tree.StorageSettings != nil {
_, err := tree.StorageSettings.UnmarshalNew()
if err != nil {
return status.Errorf(codes.InvalidArgument, "invalid storage_settings: %v", err)
}
}
return nil
}