package main
  
  import (

  	"bufio"

  	"bytes"
  	"encoding/binary"

  	"github.com/golang/protobuf/proto"

  	"net"

  	"pro2d/common/components"

  	"pro2d/common/logger"

  	"pro2d/pb"

  	"time"

  )
  

  func main() {

  	head := &components.PBHead{

  		Length:   0,

  		Cmd:      uint32(pb.ProtoCode_LoginReq),

  		ErrCode:  0,
  		PreField: 0,

  	}

  	loginReq := &pb.LoginReq{
  		Uid:    "141815055745814528",
  		Device: "123123",
  	}
  	l, _ :=proto.Marshal(loginReq)

  	b := components.PBMessage{

  		Head: head,

  		Body: l,

  	}

  	head.Length = uint32(16 + len(b.Body))

  	buf := &bytes.Buffer{}
  	err := binary.Write(buf, binary.BigEndian, head)

  	if err != nil {

  		logger.Error("err: %v, head: %v", err, head)

  		return
  	}

  	logger.Debug("head: %v", head)

  	err = binary.Write(buf, binary.BigEndian, b.Body)

  	if err != nil {

  		logger.Error("err: %v, msg: %v", err, b.Body)

  		return
  	}

  	client, err := net.Dial("tcp", "localhost:8850")

  	if err != nil {

  		logger.Error(err)

  		return
  	}

  
  	rd := bufio.NewReadWriter(bufio.NewReader(client), bufio.NewWriter(client))
  	for  {
  		b1 := make([]byte, 1024)
  		n, err := rd.Write(buf.Bytes())
  		if err != nil {
  			logger.Error(err)
  			return
  		}
  		rd.Flush()
  		logger.Debug("write:n: %d, msg: %s", n, buf.Bytes())
  
  		n, err = rd.Read(b1)
  		if err != nil {
  			logger.Error(err)
  			return
  		}
  		logger.Debug("recv: %s, n: %d\n", b1, n)

  		time.Sleep(1*time.Second)

  	}
  

  }