package main

import (
	"time"

	"github.com/ThreeDotsLabs/watermill"
	"github.com/ThreeDotsLabs/watermill-googlecloud/pkg/googlecloud"
	"github.com/ThreeDotsLabs/watermill/message"
	"github.com/google/uuid"
	"google.golang.org/api/option"
)

func main() {
	opts := []option.ClientOption{
		option.WithCredentialsJSON([]byte("<replace-credentials>")),
	}

	cfg := googlecloud.PublisherConfig{
		Marshaler:                 googlecloud.DefaultMarshalerUnmarshaler{},
		ProjectID:                 "<replace-project-id>",
		ClientOptions:             opts,
		DoNotCreateTopicIfMissing: false,
		DoNotCheckTopicExistence:  true,
		PublishTimeout:            1 * time.Nanosecond, // Simulate context cancellation by setting a very low timeout
	}

	publisher, err := googlecloud.NewPublisher(cfg, watermill.NopLogger{})
	if err != nil {
		panic(err)
	}

	payload := `{"message": "hello world!"}`
	msgId := uuid.New().String()
	publisher.Publish("<replace-topic-id>", message.NewMessage(msgId, message.Payload(payload)))
}

result := t.Publish(ctx, googlecloudMsg)
<-result.Ready()

serverMessageID, err := result.Get(ctx)