mirrors/apollo-backend
2
0
Fork 0
mirror of https://github.com/christianselig/apollo-backend synced 2024-11-25 13:17:42 +00:00
Code Issues Projects Releases Packages Wiki Activity

clean orphaned accounts

Browse source
This commit is contained in:
Andre Medeiros 2021-08-14 11:54:48 -04:00
parent 905235a8ff
commit f6e05a6fd8
1 changed files with 14 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
internal/cmd/scheduler.go
View file

@ -10,6 +10,7 @@ import (
"github.com/DataDog/datadog-go/statsd" "github.com/DataDog/datadog-go/statsd"
"github.com/adjust/rmq/v4" "github.com/adjust/rmq/v4"
"github.com/christianselig/apollo-backend/internal/cmdutil" "github.com/christianselig/apollo-backend/internal/cmdutil"
"github.com/christianselig/apollo-backend/internal/repository"
"github.com/go-co-op/gocron" "github.com/go-co-op/gocron"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v8"
"github.com/jackc/pgx/v4" "github.com/jackc/pgx/v4"
@ -70,7 +71,7 @@ func SchedulerCmd(ctx context.Context) *cobra.Command {
s.Every(200).Milliseconds().SingletonMode().Do(func() { enqueueAccounts(ctx, logger, statsd, db, redis, luaSha, notifQueue) }) s.Every(200).Milliseconds().SingletonMode().Do(func() { enqueueAccounts(ctx, logger, statsd, db, redis, luaSha, notifQueue) })
s.Every(1).Second().Do(func() { cleanQueues(ctx, logger, queue) }) s.Every(1).Second().Do(func() { cleanQueues(ctx, logger, queue) })
s.Every(1).Minute().Do(func() { reportStats(ctx, logger, statsd, db, redis) }) s.Every(1).Minute().Do(func() { reportStats(ctx, logger, statsd, db, redis) })
s.Every(1).Minute().Do(func() { cleanAccounts(ctx, logger, db) }) s.Every(1).Minute().Do(func() { pruneStale(ctx, logger, db) })
s.StartAsync() s.StartAsync()
<-ctx.Done() <-ctx.Done()
@ -103,12 +104,21 @@ func evalScript(ctx context.Context, redis *redis.Client) (string, error) {
return redis.ScriptLoad(ctx, lua).Result() return redis.ScriptLoad(ctx, lua).Result()
} }
func cleanAccounts(ctx context.Context, logger *logrus.Logger, pool *pgxpool.Pool) { func pruneStale(ctx context.Context, logger *logrus.Logger, pool *pgxpool.Pool) {
ar := repository.NewPostgresAccount(pool)
count, err := ar.PruneStale(ctx)
if err != nil {
logger.WithFields(logrus.Fields{
"err": err,
}).Error("failed cleaning stale accounts")
return
}
now := time.Now().Unix() - 7200 now := time.Now().Unix() - 7200
count := 0
ids := []int64{} ids := []int64{}
err := pool.BeginFunc(ctx, func(tx pgx.Tx) error { err = pool.BeginFunc(ctx, func(tx pgx.Tx) error {
stmt := ` stmt := `
WITH account AS ( WITH account AS (
SELECT id SELECT id