dao

package
v0.96.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	GenCacheUserDataCacheKey   = genCacheUserDataCacheKey
	ParseCacheUserDataCacheKey = parseCacheUserDataCacheKey
	IsCacheUserDataCacheKey    = isCacheUserDataCacheKey
)
View Source 
var (
	GenContactCacheKey   = genContactCacheKey
	IsContactCacheKey    = isContactCacheKey
	ParseContactCacheKey = parseContactCacheKey
)
View Source 
var (
	GenUserPresencesKey   = genUserPresencesKey
	IsUserPresencesKey    = isUserPresencesKey
	ParseUserPresencesKey = parseUserPresencesKey
)

Functions

This section is empty.

Types

type CacheUserData added in v0.87.3 

type CacheUserData struct {
	UserData              *mtproto.UserData          `json:"user_data"`
	ContactIdList         []int64                    `json:"contact_id_list"`
	CachesPrivacyKeyRules []*mtproto.PrivacyKeyRules `json:"caches_privacy_key_rules"`
	ReverseContactIdList  []int64                    `json:"reverse_contact_id_list"`
}

func NewCacheUserData added in v0.87.3 

func NewCacheUserData() *CacheUserData

func (*CacheUserData) GetContactIdList added in v0.87.3 

func (m *CacheUserData) GetContactIdList() []int64

func (*CacheUserData) GetReverseContactIdList added in v0.90.4 

func (m *CacheUserData) GetReverseContactIdList() []int64

func (*CacheUserData) GetUserData added in v0.87.3 

func (m *CacheUserData) GetUserData() *mtproto.UserData

type CachedPeerBlocked added in v0.86.3 

type CachedPeerBlocked struct {
	PeerBlocked *mtproto.PeerBlocked `json:"peer_blocked"`
}

func (*CachedPeerBlocked) IsEmpty added in v0.86.3 

func (c *CachedPeerBlocked) IsEmpty() bool

type ContactItem added in v0.90.1 

type ContactItem struct {
	C               *mtproto.InputContact
	Unregistered    bool  // 未注册
	UserId          int64 // 已经注册的用户ID
	ContactId       int64 // 已经注册是我的联系人
	ImportContactId int64 // 已经注册的反向联系人
}

type Dao 

type Dao struct {
	*Mysql
	sqlc.CachedConn
	media_client.MediaClient
}

Dao dao.

func New 

func New(c config.Config) *Dao

New new a dao and return.

func (*Dao) BlockUser added in v0.86.3 

func (d *Dao) BlockUser(ctx context.Context, id, blockId int64) bool

func (*Dao) CheckBlocked added in v0.86.3 

func (d *Dao) CheckBlocked(ctx context.Context, id, blockedId int64) bool

func (*Dao) ClearContactCaches added in v0.90.1 

func (d *Dao) ClearContactCaches(ctx context.Context, userId int64, contactId ...int64)

func (*Dao) CreateNewUserV2 added in v0.90.1 

func (d *Dao) CreateNewUserV2(
	ctx context.Context,
	secretKeyId int64,
	phone string,
	countryCode string,
	firstName string, lastName string) (*mtproto.ImmutableUser, error)

func (*Dao) DeleteUser added in v0.90.1 

func (d *Dao) DeleteUser(ctx context.Context, id int64, reason string) bool

func (*Dao) DeleteUserContact added in v0.86.3 

func (d *Dao) DeleteUserContact(ctx context.Context, id int64, contactId int64)

func (*Dao) DeleteUserPeerSettings added in v0.86.3 

func (d *Dao) DeleteUserPeerSettings(ctx context.Context, id int64, peerType int32, peerId int64) error

func (*Dao) GetCacheImmutableUserList added in v0.90.1 

func (d *Dao) GetCacheImmutableUserList(ctx context.Context, idList2 []int64, contacts []int64) []*mtproto.ImmutableUser

func (*Dao) GetCacheUserData added in v0.87.3 

func (d *Dao) GetCacheUserData(ctx context.Context, id int64) *CacheUserData

func (*Dao) GetImmutableUser added in v0.87.3 

func (d *Dao) GetImmutableUser(ctx context.Context, id int64, privacy bool, contacts ...int64) (*mtproto.ImmutableUser, error)

func (*Dao) GetLastSeenAt added in v0.86.3 

func (d *Dao) GetLastSeenAt(ctx context.Context, id int64) (*dataobject.UserPresencesDO, error)

func (*Dao) GetNoCacheUserData added in v0.90.1 

func (d *Dao) GetNoCacheUserData(ctx context.Context, id int64) (*CacheUserData, error)

func (*Dao) GetUserContact added in v0.86.3 

func (d *Dao) GetUserContact(ctx context.Context, id, contactId int64) *mtproto.ContactData

func (*Dao) GetUserContactList added in v0.86.3 

func (d *Dao) GetUserContactList(ctx context.Context, id int64) []*mtproto.ContactData

func (*Dao) GetUserContactListByIdList added in v0.86.3 

func (d *Dao) GetUserContactListByIdList(ctx context.Context, id int64, contactId ...int64) []*mtproto.ContactData

func (*Dao) GetUserNotifySettings added in v0.86.3 

func (d *Dao) GetUserNotifySettings(ctx context.Context, id int64, peerType int32, peerId int64) (*mtproto.PeerNotifySettings, error)

func (*Dao) GetUserPeerSettings added in v0.86.3 

func (d *Dao) GetUserPeerSettings(ctx context.Context, id int64, peerType int32, peerId int64) (*mtproto.PeerSettings, error)

func (*Dao) GetUserPrivacyRules added in v0.86.3 

func (d *Dao) GetUserPrivacyRules(ctx context.Context, id int64, key int32) (*mtproto.PrivacyKeyRules, error)

func (*Dao) GetUserPrivacyRulesListByKeys added in v0.86.3 

func (d *Dao) GetUserPrivacyRulesListByKeys(ctx context.Context, id int64, keys ...int32) []*mtproto.PrivacyKeyRules

func (*Dao) MakeUserDataByDO added in v0.96.0 

func (d *Dao) MakeUserDataByDO(userDO *dataobject.UsersDO) *mtproto.UserData

func (*Dao) PutLastSeenAt added in v0.86.3 

func (d *Dao) PutLastSeenAt(ctx context.Context, userId int64, lastSeenAt int64, expires int32)

func (*Dao) PutUserContact added in v0.86.3 

func (d *Dao) PutUserContact(ctx context.Context, changeMutual bool, do *dataobject.UserContactsDO) error

func (*Dao) SetUserPeerNotifySettings added in v0.86.3 

func (d *Dao) SetUserPeerNotifySettings(ctx context.Context, id int64, peerType int32, peerId int64, settings *mtproto.PeerNotifySettings) error

func (*Dao) SetUserPeerSettings added in v0.86.3 

func (d *Dao) SetUserPeerSettings(ctx context.Context, id int64, peerType int32, peerId int64, settings *mtproto.PeerSettings) error

func (*Dao) SetUserPrivacyRules added in v0.86.3 

func (d *Dao) SetUserPrivacyRules(ctx context.Context, id int64, key int32, rules []*mtproto.PrivacyRule) bool

func (*Dao) UnBlockUser added in v0.86.3 

func (d *Dao) UnBlockUser(ctx context.Context, id, unblockId int64) bool

func (*Dao) UpdateProfilePhoto added in v0.86.3 

func (d *Dao) UpdateProfilePhoto(ctx context.Context, userId, photoId int64) int64

func (*Dao) UpdateUserAbout added in v0.86.3 

func (d *Dao) UpdateUserAbout(ctx context.Context, id int64, about string) bool

func (*Dao) UpdateUserEmojiStatus added in v0.90.0 

func (d *Dao) UpdateUserEmojiStatus(ctx context.Context, id int64, emojiStatusDocumentId int64, emojiStatusUntil int32) bool

func (*Dao) UpdateUserFirstAndLastName added in v0.86.3 

func (d *Dao) UpdateUserFirstAndLastName(ctx context.Context, id int64, firstName, lastName string) bool

func (*Dao) UpdateUserUsername added in v0.86.3 

func (d *Dao) UpdateUserUsername(ctx context.Context, id int64, username string) bool

type Mysql 

type Mysql struct {
	*sqlx.DB
	*mysql_dao.BotCommandsDAO
	*mysql_dao.BotsDAO
	*mysql_dao.ImportedContactsDAO
	*mysql_dao.PhoneBooksDAO
	*mysql_dao.PopularContactsDAO
	*mysql_dao.PredefinedUsersDAO
	*mysql_dao.UserContactsDAO
	*mysql_dao.UserGlobalPrivacySettingsDAO
	*mysql_dao.UserNotifySettingsDAO
	*mysql_dao.UserPeerBlocksDAO
	*mysql_dao.UserPeerSettingsDAO
	*mysql_dao.UserPresencesDAO
	*mysql_dao.UserPrivaciesDAO
	*mysql_dao.UserSettingsDAO
	*mysql_dao.UsersDAO
	*mysql_dao.UserProfilePhotosDAO
	*mysql_dao.UnregisteredContactsDAO
	*sqlx.CommonDAO
}

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.