database

package
v0.5.6 Latest Latest
Warning

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

 Go to latest Published: Oct 30, 2023 License: AGPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ActivitiesDB added in v0.4.0 

type ActivitiesDB interface {
	GetActivities(ctx context.Context) ([]*entry.Activity, error)

	GetActivityByID(ctx context.Context, activityID umid.UMID) (*entry.Activity, error)
	GetActivityIDsByParentID(ctx context.Context, parentID umid.UMID) ([]umid.UMID, error)
	GetActivitiesByUserID(ctx context.Context, userID umid.UMID) ([]*entry.Activity, error)
	GetActivitiesByObjectID(ctx context.Context, objectID umid.UMID) ([]*entry.Activity, error)

	RemoveActivityByID(ctx context.Context, activityID umid.UMID) error
	RemoveActivitiesByIDs(ctx context.Context, activityIDs []umid.UMID) error

	UpdateActivityData(ctx context.Context, activityID umid.UMID, options *entry.ActivityData) error
	UpdateActivityType(ctx context.Context, activityID umid.UMID, activityType *entry.ActivityType) error
	UpdateActivityObjectID(ctx context.Context, activityID umid.UMID, objectID *umid.UMID) error
	UpdateActivityUserID(ctx context.Context, activityID umid.UMID, userID *umid.UMID) error
	UpdateActivityCreatedAt(ctx context.Context, activityID umid.UMID, createdAt time.Time) error

	UpsertActivity(ctx context.Context, activity *entry.Activity) error
	UpsertActivities(ctx context.Context, activities []*entry.Activity) error
}

type Assets2dDB 

type Assets2dDB interface {
	GetAssets(ctx context.Context) ([]*entry.Asset2d, error)

	UpsertAsset(ctx context.Context, asset2d *entry.Asset2d) error
	UpsertAssets(ctx context.Context, assets2d []*entry.Asset2d) error

	UpdateAssetMeta(ctx context.Context, asset2dID umid.UMID, meta entry.Asset2dMeta) error
	UpdateAssetOptions(ctx context.Context, asset2dID umid.UMID, options *entry.Asset2dOptions) error

	RemoveAssetByID(ctx context.Context, asset2dID umid.UMID) error
	RemoveAssetsByIDs(ctx context.Context, asset2dIDs []umid.UMID) error
}

type Assets3dDB 

type Assets3dDB interface {
	GetAssets(ctx context.Context) ([]*entry.Asset3d, error)
	GetUserAssets(ctx context.Context) ([]*entry.UserAsset3d, error)

	UpsertAsset(ctx context.Context, asset3d *entry.Asset3d) error
	UpsertUserAsset(ctx context.Context, userAsset3d *entry.UserAsset3d) error
	UpsertAssets(ctx context.Context, assets3d []*entry.Asset3d, userAssets3d []*entry.UserAsset3d) error

	UpdateAssetMeta(ctx context.Context, assetID umid.UMID, meta *entry.Asset3dMeta) error
	UpdateAssetOptions(ctx context.Context, asset3dID umid.UMID, options *entry.Asset3dOptions) error

	UpdateUserAssetMeta(ctx context.Context, assetUserID universe.AssetUserIDPair, meta *entry.Asset3dMeta) error
	UpdateUserAssetIsPrivate(ctx context.Context, assetUserID universe.AssetUserIDPair, isPrivate bool) error

	RemoveUserAssetByID(ctx context.Context, assetUserID universe.AssetUserIDPair) error
}

type AttributeTypesDB 

type AttributeTypesDB interface {
	GetAttributeTypes(ctx context.Context) ([]*entry.AttributeType, error)

	UpsertAttributeType(ctx context.Context, attributeType *entry.AttributeType) error
	UpsertAttributeTypes(ctx context.Context, attributeTypes []*entry.AttributeType) error

	UpdateAttributeTypeName(ctx context.Context, attributeTypeID entry.AttributeTypeID, name string) error
	UpdateAttributeTypeDescription(
		ctx context.Context, attributeTypeID entry.AttributeTypeID, description *string,
	) error
	UpdateAttributeTypeOptions(
		ctx context.Context, attributeTypeID entry.AttributeTypeID, options *entry.AttributeOptions,
	) error

	RemoveAttributeTypeByID(ctx context.Context, attributeTypeID entry.AttributeTypeID) error
	RemoveAttributeTypesByIDs(ctx context.Context, attributeTypeIDs []entry.AttributeTypeID) error
	RemoveAttributeTypesByName(ctx context.Context, name string) error
	RemoveAttributeTypesByNames(ctx context.Context, names []string) error
	RemoveAttributeTypesByPluginID(ctx context.Context, pluginID umid.UMID) error
}

type CommonDB 

type CommonDB interface {
	GetConnection() *pgxpool.Pool
}

type DB 

type DB interface {
	GetCommonDB() CommonDB
	GetNodesDB() NodesDB
	GetWorldsDB() WorldsDB
	GetObjectsDB() ObjectsDB
	GetActivitiesDB() ActivitiesDB
	GetObjectActivitiesDB() ObjectActivitiesDB
	GetUserActivitiesDB() UserActivitiesDB
	GetUsersDB() UsersDB
	GetAssets2dDB() Assets2dDB
	GetAssets3dDB() Assets3dDB
	GetPluginsDB() PluginsDB
	GetUserObjectsDB() UserObjectsDB
	GetObjectTypesDB() ObjectTypesDB
	GetUserTypesDB() UserTypesDB
	GetAttributeTypesDB() AttributeTypesDB
	GetNodeAttributesDB() NodeAttributesDB
	GetObjectAttributesDB() ObjectAttributesDB
	GetObjectUserAttributesDB() ObjectUserAttributesDB
	GetUserAttributesDB() UserAttributesDB
	GetUserUserAttributesDB() UserUserAttributesDB
	GetStakesDB() StakesDB
	GetNFTsDB() NFTsDB
}

type NFTsDB added in v0.4.0 

type NFTsDB interface {
	ListNewByWallet(ctx context.Context, w string) ([]*entry.NFT, error)
}

type NodeAttributesDB 

type NodeAttributesDB interface {
	GetNodeAttributes(ctx context.Context) ([]*entry.NodeAttribute, error)
	GetNodeAttributeByAttributeID(ctx context.Context, attributeID entry.AttributeID) (*entry.NodeAttribute, error)
	GetNodeAttributeValueByAttributeID(ctx context.Context, attributeID entry.AttributeID) (
		*entry.AttributeValue, error,
	)
	GetNodeAttributeOptionsByAttributeID(
		ctx context.Context, attributeID entry.AttributeID,
	) (
		*entry.AttributeOptions, error,
	)

	UpsertNodeAttribute(ctx context.Context, nodeAttribute *entry.NodeAttribute) error
	UpsertNodeAttributes(ctx context.Context, nodeAttributes []*entry.NodeAttribute) error

	UpdateNodeAttributeValue(ctx context.Context, attributeID entry.AttributeID, value *entry.AttributeValue) error
	UpdateNodeAttributeOptions(
		ctx context.Context, attributeID entry.AttributeID, options *entry.AttributeOptions,
	) error

	RemoveNodeAttributeByAttributeID(ctx context.Context, attributeID entry.AttributeID) error
	RemoveNodeAttributesByName(ctx context.Context, name string) error
	RemoveNodeAttributesByNames(ctx context.Context, names []string) error
	RemoveNodeAttributesByPluginID(ctx context.Context, pluginID umid.UMID) error
}

type NodesDB 

type NodesDB interface {
	GetNode(ctx context.Context) (*entry.Node, error)
}

type ObjectActivitiesDB added in v0.4.0 

type ObjectActivitiesDB interface {
	GetObjectIDsByActivityID(ctx context.Context, activityID umid.UMID) ([]umid.UMID, error)

	DeleteObjectActivity(ctx context.Context, activityID umid.UMID) error

	UpsertObjectActivity(ctx context.Context, objectActivity *entry.ObjectActivity) error
	UpsertObjectActivities(ctx context.Context, objectActivities []*entry.ObjectActivity) error
}

type ObjectAttributesDB added in v0.4.0 

type ObjectAttributesDB interface {
	GetObjectAttributes(ctx context.Context) ([]*entry.ObjectAttribute, error)
	GetObjectAttributeByID(ctx context.Context, objectAttributeID entry.ObjectAttributeID) (
		*entry.ObjectAttribute, error,
	)
	GetObjectAttributesByObjectID(ctx context.Context, objectID umid.UMID) ([]*entry.ObjectAttribute, error)
	GetObjectAttributesByAttributeID(
		ctx context.Context, attributeID entry.AttributeID,
	) ([]*entry.ObjectAttribute, error)

	UpsertObjectAttribute(ctx context.Context, objectAttribute *entry.ObjectAttribute) error
	UpsertObjectAttributes(ctx context.Context, objectAttributes []*entry.ObjectAttribute) error

	UpdateObjectAttributeValue(
		ctx context.Context, objectAttributeID entry.ObjectAttributeID, value *entry.AttributeValue,
	) error
	UpdateObjectAttributeOptions(
		ctx context.Context, objectAttributeID entry.ObjectAttributeID, options *entry.AttributeOptions,
	) error

	RemoveObjectAttributeByID(ctx context.Context, objectAttributeID entry.ObjectAttributeID) error
	RemoveObjectAttributesByName(ctx context.Context, name string) error
	RemoveObjectAttributesByNames(ctx context.Context, names []string) error
	RemoveObjectAttributesByPluginID(ctx context.Context, pluginID umid.UMID) error
	RemoveObjectAttributesByAttributeID(ctx context.Context, attributeID entry.AttributeID) error
	RemoveObjectAttributesByObjectID(ctx context.Context, objectID umid.UMID) error
	RemoveObjectAttributesByNameAndObjectID(ctx context.Context, name string, objectID umid.UMID) error
	RemoveObjectAttributesByNamesAndObjectID(ctx context.Context, names []string, objectID umid.UMID) error
	RemoveObjectAttributesByPluginIDAndObjectID(ctx context.Context, pluginID umid.UMID, objectID umid.UMID) error
}

type ObjectTypesDB added in v0.4.0 

type ObjectTypesDB interface {
	GetObjectTypes(ctx context.Context) ([]*entry.ObjectType, error)

	UpsertObjectType(ctx context.Context, objectType *entry.ObjectType) error
	UpsertObjectTypes(ctx context.Context, objectTypes []*entry.ObjectType) error

	UpdateObjectTypeName(ctx context.Context, objectTypeID umid.UMID, name string) error
	UpdateObjectTypeCategoryName(ctx context.Context, objectTypeID umid.UMID, categoryName string) error
	UpdateObjectTypeDescription(ctx context.Context, objectTypeID umid.UMID, description *string) error
	UpdateObjectTypeOptions(ctx context.Context, objectTypeID umid.UMID, options *entry.ObjectOptions) error

	RemoveObjectTypeByID(ctx context.Context, objectTypeID umid.UMID) error
	RemoveObjectTypesByIDs(ctx context.Context, objectTypeIDs []umid.UMID) error
}

type ObjectUserAttributesDB added in v0.4.0 

type ObjectUserAttributesDB interface {
	GetObjectUserAttributes(ctx context.Context) ([]*entry.ObjectUserAttribute, error)
	GetObjectUserAttributeByID(
		ctx context.Context, objectUserAttributeID entry.ObjectUserAttributeID,
	) (*entry.ObjectUserAttribute, error)
	GetObjectUserAttributePayloadByID(
		ctx context.Context, objectUserAttributeID entry.ObjectUserAttributeID,
	) (*entry.AttributePayload, error)
	GetObjectUserAttributeValueByID(
		ctx context.Context, objectUserAttributeID entry.ObjectUserAttributeID,
	) (*entry.AttributeValue, error)
	GetObjectUserAttributeOptionsByID(
		ctx context.Context, objectUserAttributeID entry.ObjectUserAttributeID,
	) (*entry.AttributeOptions, error)
	GetObjectUserAttributesByObjectID(ctx context.Context, objectID umid.UMID) ([]*entry.ObjectUserAttribute, error)
	GetObjectUserAttributesByUserID(ctx context.Context, userID umid.UMID) ([]*entry.ObjectUserAttribute, error)
	GetObjectUserAttributesByObjectIDAndUserID(
		ctx context.Context, objectID umid.UMID, userID umid.UMID,
	) ([]*entry.ObjectUserAttribute, error)
	GetObjectUserAttributesByObjectAttributeID(
		ctx context.Context, objectAttributeID entry.ObjectAttributeID,
	) ([]*entry.ObjectUserAttribute, error)
	GetObjectUserAttributesByObjectIDsAttributeIDs(
		ctx context.Context, attributeIDs []entry.AttributeID, objectIDs []umid.UMID, query string, orderType universe.OrderType, limit uint, offset uint,
	) ([]*entry.ObjectUserAttribute, error)

	GetObjectUserAttributesCount(ctx context.Context) (int64, error)
	GetObjectUserAttributesCountByObjectID(ctx context.Context, objectID umid.UMID, attributeName string, sinceTime *time.Time) (uint64, error)
	GetObjectUserAttributesCountByObjectIDNullable(ctx context.Context, objectID umid.UMID, attributeName string) (uint64, error)

	UpsertObjectUserAttribute(
		ctx context.Context, objectUserAttributeID entry.ObjectUserAttributeID,
		modifyFn modify.Fn[entry.AttributePayload],
	) (*entry.AttributePayload, error)

	UpdateObjectUserAttributeOptions(
		ctx context.Context, objectUserAttributeID entry.ObjectUserAttributeID,
		modifyFn modify.Fn[entry.AttributeOptions],
	) (*entry.AttributeOptions, error)
	UpdateObjectUserAttributeValue(
		ctx context.Context, objectUserAttributeID entry.ObjectUserAttributeID,
		modifyFn modify.Fn[entry.AttributeValue],
	) (*entry.AttributeValue, error)

	RemoveObjectUserAttributeByID(ctx context.Context, objectUserAttributeID entry.ObjectUserAttributeID) error
	RemoveObjectUserAttributesByName(ctx context.Context, name string) error
	RemoveObjectUserAttributesByNames(ctx context.Context, names []string) error
	RemoveObjectUserAttributesByPluginID(ctx context.Context, pluginID umid.UMID) error
	RemoveObjectUserAttributesByAttributeID(ctx context.Context, attributeID entry.AttributeID) error
	RemoveObjectUserAttributesByObjectID(ctx context.Context, objectID umid.UMID) error
	RemoveObjectUserAttributesByNameAndObjectID(ctx context.Context, name string, objectID umid.UMID) error
	RemoveObjectUserAttributesByNamesAndObjectID(ctx context.Context, names []string, objectID umid.UMID) error
	RemoveObjectUserAttributesByUserID(ctx context.Context, userID umid.UMID) error
	RemoveObjectUserAttributesByNameAndUserID(ctx context.Context, name string, userID umid.UMID) error
	RemoveObjectUserAttributesByNamesAndUserID(ctx context.Context, names []string, userID umid.UMID) error
	RemoveObjectUserAttributesByObjectIDAndUserID(ctx context.Context, objectID umid.UMID, userID umid.UMID) error
	RemoveObjectUserAttributesByPluginIDAndObjectID(ctx context.Context, pluginID umid.UMID, objectID umid.UMID) error
	RemoveObjectUserAttributesByObjectAttributeID(ctx context.Context, objectAttributeID entry.ObjectAttributeID) error
	RemoveObjectUserAttributesByPluginIDAndUserID(ctx context.Context, pluginID umid.UMID, userID umid.UMID) error
	RemoveObjectUserAttributesByUserAttributeID(ctx context.Context, userAttributeID entry.UserAttributeID) error
	RemoveObjectUserAttributesByNameAndObjectIDAndUserID(
		ctx context.Context, name string, objectID umid.UMID, userID umid.UMID,
	) error
	RemoveObjectUserAttributesByNamesAndObjectIDAndUserID(
		ctx context.Context, names []string, objectID umid.UMID, userID umid.UMID,
	) error
	RemoveObjectUserAttributesByPluginIDAndObjectIDAndUserID(
		ctx context.Context, pluginID umid.UMID, objectID umid.UMID, userID umid.UMID,
	) error

	ValueEntries(
		ctx context.Context,
		attrID entry.ObjectAttributeID,
		fields []string,
		filters map[string]string,
		search string,
		order string,
		descending bool,
		limit uint,
		offset uint,
	) ([]map[string]interface{}, error)
	ValueEntriesCount(
		ctx context.Context,
		attrID entry.ObjectAttributeID,
		fields []string,
		filters map[string]string,
		search string,
	) (uint, error)
}

type ObjectsDB added in v0.4.0 

type ObjectsDB interface {
	GetObjectByID(ctx context.Context, objectID umid.UMID) (*entry.Object, error)
	GetObjectIDsByParentID(ctx context.Context, parentID umid.UMID) ([]umid.UMID, error)
	GetObjectsByParentID(ctx context.Context, parentID umid.UMID) ([]*entry.Object, error)
	GetObjectsByOwnerID(ctx context.Context, ownerID umid.UMID) ([]*entry.Object, error)

	UpsertObject(ctx context.Context, object *entry.Object) error
	UpsertObjects(ctx context.Context, objects []*entry.Object) error

	UpdateObjectParentID(ctx context.Context, objectID umid.UMID, parentID umid.UMID) error
	UpdateObjectTransform(ctx context.Context, objectID umid.UMID, position *cmath.Transform) error
	UpdateObjectOwnerID(ctx context.Context, objectID, ownerID umid.UMID) error
	UpdateObjectAsset2dID(ctx context.Context, objectID umid.UMID, asset2dID *umid.UMID) error
	UpdateObjectAsset3dID(ctx context.Context, objectID umid.UMID, asset3dID *umid.UMID) error
	UpdateObjectObjectTypeID(ctx context.Context, objectID, objectTypeID umid.UMID) error
	UpdateObjectOptions(ctx context.Context, objectID umid.UMID, options *entry.ObjectOptions) error

	RemoveObjectByID(ctx context.Context, objectID umid.UMID) error
	RemoveObjectsByIDs(ctx context.Context, objectIDs []umid.UMID) error
}

type PluginsDB 

type PluginsDB interface {
	GetPlugins(ctx context.Context) ([]*entry.Plugin, error)

	UpsertPlugin(ctx context.Context, plugin *entry.Plugin) error
	UpsertPlugins(ctx context.Context, plugins []*entry.Plugin) error

	UpdatePluginMeta(ctx context.Context, pluginID umid.UMID, meta entry.PluginMeta) error
	UpdatePluginOptions(ctx context.Context, pluginID umid.UMID, options *entry.PluginOptions) error

	RemovePluginByID(ctx context.Context, pluginID umid.UMID) error
	RemovePluginsByIDs(ctx context.Context, pluginIDs []umid.UMID) error
}

type StakesDB added in v0.4.0 

type StakesDB interface {
	GetStakesByWalletID(ctx context.Context, walletID string) ([]*entry.Stake, error)
	GetStakesByWorldID(ctx context.Context, worldID umid.UMID) ([]*entry.Stake, error)
	GetStakeByLatestStake(ctx context.Context) (*string, error)
	GetStakes(ctx context.Context, walletID []byte) ([]*dto.Stake, error)
	GetStakesWithCount(ctx context.Context) ([]*entry.Stake, error)
	GetWalletsInfo(ctx context.Context, walletIDs [][]byte) ([]*dto.WalletInfo, error)
	InsertIntoPendingStakes(ctx context.Context, transactionID []byte,
		objectID umid.UMID,
		walletID []byte,
		blockchainID umid.UMID,
		amount *big.Int,
		comment string,
		kind uint8) error
}

type UserActivitiesDB added in v0.4.0 

type UserActivitiesDB interface {
	UpsertUserActivity(ctx context.Context, userActivity *entry.UserActivity) error
	UpsertUserActivities(ctx context.Context, userActivities []*entry.UserActivity) error
}

type UserAttributesDB 

type UserAttributesDB interface {
	GetUserAttributes(ctx context.Context) ([]*entry.UserAttribute, error)
	GetUserAttributeByID(ctx context.Context, userAttributeID entry.UserAttributeID) (*entry.UserAttribute, error)
	GetUserAttributeByWallet(ctx context.Context, wallet string) (*entry.UserAttribute, error)
	GetUserAttributesByUserID(ctx context.Context, userID umid.UMID) ([]*entry.UserAttribute, error)
	GetUserAttributePayloadByID(ctx context.Context, userAttributeID entry.UserAttributeID) (
		*entry.AttributePayload, error,
	)
	GetUserAttributeValueByID(ctx context.Context, userAttributeID entry.UserAttributeID) (*entry.AttributeValue, error)
	GetUserAttributeOptionsByID(ctx context.Context, userAttributeID entry.UserAttributeID) (
		*entry.AttributeOptions, error,
	)

	GetUserAttributesCount(ctx context.Context) (int64, error)

	UpsertUserAttribute(
		ctx context.Context, userAttributeID entry.UserAttributeID,
		modifyFn modify.Fn[entry.AttributePayload],
	) (*entry.AttributePayload, error)

	UpdateUserAttributeValue(
		ctx context.Context, userAttributeID entry.UserAttributeID,
		modifyFn modify.Fn[entry.AttributeValue],
	) (*entry.AttributeValue, error)
	UpdateUserAttributeOptions(
		ctx context.Context, userAttributeID entry.UserAttributeID,
		modifyFn modify.Fn[entry.AttributeOptions],
	) (*entry.AttributeOptions, error)

	RemoveUserAttributeByID(ctx context.Context, userAttributeID entry.UserAttributeID) error
	RemoveUserAttributesByName(ctx context.Context, name string) error
	RemoveUserAttributesByNames(ctx context.Context, names []string) error
	RemoveUserAttributesByPluginID(ctx context.Context, pluginID umid.UMID) error
	RemoveUserAttributesByAttributeID(ctx context.Context, attributeID entry.AttributeID) error
	RemoveUserAttributesByUserID(ctx context.Context, userID umid.UMID) error
	RemoveUserAttributesByNameAndUserID(ctx context.Context, name string, userID umid.UMID) error
	RemoveUserAttributesByNamesAndUserID(ctx context.Context, names []string, userID umid.UMID) error
	RemoveUserAttributesByPluginIDAndUserID(ctx context.Context, pluginID umid.UMID, userID umid.UMID) error
}

type UserObjectsDB added in v0.4.0 

type UserObjectsDB interface {
	GetUserObjects(ctx context.Context) ([]*entry.UserObject, error)
	GetUserObjectByID(ctx context.Context, userObjectID entry.UserObjectID) (*entry.UserObject, error)
	GetUserObjectsByUserID(ctx context.Context, userID umid.UMID) ([]*entry.UserObject, error)
	GetUserObjectsByObjectID(ctx context.Context, objectID umid.UMID) ([]*entry.UserObject, error)
	GetUserObjectValueByID(ctx context.Context, userObjectID entry.UserObjectID) (*entry.UserObjectValue, error)

	GetObjectIndirectAdmins(ctx context.Context, objectID umid.UMID) ([]*umid.UMID, error)
	CheckIsIndirectAdminByID(ctx context.Context, userObjectID entry.UserObjectID) (bool, error)

	UpsertUserObject(
		ctx context.Context, userObjectID entry.UserObjectID,
		modifyFn modify.Fn[entry.UserObjectValue],
	) (*entry.UserObjectValue, error)

	UpdateUserObjectValue(
		ctx context.Context, userObjectID entry.UserObjectID,
		modifyFn modify.Fn[entry.UserObjectValue],
	) (*entry.UserObjectValue, error)

	RemoveUserObjectByID(ctx context.Context, userObjectID entry.UserObjectID) error
	RemoveUserObjectsByIDs(ctx context.Context, userObjectIDs []entry.UserObjectID) error
}

type UserTypesDB 

type UserTypesDB interface {
	GetUserTypes(ctx context.Context) ([]*entry.UserType, error)

	UpsertUserType(ctx context.Context, userType *entry.UserType) error
	UpsertUserTypes(ctx context.Context, userTypes []*entry.UserType) error

	UpdateUserTypeName(ctx context.Context, userTypeID umid.UMID, name string) error
	UpdateUserTypeDescription(ctx context.Context, userTypeID umid.UMID, description string) error
	UpdateUserTypeOptions(ctx context.Context, userTypeID umid.UMID, options *entry.UserOptions) error

	RemoveUserTypeByID(ctx context.Context, userTypeID umid.UMID) error
	RemoveUserTypesByIDs(ctx context.Context, userTypeIDs []umid.UMID) error
}

type UserUserAttributesDB 

type UserUserAttributesDB interface {
	GetUserUserAttributes(ctx context.Context) ([]*entry.UserUserAttribute, error)
	GetUserUserAttributeByID(
		ctx context.Context, userUserAttributeID entry.UserUserAttributeID,
	) (*entry.UserUserAttribute, error)
	GetUserUserAttributePayloadByID(
		ctx context.Context, userUserAttributeID entry.UserUserAttributeID,
	) (*entry.AttributePayload, error)
	GetUserUserAttributeValueByID(
		ctx context.Context, userUserAttributeID entry.UserUserAttributeID,
	) (*entry.AttributeValue, error)
	GetUserUserAttributeOptionsByID(
		ctx context.Context, userUserAttributeID entry.UserUserAttributeID,
	) (*entry.AttributeOptions, error)
	GetUserUserAttributesBySourceUserID(
		ctx context.Context, sourceUserID umid.UMID,
	) ([]*entry.UserUserAttribute, error)
	GetUserUserAttributesByTargetUserID(
		ctx context.Context, targetUserID umid.UMID,
	) ([]*entry.UserUserAttribute, error)
	GetUserUserAttributesBySourceUserIDAndTargetUserID(
		ctx context.Context, sourceUserID umid.UMID, targetUserID umid.UMID,
	) ([]*entry.UserUserAttribute, error)

	GetUserUserAttributesCount(ctx context.Context) (int64, error)

	UpsertUserUserAttribute(
		ctx context.Context, userUserAttributeID entry.UserUserAttributeID,
		modifyFn modify.Fn[entry.AttributePayload],
	) (*entry.AttributePayload, error)

	UpdateUserUserAttributeValue(
		ctx context.Context, userUserAttributeID entry.UserUserAttributeID,
		modifyFn modify.Fn[entry.AttributeValue],
	) (*entry.AttributeValue, error)
	UpdateUserUserAttributeOptions(
		ctx context.Context, userUserAttributeID entry.UserUserAttributeID,
		modifyFn modify.Fn[entry.AttributeOptions],
	) (*entry.AttributeOptions, error)

	RemoveUserUserAttributeByID(ctx context.Context, userUserAttributeID entry.UserUserAttributeID) error
	RemoveUserUserAttributesByName(ctx context.Context, name string) error
	RemoveUserUserAttributesByNames(ctx context.Context, names []string) error
	RemoveUserUserAttributesByPluginID(ctx context.Context, pluginID umid.UMID) error
	RemoveUserUserAttributesByAttributeID(ctx context.Context, attributeID entry.AttributeID) error
	RemoveUserUserAttributesBySourceUserID(ctx context.Context, sourceUserID umid.UMID) error
	RemoveUserUserAttributesByNameAndSourceUserID(ctx context.Context, name string, sourceUserID umid.UMID) error
	RemoveUserUserAttributesByNamesAndSourceUserID(ctx context.Context, names []string, sourceUserID umid.UMID) error
	RemoveUserUserAttributesByTargetUserID(ctx context.Context, targetUserID umid.UMID) error
	RemoveUserUserAttributesByNameAndTargetUserID(ctx context.Context, name string, targetUserID umid.UMID) error
	RemoveUserUserAttributesByNamesAndTargetUserID(ctx context.Context, names []string, targetUserID umid.UMID) error
	RemoveUserUserAttributesBySourceUserIDAndTargetUserID(
		ctx context.Context, sourceUserID umid.UMID, targetUserID umid.UMID,
	) error
	RemoveUserUserAttributesByNameAndSourceUserIDAndTargetUserID(
		ctx context.Context, name string, sourceUserID umid.UMID, targetUserID umid.UMID,
	) error
	RemoveUserUserAttributesByNamesAndSourceUserIDAndTargetUserID(
		ctx context.Context, names []string, sourceUserID umid.UMID, targetUserID umid.UMID,
	) error
	RemoveUserUserAttributesByPluginIDAndSourceUserID(
		ctx context.Context, pluginID umid.UMID, sourceUserID umid.UMID,
	) error
	RemoveUserUserAttributesBySourceUserAttributeID(
		ctx context.Context, sourceUserAttributeID entry.UserAttributeID,
	) error
	RemoveUserUserAttributesByPluginIDAndTargetUserID(
		ctx context.Context, pluginID umid.UMID, targetUserID umid.UMID,
	) error
	RemoveUserUserAttributesByTargetUserAttributeID(
		ctx context.Context, targetUserAttributeID entry.UserAttributeID,
	) error
	RemoveUserUserAttributesByPluginIDAndSourceUserIDAndTargetUserID(
		ctx context.Context, pluginID umid.UMID, sourceUserID umid.UMID, targetUserID umid.UMID,
	) error
}

type UsersDB 

type UsersDB interface {
	GetUserByID(ctx context.Context, userID umid.UMID) (*entry.User, error)
	GetUsersByIDs(ctx context.Context, userIDs []umid.UMID) ([]*entry.User, error)
	GetAllUsers(ctx context.Context, userTypeID umid.UMID) ([]*entry.User, error)
	GetUserByWallet(ctx context.Context, wallet string) (*entry.User, error)
	GetUserWalletByUserID(ctx context.Context, userID umid.UMID) (*string, error)
	GetUserWalletsByUserID(ctx context.Context, userID umid.UMID) ([]*string, error)
	GetUserProfileByUserID(ctx context.Context, userID umid.UMID) (*entry.UserProfile, error)
	GetUsersByUserType(ctx context.Context, userTypeID umid.UMID) ([]*entry.User, error)

	GetUserIDs(ctx context.Context, sortType universe.SortType, limit string, userTypeID umid.UMID) ([]umid.UMID, error)

	CheckIsUserExistsByName(ctx context.Context, name string) (bool, error)
	CheckIsUserExistsByWallet(ctx context.Context, wallet string) (bool, error)

	UpsertUser(ctx context.Context, user *entry.User) error
	UpsertUsers(ctx context.Context, user []*entry.User) error

	UpdateUserUserTypeID(ctx context.Context, userID, userTypeID umid.UMID) error
	UpdateUserOptions(ctx context.Context, userID umid.UMID, options *entry.UserOptions) error
	UpdateUserProfile(ctx context.Context, userID umid.UMID, profile *entry.UserProfile) error

	RemoveUserByID(ctx context.Context, userID umid.UMID) error
	RemoveUsersByIDs(ctx context.Context, userID []umid.UMID) error
}

type WorldsDB 

type WorldsDB interface {
	GetAllWorldIDs(ctx context.Context) ([]umid.UMID, error)
	GetWorldIDs(ctx context.Context, sortType universe.SortType, limit string) ([]umid.UMID, error)
	GetWorlds(ctx context.Context) ([]*entry.Object, error)
}

Source Files

View all Source files

Directories

Path Synopsis

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.