worker/internal/privilegewc/consumer_test.go

package privilegewc

import (
	"context"
	"gitea.pena/SQuiz/common/dal"
	"gitea.pena/SQuiz/common/model"
	"testing"
)

func TestProcessValidMessage(t *testing.T) {
	ctx := context.Background()
	d, err := dal.New(ctx, "host=localhost port=35432 user=squiz password=Redalert2 dbname=squiz sslmode=disable", nil)
	if err != nil {
		panic(err)
	}
	cfg, err := NewKafkaConsumerWorker(Config{}, nil, d)
	if err != nil {
		panic(err)
	}

	msg := []model.PrivilegeMessage{
		{
			PrivilegeID: "quizUnlimTime",
			Amount:      1000,
		},
		{
			PrivilegeID: "quizCnt",
			Amount:      1000,
		},
		{
			PrivilegeID: "squizHideBadge",
			Amount:      1000,
		},
	}

	err = cfg.processValidMessage(ctx, msg, "65f42bc9059f40a30ab21f68")
	if err != nil {
		panic(err)
	}
}