keeper

package
v1.0.4 Latest Latest
Warning

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

 Go to latest Published: Sep 20, 2021 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AllInvariants 

func AllInvariants(k Keeper) sdk.Invariant

func NewMsgServerImpl added in v0.15.0 

func NewMsgServerImpl(keeper Keeper) types.MsgServer

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

func RegisterInvariants 

func RegisterInvariants(ir sdk.InvariantRegistry, keeper Keeper)

RegisterInvariants registers all posts invariants 

func ValidApplicationLinks(k Keeper) sdk.Invariant

ValidApplicationLinks checks that all application links are associated with a user that has a profile 

func ValidChainLinks(k Keeper) sdk.Invariant

ValidChainLinks checks that all chain links are associated with a user that has a profile

func ValidDTagTransferRequests added in v0.17.0 

func ValidDTagTransferRequests(k Keeper) sdk.Invariant

ValidDTagTransferRequests checks that all DTag transfer requests are associated with a recipient that has a profile and they have not been made from the same user towards the same user

func ValidProfilesInvariant added in v0.17.0 

func ValidProfilesInvariant(k Keeper) sdk.Invariant

ValidProfilesInvariant checks that all registered Profiles have a non-empty DTag and a non-empty creator

func ValidRelationshipsInvariant added in v0.17.0 

func ValidRelationshipsInvariant(k Keeper) sdk.Invariant

ValidRelationshipsInvariant checks that all relationships are associated with a creator that has a profile and they do not have the same user as creator and recipient

func ValidUserBlocksInvariant added in v0.17.0 

func ValidUserBlocksInvariant(k Keeper) sdk.Invariant

ValidUserBlocksInvariant checks that all created user blocks have been created by a user with a profile and they do not have the same user as creator and recipient

Types

type Keeper 

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

Keeper maintains the link to data storage and exposes getter/setter methods for the various parts of the state machine

func NewKeeper 

func NewKeeper(
	cdc codec.BinaryMarshaler,
	storeKey sdk.StoreKey,
	paramSpace paramstypes.Subspace,
	ak authkeeper.AccountKeeper,
	channelKeeper types.ChannelKeeper,
	portKeeper types.PortKeeper,
	scopedKeeper types.ScopedKeeper,
) Keeper

NewKeeper creates new instances of the Profiles Keeper. This k stores the profile data using two different associations:

  1. Address -> Profile This is used to easily retrieve the profile of a user based on an address
  2. DTag -> Address This is used to get the address of a user based on a DTag

func (Keeper) ApplicationLinkByClientID added in v0.17.0 

func (k Keeper) ApplicationLinkByClientID(ctx context.Context, request *types.QueryApplicationLinkByClientIDRequest) (*types.QueryApplicationLinkByClientIDResponse, error)

ApplicationLinkByClientID implements the Query/ApplicationLinkByClientID gRPC method

func (Keeper) AuthenticateCapability added in v0.17.0 

func (k Keeper) AuthenticateCapability(ctx sdk.Context, cap *capabilitytypes.Capability, name string) bool

AuthenticateCapability wraps the scopedKeeper's AuthenticateCapability function

func (Keeper) BindPort added in v0.17.0 

func (k Keeper) BindPort(ctx sdk.Context, portID string) error

BindPort defines a wrapper function for the port Keeper's function in order to expose it to module's InitGenesis function

func (Keeper) ChanCloseInit added in v0.17.0 

func (k Keeper) ChanCloseInit(ctx sdk.Context, portID, channelID string) error

ChanCloseInit defines a wrapper function for the channel Keeper's function

func (Keeper) ClaimCapability added in v0.17.0 

func (k Keeper) ClaimCapability(ctx sdk.Context, cap *capabilitytypes.Capability, name string) error

ClaimCapability wraps the scopedKeeper's ClaimCapability method 

func (k Keeper) DeleteAllUserApplicationLinks(ctx sdk.Context, user string)

DeleteAllUserApplicationLinks delete all the applications links associated with the given user

func (Keeper) DeleteAllUserBlocks added in v0.17.0 

func (k Keeper) DeleteAllUserBlocks(ctx sdk.Context, user string)

DeleteAllUserBlocks deletes all the user blocks that have been created by the given user 

func (k Keeper) DeleteAllUserChainLinks(ctx sdk.Context, user string)

DeleteAllUserChainLinks deletes all the chain links associated with the given user

func (Keeper) DeleteAllUserIncomingDTagTransferRequests added in v0.17.0 

func (k Keeper) DeleteAllUserIncomingDTagTransferRequests(ctx sdk.Context, receiver string)

DeleteAllUserIncomingDTagTransferRequests deletes all the requests made to the given user

func (Keeper) DeleteAllUserRelationships added in v0.17.0 

func (k Keeper) DeleteAllUserRelationships(ctx sdk.Context, user string)

DeleteAllUserRelationships removes all the relationships that somehow involve the given user 

func (k Keeper) DeleteApplicationLink(ctx sdk.Context, user string, application, username string) error

DeleteApplicationLink removes the application link associated to the given user, for the given application and username 

func (k Keeper) DeleteChainLink(ctx sdk.Context, owner, chainName, target string) error

DeleteChainLink deletes the link associated with the given address and chain name

func (Keeper) DeleteDTagTransferRequest added in v0.13.0 

func (k Keeper) DeleteDTagTransferRequest(ctx sdk.Context, sender, recipient string) error

DeleteDTagTransferRequest deletes the transfer request made from the sender towards the recipient

func (Keeper) DeleteUserBlock added in v0.16.0 

func (k Keeper) DeleteUserBlock(ctx sdk.Context, blocker, blocked string, subspace string) error

DeleteUserBlock allows to the specified blocker to unblock the given blocked user.

func (Keeper) ExportGenesis added in v0.15.0 

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

ExportGenesis returns the GenesisState associated with the given context

func (Keeper) GetAddressFromDTag added in v0.16.0 

func (k Keeper) GetAddressFromDTag(ctx sdk.Context, dTag string) (addr string)

GetAddressFromDTag returns the address associated to the given DTag or an empty string if it does not exists

func (Keeper) GetAllRelationships added in v0.16.0 

func (k Keeper) GetAllRelationships(ctx sdk.Context) []types.Relationship

GetAllRelationships allows to returns the list of all stored relationships

func (Keeper) GetAllUsersBlocks added in v0.16.0 

func (k Keeper) GetAllUsersBlocks(ctx sdk.Context) []types.UserBlock

GetAllUsersBlocks returns a list of all the users blocks inside the given context. 

func (k Keeper) GetApplicationLink(ctx sdk.Context, user, application, username string) (types.ApplicationLink, bool, error)

GetApplicationLink returns the link for the given application and username. If the link is not found returns an error instead.

func (Keeper) GetApplicationLinkByClientID added in v0.17.0 

func (k Keeper) GetApplicationLinkByClientID(ctx sdk.Context, clientID string) (types.ApplicationLink, error)

GetApplicationLinkByClientID returns the application link and user given a specific client id 

func (k Keeper) GetApplicationLinks(ctx sdk.Context) []types.ApplicationLink

GetApplicationLinks returns a slice of ApplicationLinkEntry objects containing the details of all the applications links entries stored inside the current context 

func (k Keeper) GetChainLink(ctx sdk.Context, owner, chainName, target string) (types.ChainLink, bool)

GetChainLink returns the chain link for the given owner, chain name and target. If such link does not exist, returns false instead. 

func (k Keeper) GetChainLinks(ctx sdk.Context) []types.ChainLink

GetChainLinks allows to returns the list of all stored chain links

func (Keeper) GetDTagTransferRequest added in v0.17.0 

func (k Keeper) GetDTagTransferRequest(ctx sdk.Context, sender, receiver string) (types.DTagTransferRequest, bool, error)

GetDTagTransferRequest retries the DTag transfer request made from the specified sender to the given receiver. If the request was not found, returns false instead.

func (Keeper) GetDTagTransferRequests added in v0.12.0 

func (k Keeper) GetDTagTransferRequests(ctx sdk.Context) (requests []types.DTagTransferRequest)

GetDTagTransferRequests returns all the requests inside the given context

func (Keeper) GetParams 

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

GetParams returns the params from the store

func (Keeper) GetPort added in v0.17.0 

func (k Keeper) GetPort(ctx sdk.Context) string

GetPort returns the portID for the module. Used in ExportGenesis

func (Keeper) GetProfile 

func (k Keeper) GetProfile(ctx sdk.Context, address string) (profile *types.Profile, found bool, err error)

GetProfile returns the profile corresponding to the given address inside the current context.

func (Keeper) GetProfiles 

func (k Keeper) GetProfiles(ctx sdk.Context) []*types.Profile

GetProfiles returns all the profiles that are stored inside the given context

func (Keeper) GetRelationship added in v0.17.0 

func (k Keeper) GetRelationship(ctx sdk.Context, creator, subspace, recipient string) (types.Relationship, bool)

GetRelationship returns the relationship existing between the provided creator and recipient inside the given subspace

func (Keeper) GetUserBlocks added in v0.16.0 

func (k Keeper) GetUserBlocks(ctx sdk.Context, blocker string) []types.UserBlock

GetUserBlocks returns the list of users that the specified user has blocked.

func (Keeper) GetUserRelationships added in v0.16.0 

func (k Keeper) GetUserRelationships(ctx sdk.Context, user string) []types.Relationship

GetUserRelationships allows to list all the stored relationships that involve the given user.

func (Keeper) HasProfile added in v0.17.0 

func (k Keeper) HasProfile(ctx sdk.Context, user string) bool

HasProfile returns true iff the given user has a profile, or an error if something is wrong.

func (Keeper) HasUserBlocked added in v0.16.0 

func (k Keeper) HasUserBlocked(ctx sdk.Context, blocker, blocked, subspace string) bool

HasUserBlocked returns true if the provided blocker has blocked the given user for the given subspace. If the provided subspace is empty, all subspaces will be checked

func (Keeper) IncomingDTagTransferRequests added in v0.17.0 

func (k Keeper) IncomingDTagTransferRequests(ctx context.Context, request *types.QueryIncomingDTagTransferRequestsRequest) (*types.QueryIncomingDTagTransferRequestsResponse, error)

func (Keeper) InitGenesis added in v0.15.0 

func (k Keeper) InitGenesis(ctx sdk.Context, data types.GenesisState) []abci.ValidatorUpdate

InitGenesis initializes the chain state based on the given GenesisState

func (Keeper) IsBound added in v0.17.0 

func (k Keeper) IsBound(ctx sdk.Context, portID string) bool

IsBound checks if the module is already bound to the desired port

func (Keeper) IsUserBlocked added in v0.14.0 

func (k Keeper) IsUserBlocked(ctx sdk.Context, blocker, blocked string) bool

IsUserBlocked tells if the given blocker has blocked the given blocked user 

func (k Keeper) IterateApplicationLinks(ctx sdk.Context, fn func(index int64, link types.ApplicationLink) (stop bool))

IterateApplicationLinks iterates through all the application links and performs the provided function

func (Keeper) IterateBlocks added in v0.17.0 

func (k Keeper) IterateBlocks(ctx sdk.Context, fn func(index int64, block types.UserBlock) (stop bool))

IterateBlocks iterates through the list of user blocks and performs the given function 

func (k Keeper) IterateChainLinks(ctx sdk.Context, fn func(index int64, link types.ChainLink) (stop bool))

IterateChainLinks iterates through the chain links and perform the provided function

func (Keeper) IterateDTagTransferRequests added in v0.17.0 

func (k Keeper) IterateDTagTransferRequests(
	ctx sdk.Context, fn func(index int64, dTagTransferRequest types.DTagTransferRequest) (stop bool),
)

IterateDTagTransferRequests iterates over all the DTag transfer requests and performs the provided function

func (Keeper) IterateProfiles 

func (k Keeper) IterateProfiles(ctx sdk.Context, fn func(index int64, profile *types.Profile) (stop bool))

IterateProfiles iterates through the Profiles set and performs the provided function

func (Keeper) IterateRelationships added in v0.16.0 

func (k Keeper) IterateRelationships(ctx sdk.Context, fn func(index int64, relationship types.Relationship) (stop bool))

IterateRelationships iterates through the relationships and perform the provided function 

func (k Keeper) IterateUserApplicationLinks(ctx sdk.Context, user string, fn func(index int64, link types.ApplicationLink) (stop bool))

IterateUserApplicationLinks iterates through all the application links related to the given user and performs the provided function

func (Keeper) IterateUserBlocks added in v0.17.0 

func (k Keeper) IterateUserBlocks(ctx sdk.Context, user string, fn func(index int64, block types.UserBlock) (stop bool))

IterateUserBlocks iterates through the list of user blocks created by the specified user and performs the given function 

func (k Keeper) IterateUserChainLinks(ctx sdk.Context, user string, fn func(index int64, link types.ChainLink) (stop bool))

IterateUserChainLinks iterates through all the chain links related to the given user and perform the provided function

func (Keeper) IterateUserIncomingDTagTransferRequests added in v0.17.0 

func (k Keeper) IterateUserIncomingDTagTransferRequests(
	ctx sdk.Context, user string, fn func(index int64, dTagTransferRequest types.DTagTransferRequest) (stop bool),
)

IterateUserIncomingDTagTransferRequests iterates over all the DTag transfer request made to the given user and performs the provided function

func (Keeper) IterateUserRelationships added in v0.17.0 

func (k Keeper) IterateUserRelationships(ctx sdk.Context, user string, fn func(index int64, relationship types.Relationship) (stop bool))

IterateUserRelationships iterates through the relationships with the given user address and performs the provided function

func (Keeper) LinkApplication added in v0.17.0 

func (k Keeper) LinkApplication(
	goCtx context.Context, msg *types.MsgLinkApplication,
) (*types.MsgLinkApplicationResponse, error)

LinkApplication defines a rpc handler method for MsgLinkApplication.

func (Keeper) Logger added in v0.17.0 

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

Logger returns a module-specific logger.

func (Keeper) OnOracleRequestAcknowledgementPacket added in v0.17.0 

func (k Keeper) OnOracleRequestAcknowledgementPacket(
	ctx sdk.Context,
	data oracletypes.OracleRequestPacketData,
	ack channeltypes.Acknowledgement,
) error

func (Keeper) OnOracleRequestTimeoutPacket added in v0.17.0 

func (k Keeper) OnOracleRequestTimeoutPacket(
	ctx sdk.Context,
	data oracletypes.OracleRequestPacketData,
) error

OnOracleRequestTimeoutPacket handles the OracleRequestPacketData instance that is sent when a request times out

func (Keeper) OnRecvApplicationLinkPacketData added in v0.17.0 

func (k Keeper) OnRecvApplicationLinkPacketData(
	ctx sdk.Context,
	data oracletypes.OracleResponsePacketData,
) error

func (Keeper) OnRecvLinkChainAccountPacket added in v0.17.0 

func (k Keeper) OnRecvLinkChainAccountPacket(
	ctx sdk.Context,
	data types.LinkChainAccountPacketData,
) (packetAck types.LinkChainAccountPacketAck, err error)

OnRecvLinkChainAccountPacket processes the reception of a LinkChainAccountPacket

func (Keeper) Params added in v0.15.0 

func (k Keeper) Params(ctx context.Context, _ *types.QueryParamsRequest) (*types.QueryParamsResponse, error)

Params implements the Query/Params gRPC method

func (Keeper) Profile added in v0.15.0 

func (k Keeper) Profile(ctx context.Context, request *types.QueryProfileRequest) (*types.QueryProfileResponse, error)

Profile implements the Query/Profile gRPC method

func (Keeper) RemoveProfile added in v0.15.0 

func (k Keeper) RemoveProfile(ctx sdk.Context, address string) error

RemoveProfile allows to delete a profile associated with the given address inside the current context. It assumes that the address-related profile exists.

func (Keeper) RemoveRelationship added in v0.16.0 

func (k Keeper) RemoveRelationship(ctx sdk.Context, relationship types.Relationship) error

RemoveRelationship allows to delete the relationship between the given user and his counterparty 

func (k Keeper) SaveApplicationLink(ctx sdk.Context, link types.ApplicationLink) error

SaveApplicationLink stores the given connection replacing any existing one for the same user and application 

func (k Keeper) SaveChainLink(ctx sdk.Context, link types.ChainLink) error

SaveChainLink stores the given chain link

func (Keeper) SaveDTagTransferRequest added in v0.12.0 

func (k Keeper) SaveDTagTransferRequest(ctx sdk.Context, request types.DTagTransferRequest) error

SaveDTagTransferRequest save the given request associating it to the request recipient. It returns an error if the same request already exists. It requires that the request recipient has already a profile.

func (Keeper) SaveRelationship added in v0.16.0 

func (k Keeper) SaveRelationship(ctx sdk.Context, relationship types.Relationship) error

SaveRelationship allows to store the given relationship returning an error if he's already present. It requires the creator to have a profile.

func (Keeper) SaveUserBlock added in v0.16.0 

func (k Keeper) SaveUserBlock(ctx sdk.Context, userBlock types.UserBlock) error

SaveUserBlock allows to store the given block inside the store, returning an error if something goes wrong. It requires the blocker to have a registered profile.

func (Keeper) SetParams 

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

SetParams sets params on the store

func (Keeper) SetPort added in v0.17.0 

func (k Keeper) SetPort(ctx sdk.Context, portID string)

SetPort sets the portID for the module. Used in InitGenesis

func (Keeper) StartProfileConnection added in v0.17.0 

func (k Keeper) StartProfileConnection(
	ctx sdk.Context,
	applicationData types.Data,
	dataSourceCallData string,
	sender sdk.AccAddress,
	sourcePort,
	sourceChannel string,
	timeoutHeight clienttypes.Height,
	timeoutTimestamp uint64,
) error

StartProfileConnection creates and sends an IBC packet containing the proper data allowing to call the Band Protocol oracle script so that the sender account can be verified using the given verification data. nolint:interfacer

func (Keeper) StoreProfile added in v0.15.0 

func (k Keeper) StoreProfile(ctx sdk.Context, profile *types.Profile) error

StoreProfile stores the given profile inside the current context. It assumes that the given profile has already been validated. It returns an error if a profile with the same DTag from a different creator already exists 

func (k Keeper) UserApplicationLink(ctx context.Context, request *types.QueryUserApplicationLinkRequest) (*types.QueryUserApplicationLinkResponse, error)

UserApplicationLink implements the Query/UserApplicationLink gRPC method 

func (k Keeper) UserApplicationLinks(ctx context.Context, request *types.QueryUserApplicationLinksRequest) (*types.QueryUserApplicationLinksResponse, error)

UserApplicationLinks implements the Query/UserApplicationLinks gRPC method

func (Keeper) UserBlocks added in v0.16.0 

func (k Keeper) UserBlocks(ctx context.Context, request *types.QueryUserBlocksRequest) (*types.QueryUserBlocksResponse, error)

UserBlocks implements the Query/UserBlocks gRPC method 

func (k Keeper) UserChainLink(ctx context.Context, request *types.QueryUserChainLinkRequest) (*types.QueryUserChainLinkResponse, error)

UserChainLink implements the Query/UserChainLink gRPC method 

func (k Keeper) UserChainLinks(ctx context.Context, request *types.QueryUserChainLinksRequest) (*types.QueryUserChainLinksResponse, error)

UserChainLinks implements the Query/UserChainLinks gRPC method

func (Keeper) UserRelationships added in v0.16.0 

func (k Keeper) UserRelationships(ctx context.Context, request *types.QueryUserRelationshipsRequest) (*types.QueryUserRelationshipsResponse, error)

UserRelationships implements the Query/UserRelationships gRPC method

func (Keeper) ValidateProfile added in v0.15.0 

func (k Keeper) ValidateProfile(ctx sdk.Context, profile *types.Profile) error

ValidateProfile checks if the given profile is valid according to the current profile's module params

type Migrator added in v0.16.3 

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

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

func NewMigrator added in v0.16.3 

func NewMigrator(amino *codec.LegacyAmino, keeper Keeper) Migrator

NewMigrator returns a new Migrators

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.