StrafesNET/maps-service
5
Fork 0
Code Issues15 Pull Requests Packages Projects Releases Wiki Activity

submissions: encode operations CountSince parameter as time

Browse Source
This commit is contained in:
Quaternions 2025-04-05 12:38:12 -07:00
parent e3539d0f81
commit 68d7aaf4f8
Signed by: Quaternions
GPG Key ID: D0DF5964F79AC131
4 changed files with 7 additions and 4 deletions

4
pkg/datastore/datastore.go

@ -3,6 +3,8 @@ package datastore
import (
"context"
"errors"
"time"
"git.itzana.me/strafesnet/maps-service/pkg/model"
)
@ -45,7 +47,7 @@ type Operations interface {
Create(ctx context.Context, smap model.Operation) (model.Operation, error)
Update(ctx context.Context, id int32, values OptionalMap) error
Delete(ctx context.Context, id int32) error
CountSince(ctx context.Context, owner int64, since int64) (int64, error)
CountSince(ctx context.Context, owner int64, since time.Time) (int64, error)
}
type Submissions interface {

3
pkg/datastore/gormstore/operations.go

@ -3,6 +3,7 @@ package gormstore
import (
"context"
"errors"
"time"
"git.itzana.me/strafesnet/maps-service/pkg/datastore"
"git.itzana.me/strafesnet/maps-service/pkg/model"
@ -54,7 +55,7 @@ func (env *Operations) Delete(ctx context.Context, id int32) error {
return nil
}
func (env *Operations) CountSince(ctx context.Context, owner int64, since int64) (int64, error) {
func (env *Operations) CountSince(ctx context.Context, owner int64, since time.Time) (int64, error) {
var count int64
if err := env.db.Model(&model.Operation{}).Where("owner = ? AND created_at > ?",owner,since).Count(&count).Error; err != nil {
return count, err

2
pkg/service/mapfixes.go

@ -84,7 +84,7 @@ func (svc *Service) CreateMapfix(ctx context.Context, request *api.MapfixTrigger
{
count, err := svc.DB.Operations().CountSince(ctx,
int64(userId),
time.Now().Add(-CreateMapfixRecencyWindow).Unix(),
time.Now().Add(-CreateMapfixRecencyWindow),
)
if err != nil {
return nil, err

2
pkg/service/submissions.go

@ -75,7 +75,7 @@ func (svc *Service) CreateSubmission(ctx context.Context, request *api.Submissio
{
count, err := svc.DB.Operations().CountSince(ctx,
int64(userId),
time.Now().Add(-CreateSubmissionRecencyWindow).Unix(),
time.Now().Add(-CreateSubmissionRecencyWindow),
)
if err != nil {
return nil, err