refactor: move FilterLink to domain layer and update wire DI

- Move FilterLink and StringFilterInput from infrastructure to domain layer
- Update wire DI to bind repository interfaces to concrete implementations
- Fix protobuf go_package options to resolve import cycles
- Add DTO for PostgreSQL JSON serialization of domain.Link
- Update metadata service to use latest protobuf contract from buf registry
- Fix DLQ retry logic: use Nack() for unmarshal errors to allow Watermill DLQ tracking
- Publish new protobuf contract version to buf registry (c73856f570c94397946275f266534315)

Author: batazor

boundaries/link/internal/di/wire.go

@@ -149,6 +149,10 @@ var LinkSet = wire.NewSet(
 	crud.New,
 	cqs.New,
 	query.New,
+	// Bind concrete Store types to Repository interfaces
+	wire.Bind(new(crud.Repository), new(*crud.Store)),
+	wire.Bind(new(cqs.Repository), new(*cqs.Store)),
+	wire.Bind(new(query.Repository), new(*query.Store)),
 
 	NewLinkService,
 )
@@ -180,7 +184,7 @@ func NewRPCClient(
 func NewLinkApplication(
 	log logger.Logger,
 	eventBus *bus.EventBus,
-	store *crud.Store,
+	store crud.Repository,
 	authPermission *authzed.Client,
 ) (*link.UC, error) {
 	linkService, err := link.New(log, nil, store, authPermission, eventBus)

boundaries/link/internal/di/wire_gen.go

@@ -0,0 +1,27 @@
+package v1
+
+// StringFilterInput represents filter conditions for string fields
+type StringFilterInput struct {
+	Eq          string
+	Ne          string
+	Lt          string
+	Le          string
+	Gt          string
+	Ge          string
+	Contains    []string
+	NotContains []string
+	StartsWith  string
+	EndsWith    string
+	IsEmpty     bool
+	IsNotEmpty  bool
+}
+
+// FilterLink represents filter conditions for Link queries
+type FilterLink struct {
+	URL       *StringFilterInput
+	Hash      *StringFilterInput
+	Describe  *StringFilterInput
+	CreatedAt *StringFilterInput
+	UpdatedAt *StringFilterInput
+}
+

boundaries/link/internal/domain/link/v1/filter.go

@@ -4,6 +4,22 @@ package domain.link.v1;
 
 option go_package = "github.com/shortlink-org/shortlink/boundaries/link/internal/domain/link/v1";
 
+import "google/protobuf/timestamp.proto";
+
+// LinkProto is the protobuf representation of a link for events
+message LinkProto {
+  // URL of the link
+  string url = 1;
+  // Hash by URL + salt
+  string hash = 2;
+  // Describe of link
+  string describe = 3;
+  // Created at timestamp
+  google.protobuf.Timestamp created_at = 4;
+  // Updated at timestamp
+  google.protobuf.Timestamp updated_at = 5;
+}
+
 // DEPRECATED: LinkEvent enum is deprecated and will be removed after migration to go-sdk/cqrs.
 // Use individual event messages from link_events.proto instead:
 //   - LinkCreated (canonical: link.link.created.v1) replaces LINK_EVENT_ADD

boundaries/link/internal/domain/link/v1/link.pb.go

@@ -19,7 +19,7 @@ func ToLinkUpdatedEvent(link *LinkData) *linkpb.LinkUpdated {
 		Hash:       link.Hash,
 		Describe:   link.Describe,
 		CreatedAt:  timestamppb.New(link.CreatedAt),
-		UpdatedAt:  timestamppb.New(link.UpdatedAt),
+		UpdatedAt: timestamppb.New(link.UpdatedAt),
 		OccurredAt: timestamppb.New(time.Now()),
 	}
 }

boundaries/link/internal/domain/link/v1/link.proto

@@ -12,6 +12,7 @@ import (
 	"google.golang.org/protobuf/proto"
 	"google.golang.org/protobuf/types/known/timestamppb"
 
+	rpclinkpb "github.com/shortlink-org/shortlink/boundaries/link/internal/infrastructure/rpc/link/v1"
 	linkpb "github.com/shortlink-org/shortlink/boundaries/link/internal/domain/link/v1"
 )
 

boundaries/link/internal/dto/linkupdated.go

@@ -92,9 +92,10 @@ func TestEventBus_PublishLinkCreated(t *testing.T) {
 		// Verify event data
 		linkCreated, ok := unmarshaledEvent.(*linkpb.LinkCreated)
 		require.True(t, ok)
-		assert.Equal(t, event.Url, linkCreated.Url)
-		assert.Equal(t, event.Hash, linkCreated.Hash)
-		assert.Equal(t, event.Describe, linkCreated.Describe)
+		require.NotNil(t, linkCreated.GetLink(), "Link should not be nil")
+		assert.Equal(t, event.Link.GetUrl(), linkCreated.GetLink().GetUrl())
+		assert.Equal(t, event.Link.GetHash(), linkCreated.GetLink().GetHash())
+		assert.Equal(t, event.Link.GetDescribe(), linkCreated.GetLink().GetDescribe())
 
 	case <-time.After(10 * time.Second):
 		t.Fatal("Timeout waiting for message")

boundaries/link/internal/infrastructure/cqrs/e2e_topics_test.go

@@ -9,8 +9,8 @@ import (
 	"github.com/shortlink-org/go-sdk/db"
 
 	v1 "github.com/shortlink-org/shortlink/boundaries/link/internal/domain/link/v1"
+	v13 "github.com/shortlink-org/shortlink/boundaries/link/internal/domain/link/v1"
 	v12 "github.com/shortlink-org/shortlink/boundaries/link/internal/domain/link_cqrs/v1"
-	v13 "github.com/shortlink-org/shortlink/boundaries/link/internal/infrastructure/repository/crud/types/v1"
 )
 
 var psql = squirrel.StatementBuilder.PlaceholderFormat(squirrel.Dollar)
@@ -68,7 +68,7 @@ func (s *Store) Get(ctx context.Context, id string) (*v12.LinkView, error) {
 // List - list
 func (s *Store) List(ctx context.Context, filter *v13.FilterLink) (*v12.LinksView, error) {
 	links := psql.Select("hash, describe, ts_headline(meta_description, q, 'StartSel=<em>, StopSel=</em>') as meta_description, created_at, updated_at").
-		From(fmt.Sprintf(`link.link_view, to_tsquery('%s') AS q`, filter.Url.Contains)).
+		From(fmt.Sprintf(`link.link_view, to_tsquery('%s') AS q`, filter.URL.Contains)).
 		Where("make_tsvector_link_view(meta_keywords, meta_description) @@ q").
 		OrderBy("ts_rank(make_tsvector_link_view(meta_keywords, meta_description), q) DESC")
 

boundaries/link/internal/infrastructure/cqrs/eventbus_linkcreated_test.go

@@ -12,9 +12,9 @@ import (
 	"github.com/shortlink-org/go-sdk/logger"
 	"github.com/spf13/viper"
 
+	v1 "github.com/shortlink-org/shortlink/boundaries/link/internal/domain/link/v1"
 	v12 "github.com/shortlink-org/shortlink/boundaries/link/internal/domain/link_cqrs/v1"
 	"github.com/shortlink-org/shortlink/boundaries/link/internal/infrastructure/repository/cqrs/query/postgres"
-	types "github.com/shortlink-org/shortlink/boundaries/link/internal/infrastructure/repository/crud/types/v1"
 )
 
 // New return implementation of db
@@ -50,7 +50,7 @@ func (s *Store) Get(ctx context.Context, id string) (*v12.LinkView, error) {
 	return s.store.Get(ctx, id)
 }
 
-func (s *Store) List(ctx context.Context, filter *types.FilterLink) (*v12.LinksView, error) {
+func (s *Store) List(ctx context.Context, filter *v1.FilterLink) (*v12.LinksView, error) {
 	return s.store.List(ctx, filter)
 }