franklin/agent/main.go

package main

import (
	"encoding/json"
	"git.wanbits.io/joe/franklin/comp"
	"git.wanbits.io/joe/franklin/protos"
	"git.wanbits.io/joe/kettle/utl"
	"git.wanbits.io/joe/nnet/cpn"
)

func main() {
	var err error
	comp.InitEnv("agent.toml", "agent.toml")
	// load conf
	g_conf, err = comp.LoadConf(comp.GConfile)
	utl.ErrPanic(err)
	// connect etcd
	// connect redis
	// connect mq
	// connect evbus
	comp.InitAll(g_conf)

	// connect to login
	loginjs, err := comp.GEtcdc.Get(comp.PathLogin(g_conf))
	utl.ErrPanic(err)

	var loginConf protos.LoginConfConf
	err = json.Unmarshal(loginjs, &loginConf)
	utl.ErrPanic(err)

	rabbitProto := RabbitCProtocol{}
	g_rabbit = cpn.NewWsClient(&hubConfC, &rabbitProto, &rabbitProto)
	//TODO: add feature auto-reconnect
	err = g_rabbit.NewConnection(loginConf.Addrs[0], g_conf.Id)
	utl.UnUsed(err)

	// connect to lobbies
	// connect to logics
	// start rpc
	// register self
	// start listener
	// wait signal
}