dao

func (*FriendDao) CountFriends ¶

func (d *FriendDao) CountFriends(ctx context.Context, uid string) (int64, error)

func (*FriendDao) CreateFriend ¶

func (d *FriendDao) CreateFriend(ctx context.Context, friend *data.Friend) error

func (*FriendDao) DeleteFriendStatusFromCache ¶

func (d *FriendDao) DeleteFriendStatusFromCache(ctx context.Context, uid, friendUID string) error

func (*FriendDao) GetFriend ¶

func (d *FriendDao) GetFriend(ctx context.Context, uid, friendUID string) (*data.Friend, error)

func (*FriendDao) GetFriendStatusFromCache ¶

func (d *FriendDao) GetFriendStatusFromCache(ctx context.Context, uid, friendUID string) (bool, error)

GetFriendStatusFromCache get friend status from cache. cache key: sort(uid, friend_uid), so that there is no duplicated key, only one record between two users. cache value: 1 as constant.

func (*FriendDao) GetFriends ¶

func (d *FriendDao) GetFriends(ctx context.Context, uid string) ([]*data.Friend, error)

func (*FriendDao) SetFriendStatusToCache ¶

func (d *FriendDao) SetFriendStatusToCache(ctx context.Context, uid, friendUID string) error

SetFriendStatusToCache set friend status to cache.

func (*FriendDao) UpdateFriendStatus ¶

func (d *FriendDao) UpdateFriendStatus(ctx context.Context, userRelation *data.Friend) error

func (*FriendRequestDao) CreateFriendRequest ¶

func (d *FriendRequestDao) CreateFriendRequest(ctx context.Context, fr *data.FriendRequest) error

func (*FriendRequestDao) GetFriendRequest ¶

func (d *FriendRequestDao) GetFriendRequest(ctx context.Context, uid, friendUID string) (*data.FriendRequest, error)

func (*FriendRequestDao) GetFriendRequestByID ¶

func (d *FriendRequestDao) GetFriendRequestByID(ctx context.Context, id int64) (*data.FriendRequest, error)

func (*FriendRequestDao) GetFriendRequests ¶

func (d *FriendRequestDao) GetFriendRequests(ctx context.Context, uid string) ([]*data.FriendRequest, error)

func (*FriendRequestDao) UpdateFriendRequest ¶

func (d *FriendRequestDao) UpdateFriendRequest(ctx context.Context, fr *data.FriendRequest) error

func (*UserDao) CreateUser ¶

func (u *UserDao) CreateUser(ctx context.Context, user *data.User) error

func (*UserDao) GetUser ¶

func (u *UserDao) GetUser(ctx context.Context, id int64) (*data.User, error)

func (*UserDao) GetUserByEmail ¶

func (u *UserDao) GetUserByEmail(ctx context.Context, email string) (*data.User, error)

GetUserByEmail get user by email directly from db

func (*UserDao) GetUserByPhone ¶

func (u *UserDao) GetUserByPhone(ctx context.Context, phone string) (*data.User, error)

GetUserByPhone get user by phone directly from db

func (*UserDao) GetUserByUID ¶

func (u *UserDao) GetUserByUID(ctx context.Context, uid string) (*data.User, error)

GetUserByUID get user by uid

func (*UserDao) GetUserOnlineAgent ¶

func (u *UserDao) GetUserOnlineAgent(ctx context.Context, uid string) (string, error)

GetUserOnlineAgent get user online agent from redis

func (*UserDao) ListUsers ¶

func (u *UserDao) ListUsers(ctx context.Context, uids ...string) ([]*data.User, error)

func (*UserDao) UndoDelete ¶

func (u *UserDao) UndoDelete(ctx context.Context, user *data.User) error

UndoDelete undo delete user with new password

func (*UserDao) UpdateUser ¶

func (u *UserDao) UpdateUser(ctx context.Context, user *data.User) error