activte cleanup
This commit is contained in:
parent
f0418fb389
commit
574f229cee
3 changed files with 17 additions and 5 deletions
|
|
@ -391,7 +391,7 @@ export class AdminManager {
|
||||||
liquidityProviders.push(liquidityEntry)
|
liquidityProviders.push(liquidityEntry)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
const usersBalance = await this.storage.paymentStorage.GetTotalUsersBalance()
|
const usersBalance = await this.storage.paymentStorage.GetTotalUsersBalance(true)
|
||||||
return {
|
return {
|
||||||
users_balance: usersBalance,
|
users_balance: usersBalance,
|
||||||
lnds,
|
lnds,
|
||||||
|
|
|
||||||
|
|
@ -132,7 +132,7 @@ export default class {
|
||||||
}
|
}
|
||||||
|
|
||||||
this.log("Found", toDelete.length, "inactive users to delete")
|
this.log("Found", toDelete.length, "inactive users to delete")
|
||||||
// await this.RemoveUsers(toDelete)
|
await this.LockUsers(toDelete.map(u => u.userId))
|
||||||
}
|
}
|
||||||
|
|
||||||
async CleanupNeverActiveUsers() {
|
async CleanupNeverActiveUsers() {
|
||||||
|
|
@ -161,7 +161,15 @@ export default class {
|
||||||
}
|
}
|
||||||
|
|
||||||
this.log("Found", toDelete.length, "never active users to delete")
|
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[] }[]) {
|
async RemoveUsers(toDelete: { userId: string, appUserIds: string[] }[]) {
|
||||||
|
|
|
||||||
|
|
@ -452,8 +452,12 @@ export default class {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
async GetTotalUsersBalance(txId?: string) {
|
async GetTotalUsersBalance(excludeLocked?: boolean, txId?: string) {
|
||||||
const total = await this.dbs.Sum<User>('User', "balance_sats", {})
|
const where: { locked?: boolean } = {}
|
||||||
|
if (excludeLocked) {
|
||||||
|
where.locked = false
|
||||||
|
}
|
||||||
|
const total = await this.dbs.Sum<User>('User', "balance_sats", where, txId)
|
||||||
return total || 0
|
return total || 0
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue