-
Notifications
You must be signed in to change notification settings - Fork 48
/
context.go
76 lines (61 loc) · 1.38 KB
/
context.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
package client
import (
"context"
"github.com/dobyte/due/v2/packet"
)
type Context struct {
ctx context.Context // 上下文
client *Client // 客户端
message *packet.Message // 消息
}
// Proxy 响应请求
func (c *Context) Proxy() *Proxy {
return c.client.proxy
}
// Context 获取上线文
func (c *Context) Context() context.Context {
return c.ctx
}
// CID 获取连接ID
func (c *Context) CID() int64 {
return c.client.conn.ID()
}
// UID 获取用户ID
func (c *Context) UID() int64 {
return c.client.conn.UID()
}
// Seq 获取消息序列号
func (c *Context) Seq() int32 {
return c.message.Seq
}
// Route 获取消息路由
func (c *Context) Route() int32 {
return c.message.Route
}
// Data 获取消息数据
func (c *Context) Data() interface{} {
return c.message.Buffer
}
// Parse 解析消息
func (c *Context) Parse(v interface{}) (err error) {
buffer := c.message.Buffer
if c.client.opts.encryptor != nil {
buffer, err = c.client.opts.encryptor.Decrypt(buffer)
if err != nil {
return
}
}
return c.client.opts.codec.Unmarshal(buffer, v)
}
// Bind 绑定用户ID
func (c *Context) Bind(uid int64) error {
return c.client.proxy.Bind(uid)
}
// Unbind 解绑用户ID
func (c *Context) Unbind() error {
return c.client.proxy.Unbind()
}
// Push 推送消息
func (c *Context) Push(message *Message) error {
return c.client.proxy.Push(message)
}