storage-new/cleaners/gdprUsers.go

@@ -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
-}

storage-new/cleaners/manager.go

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

storage-new/dbgen/users.gen.go

@@ -1460,7 +1460,6 @@ type IUserDo interface {
 	GetPagedTruePublic(pageNr uint) (result []models.User, err error)
 	GetPagedAllDeleted(pageNr uint) (result []models.User, err error)
 	GetPagedAllNonDeleted(pageNr uint) (result []models.User, err error)
-	GdprUsers() (err error)
 }
 
 // Get a user by a username
@@ -1553,20 +1552,6 @@ func (u userDo) GetPagedAllNonDeleted(pageNr uint) (result []models.User, err er
 	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 {
 	return u.withDO(u.DO.Debug())
 }

storage-new/models/User.go

@@ -112,8 +112,4 @@ type IUser interface {
 	// LIMIT 50
 	// OFFSET @pageNr * 50
 	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
 }