package main

import (
	"encoding/json"
	"fmt"
	"log"
	"os"
	"time"

	datatracker "gitee.com/limylily/data-tracker-sdk-go/v2/data-tracker"
)

func sendStruct() {
	type DataType struct {
		DataType string `json:"dataType"`
		Model    string `json:"model"`
		UserId   int    `json:"userId"`
		Other    string `json:"other"`
	}

	client := datatracker.GenerateDataTrackerClient()
	if client == nil {
		fmt.Printf("Expected client to be non-nil")
	}

	jsonData, err := json.Marshal(DataType{DataType: "dataReflux", Model: "qwenQ47*%$#FD", UserId: 1, Other: "other"})
	if err != nil {
		panic(err)
	}
	jsonString := string(jsonData)
	client.CollectData(jsonString)

	log.Printf("send success")
}

func sendMap() {
	client := datatracker.GenerateDataTrackerClient()
	if client == nil {
		fmt.Printf("Expected client to be non-nil")
	}

	jsonData, err := json.Marshal(map[string]interface{}{
		"dataType": "dataReflux",
		"model":    "qwenQ47*%$#FD",
		"userId":   1235,
		"other":    "fdsds",
	})
	if err != nil {
		panic(err)
	}
	jsonString := string(jsonData)
	client.CollectData(jsonString)
	log.Printf("send success")
}

func main() {
	os.Setenv("LOGSTASH_URL", "http://172.17.2.250:5044/")
	client := datatracker.GenerateDataTrackerClient()
	if client == nil {
		fmt.Printf("Expected client to be non-nil")
	}

	sendStruct()
	sendMap()

	time.Sleep(10 * time.Second)
}