141 lines
4.1 KiB
JavaScript
141 lines
4.1 KiB
JavaScript
const { Resource } = require('./models/resource');
|
|
const { initORM } = require('./models/index');
|
|
|
|
async function run() {
|
|
await initORM();
|
|
const all = await Resource.list();
|
|
console.log(`Found ${all.length} resources`);
|
|
|
|
const byIp = {};
|
|
const byName = {};
|
|
|
|
for (const r of all) {
|
|
if (!r.metadata) r.metadata = {};
|
|
|
|
// gather IPs
|
|
const ips = new Set();
|
|
if (r.metadata.address) ips.add(r.metadata.address);
|
|
if (r.metadata.interfaces) {
|
|
r.metadata.interfaces.forEach(i => { if (i.ip) ips.add(i.ip); });
|
|
}
|
|
|
|
for (const ip of ips) {
|
|
if (!byIp[ip]) byIp[ip] = [];
|
|
byIp[ip].push(r);
|
|
}
|
|
|
|
const nameLower = (r.name || '').toLowerCase();
|
|
if (nameLower) {
|
|
if (!byName[nameLower]) byName[nameLower] = [];
|
|
byName[nameLower].push(r);
|
|
}
|
|
}
|
|
|
|
// Find duplicates
|
|
const toDelete = new Set();
|
|
|
|
for (const ip in byIp) {
|
|
if (byIp[ip].length > 1) {
|
|
// Sort so managed/older is kept
|
|
const group = byIp[ip].sort((a, b) => {
|
|
const aM = a.metadata?.managed ? 1 : 0;
|
|
const bM = b.metadata?.managed ? 1 : 0;
|
|
if (aM !== bM) return bM - aM;
|
|
return a.created_on - b.created_on;
|
|
});
|
|
|
|
const primary = group[0];
|
|
for (let i = 1; i < group.length; i++) {
|
|
const sec = group[i];
|
|
if (toDelete.has(sec.id) || toDelete.has(primary.id)) continue;
|
|
console.log(`Merging ${sec.name} into ${primary.name} due to IP ${ip}`);
|
|
|
|
// merge metadata
|
|
const m1 = primary.metadata || {};
|
|
const m2 = sec.metadata || {};
|
|
|
|
const mergedMeta = { ...m2, ...m1 };
|
|
|
|
// merge interfaces
|
|
const intfs = [...(m1.interfaces||[]), ...(m2.interfaces||[])];
|
|
const uniqIntfs = [];
|
|
const seenIps = new Set();
|
|
for (const intf of intfs) {
|
|
if (intf.ip && seenIps.has(intf.ip)) continue;
|
|
if (intf.ip) seenIps.add(intf.ip);
|
|
uniqIntfs.push(intf);
|
|
}
|
|
mergedMeta.interfaces = uniqIntfs;
|
|
|
|
const sources = new Set([...(m1.discovery_sources||[]), ...(m2.discovery_sources||[])]);
|
|
mergedMeta.discovery_sources = [...sources];
|
|
|
|
await primary.update({
|
|
metadata: mergedMeta,
|
|
description: primary.description || sec.description
|
|
});
|
|
|
|
toDelete.add(sec.id);
|
|
}
|
|
}
|
|
}
|
|
|
|
for (const name in byName) {
|
|
if (byName[name].length > 1) {
|
|
// Sort so managed/older is kept
|
|
const group = byName[name].sort((a, b) => {
|
|
const aM = a.metadata?.managed ? 1 : 0;
|
|
const bM = b.metadata?.managed ? 1 : 0;
|
|
if (aM !== bM) return bM - aM;
|
|
return a.created_on - b.created_on;
|
|
});
|
|
|
|
const primary = group[0];
|
|
for (let i = 1; i < group.length; i++) {
|
|
const sec = group[i];
|
|
if (toDelete.has(sec.id) || toDelete.has(primary.id)) continue;
|
|
console.log(`Merging ${sec.name} into ${primary.name} due to name ${name}`);
|
|
|
|
// merge metadata
|
|
const m1 = primary.metadata || {};
|
|
const m2 = sec.metadata || {};
|
|
|
|
const mergedMeta = { ...m2, ...m1 };
|
|
|
|
// merge interfaces
|
|
const intfs = [...(m1.interfaces||[]), ...(m2.interfaces||[])];
|
|
const uniqIntfs = [];
|
|
const seenIps = new Set();
|
|
for (const intf of intfs) {
|
|
if (intf.ip && seenIps.has(intf.ip)) continue;
|
|
if (intf.ip) seenIps.add(intf.ip);
|
|
uniqIntfs.push(intf);
|
|
}
|
|
mergedMeta.interfaces = uniqIntfs;
|
|
|
|
const sources = new Set([...(m1.discovery_sources||[]), ...(m2.discovery_sources||[])]);
|
|
mergedMeta.discovery_sources = [...sources];
|
|
|
|
await primary.update({
|
|
metadata: mergedMeta,
|
|
description: primary.description || sec.description
|
|
});
|
|
|
|
toDelete.add(sec.id);
|
|
}
|
|
}
|
|
}
|
|
|
|
// Delete merged items
|
|
for (const id of toDelete) {
|
|
console.log(`Deleting merged resource ${id}`);
|
|
const r = all.find(r => r.id === id);
|
|
if (r) await r.delete();
|
|
}
|
|
|
|
console.log(`Merged ${toDelete.size} items.`);
|
|
process.exit(0);
|
|
}
|
|
|
|
run().catch(console.error);
|