franklin/agent/lobbies.go

package main

import (
	"git.wanbits.io/joe/franklin/comp"
	pb "git.wanbits.io/joe/franklin/protos"
	"git.wanbits.io/joe/kettle/log"
	"git.wanbits.io/joe/nnet"
	"github.com/gogo/protobuf/proto"
	"go.uber.org/zap"
	"time"
)

func RandALobbies(userId uint64) (nnet.ISession, error) {
	return g_taj.RandSession()
}

func ForwardLobby(pkt *CSPacket) {
	ses, err := g_taj.RandSession()
	if err != nil {
		log.Error("no lobby", zap.Error(err))
		return
	}

	err = ses.AWrite(pkt, time.Second)
	if err != nil {
		log.Error("forward to lobby", zap.Error(err))
	}
}

func SendToLobby(userId uint64, inner proto.Message) {
	ses, err := g_taj.RandSession()
	if err != nil {
		log.Error("cant find lobby server", zap.Error(err))
		return
	}

	// 不做 guid 合法性检查，而直接发出消息
	bst, err := proto.Marshal(inner)
	if nil != err {
		log.Error("proto.Marshal", zap.Error(err))
		return
	}
	name := comp.GetMsgName(inner)
	id := comp.GetMsgId(name)
	req := &pb.Request{
		MsgId:   id,
		UserId:  userId,
		MsgName: name,
		Req:     bst,
	}

	err = ses.AWrite(&CSPacket{req}, time.Second)
	if nil != err {
		log.Error("proto.AWrite", zap.Error(err))
	}
}