90 lines
2.4 KiB
Go
90 lines
2.4 KiB
Go
package scylladb
|
|
|
|
import (
|
|
"time"
|
|
|
|
"clickandjoin.app/managementsystem/modules/utils"
|
|
gocnjhelper "git.clickandjoin.umbach.dev/ClickandJoin/go-cnj-helper"
|
|
"git.clickandjoin.umbach.dev/ClickandJoin/go-cnj-helper/dbstructs"
|
|
"github.com/gocql/gocql"
|
|
)
|
|
|
|
func TableCleaner() {
|
|
currentTime := time.Now()
|
|
desiredTime := time.Date(currentTime.Year(), currentTime.Month(), currentTime.Day()+1, 3, 0, 0, 0, currentTime.Location())
|
|
duration := desiredTime.Sub(currentTime)
|
|
|
|
// handling expired userSignUpProcesses
|
|
|
|
time.Sleep(duration)
|
|
|
|
var userSignUpProcesses []dbstructs.UserSignUpProcess
|
|
|
|
if err := Session.Query(gocnjhelper.DbMUserSignUpProcess.SelectAll()).SelectRelease(&userSignUpProcesses); err != nil {
|
|
gocnjhelper.LogErrorf("Failed to select user sign up processes, err: %s", err.Error())
|
|
return
|
|
}
|
|
|
|
currentTimeUnix := time.Now().Unix()
|
|
|
|
var expiredUserSignUpProcesses []dbstructs.UserSignUpProcess
|
|
|
|
for _, us := range userSignUpProcesses {
|
|
if us.ExpiresAt < currentTimeUnix {
|
|
expiredUserSignUpProcesses = append(expiredUserSignUpProcesses, us)
|
|
}
|
|
}
|
|
|
|
if len(expiredUserSignUpProcesses) > 0 {
|
|
batch := Session.NewBatch(gocql.UnloggedBatch)
|
|
|
|
q := "DELETE FROM " + Cluster.Keyspace + "." + gocnjhelper.DbMUserSignUpProcess.Name() + " WHERE x_token = ?"
|
|
|
|
for _, us := range expiredUserSignUpProcesses {
|
|
batch.Query(q, us.XToken)
|
|
}
|
|
|
|
if err := Session.ExecuteBatch(batch); err != nil {
|
|
gocnjhelper.LogErrorf("Failed to execute batch, err:", err.Error())
|
|
return
|
|
}
|
|
}
|
|
|
|
// handling reserved account names
|
|
|
|
var users []dbstructs.User
|
|
|
|
if err := Session.Query(gocnjhelper.DbMUsers.SelectAll()).SelectRelease(&users); err != nil {
|
|
gocnjhelper.LogErrorf("Failed to select users, err: %s", err.Error())
|
|
return
|
|
}
|
|
|
|
var updatingUsers []dbstructs.User
|
|
|
|
accountNameReservingTime := currentTime.Add(-utils.AccountNameReservingTime * 24 * time.Hour).Unix()
|
|
|
|
for _, u := range users {
|
|
if u.LastAccountNameLc != "" && u.AccountNameUpdatedAt < accountNameReservingTime {
|
|
updatingUsers = append(updatingUsers, u)
|
|
}
|
|
}
|
|
|
|
if len(updatingUsers) > 0 {
|
|
batch := Session.NewBatch(gocql.UnloggedBatch)
|
|
|
|
q := "UPDATE " + Cluster.Keyspace + "." + gocnjhelper.DbMUsers.Name() + " SET last_account_name_lc='' WHERE id = ?"
|
|
|
|
for _, us := range updatingUsers {
|
|
batch.Query(q, us.Id)
|
|
}
|
|
|
|
if err := Session.ExecuteBatch(batch); err != nil {
|
|
gocnjhelper.LogErrorf("Failed to execute batch, err:", err.Error())
|
|
return
|
|
}
|
|
}
|
|
|
|
// restart timer
|
|
go TableCleaner()
|
|
}
|