mstar/linstrom
1
0
Fork 0
Code Issues 3 Pull requests Projects Releases Packages 1 Wiki Activity Actions

Compare commits

base: mstar:fb95ee48cc933c0138f0953658aaf880c0fc6850
Branches Tags
mstar:main
..
compare: mstar:954e4c5a345a603956b483790cdf149f1c19007e
Branches Tags
mstar:main

No commits in common. "fb95ee48cc933c0138f0953658aaf880c0fc6850" and "954e4c5a345a603956b483790cdf149f1c19007e" have entirely different histories.
fb95ee48cc ... 954e4c5a34

4 changed files with 0 additions and 46 deletions
Show stats Expand all files Collapse all files

23
storage-new/cleaners/gdprUsers.go
View file

@ -1,23 +0,0 @@
package cleaners
import (
"time"
"github.com/rs/zerolog/log"
"git.mstar.dev/mstar/linstrom/storage-new/dbgen"
)
func init() {
cleanerBuilders = append(cleanerBuilders, buildGdprUsers)
}
func tickGdprUsers(now time.Time) {
if err := dbgen.User.GdprUsers(); err != nil {
log.Error().Err(err).Msg("Failed to gdpr users")
}
}
func buildGdprUsers() (onTick func(time.Time), name string, tickSpeed time.Duration) {
return tickGdprUsers, "gdpr-users", time.Hour
}

4
storage-new/cleaners/manager.go
View file

@ -3,8 +3,6 @@ package cleaners
import ( import (
"sync" "sync"
"time" "time"
"github.com/rs/zerolog/log"
) )
type CleanerManager struct { type CleanerManager struct {
@ -28,7 +26,6 @@ func NewManager() *CleanerManager {
exitChan := make(chan any, 1) exitChan := make(chan any, 1)
onTick, name, tickSpeed := builder() onTick, name, tickSpeed := builder()
cm.exitChans = append(cm.exitChans, exitChan) cm.exitChans = append(cm.exitChans, exitChan)
log.Info().Str("name", name).Msg("Starting ticker for cleaner")
go cm.tickOrExit(tickSpeed, name, exitChan, onTick) go cm.tickOrExit(tickSpeed, name, exitChan, onTick)
} }
@ -66,7 +63,6 @@ func (m *CleanerManager) wrapOnTick(name string, now time.Time, onTick func(time
} }
m.activeCleaners[name] = true m.activeCleaners[name] = true
m.activeCleanerLock.Unlock() m.activeCleanerLock.Unlock()
log.Info().Str("cleaner", name).Msg("Ticking cleaner")
onTick(now) onTick(now)
m.activeCleanerLock.Lock() m.activeCleanerLock.Lock()
m.activeCleaners[name] = false m.activeCleaners[name] = false

15
storage-new/dbgen/users.gen.go
View file

@ -1460,7 +1460,6 @@ type IUserDo interface {
GetPagedTruePublic(pageNr uint) (result []models.User, err error) GetPagedTruePublic(pageNr uint) (result []models.User, err error)
GetPagedAllDeleted(pageNr uint) (result []models.User, err error) GetPagedAllDeleted(pageNr uint) (result []models.User, err error)
GetPagedAllNonDeleted(pageNr uint) (result []models.User, err error) GetPagedAllNonDeleted(pageNr uint) (result []models.User, err error)
GdprUsers() (err error)
} }
// Get a user by a username // Get a user by a username
@ -1553,20 +1552,6 @@ func (u userDo) GetPagedAllNonDeleted(pageNr uint) (result []models.User, err er
return return
} }
// Gdpr deleted users
//
// DELETE FROM @@table WHERE deleted_at IS NOT NULL AND deleted_at + interval '30 days' < NOW()
func (u userDo) GdprUsers() (err error) {
var generateSQL strings.Builder
generateSQL.WriteString("DELETE FROM users WHERE deleted_at IS NOT NULL AND deleted_at + interval '30 days' < NOW() ")
var executeSQL *gorm.DB
executeSQL = u.UnderlyingDB().Exec(generateSQL.String()) // ignore_security_alert
err = executeSQL.Error
return
}
func (u userDo) Debug() IUserDo { func (u userDo) Debug() IUserDo {
return u.withDO(u.DO.Debug()) return u.withDO(u.DO.Debug())
} }

4
storage-new/models/User.go
View file

@ -112,8 +112,4 @@ type IUser interface {
// LIMIT 50 // LIMIT 50
// OFFSET @pageNr * 50 // OFFSET @pageNr * 50
GetPagedAllNonDeleted(pageNr uint) ([]gen.T, error) GetPagedAllNonDeleted(pageNr uint) ([]gen.T, error)
// Gdpr deleted users
//
// DELETE FROM @@table WHERE deleted_at IS NOT NULL AND deleted_at + interval '30 days' < NOW()
GdprUsers() error
} }