pk/pool-stats
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix time window recalc

Browse Source
This commit is contained in:
Pijus Kamandulis 2025-07-02 14:24:32 +03:00
parent 844f7fa08b
commit edb17e825d
2 changed files with 8 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
database/db.go
View File

@ -218,13 +218,12 @@ func GetTimeWindowHighShares(db *clover.DB) []models.TimeWindowHighShare {
func SetTimeWindowHighShare(db *clover.DB, share models.TimeWindowHighShare) error {
doc := document.NewDocumentOf(&share)
existingDoc, _ := db.FindFirst(c.NewQuery(TimeWindowHighShareCollectionName).
Where(c.Field("TimeWindowID").Eq(share.TimeWindowID)))
if existingDoc != nil {
db.ReplaceById(TimeWindowHighShareCollectionName, existingDoc.ObjectId(), doc)
} else {
db.InsertOne(TimeWindowHighShareCollectionName, doc)
}
db.Delete(
c.NewQuery(TimeWindowHighShareCollectionName).
Where(c.Field("TimeWindowID").
Eq(share.TimeWindowID)))
db.InsertOne(TimeWindowHighShareCollectionName, doc)
return nil
}

6
jobs/recalculateTimeWindowHighShares.go
View File

@ -24,10 +24,8 @@ func (job *RecalculateTimeWindowHighSharesJob) Run() error {
defer ticker.Stop()
for {
select {
case <-ticker.C:
job.recalculateTimeWindowHighShares()
}
<-ticker.C
job.recalculateTimeWindowHighShares()
}
}