// main.go
package main

import (
	"log"

	"context"

	"github.com/ThreeDotsLabs/watermill"
	watermillsqs "github.com/ThreeDotsLabs/watermill-aws/sqs"
	"github.com/ThreeDotsLabs/watermill/message"
	"github.com/aws/aws-sdk-go-v2/config"
)

func main() {
	ctx := context.Background()
	cfg, _ := config.LoadDefaultConfig(ctx, config.WithRegion("eu-west-1"))

	logger := watermill.NewStdLogger(false, false)

	pub, err := watermillsqs.NewPublisher(watermillsqs.PublisherConfig{
		AWSConfig:                   cfg,
		DoNotCreateQueueIfNotExists: true,
		QueueUrlResolver:            watermillsqs.TransparentUrlResolver{},
	}, logger)
	if err != nil {
		log.Fatal(err)
	}
	defer pub.Close()

	msg := message.NewMessage(watermill.NewUUID(), []byte(`{"test": "data"}`))
	queueURL := "https://sqs.eu-west-1.amazonaws.com/000011112222/my-existing-queue"

	// HERE --> This always fails with: queue for topic ... doesn't exist
	if err := pub.Publish(queueURL, msg); err != nil {
		log.Fatalf("Failed to publish: %v", err)
	}

	log.Println("Published successfully")
}