Merge pull request #894 from shocknet/activate-users-cleanup
activte cleanup
This commit is contained in:
commit
71b55c06d4
3 changed files with 18 additions and 6 deletions
|
|
@ -391,7 +391,7 @@ export class AdminManager {
|
|||
liquidityProviders.push(liquidityEntry)
|
||||
}
|
||||
}
|
||||
const usersBalance = await this.storage.paymentStorage.GetTotalUsersBalance()
|
||||
const usersBalance = await this.storage.paymentStorage.GetTotalUsersBalance(true)
|
||||
return {
|
||||
users_balance: usersBalance,
|
||||
lnds,
|
||||
|
|
|
|||
|
|
@ -132,12 +132,12 @@ export default class {
|
|||
}
|
||||
|
||||
this.log("Found", toDelete.length, "inactive users to delete")
|
||||
// await this.RemoveUsers(toDelete)
|
||||
await this.LockUsers(toDelete.map(u => u.userId))
|
||||
}
|
||||
|
||||
async CleanupNeverActiveUsers() {
|
||||
this.log("Cleaning up never active users")
|
||||
const inactiveUsers = await this.storage.userStorage.GetInactiveUsers(30)
|
||||
const inactiveUsers = await this.storage.userStorage.GetInactiveUsers(90)
|
||||
const toDelete: { userId: string, appUserIds: string[] }[] = []
|
||||
for (const u of inactiveUsers) {
|
||||
const user = await this.storage.userStorage.GetUser(u.user_id)
|
||||
|
|
@ -161,7 +161,15 @@ export default class {
|
|||
}
|
||||
|
||||
this.log("Found", toDelete.length, "never active users to delete")
|
||||
// await this.RemoveUsers(toDelete) TODO: activate deletion
|
||||
await this.RemoveUsers(toDelete)
|
||||
}
|
||||
|
||||
async LockUsers(toLock: string[]) {
|
||||
this.log("Locking", toLock.length, "users")
|
||||
for (const userId of toLock) {
|
||||
await this.storage.userStorage.BanUser(userId)
|
||||
}
|
||||
this.log("Locked users")
|
||||
}
|
||||
|
||||
async RemoveUsers(toDelete: { userId: string, appUserIds: string[] }[]) {
|
||||
|
|
|
|||
|
|
@ -452,8 +452,12 @@ export default class {
|
|||
}
|
||||
}
|
||||
|
||||
async GetTotalUsersBalance(txId?: string) {
|
||||
const total = await this.dbs.Sum<User>('User', "balance_sats", {})
|
||||
async GetTotalUsersBalance(excludeLocked?: boolean, txId?: string) {
|
||||
const where: { locked?: boolean } = {}
|
||||
if (excludeLocked) {
|
||||
where.locked = false
|
||||
}
|
||||
const total = await this.dbs.Sum<User>('User', "balance_sats", where, txId)
|
||||
return total || 0
|
||||
}
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue