keeper

package
v2.4.0 Latest Latest
Warning

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

 Go to latest Published: Oct 17, 2022 License: Apache-2.0 Imports: 35 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 

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 

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 

func ValidProfilesInvariant(k Keeper) sdk.Invariant

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

func ValidRelationshipsInvariant 

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 

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.BinaryCodec,
	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 

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

ApplicationLinkByClientID implements the Query/ApplicationLinkByClientID gRPC method 

func (k Keeper) ApplicationLinks(ctx context.Context, request *types.QueryApplicationLinksRequest) (*types.QueryApplicationLinksResponse, error)

ApplicationLinks implements the Query/ApplicationLinks gRPC method

func (Keeper) AuthenticateCapability 

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

AuthenticateCapability wraps the scopedKeeper's AuthenticateCapability function

func (Keeper) BindPort 

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) Blocks 

func (k Keeper) Blocks(ctx context.Context, request *types.QueryBlocksRequest) (*types.QueryBlocksResponse, error)

Blocks implements the Query/Blocks gRPC method 

func (k Keeper) ChainLinks(ctx context.Context, request *types.QueryChainLinksRequest) (*types.QueryChainLinksResponse, error)

ChainLinks implements the Query/ChainLinks gRPC method

func (Keeper) ChanCloseInit 

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 

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 

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 

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

DeleteAllUserIncomingDTagTransferRequests deletes all the requests made to the given user

func (Keeper) DeleteAllUserRelationships 

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 

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 

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 

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

ExportGenesis returns the GenesisState associated with the given context

func (Keeper) GetAddressFromDTag 

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 

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

GetAllRelationships allows to returns the list of all stored relationships

func (Keeper) GetAllUsersBlocks 

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 

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

GetApplicationLinkByClientID returns the application link and user given a specific client id. If the link is not found, returns false instead. 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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

func (Keeper) InitGenesis 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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

LinkApplication defines a rpc handler method for MsgLinkApplication.

func (Keeper) Logger 

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

Logger returns a module-specific logger.

func (Keeper) OnOracleRequestAcknowledgementPacket 

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

func (Keeper) OnOracleRequestTimeoutPacket 

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 

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

func (Keeper) OnRecvLinkChainAccountPacket 

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 

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

Params implements the Query/Params gRPC method

func (Keeper) Profile 

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

Profile implements the Query/Profile gRPC method

func (Keeper) Relationships 

func (k Keeper) Relationships(ctx context.Context, request *types.QueryRelationshipsRequest) (*types.QueryRelationshipsResponse, error)

Relationships implements the Query/Relationships gRPC method

func (Keeper) RemoveProfile 

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 

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 

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 

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 

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 

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

SetPort sets the portID for the module. Used in InitGenesis

func (Keeper) StartProfileConnection 

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 

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) UserChainLink(ctx context.Context, request *types.QueryUserChainLinkRequest) (*types.QueryUserChainLinkResponse, error)

UserChainLink implements the Query/UserChainLink gRPC method

func (Keeper) ValidateProfile 

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 

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

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

func NewMigrator 

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

NewMigrator returns a new Migrator

func (Migrator) Migrate1to2 

func (m Migrator) Migrate1to2(ctx sdk.Context) error

Migrate1to2 migrates from version 1 to 2.

func (Migrator) Migrate2to3 added in v2.3.1 

func (m Migrator) Migrate2to3(ctx sdk.Context) error

Migrate2to3 migrates from version 2 to 3.

func (Migrator) Migrate3to4 added in v2.3.1 

func (m Migrator) Migrate3to4(ctx sdk.Context) error

Migrate3to4 migrates from version 3 to 4.

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.