From 55159196f4bdf112089c8ed13e81e4e71f3864de Mon Sep 17 00:00:00 2001
From: Mohammed Sohail <sohailsameja@gmail.com>
Date: Fri, 4 Oct 2024 11:54:10 +0300
Subject: [PATCH] fix: remove wide jetstream dedup window. Now reduced to 1
 minute.

* closes #39
---
 cmd/service/main.go       | 1 -
 internal/pub/jetstream.go | 3 +--
 2 files changed, 1 insertion(+), 3 deletions(-)

diff --git a/cmd/service/main.go b/cmd/service/main.go
index 3cdf2f3..1a7f2fc 100644
--- a/cmd/service/main.go
+++ b/cmd/service/main.go
@@ -83,7 +83,6 @@ func main() {
 	jetStreamPub, err := pub.NewJetStreamPub(pub.JetStreamOpts{
 		Endpoint:        ko.MustString("jetstream.endpoint"),
 		PersistDuration: time.Duration(ko.MustInt("jetstream.persist_duration_hrs")) * time.Hour,
-		DedupDuration:   time.Duration(ko.MustInt("jetstream.dedup_duration_hrs")) * time.Hour,
 		Logg:            lo,
 	})
 	if err != nil {
diff --git a/internal/pub/jetstream.go b/internal/pub/jetstream.go
index e13fc15..590d358 100644
--- a/internal/pub/jetstream.go
+++ b/internal/pub/jetstream.go
@@ -15,7 +15,6 @@ type (
 	JetStreamOpts struct {
 		Logg            *slog.Logger
 		Endpoint        string
-		DedupDuration   time.Duration
 		PersistDuration time.Duration
 	}
 
@@ -53,7 +52,7 @@ func NewJetStreamPub(o JetStreamOpts) (Pub, error) {
 			MaxAge:     o.PersistDuration,
 			Storage:    nats.FileStorage,
 			Subjects:   streamSubjects,
-			Duplicates: o.DedupDuration,
+			Duplicates: time.Minute,
 		})
 		if err != nil {
 			return nil, err