package main

import (
	"empty_zinx/src/ziface"
	"empty_zinx/src/znet"
	"fmt"
)

/*
	基于Zinx开发的应用程序
*/

// PingRouter ping test 自定义路由
type PingRouter struct {
	znet.BaseRouter
}

// Handle Test Handle
func (pr *PingRouter) Handle(request ziface.IRequest) {
	fmt.Println("Call ping Handle...")
	// 先读取客户端的数据， 再回写ping...ping..ping
	fmt.Println("recv from client: msgID = ", request.GetMessageID(),
		",Data = ", string(request.GetMessageBody()))
	err := request.GetConnection().SendMsg(200, []byte("ping...ping...ping"))
	if err != nil {
		fmt.Println(err)
	}
}

// HelloEmpty hello test 自定义路由
type HelloEmpty struct {
	znet.BaseRouter
}

// Handle Test Handle
func (pr *HelloEmpty) Handle(request ziface.IRequest) {
	fmt.Println("Call Hello Handle...")
	// 先读取客户端的数据， 再回写ping...ping..ping
	fmt.Println("recv from client: msgID = ", request.GetMessageID(),
		",Data = ", string(request.GetMessageBody()))
	err := request.GetConnection().SendMsg(201, []byte("Hello Welcome to Empty"))
	if err != nil {
		fmt.Println(err)
	}
}

func main() {
	// 创建一个Server句柄， 使用Zinx的api
	s := znet.NewServer()

	// 给当前zinx框架添加一个自定义的router
	s.AddRouter(0, &PingRouter{})

	// 给当前zinx框架添加一个自定义的router
	s.AddRouter(1, &HelloEmpty{})
	// 启动Server
	s.Run("src/demo/ZinxV0.8/config/zinx.json")
}