Upgrade go-sdk to 05d50a0 and migrate metadata from mq.MQ to watermill

- Upgrade all go-sdk dependencies to commit 05d50a0
- Add wire.Value for empty watermill.Option slice in link module
- Replace mq.MQ with watermill Publisher/Subscriber in metadata
- Update metadata MQ infrastructure to use watermill directly
- Regenerate wire_gen.go files for both modules

Author: batazor

boundaries/link/internal/di/wire.go

@@ -104,6 +104,7 @@ var LinkSet = wire.NewSet(
 	// Delivery
 	wire.Bind(new(watermill.Backend), new(*watermill_kafka.Backend)),
 	watermill_kafka.New,
+	wire.Value([]watermill.Option{}),
 	watermill.New,
 	wire.FieldsOf(new(*watermill.Client), "Publisher"),
 	rpc.InitServer,

boundaries/link/internal/di/wire_gen.go

@@ -5,6 +5,7 @@ go 1.25.4
 require (
 	buf.build/gen/go/shortlink-org/shortlink-link-link/protocolbuffers/go v1.36.10-20251123201407-1a9472e15af6.1
 	github.com/PuerkitoBio/goquery v1.11.0
+	github.com/ThreeDotsLabs/watermill v1.5.1
 	github.com/chromedp/chromedp v0.14.2
 	github.com/google/wire v0.7.0
 	github.com/minio/minio-go/v7 v7.0.97
@@ -25,8 +26,11 @@ require (
 	github.com/shortlink-org/go-sdk/observability v0.0.0-20251125180156-05d50a07cca8
 	github.com/shortlink-org/go-sdk/s3 v0.0.0-20251125180156-05d50a07cca8
 	github.com/shortlink-org/go-sdk/saga v0.0.0-20251125180156-05d50a07cca8
+	github.com/shortlink-org/go-sdk/watermill v0.0.0-20251125180156-05d50a07cca8
 	github.com/spf13/viper v1.21.0
 	github.com/stretchr/testify v1.11.1
+	go.opentelemetry.io/otel/metric v1.38.0
+	go.opentelemetry.io/otel/sdk/metric v1.38.0
 	go.opentelemetry.io/otel/trace v1.38.0
 	google.golang.org/grpc v1.77.0
 	google.golang.org/protobuf v1.36.10
@@ -103,6 +107,7 @@ require (
 	github.com/klauspost/cpuid/v2 v2.3.0 // indirect
 	github.com/klauspost/crc32 v1.3.0 // indirect
 	github.com/lib/pq v1.10.9 // indirect
+	github.com/lithammer/shortuuid/v3 v3.0.7 // indirect
 	github.com/mattn/go-sqlite3 v1.14.32 // indirect
 	github.com/minio/crc64nvme v1.1.1 // indirect
 	github.com/minio/md5-simd v1.1.2 // indirect
@@ -112,6 +117,7 @@ require (
 	github.com/nats-io/nkeys v0.4.11 // indirect
 	github.com/nats-io/nuid v1.0.1 // indirect
 	github.com/neo4j/neo4j-go-driver/v5 v5.28.4 // indirect
+	github.com/oklog/ulid v1.3.1 // indirect
 	github.com/onsi/ginkgo/v2 v2.23.4 // indirect
 	github.com/onsi/gomega v1.38.0 // indirect
 	github.com/ory/client-go v1.22.11 // indirect
@@ -136,6 +142,7 @@ require (
 	github.com/sagikazarmark/locafero v0.12.0 // indirect
 	github.com/samber/lo v1.52.0 // indirect
 	github.com/segmentio/asm v1.2.0 // indirect
+	github.com/sony/gobreaker v1.0.0 // indirect
 	github.com/spf13/afero v1.15.0 // indirect
 	github.com/spf13/cast v1.10.0 // indirect
 	github.com/spf13/cobra v1.10.1 // indirect
@@ -162,9 +169,7 @@ require (
 	go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.38.0 // indirect
 	go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.38.0 // indirect
 	go.opentelemetry.io/otel/exporters/prometheus v0.60.0 // indirect
-	go.opentelemetry.io/otel/metric v1.38.0 // indirect
 	go.opentelemetry.io/otel/sdk v1.38.0 // indirect
-	go.opentelemetry.io/otel/sdk/metric v1.38.0 // indirect
 	go.opentelemetry.io/proto/otlp v1.7.1 // indirect
 	go.uber.org/atomic v1.11.0 // indirect
 	go.yaml.in/yaml/v2 v2.4.3 // indirect

boundaries/metadata/go.mod

@@ -11,6 +11,7 @@ package metadata_di
 import (
 	"context"
 
+	"github.com/ThreeDotsLabs/watermill/message"
 	"github.com/google/wire"
 	"github.com/shortlink-org/go-sdk/auth/permission"
 	"github.com/shortlink-org/go-sdk/cache"
@@ -21,12 +22,15 @@ import (
 	"github.com/shortlink-org/go-sdk/flight_trace"
 	rpc "github.com/shortlink-org/go-sdk/grpc"
 	"github.com/shortlink-org/go-sdk/logger"
-	"github.com/shortlink-org/go-sdk/mq"
 	"github.com/shortlink-org/go-sdk/notify"
+	"github.com/shortlink-org/go-sdk/watermill"
+	watermill_kafka "github.com/shortlink-org/go-sdk/watermill/backends/kafka"
 	"github.com/shortlink-org/go-sdk/observability/metrics"
 	"github.com/shortlink-org/go-sdk/observability/profiling"
 	"github.com/shortlink-org/go-sdk/observability/tracing"
 	"github.com/shortlink-org/go-sdk/s3"
+	"go.opentelemetry.io/otel/metric"
+	api "go.opentelemetry.io/otel/sdk/metric"
 	"go.opentelemetry.io/otel/trace"
 
 	metadata_domain "github.com/shortlink-org/shortlink/boundaries/metadata/internal/domain/metadata/v1"
@@ -78,11 +82,16 @@ var DefaultSet = wire.NewSet(
 var MetaDataSet = wire.NewSet(
 	DefaultSet,
 	permission.New,
-	mq.New,
+	wire.FieldsOf(new(*metrics.Monitoring), "Prometheus", "Metrics"),
+	wire.Bind(new(metric.MeterProvider), new(*api.MeterProvider)),
 	db.New,
+	wire.Bind(new(watermill.Backend), new(*watermill_kafka.Backend)),
+	watermill_kafka.New,
+	wire.Value([]watermill.Option{}),
+	watermill.New,
+	wire.FieldsOf(new(*watermill.Client), "Publisher", "Subscriber"),
 	rpc.InitServer,
 	s3.New,
-	wire.FieldsOf(new(*metrics.Monitoring), "Prometheus", "Metrics"),
 
 	// Delivery
 	InitMetadataMQ,
@@ -100,8 +109,8 @@ var MetaDataSet = wire.NewSet(
 	NewMetaDataService,
 )
 
-func InitMetadataMQ(ctx context.Context, log logger.Logger, dataBus mq.MQ, metadataUC *metadata.UC) (*metadata_mq.Event, error) {
-	metadataMQ, err := metadata_mq.New(dataBus, metadataUC)
+func InitMetadataMQ(ctx context.Context, log logger.Logger, publisher message.Publisher, subscriber message.Subscriber, metadataUC *metadata.UC) (*metadata_mq.Event, error) {
+	metadataMQ, err := metadata_mq.New(publisher, subscriber, metadataUC)
 	if err != nil {
 		return nil, err
 	}
@@ -110,7 +119,7 @@ func InitMetadataMQ(ctx context.Context, log logger.Logger, dataBus mq.MQ, metad
 	notify.Subscribe(metadata_domain.METHOD_ADD, metadataMQ)
 
 	// Subscribe to link creation events from Kafka
-	if err := metadataMQ.SubscribeLinkCreated(log); err != nil {
+	if err := metadataMQ.SubscribeLinkCreated(ctx, log); err != nil {
 		return nil, err
 	}