ctmesh/map
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

implement purging neighbour infos

Browse Source
This commit is contained in:
liamcottle
2024-08-21 00:46:23 +12:00
parent f310a17423
commit a3242c9055
1 changed files with 33 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
src/mqtt.js
View File

@ -98,6 +98,11 @@ const optionsList = [
type: Number, type: Number,
description: "Map reports older than this many seconds will be purged from the database.", description: "Map reports older than this many seconds will be purged from the database.",
}, },
{
name: "purge-neighbour-infos-after-seconds",
type: Number,
description: "Neighbour infos older than this many seconds will be purged from the database.",
},
{ {
name: "purge-nodes-unheard-for-seconds", name: "purge-nodes-unheard-for-seconds",
type: Number, type: Number,
@ -163,6 +168,7 @@ const purgeNodesUnheardForSeconds = options["purge-nodes-unheard-for-seconds"] ?
const purgeDeviceMetricsAfterSeconds = options["purge-device-metrics-after-seconds"] ?? null; const purgeDeviceMetricsAfterSeconds = options["purge-device-metrics-after-seconds"] ?? null;
const purgeEnvironmentMetricsAfterSeconds = options["purge-environment-metrics-after-seconds"] ?? null; const purgeEnvironmentMetricsAfterSeconds = options["purge-environment-metrics-after-seconds"] ?? null;
const purgeMapReportsAfterSeconds = options["purge-map-reports-after-seconds"] ?? null; const purgeMapReportsAfterSeconds = options["purge-map-reports-after-seconds"] ?? null;
const purgeNeighbourInfosAfterSeconds = options["purge-neighbour-infos-after-seconds"] ?? null;
const purgePowerMetricsAfterSeconds = options["purge-power-metrics-after-seconds"] ?? null; const purgePowerMetricsAfterSeconds = options["purge-power-metrics-after-seconds"] ?? null;
const purgePositionsAfterSeconds = options["purge-positions-after-seconds"] ?? null; const purgePositionsAfterSeconds = options["purge-positions-after-seconds"] ?? null;
const purgeTextMessagesAfterSeconds = options["purge-text-messages-after-seconds"] ?? null; const purgeTextMessagesAfterSeconds = options["purge-text-messages-after-seconds"] ?? null;
@ -196,6 +202,7 @@ if(purgeIntervalSeconds){
await purgeOldDeviceMetrics(); await purgeOldDeviceMetrics();
await purgeOldEnvironmentMetrics(); await purgeOldEnvironmentMetrics();
await purgeOldMapReports(); await purgeOldMapReports();
await purgeOldNeighbourInfos();
await purgeOldPowerMetrics(); await purgeOldPowerMetrics();
await purgeOldPositions(); await purgeOldPositions();
await purgeOldTextMessages(); await purgeOldTextMessages();
@ -308,6 +315,32 @@ async function purgeOldMapReports() {
} }
/**
* Purges all neighbour infos from the database that are older than the configured timeframe.
*/
async function purgeOldNeighbourInfos() {
// make sure seconds provided
if(!purgeNeighbourInfosAfterSeconds){
return;
}
// delete all neighbour infos that are older than the configured purge time
try {
await prisma.neighbourInfo.deleteMany({
where: {
created_at: {
// created before x seconds ago
lt: new Date(Date.now() - purgeNeighbourInfosAfterSeconds * 1000),
},
}
});
} catch(e) {
// do nothing
}
}
/** /**
* Purges all power metrics from the database that are older than the configured timeframe. * Purges all power metrics from the database that are older than the configured timeframe.
*/ */