service

package

v0.0.0-...-eeb3a9e Latest Latest Go to latest Published: Nov 2, 2022 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Pivot-Studio/pivot-chat

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func AddToken(token string, email string)
func CaptchaCheck(ctx *gin.Context, input string, email string) bool
func CaptchaLogic(ctx *gin.Context, code, email string) error
func ChgPwd(email string, oldPwd string, newPwd string) error
func DeleteConn(userID int64)
func DeleteToken(email string)
func Email(ctx *gin.Context, email string) (code string, err error)
func FindUserById(ctx *gin.Context, userid int64) (data map[string]interface{}, err error)
func GetMyGroups(UserId int64) (*[]GetMyGroupResp, error)
func GetToken(email string) string
func GetUserFromAuth(ctx *gin.Context) (user *model.User, err error)
func JudgeToken(token string, email string) bool
func Login(email string, password string) (user *model.User, token string, err error)
func ParseToken(tokenString string) (email string, id int64, tokenTime time.Time, err error)
func Register(user *model.User, captcha string) (err error)
func SendEmail(ctx context.Context, email string, captcha string) (err error)
func SendToUser(userID int64, data interface{}, infoType PackageType) error
func SetConn(userID int64, conn *Conn)
func Sync(ctx *gin.Context, input *model.GroupMessageSyncInput) (*model.GroupMessageSyncOutput, error)
func WSLoginAuth(tokenString string) (user *model.User, err error)
type Conn
- func GetConn(userID int64) *Conn
- func (c *Conn) Send(data interface{}, t PackageType) error
type CreateGroupResp
- func CreateGroup(Name string, Introduction string, OwnerId int64) (*CreateGroupResp, error)
type GetMyGroupResp
type GroupOperator
- func (gpo *GroupOperator) GetGroup(groupID int64) (*Group_, error)
- func (gpo *GroupOperator) GetMembersByGroupId(ctx *gin.Context, groupID int64) ([]map[string]interface{}, error)
- func (gpo *GroupOperator) JoinGroup(input *model.UserJoinGroupInput) error
- func (gpo *GroupOperator) QuitGroup()
- func (gpo *GroupOperator) SaveGroupMessage(SendInfo *model.GroupMessageInput) error
- func (gpo *GroupOperator) StoreGroup(groupID int64, group *Group_)
- func (gpo *GroupOperator) UpdateGroup()
type Group_
- func (g *Group_) IsMember(userID int64) bool
- func (g *Group_) SendGroupMessage(sendInfo *model.GroupMessageInput, seq int64)
type Package
type PackageType

Constants ¶

View Source

const (
	CHAT_CODE_PREFIX = "CHAT_CODE_PREFIX"
)

View Source

const (
	CHAT_TOKEN_PREFIX = "CHAT_TOKEN_PREFIX"
)

Variables ¶

View Source

var ConnsManager = sync.Map{} // (userID, conn)

View Source

var TokenMap sync.Map

Functions ¶

func AddToken ¶

func AddToken(token string, email string)

func CaptchaCheck ¶

func CaptchaCheck(ctx *gin.Context, input string, email string) bool

比较验证码

func CaptchaLogic ¶

func CaptchaLogic(ctx *gin.Context, code, email string) error

将验证码存入redis

func ChgPwd ¶

func ChgPwd(email string, oldPwd string, newPwd string) error

func DeleteConn ¶

func DeleteConn(userID int64)

DeleteConn 删除

func DeleteToken ¶

func DeleteToken(email string)

func Email ¶

func Email(ctx *gin.Context, email string) (code string, err error)

生成验证码

func FindUserById ¶

func FindUserById(ctx *gin.Context, userid int64) (data map[string]interface{}, err error)

func GetMyGroups ¶

func GetMyGroups(UserId int64) (*[]GetMyGroupResp, error)

func GetToken ¶

func GetToken(email string) string

func GetUserFromAuth ¶

func GetUserFromAuth(ctx *gin.Context) (user *model.User, err error)

func JudgeToken ¶

func JudgeToken(token string, email string) bool

func Login(email string, password string) (user *model.User, token string, err error)

func ParseToken ¶

func ParseToken(tokenString string) (email string, id int64, tokenTime time.Time, err error)

func Register ¶

func Register(user *model.User, captcha string) (err error)

func SendEmail ¶

func SendEmail(ctx context.Context, email string, captcha string) (err error)

发送验证码

func SendToUser ¶

func SendToUser(userID int64, data interface{}, infoType PackageType) error

func SetConn ¶

func SetConn(userID int64, conn *Conn)

SetConn 存储

func Sync ¶

func Sync(ctx *gin.Context, input *model.GroupMessageSyncInput) (*model.GroupMessageSyncOutput, error)

func WSLoginAuth ¶

func WSLoginAuth(tokenString string) (user *model.User, err error)

Types ¶

type Conn ¶

type Conn struct {
	WSMutex sync.Mutex      // WS写锁
	WS      *websocket.Conn // websocket连接
	UserId  int64           // 用户ID
}

func GetConn ¶

func GetConn(userID int64) *Conn

GetConn 获取

func (*Conn) Send ¶

func (c *Conn) Send(data interface{}, t PackageType) error

type CreateGroupResp ¶

type CreateGroupResp struct {
	GroupId      int64     `json:"group_id"`
	OwnerId      int64     `json:"owner_id"`
	Name         string    `json:"name"`
	Introduction string    `json:"introduction"`
	UserNum      int32     `json:"user_num"`
	CreateTime   time.Time `json:"create_time"`
	MaxSeq       int64     `json:"max_seq"`
}

func CreateGroup ¶

func CreateGroup(Name string, Introduction string, OwnerId int64) (*CreateGroupResp, error)

type GetMyGroupResp ¶

type GetMyGroupResp struct {
	GroupId      int64     `json:"group_id"`
	OwnerId      int64     `json:"owner_id"`
	Name         string    `json:"name"`
	Introduction string    `json:"introduction"`
	UserNum      int32     `json:"user_num"`
	CreateTime   time.Time `json:"create_time"`
}

type GroupOperator ¶

type GroupOperator struct {
	Groups    []*Group_
	GroupsMap sync.Map
	// contains filtered or unexported fields
}

var GroupOp GroupOperator

func (*GroupOperator) GetGroup ¶

func (gpo *GroupOperator) GetGroup(groupID int64) (*Group_, error)

GetGroup 根据groupID获取群组, 能够保证获取的群组成员是最新的, 其他属性更新时需要保持DB中一致性

func (*GroupOperator) GetMembersByGroupId ¶

func (gpo *GroupOperator) GetMembersByGroupId(ctx *gin.Context, groupID int64) ([]map[string]interface{}, error)

GetMembersByGroupId GetUsersByGroupId 根据GroupID获取当前members

func (*GroupOperator) JoinGroup ¶

func (gpo *GroupOperator) JoinGroup(input *model.UserJoinGroupInput) error

JoinGroup 加入群组

func (*GroupOperator) QuitGroup ¶

func (gpo *GroupOperator) QuitGroup()

QuitGroup todo 退出群组

func (*GroupOperator) SaveGroupMessage ¶

func (gpo *GroupOperator) SaveGroupMessage(SendInfo *model.GroupMessageInput) error

SaveGroupMessage 持久化群组消息, 同时会发送给每一个人

func (*GroupOperator) StoreGroup ¶

func (gpo *GroupOperator) StoreGroup(groupID int64, group *Group_)

func (*GroupOperator) UpdateGroup ¶

func (gpo *GroupOperator) UpdateGroup()

UpdateGroup todo 修改群组信息

type Group_ ¶

type Group_ struct {
	Members *[]model.GroupUser
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Group_) IsMember ¶

func (g *Group_) IsMember(userID int64) bool

func (*Group_) SendGroupMessage ¶

func (g *Group_) SendGroupMessage(sendInfo *model.GroupMessageInput, seq int64)

SendGroupMessage 群发消息, 无锁

type Package ¶

type Package struct {
	//数据包内容, 按需修改
	Type PackageType
	Data interface{}
}

type PackageType ¶

type PackageType int

const (
	PackageType_PT_ERR       PackageType = 0
	PackageType_PT_UNKNOWN   PackageType = 0
	PackageType_PT_SIGN_IN   PackageType = 1
	PackageType_PT_SYNC      PackageType = 2
	PackageType_PT_HEARTBEAT PackageType = 3
	PackageType_PT_MESSAGE   PackageType = 4
	PackageType_PT_JOINGROUP PackageType = 5
)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func AddToken ¶

func CaptchaCheck ¶

func CaptchaLogic ¶

func ChgPwd ¶

func DeleteConn ¶

func DeleteToken ¶

func Email ¶

func FindUserById ¶

func GetMyGroups ¶

func GetToken ¶

func GetUserFromAuth ¶

func JudgeToken ¶

func Login ¶

func ParseToken ¶

func Register ¶

func SendEmail ¶

func SendToUser ¶

func SetConn ¶

func Sync ¶

func WSLoginAuth ¶

Types ¶

type Conn ¶

func GetConn ¶

func (*Conn) Send ¶

type CreateGroupResp ¶

func CreateGroup ¶

type GetMyGroupResp ¶

type GroupOperator ¶

func (*GroupOperator) GetGroup ¶

func (*GroupOperator) GetMembersByGroupId ¶

func (*GroupOperator) JoinGroup ¶

func (*GroupOperator) QuitGroup ¶

func (*GroupOperator) SaveGroupMessage ¶

func (*GroupOperator) StoreGroup ¶

func (*GroupOperator) UpdateGroup ¶

type Group_ ¶

func (*Group_) IsMember ¶

func (*Group_) SendGroupMessage ¶

type Package ¶

type PackageType ¶

Source Files ¶