本文整理汇总了Golang中euphoria/io/heim/proto.Client类的典型用法代码示例。如果您正苦于以下问题:Golang Client类的具体用法?Golang Client怎么用?Golang Client使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了Client类的3个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: newSession
func newSession(
ctx scope.Context, server *Server, conn *websocket.Conn,
roomName string, room proto.Room, client *proto.Client, agentKey *security.ManagedKey) *session {
nextID := atomic.AddUint64(&sessionIDCounter, 1)
sessionCount.WithLabelValues(roomName).Set(float64(nextID))
sessionID := fmt.Sprintf("%x-%08x", client.Agent.IDString(), nextID)
ctx = LoggingContext(ctx, fmt.Sprintf("[%s] ", sessionID))
session := &session{
id: sessionID,
ctx: ctx,
server: server,
conn: conn,
identity: newMemIdentity(client.UserID(), server.ID, server.Era),
client: client,
agentKey: agentKey,
serverID: server.ID,
serverEra: server.Era,
roomName: roomName,
room: room,
backend: server.b,
kms: server.kms,
incoming: make(chan *proto.Packet),
outgoing: make(chan *proto.Packet, 100),
floodLimiter: ratelimit.NewBucketWithQuantum(time.Second, 50, 10),
}
return session
}
开发者ID:robot0x,项目名称:heim,代码行数:31,代码来源:session.go
示例2: resolveRoom
func (s *Server) resolveRoom(ctx scope.Context, prefix, roomName string, client *proto.Client) (room proto.Room, err error) {
// TODO: support room creation?
switch prefix {
case "pm:":
var (
sf snowflake.Snowflake
roomKey *security.ManagedKey
)
if err := sf.FromString(roomName); err != nil {
return nil, proto.ErrRoomNotFound
}
room, roomKey, err = s.b.PMTracker().Room(ctx, s.kms, sf, client)
if err != nil {
switch err {
case proto.ErrAccessDenied, proto.ErrPMNotFound:
return nil, proto.ErrRoomNotFound
default:
return nil, err
}
}
client.Authorization.AddMessageKey("pm:"+roomName, roomKey)
return room, nil
case "":
room, err = s.b.GetRoom(ctx, roomName)
if s.allowRoomCreation && err == proto.ErrRoomNotFound {
room, err = s.b.CreateRoom(ctx, s.kms, false, roomName)
}
if err != nil {
return nil, err
}
if err := client.RoomAuthorize(ctx, room); err != nil {
return nil, err
}
return room, nil
default:
return nil, proto.ErrRoomNotFound
}
}
开发者ID:logan,项目名称:heim,代码行数:38,代码来源:handlers.go
示例3: Initiate
func (t *PMTracker) Initiate(
ctx scope.Context, kms security.KMS, room proto.Room, client *proto.Client, recipient proto.UserID) (
snowflake.Snowflake, error) {
initiatorNick, ok, err := room.ResolveNick(ctx, proto.UserID(fmt.Sprintf("account:%s", client.Account.ID())))
if err != nil {
return 0, err
}
if !ok {
initiatorNick = fmt.Sprintf("account:%s", client.Account.ID())
}
recipientNick, ok, err := room.ResolveNick(ctx, recipient)
if err != nil {
return 0, err
}
if !ok {
recipientNick = string(recipient)
}
pm, err := proto.InitiatePM(ctx, t.Backend, kms, client, initiatorNick, recipient, recipientNick)
if err != nil {
return 0, err
}
row := &PM{
ID: pm.ID.String(),
Initiator: pm.Initiator.String(),
InitiatorNick: pm.InitiatorNick,
Receiver: string(pm.Receiver),
ReceiverNick: pm.ReceiverNick,
ReceiverMAC: pm.ReceiverMAC,
IV: pm.IV,
EncryptedSystemKey: pm.EncryptedSystemKey.Ciphertext,
EncryptedInitiatorKey: pm.EncryptedInitiatorKey.Ciphertext,
}
if pm.EncryptedReceiverKey != nil {
row.EncryptedReceiverKey = pm.EncryptedReceiverKey.Ciphertext
}
// Look for existing PM to reuse.
tx, err := t.DbMap.Begin()
if err != nil {
return 0, err
}
var existingRow PM
err = tx.SelectOne(
&existingRow,
"SELECT id FROM pm WHERE initiator = $1 AND receiver = $2",
client.Account.ID().String(), string(recipient))
if err != nil && err != sql.ErrNoRows {
rollback(ctx, tx)
return 0, err
}
if err == nil {
rollback(ctx, tx)
var pmID snowflake.Snowflake
if err := pmID.FromString(existingRow.ID); err != nil {
return 0, err
}
return pmID, nil
}
kind, id := recipient.Parse()
if kind == "account" {
var existingRow PM
err = tx.SelectOne(
&existingRow,
"SELECT id FROM pm WHERE initiator = $1 AND receiver = $2",
id, string(client.UserID()))
if err != nil && err != sql.ErrNoRows {
rollback(ctx, tx)
return 0, err
}
if err == nil {
rollback(ctx, tx)
var pmID snowflake.Snowflake
if err := pmID.FromString(existingRow.ID); err != nil {
return 0, err
}
return pmID, nil
}
}
if err := tx.Insert(row); err != nil {
rollback(ctx, tx)
return 0, err
}
if err := tx.Commit(); err != nil {
return 0, err
}
return pm.ID, nil
}
开发者ID:logan,项目名称:heim,代码行数:95,代码来源:pm.go
注:本文中的euphoria/io/heim/proto.Client类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论