package main

import (
	"flag"
	"net"
	"strconv"
	"time"

	"github.com/long/test/esutil"
	log "github.com/long/test/log"
)

var addr = flag.String("addr", "192.168.1.124", "The address to listen to;")
var Eurl = flag.String("eurl", "http://192.168.1.182:9200/", "The port to listen on; ")

var port = flag.Int("port", 6000, "The port to listen on; ")
var sec = flag.Int("sec", 10, "the second for query data. ")

func main() {
	flag.Parse()

	log.Log.Infoln("starting server...")

	src := *addr + ":" + strconv.Itoa(*port)
	listener, err := net.Listen("tcp", src)
	if err != nil {
		log.Log.Errorln(err)
		return
	}
	log.Log.Infof("Listening on %s.\n", src)

	defer listener.Close()

	for {
		conn, err := listener.Accept()
		if err != nil {
			log.Log.Errorf("some connecion error: %s\n", err)
		}
		go handleConnection(conn)
	}
}

func handleConnection(conn net.Conn) {
	remoteAddr := conn.RemoteAddr().String()
	log.Log.Infoln("Client connected from ", remoteAddr)

	ech := make(chan error)
	go func(conn net.Conn, ech chan error) {
		buf := make([]byte, 10)
		_, err := conn.Read(buf)
		if err != nil {
			ech <- err
		}
	}(conn, ech)
	tick := time.NewTicker(10 * time.Second)

	for {
		select {
		case <-tick.C:
			handleMessage(conn)
		case err := <-ech:
			log.Log.Errorln(err, "remoteAddr ", remoteAddr, " close")
			break
		}
	}

	log.Log.Infoln("Client at " + remoteAddr + " disconnected.")
}

func handleMessage(conn net.Conn) {
	jsonstring := esutil.PostAction(*sec, *Eurl)
	if jsonstring == nil {
		log.Log.Infoln("the data is nil")
		return
	}
	jsonstring = append(jsonstring, []byte("\000")...)
	log.Log.Infoln("jsonstring len: ", len(jsonstring), "\000 data: ", len("\000"))
	conn.Write(jsonstring)
}