package main

import (
	"time"

	"desktop-go/message"

	"google.golang.org/protobuf/proto"
)

func (c *ChatClient) heartbeat(msg *message.Message) {
	tickMsg := &message.Message{
		From: 1,
		To:   msg.From,
		Cmd:  message.CommandType_HEARTBEAT,
	}
	tickMsgData, _ := proto.Marshal(tickMsg)
	pbData, _ := Encode(tickMsgData)
	_, _ = c.imConn.Write(pbData)
}

func (c *ChatClient) imLoginReq(wsMsg WsRequest) {
	msg := &message.Message{
		To:         ServerId,
		Cmd:        message.CommandType_LOGIN_REQ,
		CreateTime: time.Now().UnixNano() / 1e6,
		Content:    wsMsg.Token,
	}
	data, _ := proto.Marshal(msg)
	pbData, err := Encode(data)
	if err != nil {
		Logger.Errorf("[IM客户端]登录消息编码错误, %v", err)
		return
	}
	_, _ = c.imConn.Write(pbData)
}

func (c *ChatClient) imLoginResp(msg *message.Message) {
	if msg.Content == "success" {
		Logger.Debug("[IM客户端]登录成功")
	} else {
		Logger.Debugf("[IM客户端]登录失败, %s", msg.Content)
	}
	c.wsLoginResp(msg.Content == "success")
	c.userId = msg.To
}

func (c *ChatClient) imMsgAck(msg *message.Message) {

}

func (c *ChatClient) imMsgNotify(msg *message.Message) {

}