128 lines
2.6 KiB
JavaScript
128 lines
2.6 KiB
JavaScript
// node src/admin.js --purge-node-id 123
|
|
// node src/admin.js --purge-node-id '!AABBCCDD'
|
|
|
|
const commandLineArgs = require("command-line-args");
|
|
const commandLineUsage = require("command-line-usage");
|
|
|
|
// create prisma db client
|
|
const { PrismaClient } = require("@prisma/client");
|
|
const NodeIdUtil = require("./utils/node_id_util");
|
|
const prisma = new PrismaClient();
|
|
|
|
const optionsList = [
|
|
{
|
|
name: 'help',
|
|
alias: 'h',
|
|
type: Boolean,
|
|
description: 'Display this usage guide.'
|
|
},
|
|
{
|
|
name: "purge-node-id",
|
|
type: String,
|
|
description: "Purges all records for the provided node id.",
|
|
},
|
|
];
|
|
|
|
// parse command line args
|
|
const options = commandLineArgs(optionsList);
|
|
|
|
// show help
|
|
if(options.help){
|
|
const usage = commandLineUsage([
|
|
{
|
|
header: 'Meshtastic Map Admin',
|
|
content: 'Command line admin tool for the Meshtastic Map',
|
|
},
|
|
{
|
|
header: 'Options',
|
|
optionList: optionsList,
|
|
},
|
|
]);
|
|
console.log(usage);
|
|
return;
|
|
}
|
|
|
|
// get options and fallback to default values
|
|
const purgeNodeId = options["purge-node-id"] ?? null;
|
|
|
|
async function purgeNodeById(nodeId) {
|
|
|
|
// convert to numeric id
|
|
nodeId = NodeIdUtil.convertToNumeric(nodeId);
|
|
|
|
// purge environment metrics
|
|
await prisma.environmentMetric.deleteMany({
|
|
where: {
|
|
node_id: nodeId,
|
|
},
|
|
});
|
|
|
|
// purge map reports
|
|
await prisma.mapReport.deleteMany({
|
|
where: {
|
|
node_id: nodeId,
|
|
},
|
|
});
|
|
|
|
// purge neighbour infos
|
|
await prisma.neighbourInfo.deleteMany({
|
|
where: {
|
|
node_id: nodeId,
|
|
},
|
|
});
|
|
|
|
// purge this node
|
|
await prisma.node.deleteMany({
|
|
where: {
|
|
node_id: nodeId,
|
|
},
|
|
});
|
|
|
|
// purge positions
|
|
await prisma.position.deleteMany({
|
|
where: {
|
|
node_id: nodeId,
|
|
},
|
|
});
|
|
|
|
// purge power metrics
|
|
await prisma.powerMetric.deleteMany({
|
|
where: {
|
|
node_id: nodeId,
|
|
},
|
|
});
|
|
|
|
// purge text messages
|
|
await prisma.textMessage.deleteMany({
|
|
where: {
|
|
from: nodeId,
|
|
},
|
|
});
|
|
|
|
// purge traceroutes
|
|
await prisma.traceRoute.deleteMany({
|
|
where: {
|
|
from: nodeId,
|
|
},
|
|
});
|
|
|
|
// purge waypoints
|
|
await prisma.waypoint.deleteMany({
|
|
where: {
|
|
from: nodeId,
|
|
},
|
|
});
|
|
|
|
console.log(`✅ Node '${nodeId}' has been purged from the database.`);
|
|
|
|
}
|
|
|
|
(async () => {
|
|
|
|
// purge node by id
|
|
if(purgeNodeId){
|
|
await purgeNodeById(purgeNodeId);
|
|
}
|
|
|
|
})();
|