Update deps

Signed-off-by: Tamal Saha <tamal@appscode.com>

Author: tamalsaha

apis/config.go

@@ -41,7 +41,7 @@ type ListenerCfg struct {
 type PublisherCfg struct {
 	Type            PublisherType `valid:"required" json:"type" mapstructure:"type"`
 	Address         string        `valid:"required" json:"address" mapstructure:"address"`
-	NatsCredPath    string        `valid:"required" json:"natsCredPath" mapstructure:"natsCredPath"`
+	NatsCredPath    string        `json:"natsCredPath" mapstructure:"natsCredPath"`
 	Topic           string        `valid:"required" json:"topic" mapstructure:"topic"`
 	TopicPrefix     string        `json:"topicPrefix" mapstructure:"topicPrefix"`
 	EnableTLS       bool          `json:"enableTLS" mapstructure:"enableTlS"`

apis/config_test.go

@@ -71,7 +71,7 @@ func TestConfig_Validate(t *testing.T) {
 					TopicPrefix: "prefix",
 				},
 			},
-			wantErr: errors.New("Listener.RefreshConnection: non zero value required;Listener.SlotName: non zero value required"),
+			wantErr: errors.New("Listener.refreshConnection: non zero value required;Listener.slotName: non zero value required"),
 		},
 		{
 			name: "bad db cfg",
@@ -97,7 +97,7 @@ func TestConfig_Validate(t *testing.T) {
 					TopicPrefix: "prefix",
 				},
 			},
-			wantErr: errors.New("Database.Host: non zero value required;Database.Port: non zero value required"),
+			wantErr: errors.New("Database.host: non zero value required;Database.port: non zero value required"),
 		},
 		{
 			name: "empty publisher kind",
@@ -123,7 +123,7 @@ func TestConfig_Validate(t *testing.T) {
 					TopicPrefix: "prefix",
 				},
 			},
-			wantErr: errors.New("Publisher.Type: non zero value required"),
+			wantErr: errors.New("Publisher.address: non zero value required;Publisher.type: non zero value required"),
 		},
 	}
 

cmd/pgoutbox/main.go

@@ -35,7 +35,7 @@ import (
 
 // GetVersion returns latest git hash of commit.
 func GetVersion() string {
-	var version = "unknown"
+	version := "unknown"
 
 	info, ok := debug.ReadBuildInfo()
 	if ok {

go.mod

@@ -9,7 +9,7 @@ require (
 	github.com/goccy/go-json v0.10.3
 	github.com/google/uuid v1.6.0
 	github.com/jackc/pglogrepl v0.0.0-20251213150135-2e8d0df862c1
-	github.com/jackc/pgx/v5 v5.7.4
+	github.com/jackc/pgx/v5 v5.8.0
 	github.com/magiconair/properties v1.8.7
 	github.com/nats-io/nats.go v1.48.0
 	github.com/prometheus/client_golang v1.20.5

go.sum

@@ -113,8 +113,8 @@ github.com/jackc/pgpassfile v1.0.0 h1:/6Hmqy13Ss2zCq62VdNG8tM1wchn8zjSGOBJ6icpsI
 github.com/jackc/pgpassfile v1.0.0/go.mod h1:CEx0iS5ambNFdcRtxPj5JhEz+xB6uRky5eyVu/W2HEg=
 github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761 h1:iCEnooe7UlwOQYpKFhBabPMi4aNAfoODPEFNiAnClxo=
 github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761/go.mod h1:5TJZWKEWniPve33vlWYSoGYefn3gLQRzjfDlhSJ9ZKM=
-github.com/jackc/pgx/v5 v5.7.4 h1:9wKznZrhWa2QiHL+NjTSPP6yjl3451BX3imWDnokYlg=
-github.com/jackc/pgx/v5 v5.7.4/go.mod h1:ncY89UGWxg82EykZUwSpUKEfccBGGYq1xjrOpsbsfGQ=
+github.com/jackc/pgx/v5 v5.8.0 h1:TYPDoleBBme0xGSAX3/+NujXXtpZn9HBONkQC7IEZSo=
+github.com/jackc/pgx/v5 v5.8.0/go.mod h1:QVeDInX2m9VyzvNeiCJVjCkNFqzsNb43204HshNSZKw=
 github.com/jackc/puddle/v2 v2.2.2 h1:PR8nw+E/1w0GLuRFSmiioY6UooMp6KJv0/61nB7icHo=
 github.com/jackc/puddle/v2 v2.2.2/go.mod h1:vriiEXHvEE654aYKXXjOvZM39qJ0q+azkZFrfEOc3H4=
 github.com/jcmturner/aescts/v2 v2.0.0 h1:9YKLH6ey7H4eDBXW8khjYslgyqG2xZikXP0EQFKrle8=

internal/publisher/nats_test.go

@@ -40,7 +40,7 @@ func TestEvent_GetSubjectName(t *testing.T) {
 					Publisher: &apis.PublisherCfg{TopicPrefix: "prefix_", Topic: "STREAM"},
 				},
 			},
-			want: "STREAM.prefix_public_users",
+			want: "STREAM.prefix_schemas.public.tables.users",
 		},
 	}