/** * Creates a plotly.js sankey plot showing the way the selected AS is connected to reach the internet, on the specified date. * @function dependencySankey * @param {String} startDate The date of the data snapshot e.g. "2022-05-03". * @param {String} ASN The ASN of the network to be examined e.g. "1241". * @return {Object} A DOM object with the generated plot. */ async function dependencySankey(startDate, ASN) { if (!startDate) { return "No start date provided"; } else if (!ASN) { return "No ASN provided"; } else if (!validateDate(startDate)) { return "Invalid start date format, e.g. 2022-05-03"; } else if (!validateASN(ASN)) { return "Invalid ASN"; } const arrayDependencies = []; const arrayHegemony = []; const arrayNeighbours = []; const results = await fetch(`https://ihr.iijlab.net/ihr/api/hegemony/?originasn=${ASN}&af=4&timebin=${startDate}T10:00:00.000Z&ordering=timebin`); const rBody = await results.json(); for (let i = 0; i < rBody.results.length; ++i) { const element = rBody.results[i]; if (element.asn == element.originasn) { continue; } if (element.originasn == 0) { continue; } arrayDependencies.push(element.asn); arrayHegemony.push({ "asn": element.asn, "hege": element.hege }); } const neighbour = await fetch(`https://stat.ripe.net/data/asn-neighbours/data.json?resource=${ASN}&`); const nBody = await neighbour.json(); for (let i = 0; i < nBody.data.neighbours.length; ++i) { const element = nBody.data.neighbours[i]; arrayNeighbours.push(element.asn); } const arrayDepNeigh = arrayDependencies.filter(v => arrayNeighbours.indexOf(v) > -1); const chunkedArray = []; for (let i = 0; i < arrayDepNeigh.length; i += 10) { chunkedArray.push(arrayDepNeigh.slice(i, i + 10)); } const taskPromise = (chunk) => { return new Promise(async (resolve, reject) => { const finalArray = []; for (let i = 0; i < chunk.length; ++i) { const element = chunk[i]; const subResults = await fetch(`https://ihr.iijlab.net/ihr/api/hegemony/?originasn=${element}&af=4&timebin=${startDate}T10:00:00.000Z&ordering=timebin`); const subResultsBody = await subResults.json(); finalArray.push({ "asn": element, "deps": subResultsBody.results, }); } resolve(finalArray); }); } let arrayDependenciesOfNeighbourY = []; for (let i = 0; i < chunkedArray.length; ++i) { const chunk = chunkedArray[i]; const chunkResults = await taskPromise(chunk); arrayDependenciesOfNeighbourY = [...arrayDependenciesOfNeighbourY, ...chunkResults]; } const arrayDependenciesOfNeighbourYASN = [...new Set(arrayDependenciesOfNeighbourY.map(e => e.deps.map(ee => ee.asn)).reduce((acc, e) => {return [...acc, ...e]}))]; const commonNeighbours = []; for (let i = 0; i < arrayDependencies.length; ++i) { const element = arrayDependencies[i]; if (arrayNeighbours.includes(element)) { continue; } if (!arrayDependenciesOfNeighbourYASN.includes(element)) { continue; } commonNeighbours.push(element); } const nonCommonNeighbours = []; for (let i = 0; i < arrayDependencies.length; ++i) { const element = arrayDependencies[i]; if (arrayNeighbours.includes(element)) { continue; } if (arrayDependenciesOfNeighbourYASN.includes(element)) { continue; } nonCommonNeighbours.push(element); } const depthLevelOne = []; if (arrayNeighbours.filter(e => !arrayDependencies.includes(e)).length > 0) { depthLevelOne.push({ "source": parseInt(ASN), "target": "No dependencies", "value": 1, "color": "rgba(44, 160, 44, 0.5)" }); } for (let i = 0; i < arrayDepNeigh.length; ++i) { const element = arrayDepNeigh[i]; const dependencyArray = arrayDependenciesOfNeighbourY.filter(e => e.asn == element)[0].deps; depthLevelOne.push({ "source": parseInt(ASN), "target": element, "value": arrayHegemony.filter(e => e.asn == element)[0].hege * 100, "color": "rgba(255, 0, 0, 0.5)" }); const depsArray = []; for (let j = 0; j < dependencyArray.length; ++j) { const dep = dependencyArray[j]; depsArray.push(dep.asn); } if (depsArray.filter(e => !commonNeighbours.includes(e)).length > 0) { depthLevelOne.push({ "source": element, "target": "Internet", "value": 1, "color": "rgba(44, 160, 44, 0.5)" }); } } const depthLevelTwo = []; for (let i = 0; i < arrayDepNeigh.length; ++i) { const dep = arrayDepNeigh[i]; for (let j = 0; j < commonNeighbours.length; ++j) { const commonNeighbour = commonNeighbours[j]; const dep_dep2j = arrayDependenciesOfNeighbourY.filter(e => e.asn == dep)[0].deps.filter(e => e.asn == commonNeighbour); if (dep_dep2j.length > 0) { depthLevelTwo.push({ "source": dep, "target": commonNeighbour, "value": dep_dep2j[0].hege * 100, "color": "rgba(255, 0, 0, 0.5)" }); } } } const depthLevelThree = []; for (let i = 0; i < commonNeighbours.length; ++i) { const element = commonNeighbours[i]; depthLevelThree.push({ "source": element, "target": "Internet", "value": 1, "color": "rgba(44, 160, 44, 0.5)" }); } for (let i = 0; i < nonCommonNeighbours.length; ++i) { const element = nonCommonNeighbours[i]; depthLevelThree.push({ "source": element, "target": "Internet", "value": 1, "color": "rgba(44, 160, 44, 0.5)" }); } const finalObj = [...depthLevelOne, ...depthLevelTwo, ...depthLevelThree]; let labelArray = []; for (let i = 0; i < finalObj.length; ++i) { const element = finalObj[i]; labelArray.push(element.source); } labelArray = [...new Set(labelArray)]; labelArray = [...labelArray, "Internet", "No dependencies"]; const sourceArray = []; const targetArray = []; const valueArray = []; const colorArray = []; for (let i = 0; i < finalObj.length; ++i) { const element = finalObj[i]; sourceArray.push(labelArray.indexOf(element.source)); targetArray.push(labelArray.indexOf(element.target)); valueArray.push(element.value); colorArray.push(element.color); } for (let i = 0; i < labelArray.length; ++i) { labelArray[i] = labelArray[i].toString(); } let nodeColorArray = []; for (let i = 0; i < labelArray.length; ++i) { nodeColorArray.push("rgba(255, 0, 0, 0.8)"); } nodeColorArray[0] = "rgba(0, 0, 255, 0.8)"; nodeColorArray[nodeColorArray.length - 1] = "rgba(44, 160, 44, 0.7)"; nodeColorArray[nodeColorArray.length - 2] = "rgba(44, 160, 44, 0.7)"; const traces = [{ type: "sankey", node: { label: labelArray, color: nodeColorArray, width: 0 }, link: { source: sourceArray, target: targetArray, value: valueArray, color: colorArray } }]; const layout = { title: "AS Dependency Sankey", font: { size: 10 } } const div = DOM.element("div"); Plotly.newPlot(div, traces, layout); return div; }