package main

import (
	"gitee.com/simple-set/simple.io/src/event"
	"gitee.com/simple-set/simple.io/src/process/http"
	"gitee.com/simple-set/simple.io/src/process/socks"
	"log"
)

type Example struct {
	bootServer *event.BootServer
	bootClient *event.BootClient
}

func NewServer() *Example {
	return &Example{bootServer: event.NewBootServer(), bootClient: event.NewBootClient()}
}

func (s *Example) register(process event.Process) {
	s.bootServer.Register(process)
	s.bootClient.Register(process)
}

func (s *Example) httpServer() error {
	s.register(http.NewRequestProcess())
	s.register(NewHttpServer())
	s.register(http.NewResponseProcess())
	return s.bootServer.ListenTcp(":8080")
}

func (s *Example) httpProxy() error {
	s.register(http.NewRequestProcess())
	s.register(NewHttpProxy())
	return s.bootServer.ListenTcp(":8080")
}

func (s *Example) socksServer() error {
	process := socks.NewProcess()
	process.SetConnect(NewConnectHandler())
	process.AddAuthenticator(NewAuthUserPass())
	process.SetNoAuth(true)
	s.register(process)
	return s.bootServer.ListenTcp(":8080")
}

func (s *Example) echoServerUDP() error {
	s.register(NewEchoServer())
	return s.bootServer.ListenUdp(":8080")
}

func (s *Example) echoClientUDP() error {
	s.register(NewEchoClient())
	if starterClient, err := s.bootClient.DialUdp("127.0.0.1:8080"); err == nil {
		_, err = starterClient.Request(nil)
		return err
	} else {
		return err
	}
}

func main() {
	server := NewServer()
	if err := server.echoClientUDP(); err != nil {
		log.Fatalln(err)
	}
}