package test

import (
	"context"
	"encoding/json"
	"fmt"
	"github.com/twmb/franz-go/pkg/kgo"
	"gitea.pena/PenaSide/notifier/internal/models"
	"testing"
	"time"
)

func Test_Kafka(t *testing.T) {
	brokers := []string{"localhost:9092"}
	topic := "test-topic"

	client, err := kgo.NewClient(
		kgo.SeedBrokers(brokers...),
		kgo.DefaultProduceTopic(topic),
	)
	if err != nil {
		fmt.Println("Failed to send message to Kafka topic:", err)
	}

	defer func() {
		client.Close()
	}()

	for i := 0; i < 10; i++ {
		message := models.Message{
			AccountID: "",
			Email:     "pashamullin2001@gmail.com",
			SendAt:    time.Now(),
		}

		msg, err := json.Marshal(message)
		if err != nil {
			fmt.Println("errr")
			continue
		}

		resp := client.ProduceSync(context.Background(), &kgo.Record{
			Value: msg,
		})

		if err := resp.FirstErr(); err != nil {
			fmt.Println("Failed to send message to Kafka topic:", err)
		}
	}

}