keeper

package
v1.15.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2023 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddAuthzCacheToContext added in v1.15.0 

func AddAuthzCacheToContext(ctx sdk.Context) sdk.Context

AddAuthzCacheToContext either returns a new sdk.Context with the addition of an AuthzCache, or clears out the AuthzCache if it already exists in the context. It panics if the AuthzCache key exists in the context but isn't an AuthzCache.

func FindMissingMdAddr added in v1.8.0 

func FindMissingMdAddr(required, entries []types.MetadataAddress) []types.MetadataAddress

FindMissingMdAddr returns all elements of the required list that are not found in the entries list It is exported only so that it can be unit tested.

func GetAllSigners added in v1.15.0 

func GetAllSigners(parties []*PartyDetails) map[string]bool

GetAllSigners gets a map of bech32 strings to true with a key for each used signer.

func IsBase64 added in v0.3.0 

func IsBase64(s string) bool

func NewMsgServerImpl 

func NewMsgServerImpl(keeper Keeper) types.MsgServer

NewMsgServerImpl returns an implementation of the distribution MsgServer interface for the provided Keeper.

func NewQuerier 

func NewQuerier(k Keeper, legacyQuerierCdc *codec.LegacyAmino) sdk.Querier

NewQuerier creates a querier for auth REST endpoints

func ParseContractSpecID added in v1.0.0 

func ParseContractSpecID(contractSpecID string) (types.MetadataAddress, error)

ParseContractSpecID parses the provided input into a contract spec MetadataAddress. The input can either be a uuid string, a contract spec address bech32 string, or a record spec address bech32 string.

func ParseRecordAddr added in v1.0.0 

func ParseRecordAddr(recordAddr string) (types.MetadataAddress, error)

ParseRecordAddr parses the provided input into a record MetadataAddress. The input must be a record address bech32 string.

func ParseRecordSpecID added in v1.0.0 

func ParseRecordSpecID(specID string, name string) (types.MetadataAddress, error)

ParseRecordSpecID parses the provided input into a record spec MetadataAddress. The recordSpecID can either be a uuid string, a record spec address bech32 string, or a contract spec address bech32 string. If it's a contract spec address or a uuid, then a name is required.

func ParseScopeID added in v1.0.0 

func ParseScopeID(scopeID string) (types.MetadataAddress, error)

ParseScopeID parses the provided input into a scope MetadataAddress. The input can either be a uuid string or scope address bech32 string.

func ParseScopeSpecID added in v1.0.0 

func ParseScopeSpecID(scopeSpecID string) (types.MetadataAddress, error)

ParseScopeSpecID parses the provided input into a scope spec MetadataAddress. The input can either be a uuid string or scope spec address bech32 string.

func ParseSessionAddr added in v1.0.0 

func ParseSessionAddr(sessionAddr string) (types.MetadataAddress, error)

ParseSessionAddr parses the provided input into a session MetadataAddress. The input must be a session address bech32 string.

func ParseSessionID added in v1.0.0 

func ParseSessionID(scopeID string, sessionID string) (types.MetadataAddress, error)

ParseSessionID parses the provided input into a session MetadataAddress. The scopeID field can be either a uuid or scope address bech32 string. The sessionID field can be either a uuid or session address bech32 string. If the sessionID field is a bech32 address, the scopeID field is ignored. Otherwise, the scope id field is parsed using ParseScopeID and converted to a session MetadataAddress using the uuid in the sessionID field.

func UnwrapMetadataContext added in v1.15.0 

func UnwrapMetadataContext(goCtx context.Context) sdk.Context

UnwrapMetadataContext retrieves a Context from a context.Context instance attached with WrapSDKContext. It then adds an AuthzCache to it. It panics if a Context was not properly attached, or if the AuthzCache can't be added.

This should be used for all Metadata msg server endpoints instead of sdk.UnwrapSDKContext. This should not be used outside of the Metadata module.

Types

type AuthKeeper added in v1.15.0 

type AuthKeeper interface {
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
}

AuthKeeper is an interface with functions that the auth.Keeper has that are needed in this module.

type AuthzCache added in v1.15.0 

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

AuthzCache is a struct that houses a map of authz authorizations that are known to have a passed Accept (and been handled).

func GetAuthzCache added in v1.15.0 

func GetAuthzCache(ctx sdk.Context) *AuthzCache

GetAuthzCache gets the AuthzCache from the context or panics.

func NewAuthzCache added in v1.15.0 

func NewAuthzCache() *AuthzCache

NewAuthzCache creates a new AuthzCache.

func (*AuthzCache) Clear added in v1.15.0 

func (c *AuthzCache) Clear()

Clear deletes all entries from this AuthzCache.

func (*AuthzCache) GetAcceptable added in v1.15.0 

func (c *AuthzCache) GetAcceptable(grantee, granter sdk.AccAddress, msgTypeURL string) authz.Authorization

GetAcceptable gets a previously set acceptable authorization. Returns nil if no such authorization exists.

func (*AuthzCache) SetAcceptable added in v1.15.0 

func (c *AuthzCache) SetAcceptable(grantee, granter sdk.AccAddress, msgTypeURL string, authorization authz.Authorization)

SetAcceptable sets an authorization in this cache as acceptable.

type AuthzKeeper added in v1.15.0 

type AuthzKeeper interface {
	GetAuthorization(ctx sdk.Context, grantee, granter sdk.AccAddress, msgType string) (authz.Authorization, *time.Time)
	DeleteGrant(ctx sdk.Context, grantee, granter sdk.AccAddress, msgType string) error
	SaveGrant(ctx sdk.Context, grantee, granter sdk.AccAddress, authorization authz.Authorization, expiration *time.Time) error
}

AuthzKeeper is an interface with functions that the authz.Keeper has that are needed in this module.

type Keeper 

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

Keeper is the concrete state-based API for the metadata module.

func NewKeeper 

func NewKeeper(
	cdc codec.BinaryCodec, key storetypes.StoreKey, paramSpace paramtypes.Subspace,
	authKeeper AuthKeeper,
	authzKeeper AuthzKeeper,
) Keeper

NewKeeper creates new instances of the metadata Keeper.

func (Keeper) ContractSpecification added in v0.1.5 

func (k Keeper) ContractSpecification(c context.Context, req *types.ContractSpecificationRequest) (*types.ContractSpecificationResponse, error)

ContractSpecification returns a specific contract specification by id.

func (Keeper) ContractSpecificationsAll added in v1.0.0 

func (k Keeper) ContractSpecificationsAll(c context.Context, req *types.ContractSpecificationsAllRequest) (*types.ContractSpecificationsAllResponse, error)

ContractSpecificationsAll returns all contract specifications (limited by pagination).

func (Keeper) EmitEvent added in v1.3.0 

func (k Keeper) EmitEvent(ctx sdk.Context, event proto.Message)

func (Keeper) ExportGenesis 

func (k Keeper) ExportGenesis(ctx sdk.Context) (data *types.GenesisState)

ExportGenesis exports the current keeper state of the metadata module.ExportGenesis

func (Keeper) GetContractSpecification added in v0.1.5 

func (k Keeper) GetContractSpecification(ctx sdk.Context, contractSpecID types.MetadataAddress) (spec types.ContractSpecification, found bool)

GetContractSpecification returns the contract specification with the given id.

func (Keeper) GetMarkerAndCheckAuthority added in v1.15.0 

func (k Keeper) GetMarkerAndCheckAuthority(
	ctx sdk.Context,
	address string,
	signers []string,
	role markertypes.Access,
) (markertypes.MarkerAccountI, bool, string)

GetMarkerAndCheckAuthority gets a marker by address and checks if one of the signers has the provided role. If the address isn't a marker, nil, false is returned. The signer that has the requested permission is also returned.

func (Keeper) GetMaxURILength added in v1.0.0 

func (k Keeper) GetMaxURILength(ctx sdk.Context) (max uint32)

GetMaxURILength gets the configured parameter for max uri length on a locator record (or the default if unset)

func (Keeper) GetOSLocatorByScope added in v1.0.0 

func (k Keeper) GetOSLocatorByScope(ctx sdk.Context, scopeID string) ([]types.ObjectStoreLocator, error)

GetOSLocatorByScope gets all Object Store Locators associated with a scope.

func (Keeper) GetOSLocatorParams added in v0.3.0 

func (k Keeper) GetOSLocatorParams(ctx sdk.Context) (osLocatorParams types.OSLocatorParams)

GetParams returns the total set of metadata parameters.

func (Keeper) GetOsLocatorRecord added in v0.3.0 

func (k Keeper) GetOsLocatorRecord(ctx sdk.Context, ownerAddr sdk.AccAddress) (osLocator types.ObjectStoreLocator, found bool)

GetOsLocatorRecord Gets the object store locator entry from the kvstore for the given owner address.

func (Keeper) GetParams 

func (k Keeper) GetParams(ctx sdk.Context) (params types.Params)

GetParams returns the total set of metadata parameters.

func (Keeper) GetRecord 

func (k Keeper) GetRecord(ctx sdk.Context, id types.MetadataAddress) (record types.Record, found bool)

GetRecord returns the record with the given id.

func (Keeper) GetRecordSpecification added in v0.2.0 

func (k Keeper) GetRecordSpecification(ctx sdk.Context, recordSpecID types.MetadataAddress) (spec types.RecordSpecification, found bool)

GetRecordSpecification returns the record specification with the given id.

func (Keeper) GetRecordSpecificationsForContractSpecificationID added in v0.2.0 

func (k Keeper) GetRecordSpecificationsForContractSpecificationID(ctx sdk.Context, contractSpecID types.MetadataAddress) ([]*types.RecordSpecification, error)

GetRecordSpecificationsForContractSpecificationID returns all the record specifications associated with given contractSpecID

func (Keeper) GetRecords added in v0.1.5 

func (k Keeper) GetRecords(ctx sdk.Context, scopeAddress types.MetadataAddress, name string) ([]*types.Record, error)

GetRecords returns records for a scope optionally limited to a name.

func (Keeper) GetScope 

func (k Keeper) GetScope(ctx sdk.Context, id types.MetadataAddress) (scope types.Scope, found bool)

GetScope returns the scope with the given id.

func (Keeper) GetScopeSpecification 

func (k Keeper) GetScopeSpecification(ctx sdk.Context, scopeSpecID types.MetadataAddress) (spec types.ScopeSpecification, found bool)

GetScopeSpecification returns the scope specification with the given id.

func (Keeper) GetSession added in v0.2.0 

func (k Keeper) GetSession(ctx sdk.Context, id types.MetadataAddress) (session types.Session, found bool)

GetSession returns the session with the given id.

func (Keeper) ImportOSLocatorRecord added in v1.3.0 

func (k Keeper) ImportOSLocatorRecord(ctx sdk.Context, ownerAddr, encryptionKey sdk.AccAddress, uri string) error

ImportOSLocatorRecord binds a name to an address in the kvstore. Different from SetOSLocator in that there is less validation here. The uri format is not checked, and the owner address account is not looked up. This also does not emit any events.

func (Keeper) InitGenesis 

func (k Keeper) InitGenesis(ctx sdk.Context, data *types.GenesisState)

InitGenesis creates the initial genesis state for the metadata module.

func (Keeper) IterateContractSpecs added in v0.1.5 

func (k Keeper) IterateContractSpecs(ctx sdk.Context, handler func(specification types.ContractSpecification) (stop bool)) error

IterateContractSpecs processes all contract specs using a given handler.

func (Keeper) IterateContractSpecsForOwner added in v0.1.5 

func (k Keeper) IterateContractSpecsForOwner(ctx sdk.Context, ownerAddress sdk.AccAddress, handler func(contractSpecID types.MetadataAddress) (stop bool)) error

IterateContractSpecsForOwner processes all contract specs owned by an address using a given handler.

func (Keeper) IterateOSLocators added in v1.3.0 

func (k Keeper) IterateOSLocators(ctx sdk.Context, cb func(account types.ObjectStoreLocator) (stop bool)) error

IterateOSLocators runs a function for every ObjectStoreLocator entry in the kvstore.

func (Keeper) IterateRecordSpecs added in v0.2.0 

func (k Keeper) IterateRecordSpecs(ctx sdk.Context, handler func(specification types.RecordSpecification) (stop bool)) error

IterateRecordSpecs processes all record specs using a given handler.

func (Keeper) IterateRecordSpecsForContractSpec added in v0.2.0 

func (k Keeper) IterateRecordSpecsForContractSpec(ctx sdk.Context, contractSpecID types.MetadataAddress, handler func(recordSpecID types.MetadataAddress) (stop bool)) error

IterateRecordSpecsForContractSpec processes all record specs for a contract spec using a given handler.

func (Keeper) IterateRecordSpecsForOwner added in v0.2.0 

func (k Keeper) IterateRecordSpecsForOwner(ctx sdk.Context, ownerAddress sdk.AccAddress, handler func(recordSpecID types.MetadataAddress) (stop bool)) error

IterateRecordSpecsForOwner processes all record specs owned by an address using a given handler.

func (Keeper) IterateRecords 

func (k Keeper) IterateRecords(ctx sdk.Context, scopeID types.MetadataAddress, handler func(types.Record) (stop bool)) error

IterateRecords processes stored records with the given handler. If the scopeID is an empty MetadataAddress, all records will be processed. Otherwise, just the records for the given scopeID will be processed.

func (Keeper) IterateScopeSpecs added in v0.1.5 

func (k Keeper) IterateScopeSpecs(ctx sdk.Context, handler func(specification types.ScopeSpecification) (stop bool)) error

IterateScopeSpecs processes all scope specs using a given handler.

func (Keeper) IterateScopeSpecsForContractSpec added in v0.1.5 

func (k Keeper) IterateScopeSpecsForContractSpec(ctx sdk.Context, contractSpecID types.MetadataAddress, handler func(scopeSpecID types.MetadataAddress) (stop bool)) error

IterateScopeSpecsForContractSpec processes all scope specs associated with a contract spec id using a given handler.

func (Keeper) IterateScopeSpecsForOwner added in v0.1.5 

func (k Keeper) IterateScopeSpecsForOwner(ctx sdk.Context, ownerAddress sdk.AccAddress, handler func(scopeSpecID types.MetadataAddress) (stop bool)) error

IterateScopeSpecsForOwner processes all scope specs owned by an address using a given handler.

func (Keeper) IterateScopes 

func (k Keeper) IterateScopes(ctx sdk.Context, handler func(types.Scope) (stop bool)) error

IterateScopes processes all stored scopes with the given handler.

func (Keeper) IterateScopesForAddress 

func (k Keeper) IterateScopesForAddress(ctx sdk.Context, address sdk.AccAddress, handler func(scopeID types.MetadataAddress) (stop bool)) error

IterateScopesForAddress processes scopes associated with the provided address with the given handler.

func (Keeper) IterateScopesForScopeSpec 

func (k Keeper) IterateScopesForScopeSpec(ctx sdk.Context, scopeSpecID types.MetadataAddress,
	handler func(scopeID types.MetadataAddress) (stop bool),
) error

IterateScopesForScopeSpec processes scopes associated with the provided scope specification id with the given handler.

func (Keeper) IterateSessions added in v0.2.0 

func (k Keeper) IterateSessions(ctx sdk.Context, scopeID types.MetadataAddress, handler func(types.Session) (stop bool)) error

IterateSessions processes stored sessions with the given handler. If the scopeID is an empty MetadataAddress, all sessions will be processed. Otherwise, just the sessions for the given scopeID will be processed.

func (Keeper) Logger 

func (k Keeper) Logger(ctx sdk.Context) log.Logger

Logger returns a module-specific logger.

func (Keeper) ModifyOSLocator added in v1.3.0 

func (k Keeper) ModifyOSLocator(ctx sdk.Context, ownerAddr, encryptionKey sdk.AccAddress, uri string) error

ModifyOSLocator updates an existing os locator entry in the kvstore, returns an error if it doesn't exist.

func (Keeper) OSAllLocators added in v0.3.0 

func (k Keeper) OSAllLocators(ctx context.Context, request *types.OSAllLocatorsRequest) (*types.OSAllLocatorsResponse, error)

func (Keeper) OSLocator added in v0.3.0 

func (k Keeper) OSLocator(c context.Context, request *types.OSLocatorRequest) (*types.OSLocatorResponse, error)

func (Keeper) OSLocatorExists added in v0.3.0 

func (k Keeper) OSLocatorExists(ctx sdk.Context, ownerAddr sdk.AccAddress) bool

OSLocatorExists checks if the provided bech32 owner address has a OSL entry in the kvstore.

func (Keeper) OSLocatorParams added in v0.3.0 

func (k Keeper) OSLocatorParams(c context.Context, request *types.OSLocatorParamsRequest) (*types.OSLocatorParamsResponse, error)

func (Keeper) OSLocatorsByScope added in v1.0.0 

func (k Keeper) OSLocatorsByScope(ctx context.Context, request *types.OSLocatorsByScopeRequest) (*types.OSLocatorsByScopeResponse, error)

func (Keeper) OSLocatorsByURI added in v1.0.0 

func (k Keeper) OSLocatorsByURI(ctx context.Context, request *types.OSLocatorsByURIRequest) (*types.OSLocatorsByURIResponse, error)

func (Keeper) Ownership 

func (k Keeper) Ownership(c context.Context, req *types.OwnershipRequest) (*types.OwnershipResponse, error)

Ownership returns a list of scope identifiers that list the given address as a data or value owner.

func (Keeper) Params 

func (k Keeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)

Params queries params of metadata module.

func (Keeper) RecordSpecification added in v0.2.0 

func (k Keeper) RecordSpecification(c context.Context, req *types.RecordSpecificationRequest) (*types.RecordSpecificationResponse, error)

RecordSpecification returns a specific record specification.

func (Keeper) RecordSpecificationsAll added in v1.0.0 

func (k Keeper) RecordSpecificationsAll(c context.Context, req *types.RecordSpecificationsAllRequest) (*types.RecordSpecificationsAllResponse, error)

RecordSpecificationsAll returns all record specifications (limited by pagination).

func (Keeper) RecordSpecificationsForContractSpecification added in v0.2.0 

func (k Keeper) RecordSpecificationsForContractSpecification(
	c context.Context,
	req *types.RecordSpecificationsForContractSpecificationRequest,
) (*types.RecordSpecificationsForContractSpecificationResponse, error)

RecordSpecificationsForContractSpecification returns the record specifications associated with a contract specification.

func (Keeper) Records added in v1.0.0 

func (k Keeper) Records(c context.Context, req *types.RecordsRequest) (*types.RecordsResponse, error)

Records returns records based on the provided request.

func (Keeper) RecordsAll added in v1.0.0 

func (k Keeper) RecordsAll(c context.Context, req *types.RecordsAllRequest) (*types.RecordsAllResponse, error)

RecordsAll returns all records (limited by pagination).

func (Keeper) RemoveContractSpecification added in v0.1.5 

func (k Keeper) RemoveContractSpecification(ctx sdk.Context, contractSpecID types.MetadataAddress) error

RemoveContractSpecification removes a contract specification from the module kv store.

func (Keeper) RemoveOSLocator added in v1.3.0 

func (k Keeper) RemoveOSLocator(ctx sdk.Context, ownerAddr sdk.AccAddress) error

RemoveOSLocator removes an os locator record from the kvstore.

func (Keeper) RemoveRecord 

func (k Keeper) RemoveRecord(ctx sdk.Context, id types.MetadataAddress)

RemoveRecord removes a record from the module kv store.

func (Keeper) RemoveRecordSpecification added in v0.2.0 

func (k Keeper) RemoveRecordSpecification(ctx sdk.Context, recordSpecID types.MetadataAddress) error

RemoveRecordSpecification removes a record specification from the module kv store.

func (Keeper) RemoveScope added in v0.1.5 

func (k Keeper) RemoveScope(ctx sdk.Context, id types.MetadataAddress)

RemoveScope removes a scope from the module kv store along with all its records and sessions.

func (Keeper) RemoveScopeSpecification added in v0.1.5 

func (k Keeper) RemoveScopeSpecification(ctx sdk.Context, scopeSpecID types.MetadataAddress) error

RemoveScopeSpecification removes a scope specification from the module kv store.

func (Keeper) RemoveSession added in v0.2.0 

func (k Keeper) RemoveSession(ctx sdk.Context, id types.MetadataAddress)

RemoveSession removes a session from the module kv store if there are no records associated with it.

func (Keeper) Scope 

func (k Keeper) Scope(c context.Context, req *types.ScopeRequest) (*types.ScopeResponse, error)

Scope returns a specific scope by id.

func (Keeper) ScopeSpecification added in v0.1.5 

func (k Keeper) ScopeSpecification(c context.Context, req *types.ScopeSpecificationRequest) (*types.ScopeSpecificationResponse, error)

ScopeSpecification returns a specific scope specification by id.

func (Keeper) ScopeSpecificationsAll added in v1.0.0 

func (k Keeper) ScopeSpecificationsAll(c context.Context, req *types.ScopeSpecificationsAllRequest) (*types.ScopeSpecificationsAllResponse, error)

ScopeSpecificationsAll returns all scope specifications (limited by pagination).

func (Keeper) ScopesAll added in v1.0.0 

func (k Keeper) ScopesAll(c context.Context, req *types.ScopesAllRequest) (*types.ScopesAllResponse, error)

ScopesAll returns all scopes (limited by pagination).

func (Keeper) Sessions added in v1.0.0 

func (k Keeper) Sessions(c context.Context, req *types.SessionsRequest) (*types.SessionsResponse, error)

Sessions returns sessions based on the provided request.

func (Keeper) SessionsAll added in v1.0.0 

func (k Keeper) SessionsAll(c context.Context, req *types.SessionsAllRequest) (*types.SessionsAllResponse, error)

SessionsAll returns all sessions (limited by pagination).

func (Keeper) SetContractSpecification added in v0.1.5 

func (k Keeper) SetContractSpecification(ctx sdk.Context, spec types.ContractSpecification)

SetContractSpecification stores a contract specification in the module kv store.

func (Keeper) SetOSLocator added in v1.3.0 

func (k Keeper) SetOSLocator(ctx sdk.Context, ownerAddr, encryptionKey sdk.AccAddress, uri string) error

SetOSLocator binds an OS Locator to an address in the kvstore. An error is returned if no account exists for the address. An error is returned if an OS Locator already exists for the address.

func (Keeper) SetOSLocatorParams added in v0.3.0 

func (k Keeper) SetOSLocatorParams(ctx sdk.Context, params types.OSLocatorParams)

SetParams sets the distribution parameters to the param space.

func (Keeper) SetParams 

func (k Keeper) SetParams(ctx sdk.Context, params types.Params)

SetParams sets the metadata parameters to the param space.

func (Keeper) SetRecord 

func (k Keeper) SetRecord(ctx sdk.Context, record types.Record)

SetRecord stores a record in the module kv store.

func (Keeper) SetRecordSpecification added in v0.2.0 

func (k Keeper) SetRecordSpecification(ctx sdk.Context, spec types.RecordSpecification)

SetRecordSpecification stores a record specification in the module kv store.

func (Keeper) SetScope 

func (k Keeper) SetScope(ctx sdk.Context, scope types.Scope)

SetScope stores a scope in the module kv store.

func (Keeper) SetScopeSpecification 

func (k Keeper) SetScopeSpecification(ctx sdk.Context, spec types.ScopeSpecification)

SetScopeSpecification stores a scope specification in the module kv store.

func (Keeper) SetSession added in v0.2.0 

func (k Keeper) SetSession(ctx sdk.Context, session types.Session)

SetSession stores a session in the module kv store.

func (Keeper) UnionDistinct added in v1.4.0 

func (k Keeper) UnionDistinct(sets ...[]string) []string

unionUnique gets a union of the provided sets of strings without any duplicates.

func (Keeper) ValidateAddScopeDataAccess added in v1.15.0 

func (k Keeper) ValidateAddScopeDataAccess(
	ctx sdk.Context,
	existing types.Scope,
	msg *types.MsgAddScopeDataAccessRequest,
) error

ValidateAddScopeDataAccess checks the current scope and the proposed

func (Keeper) ValidateAuditUpdate added in v0.2.1 

func (k Keeper) ValidateAuditUpdate(ctx sdk.Context, existing, proposed *types.AuditFields) error

ValidateAuditUpdate ensure that a given reference to audit fields represents no changes to existing audit field data. NOTE: A nil proposed is considered "no update" and not an attempt to unset.

func (Keeper) ValidateDeleteRecord added in v1.15.0 

func (k Keeper) ValidateDeleteRecord(ctx sdk.Context, proposedID types.MetadataAddress, msg types.MetadataMsg) error

ValidateDeleteRecord checks the current record and the proposed removal scope to determine if the proposed remove is valid based on the existing state

func (Keeper) ValidateDeleteScope added in v1.15.0 

func (k Keeper) ValidateDeleteScope(ctx sdk.Context, msg *types.MsgDeleteScopeRequest) error

ValidateDeleteScope checks the current scope and the proposed removal scope to determine if the proposed remove is valid based on the existing state

func (Keeper) ValidateDeleteScopeDataAccess added in v1.15.0 

func (k Keeper) ValidateDeleteScopeDataAccess(
	ctx sdk.Context,
	existing types.Scope,
	msg *types.MsgDeleteScopeDataAccessRequest,
) error

ValidateDeleteScopeDataAccess checks the current scope data access and the proposed removed items

func (Keeper) ValidateScopeValueOwnerUpdate added in v1.15.0 

func (k Keeper) ValidateScopeValueOwnerUpdate(
	ctx sdk.Context,
	existing,
	proposed string,
	validatedParties []*PartyDetails,
	msg types.MetadataMsg,
) (map[string]bool, error)

ValidateScopeValueOwnerUpdate verifies that it's okay for the msg signers to change a scope's value owner from existing to proposed. If some parties have already been validated (possibly utilizing authz), they can be provided in order to prevent an authorization from being used twice during a single Tx.

If no error is returned, a map of bech32 strings to true is returned where each key is a signer that either has a signer in validatedParties, or is used directly in here.

func (Keeper) ValidateSignersWithParties added in v1.15.0 

func (k Keeper) ValidateSignersWithParties(
	ctx sdk.Context,
	reqParties, availableParties []types.Party,
	reqRoles []types.PartyType,
	msg types.MetadataMsg,
) error

ValidateSignersWithParties ensures the following:

  • All optional=false reqParties have signed.
  • All required roles are present in availableParties and are signers.
  • All available parties with the PROVENANCE role are a smart contract account.
  • All available parties with a smart contract account have the PROVENANCE role.
  • All signers that are smart contracts are allowed to sign.

The x/authz module is utilized to help facilitate signer checking.

  • reqParties are the parties that might be required to sign, but might not necessarily fulfill a required role. They can only fulfill a required role if also provided in availableParties. Parties in reqParties with optional=true, are ignored. Parties in reqParties with optional=false are required to be in the msg signers.
  • availableParties are the parties available to fulfill required roles. Entries in here with optional=false are NOT required to sign (unless they're in reqParties like that too).
  • reqRoles are all the roles that are required.

If a party is in both reqParties and availableParties, they are only optional if both have optional=true. Only parties in availableParties that are in the msg signers list are able to fulfill an entry in reqRoles, and each such party can only fulfill one required role entry.

When parties and roles aren't involved, use ValidateSignersWithoutParties.

func (Keeper) ValidateSignersWithoutParties added in v1.15.0 

func (k Keeper) ValidateSignersWithoutParties(
	ctx sdk.Context,
	required []string,
	msg types.MetadataMsg,
) error

ValidateSignersWithoutParties makes sure that each entry in the required list are either signers of the msg, or have granted an authz authorization to one of the signers. It then makes sure that any signers that are smart contracts are allowed to sign.

When parties (and/or roles) are involved, use ValidateSignersWithParties.

func (Keeper) ValidateUpdateScopeOwners added in v1.15.0 

func (k Keeper) ValidateUpdateScopeOwners(
	ctx sdk.Context,
	existing,
	proposed types.Scope,
	msg types.MetadataMsg,
) error

ValidateUpdateScopeOwners checks the current scopes owners and the proposed update

func (Keeper) ValidateWriteContractSpecification added in v1.15.0 

func (k Keeper) ValidateWriteContractSpecification(ctx sdk.Context, existing *types.ContractSpecification, proposed types.ContractSpecification) error

ValidateWriteContractSpecification compare the proposed contract spec with the existing to make sure the proposed is valid. This assumes that proposed.ValidateBasic() has been run and did not return an error.

func (Keeper) ValidateWriteRecord added in v1.15.0 

func (k Keeper) ValidateWriteRecord(
	ctx sdk.Context,
	existing *types.Record,
	msg *types.MsgWriteRecordRequest,
) error

ValidateWriteRecord checks the current record and the proposed record to determine if the proposed changes are valid based on the existing state Note: The proposed parameter is a reference here so that the SpecificationId can be set in cases when it's not provided.

func (Keeper) ValidateWriteRecordSpecification added in v1.15.0 

func (k Keeper) ValidateWriteRecordSpecification(ctx sdk.Context, existing *types.RecordSpecification, proposed types.RecordSpecification) error

ValidateWriteRecordSpecification compare the proposed contract spec with the existing to make sure the proposed is valid. This assumes that proposed.ValidateBasic() has been run and did not return an error.

func (Keeper) ValidateWriteScope added in v1.15.0 

func (k Keeper) ValidateWriteScope(
	ctx sdk.Context,
	existing *types.Scope,
	msg *types.MsgWriteScopeRequest,
) error

ValidateWriteScope checks the current scope and the proposed scope to determine if the proposed changes are valid based on the existing state

func (Keeper) ValidateWriteScopeSpecification added in v1.15.0 

func (k Keeper) ValidateWriteScopeSpecification(ctx sdk.Context, existing *types.ScopeSpecification, proposed types.ScopeSpecification) error

ValidateWriteScopeSpecification compare the proposed scope spec with the existing to make sure the proposed is valid. This assumes that proposed.ValidateBasic() has been run and did not return an error.

func (Keeper) ValidateWriteSession added in v1.15.0 

func (k Keeper) ValidateWriteSession(ctx sdk.Context, existing *types.Session, msg *types.MsgWriteSessionRequest) error

ValidateWriteSession checks the current session and the proposed session to determine if the proposed changes are valid based on the existing state

func (Keeper) ValueOwnership 

func (k Keeper) ValueOwnership(c context.Context, req *types.ValueOwnershipRequest) (*types.ValueOwnershipResponse, error)

ValueOwnership returns a list of scope identifiers that list the given address as a value owner.

func (Keeper) VerifyCorrectOwner added in v0.3.0 

func (k Keeper) VerifyCorrectOwner(ctx sdk.Context, ownerAddr sdk.AccAddress) bool

VerifyCorrectOwner to determines whether the signer resolves to the owner of the OSLocator record.

type MetadataKeeperI 

type MetadataKeeperI interface {
	// GetScope returns the scope with the given id.
	GetScope(sdk.Context, types.MetadataAddress) (types.Scope, bool)
	// SetScope stores a scope in the module kv store.
	SetScope(sdk.Context, types.Scope)
	// RemoveScope removes a scope from the module kv store along with all its records and sessions.
	RemoveScope(sdk.Context, types.MetadataAddress)

	// IterateScopes processes all stored scopes with the given handler.
	IterateScopes(sdk.Context, func(types.Scope) bool) error
	// IterateScopesForAddress processes scopes associated with the provided address with the given handler.
	IterateScopesForAddress(sdk.Context, sdk.AccAddress, func(types.MetadataAddress) bool) error
	// IterateScopesForScopeSpec processes scopes associated with the provided scope specification id with the given handler.
	IterateScopesForScopeSpec(sdk.Context, types.MetadataAddress, func(types.MetadataAddress) bool) error

	// GetSession returns the session with the given id.
	GetSession(sdk.Context, types.MetadataAddress) (types.Session, bool)
	// SetSession stores a session in the module kv store.
	SetSession(sdk.Context, types.Session)
	// RemoveSession removes a session from the module kv store if there are no records associated with it.
	RemoveSession(sdk.Context, types.MetadataAddress)

	// IterateSessions processes stored sessions with the given handler.
	IterateSessions(sdk.Context, types.MetadataAddress, func(types.Session) bool) error

	// GetRecord returns the record with the given id.
	GetRecord(sdk.Context, types.MetadataAddress) (types.Record, bool)
	// GetRecords returns records for a scope optionally limited to a name.
	GetRecords(sdk.Context, types.MetadataAddress, string) ([]*types.Record, error)
	// SetRecord stores a record in the module kv store.
	SetRecord(sdk.Context, types.Record)
	// RemoveRecord removes a record from the module kv store.
	RemoveRecord(sdk.Context, types.MetadataAddress)

	// IterateRecords processes stored records with the given handler.
	IterateRecords(sdk.Context, types.MetadataAddress, func(types.Record) bool) error

	// GetScopeSpecification returns the scope specification with the given id.
	GetScopeSpecification(sdk.Context, types.MetadataAddress) (types.ScopeSpecification, bool)
	// SetScopeSpecification stores a scope specification in the module kv store.
	SetScopeSpecification(sdk.Context, types.ScopeSpecification)
	// RemoveScopeSpecification removes a scope specification from the module kv store.
	RemoveScopeSpecification(sdk.Context, types.MetadataAddress) error

	// IterateScopeSpecs processes all scope specs using a given handler.
	IterateScopeSpecs(ctx sdk.Context, handler func(specification types.ScopeSpecification) (stop bool)) error
	// IterateScopeSpecsForOwner processes all scope specs owned by an address using a given handler.
	IterateScopeSpecsForOwner(ctx sdk.Context, ownerAddress sdk.AccAddress, handler func(scopeSpecID types.MetadataAddress) (stop bool)) error
	// IterateScopeSpecsForContractSpec processes all scope specs associated with a contract spec id using a given handler.
	IterateScopeSpecsForContractSpec(ctx sdk.Context, contractSpecID types.MetadataAddress, handler func(scopeSpecID types.MetadataAddress) (stop bool)) error

	// GetContractSpecification returns the contract specification with the given id.
	GetContractSpecification(sdk.Context, types.MetadataAddress) (types.ContractSpecification, bool)
	// SetContractSpecification stores a contract specification in the module kv store.
	SetContractSpecification(sdk.Context, types.ContractSpecification)
	// RemoveContractSpecification removes a contract specification from the module kv store.
	RemoveContractSpecification(sdk.Context, types.MetadataAddress) error

	// IterateContractSpecs processes all contract specs using a given handler.
	IterateContractSpecs(ctx sdk.Context, handler func(specification types.ContractSpecification) (stop bool)) error
	// IterateContractSpecsForOwner processes all contract specs owned by an address using a given handler.
	IterateContractSpecsForOwner(ctx sdk.Context, ownerAddress sdk.AccAddress, handler func(contractSpecID types.MetadataAddress) (stop bool)) error

	// GetRecordSpecification returns the record specification with the given id.
	GetRecordSpecification(sdk.Context, types.MetadataAddress) (types.RecordSpecification, bool)
	// SetRecordSpecification stores a record specification in the module kv store.
	SetRecordSpecification(sdk.Context, types.RecordSpecification)
	// RemoveRecordSpecification removes a record specification from the module kv store.
	RemoveRecordSpecification(sdk.Context, types.MetadataAddress) error

	// IterateRecordSpecs processes all record specs using a given handler.
	IterateRecordSpecs(ctx sdk.Context, handler func(specification types.RecordSpecification) (stop bool)) error
	// IterateRecordSpecsForOwner processes all record specs owned by an address using a given handler.
	IterateRecordSpecsForOwner(ctx sdk.Context, ownerAddress sdk.AccAddress, handler func(recordSpecID types.MetadataAddress) (stop bool)) error
	// IterateRecordSpecsForContractSpec processes all record specs for a contract spec using a given handler.
	IterateRecordSpecsForContractSpec(ctx sdk.Context, contractSpecID types.MetadataAddress, handler func(recordSpecID types.MetadataAddress) (stop bool)) error
	// GetRecordSpecificationsForContractSpecificationID returns all the record specifications associated with given contractSpecID
	GetRecordSpecificationsForContractSpecificationID(ctx sdk.Context, contractSpecID types.MetadataAddress) ([]*types.RecordSpecification, error)

	// GetOsLocatorRecord returns the OS locator records for a given name record.
	GetOsLocatorRecord(ctx sdk.Context, ownerAddr sdk.AccAddress) (types.ObjectStoreLocator, bool)
	// return if OSLocator exists for a given owner addr
	OSLocatorExists(ctx sdk.Context, ownerAddr sdk.AccAddress) bool
	// add OSLocator instance
	SetOSLocator(ctx sdk.Context, ownerAddr, encryptionKey sdk.AccAddress, uri string) error
	// get OS locator by scope UUID.
	GetOSLocatorByScope(ctx sdk.Context, scopeID string) ([]types.ObjectStoreLocator, error)
}

MetadataKeeperI is the internal state api for the metadata module.

type Migrator added in v1.7.0 

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

Migrator is a struct for handling in-place store migrations.

func NewMigrator added in v1.7.0 

func NewMigrator(keeper Keeper) Migrator

NewMigrator returns a new Migrator.

type PartyDetails added in v1.15.0 

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

PartyDetails is a struct used to help process party and signer validation. Even though all the fields are public, you should usually use the Get/Set methods which handle automatic bech32 conversion when needed and reduce duplicated efforts.

func BuildPartyDetails added in v1.15.0 

func BuildPartyDetails(reqParties, availableParties []types.Party) []*PartyDetails

BuildPartyDetails creates the list of PartyDetails to be used in party/signer/role validation.

func WrapAvailableParty added in v1.15.0 

func WrapAvailableParty(party types.Party) *PartyDetails

WrapAvailableParty creates a PartyDetails from the provided Party and marks it as optional and usable.

func WrapRequiredParty added in v1.15.0 

func WrapRequiredParty(party types.Party) *PartyDetails

WrapRequiredParty creates a PartyDetails from the provided Party.

func (*PartyDetails) CanBeUsed added in v1.15.0 

func (p *PartyDetails) CanBeUsed() bool

func (*PartyDetails) GetAcc added in v1.15.0 

func (p *PartyDetails) GetAcc() sdk.AccAddress

func (*PartyDetails) GetAddress added in v1.15.0 

func (p *PartyDetails) GetAddress() string

func (*PartyDetails) GetOptional added in v1.15.0 

func (p *PartyDetails) GetOptional() bool

func (*PartyDetails) GetRole added in v1.15.0 

func (p *PartyDetails) GetRole() types.PartyType

func (*PartyDetails) GetSigner added in v1.15.0 

func (p *PartyDetails) GetSigner() string

func (*PartyDetails) GetSignerAcc added in v1.15.0 

func (p *PartyDetails) GetSignerAcc() sdk.AccAddress

func (*PartyDetails) HasSigner added in v1.15.0 

func (p *PartyDetails) HasSigner() bool

func (*PartyDetails) IsRequired added in v1.15.0 

func (p *PartyDetails) IsRequired() bool

func (*PartyDetails) IsSameAs added in v1.15.0 

func (p *PartyDetails) IsSameAs(p2 types.Partier) bool

IsSameAs returns true if this is the same as the provided Party or PartyDetails. Only the address and role are considered for this test.

func (*PartyDetails) IsStillUsableAs added in v1.15.0 

func (p *PartyDetails) IsStillUsableAs(role types.PartyType) bool

IsStillUsableAs returns true if this party can be used, hasn't yet been used and has the provided role.

func (*PartyDetails) IsUsed added in v1.15.0 

func (p *PartyDetails) IsUsed() bool

func (*PartyDetails) MakeRequired added in v1.15.0 

func (p *PartyDetails) MakeRequired()

func (*PartyDetails) MarkAsUsed added in v1.15.0 

func (p *PartyDetails) MarkAsUsed()

func (*PartyDetails) SetAcc added in v1.15.0 

func (p *PartyDetails) SetAcc(addr sdk.AccAddress)

func (*PartyDetails) SetAddress added in v1.15.0 

func (p *PartyDetails) SetAddress(address string)

func (*PartyDetails) SetOptional added in v1.15.0 

func (p *PartyDetails) SetOptional(optional bool)

func (*PartyDetails) SetRole added in v1.15.0 

func (p *PartyDetails) SetRole(role types.PartyType)

func (*PartyDetails) SetSigner added in v1.15.0 

func (p *PartyDetails) SetSigner(signer string)

func (*PartyDetails) SetSignerAcc added in v1.15.0 

func (p *PartyDetails) SetSignerAcc(signerAddr sdk.AccAddress)

type SignersWrapper added in v1.15.0 

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

SignersWrapper stores the signers as strings and acc addresses. One is created by providing the strings. They are then converted to acc addresses if they're needed that way.

func NewSignersWrapper added in v1.15.0 

func NewSignersWrapper(signers []string) *SignersWrapper

func (*SignersWrapper) Accs added in v1.15.0 

func (s *SignersWrapper) Accs() []sdk.AccAddress

Accs gets the sdk.AccAddress versions of the signers. Conversion happens if it hasn't already been done yet. Any strings that fail to convert are simply ignored.

func (*SignersWrapper) Strings added in v1.15.0 

func (s *SignersWrapper) Strings() []string

Strings gets the string versions of the signers.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.