package gravity

import (
	"github.com/oylshe1314/framework/errors"
	"github.com/oylshe1314/framework/util"
	"net/http"
	"net/url"
)

func eventCollect(accessToken string, clientId string, clientIp string, event *Event) error {
	var reqUrl, err = url.Parse(apiUri)
	if err != nil {
		return err
	}

	reqUrl = reqUrl.JoinPath(apiEventCollect)

	var query = url.Values{}
	query.Add("access_token", accessToken)

	reqUrl.RawQuery = query.Encode()

	var req = MsgEventCollectReq{
		ClientId:  clientId,
		ClientIp:  clientIp,
		ClientUa:  "",
		EventList: Events{event},
	}

	var header = http.Header{}
	header.Add("Turbo-Debug-Mode", "1")

	var ack = new(MsgEventCollectAck)
	err = util.HttpJsonPost(reqUrl.String(), req, ack, header)
	if err != nil {
		return err
	}

	if ack.Code != 0 {
		return errors.Error(ack.Msg)
	}

	return nil
}

func WechatEventCollect(clientId string, clientIp string, event *Event) error {
	return eventCollect(wechatAccessToken, clientId, clientIp, event)
}

func TapTapEventCollect(clientId string, clientIp string, event *Event) error {
	return eventCollect(tapTapAccessToken, clientId, clientIp, event)
}