REF: performance improvements
This commit is contained in:
parent
a15a72c4da
commit
58f7e3963d
2
package-lock.json
generated
2
package-lock.json
generated
@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "groundcontrol",
|
||||
"version": "2.3.2",
|
||||
"version": "2.3.3",
|
||||
"lockfileVersion": 2,
|
||||
"requires": true,
|
||||
"packages": {
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "groundcontrol",
|
||||
"version": "2.3.2",
|
||||
"version": "2.3.3",
|
||||
"description": "GroundControl push server API",
|
||||
"devDependencies": {
|
||||
"@types/node": "18.7.16",
|
||||
|
||||
@ -104,6 +104,19 @@ const pushLogPurge = () => {
|
||||
.catch((error) => console.log("error purging PushLog:", error));
|
||||
};
|
||||
|
||||
const purgeOldTxidSubscriptions = () => {
|
||||
console.log("purging TokenToTxid...");
|
||||
let today = new Date();
|
||||
connection
|
||||
.createQueryBuilder()
|
||||
.delete()
|
||||
.from(TokenToTxid)
|
||||
.where("created <= :currentDate", { currentDate: new Date(today.getTime() - 3 * 30 * 24 * 60 * 60 * 1000) }) // 3 mo
|
||||
.execute()
|
||||
.then(() => console.log("TokenToTxid purged ok"))
|
||||
.catch((error) => console.log("error purging TokenToTxid:", error));
|
||||
};
|
||||
|
||||
const purgeIgnoredAddressesSubscriptions = () => {
|
||||
console.log("Purging addresses subscriptions...");
|
||||
connection
|
||||
@ -121,6 +134,7 @@ dataSource.initialize().then((c) => {
|
||||
connection = c;
|
||||
purgeIgnoredAddressesSubscriptions();
|
||||
pushLogPurge();
|
||||
purgeOldTxidSubscriptions();
|
||||
setInterval(pushLogPurge, 3600 * 1000);
|
||||
});
|
||||
|
||||
|
||||
@ -2,6 +2,8 @@ import { Entity, PrimaryGeneratedColumn, Column, Index } from "typeorm";
|
||||
|
||||
@Entity()
|
||||
@Index(["token", "txid"], { unique: true })
|
||||
@Index(["txid"], { unique: false })
|
||||
@Index(["created"], { unique: false })
|
||||
export class TokenToTxid {
|
||||
@PrimaryGeneratedColumn()
|
||||
id: number;
|
||||
|
||||
Loading…
Reference in New Issue
Block a user