loader - look back 14 days for reverts

cluebotng · Jan 4, 2025 · 3d60291 · 3d60291
1 parent 2a02e9e
commit 3d60291
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 2 deletions.
diff --git a/pkg/cbng/config/config.go b/pkg/cbng/config/config.go
@@ -10,6 +10,7 @@ import (
 
 var ReleaseTag = "development"
 var RecentRevertThreshold = int64(86400)
+var RecentChangeWindow = int64(14 * 86400)
 
 type BotConfiguration struct {
 	Owner    string

diff --git a/pkg/cbng/loader/page_recent_edit_count.go b/pkg/cbng/loader/page_recent_edit_count.go
@@ -2,6 +2,7 @@ package loader
 
 import (
 	"fmt"
+	"github.com/cluebotng/botng/pkg/cbng/config"
 	"github.com/cluebotng/botng/pkg/cbng/database"
 	"github.com/cluebotng/botng/pkg/cbng/helpers"
 	"github.com/cluebotng/botng/pkg/cbng/metrics"
@@ -26,7 +27,7 @@ func LoadPageRecentEditCount(wg *sync.WaitGroup, db *database.DatabaseConnection
 
 			logger := change.Logger.WithField("function", "loader.LoadPageRecentEditCount")
 
-			pageRecentEditCount, err := db.Replica.GetPageRecentEditCount(logger, change.Common.NamespaceId, helpers.PageTitleWithoutNamespace(change.Common.Title), change.ReceivedTime.Unix()-14*86400)
+			pageRecentEditCount, err := db.Replica.GetPageRecentEditCount(logger, change.Common.NamespaceId, helpers.PageTitleWithoutNamespace(change.Common.Title), change.ReceivedTime.Unix()-config.RecentChangeWindow)
 			if err != nil {
 				metrics.EditStatus.With(prometheus.Labels{"state": "lookup_page_recent_edits", "status": "failed"}).Inc()
 				logger.Error(err.Error())

diff --git a/pkg/cbng/loader/page_recent_revert_count.go b/pkg/cbng/loader/page_recent_revert_count.go
@@ -2,6 +2,7 @@ package loader
 
 import (
 	"fmt"
+	"github.com/cluebotng/botng/pkg/cbng/config"
 	"github.com/cluebotng/botng/pkg/cbng/database"
 	"github.com/cluebotng/botng/pkg/cbng/helpers"
 	"github.com/cluebotng/botng/pkg/cbng/metrics"
@@ -25,7 +26,7 @@ func LoadPageRecentRevertCount(wg *sync.WaitGroup, db *database.DatabaseConnecti
 			_, span := metrics.OtelTracer.Start(change.TraceContext, "LoadPageRecentRevertCount")
 			defer span.End()
 
-			pageRecentRevertCount, err := db.Replica.GetPageRecentRevertCount(logger, change.Common.NamespaceId, helpers.PageTitleWithoutNamespace(change.Common.Title), change.ReceivedTime.Unix())
+			pageRecentRevertCount, err := db.Replica.GetPageRecentRevertCount(logger, change.Common.NamespaceId, helpers.PageTitleWithoutNamespace(change.Common.Title), change.ReceivedTime.Unix()-config.RecentChangeWindow)
 			if err != nil {
 				metrics.EditStatus.With(prometheus.Labels{"state": "lookup_page_recent_reverts", "status": "failed"}).Inc()
 				logger.Error(err.Error())