user

Documentation

Index

• func LocalUserToPublicUser(user *model_struct.LocalUser) *sdk_struct.PublicUser
• func ServerCommandToLocalCommand(data *user.AllCommandInfoResp) *model_struct.LocalUserCommand
• func ServerUserToLocalUser(user *sdkws.UserInfo) *model_struct.LocalUser
• type User
  • func NewUser(dataBase db_interface.DataBase, loginUserID string, ...) *User
  • func (u *User) DoNotification(ctx context.Context, msg *sdkws.MsgData)
  • func (u *User) GetSelfUserInfo(ctx context.Context) (*model_struct.LocalUser, error)
  • func (u *User) GetSingleUserFromServer(ctx context.Context, userID string) (*model_struct.LocalUser, error)
  • func (u *User) GetUserInfoWithCache(ctx context.Context, cacheKey string) (*model_struct.LocalUser, error)
  • func (u *User) GetUsersInfo(ctx context.Context, userIDs []string) ([]*sdk_struct.PublicUser, error)
  • func (u *User) GetUsersInfoFromServer(ctx context.Context, userIDs []string) ([]*model_struct.LocalUser, error)
  • func (u *User) GetUsersInfoWithCache(ctx context.Context, cacheKeys []string) ([]*model_struct.LocalUser, error)
  • func (u *User) ProcessUserCommandAdd(ctx context.Context, userCommand *userPb.ProcessUserCommandAddReq) error
  • func (u *User) ProcessUserCommandDelete(ctx context.Context, userCommand *userPb.ProcessUserCommandDeleteReq) error
  • func (u *User) ProcessUserCommandGetAll(ctx context.Context) ([]*userPb.CommandInfoResp, error)
  • func (u *User) ProcessUserCommandUpdate(ctx context.Context, userCommand *userPb.ProcessUserCommandUpdateReq) error
  • func (u *User) SetListener(listener func() open_im_sdk_callback.OnUserListener)
  • func (u *User) SetSelfInfo(ctx context.Context, userInfo *sdkws.UserInfoWithEx) error
  • func (u *User) SyncAllCommand(ctx context.Context) error
  • func (u *User) SyncAllCommandWithoutNotice(ctx context.Context) error
  • func (u *User) SyncLoginUserInfo(ctx context.Context) error
  • func (u *User) SyncLoginUserInfoWithoutNotice(ctx context.Context) error
  • func (u *User) UserOnlineStatusChange(users map[string][]int32)

Functions

func LocalUserToPublicUser

func LocalUserToPublicUser(user *model_struct.LocalUser) *sdk_struct.PublicUser

func ServerCommandToLocalCommand

func ServerCommandToLocalCommand(data *user.AllCommandInfoResp) *model_struct.LocalUserCommand

func ServerUserToLocalUser

func ServerUserToLocalUser(user *sdkws.UserInfo) *model_struct.LocalUser

Types

type User

type User struct {
	db_interface.DataBase

	UserCache *cache.UserCache[string, *model_struct.LocalUser]
	// contains filtered or unexported fields
}

User is a struct that represents a user in the system.

func NewUser

func NewUser(dataBase db_interface.DataBase, loginUserID string, conversationCh chan common.Cmd2Value) *User

NewUser creates a new User object.

func (*User) DoNotification

func (u *User) DoNotification(ctx context.Context, msg *sdkws.MsgData)

DoNotification handles incoming notifications for the user.

func (*User) GetSelfUserInfo

func (u *User) GetSelfUserInfo(ctx context.Context) (*model_struct.LocalUser, error)

func (*User) GetSingleUserFromServer

func (u *User) GetSingleUserFromServer(ctx context.Context, userID string) (*model_struct.LocalUser, error)

GetSingleUserFromServer retrieves user information from the server.

func (*User) GetUserInfoWithCache

func (u *User) GetUserInfoWithCache(ctx context.Context, cacheKey string) (*model_struct.LocalUser, error)

func (*User) GetUsersInfo

func (u *User) GetUsersInfo(ctx context.Context, userIDs []string) ([]*sdk_struct.PublicUser, error)

func (*User) GetUsersInfoFromServer

func (u *User) GetUsersInfoFromServer(ctx context.Context, userIDs []string) ([]*model_struct.LocalUser, error)

GetUsersInfoFromServer retrieves user information from the server.

func (*User) GetUsersInfoWithCache

func (u *User) GetUsersInfoWithCache(ctx context.Context, cacheKeys []string) ([]*model_struct.LocalUser, error)

func (*User) ProcessUserCommandAdd

func (u *User) ProcessUserCommandAdd(ctx context.Context, userCommand *userPb.ProcessUserCommandAddReq) error

ProcessUserCommandAdd CRUD user command

func (*User) ProcessUserCommandDelete

func (u *User) ProcessUserCommandDelete(ctx context.Context, userCommand *userPb.ProcessUserCommandDeleteReq) error

ProcessUserCommandDelete delete user's choice

func (*User) ProcessUserCommandGetAll

func (u *User) ProcessUserCommandGetAll(ctx context.Context) ([]*userPb.CommandInfoResp, error)

ProcessUserCommandGetAll get user's choice

func (*User) ProcessUserCommandUpdate

func (u *User) ProcessUserCommandUpdate(ctx context.Context, userCommand *userPb.ProcessUserCommandUpdateReq) error

ProcessUserCommandUpdate update user's choice

func (*User) SetListener

func (u *User) SetListener(listener func() open_im_sdk_callback.OnUserListener)

SetListener sets the user's listener.

func (*User) SetSelfInfo

func (u *User) SetSelfInfo(ctx context.Context, userInfo *sdkws.UserInfoWithEx) error

func (*User) SyncAllCommand

func (u *User) SyncAllCommand(ctx context.Context) error

func (*User) SyncAllCommandWithoutNotice

func (u *User) SyncAllCommandWithoutNotice(ctx context.Context) error

func (*User) SyncLoginUserInfo

func (u *User) SyncLoginUserInfo(ctx context.Context) error

func (*User) SyncLoginUserInfoWithoutNotice

func (u *User) SyncLoginUserInfoWithoutNotice(ctx context.Context) error

func (*User) UserOnlineStatusChange

func (u *User) UserOnlineStatusChange(users map[string][]int32)