31:T5d1,# BPG prefix propagation BGP Prefix propagation as observed by [RIPE RIS](https://ris.ripe.net). You can query for multiple prefixes or ASNs (comma-separated), or a combination. BGP updates can be selected with click-and-drag ${await FileAttachment("Screenshot 2024-07-12 at 13.39.14.png").image()} and the time window can be shifted ${await FileAttachment("Screenshot 2024-07-12 at 13@2.39.14.png").image()} The initial BGP state is shown in ${styles.black}. BGP updates inside the selected time window are shown in ${styles.green}, those outside are shown in ${styles.grey}. If the time window finishes at `$now` then the updates are streamed in realtime to your browser and painted in ${styles.orange} as they arrive. If a link falls under many of those colours, then the priority is highest for realtime updates: Data sources: - Routing data (RIPE RIS) - _historical_ data through [RIPEstat](https://stat.ripe.net/docs/02.data-api/bgplay.html) - _real-time_ data routing data through [RIS Live](https://ris-live.ripe.net/) - ASN-to-organisation mapping through [CAIDA's as2org](https://catalog.caida.org/dataset/as_organizations) - ASN names - data from (in preference order): [Emile Aben](https://github.com/emileaben/asnames), [PeeringDB](https://www.peeringdb.com/api/net), [RIPE NCC](https://ftp.ripe.net/ripe/asnames/asn.txt), and [APNIC](https://bgp.potaroo.net/asn.txt) - collected through [@aguformoso/as-names](https://observablehq.com/@aguformoso/as-names)32:T85c,viewof userInput = { let stop = query.stop || now; let start = query.start || new Date(new Date().setDate(stop.getDate() - 1)); let [url, path] = [`https://observablehq.com`, html``.pathname]; let pfxLabel = inputType === "asn" ? userPrefix : userAsn; return Inputs.form( { pfx: Inputs.text({ label: html`Prefix or ASN`, value: searchValue, placeholder: "193/21", submit: true, width: "30em" }), // truncateTier1: Inputs.radio([true, false], { // label: "Stop at first Tier 1", // value: true // }), asNames: Inputs.radio([true, false], { label: "ASN names", value: query.asnnames === "true" || query.asnames === "true" || false }), af: Inputs.radio(["v4", "v6"], { label: "AF", value: query.af || (searchValue && searchValue.includes(":")) ? "v6" : "v4", disabled: inputType === "prefix" ? true : false }), asRelated: Inputs.radio([true, false], { label: "Org. ASNs", value: query.as2org === "true" || false }), atlasProbes: Inputs.radio([true, false], { label: "Atlas probes", value: query.atlasprobes === "true" || false }), // transientAnnouncements: Inputs.radio([true, false], { // label: "Updates", // value: false // }), date1: Inputs.datetime({ label: "Start", value: start, submit: true }), date2: Inputs.datetime({ label: "Stop", value: stop, submit: true }) // TODO add input for stream. now --> disabled otherwise enabled // stream: Inputs.radio({ label: "Realtime streaming", }) }, { // https://observablehq.com/framework/inputs/form#options template: (inputs) => { // console.log(inputs); return html`

${Object.values(inputs)}

`; } } ); }33:T507,legend = dot`digraph { labelloc="t"; rankdir = LR; fontsize=11; subgraph cluster_legend { label="LEGEND"; // order seems important... ${ useStream && _liveState.length ? `65536->${ filterIsActive ? "65540" : "65539" } [color=orange fontsize=11 label="BGP update \n received after \n ${userInput.date2 .toISOString() .split(":") .slice(0, 2) .join(":") .replace("T", " ")} UTC\n (real time)"];` : "" } ${ filterIsActive ? `65536->65539 [color=lightgrey fontsize=11 label="BGP update \n outside window"];` : "" } 65536->65538 [color=${updateStateColor} fontsize=11 label="BGP update${ filterIsActive ? " \n inside window" : "" }"]; ${ userInput.atlasProbes ? '65538 [style=filled; fillcolor="lightyellow"; xlabel="ASN w/ Atlas probe"]' : "" } 65536->65537 [color=black fontsize=11 label="BGP state at \n ${userInput.date1 .toISOString() .split(":") .slice(0, 2) .join(":") .replace("T", " ")} UTC"]; } }`34:T8a1,linkRep = { // link str representation class Node { constructor(nodeId, url = "", fillcolor = "black", target = "_blank") { this.nodeId = nodeId; this.url = url; this.fillcolor = fillcolor; this.target = target; } toString() { let res = `"${f(this.nodeId)}`; let extras = []; if (this.url) extras.push(`URL=${this.url}`); if (this.fillcolor) extras.push(`fillcolor=${this.fillcolor}`); if (this.target) extras.push(`target=${this.target}`); if (extras.length > 0) res = `${res} [${extras.join("; ")}]`; return res; } } class Link { constructor(source, target, others) { this.source = source; this.target = target; this.others = others; } toString() { let res = `"${f(this.source)}" -> "${f( this.target )}"; ${this.source.toString()}; ${this.target.toString()};`; // res = this.others ? `${res} ${this.others}` : res; // console.log(">>>", this.source.toString()); return res; } } let linkRep = (source, target, others = "") => { let s = new Node(source, `https://stat.ripe.net/${source}`); let t = new Node(target, `https://stat.ripe.net/${target}`); let l = new Link(source, target, others); let link = `"${f(source)}" -> "${f(target)}" ${others}`; // new Link(source, target, others); link = `${link}; "${f( source )}" [URL="https://stat.ripe.net/${source}"; target="_blank"]`; if (!userInput.atlasProbes) { // console.log(l.toString()); return link; } // if (probesConnected.includes(source)) source.fillcolor = "lightyellow"; // if (probesConnected.includes(target)) target.fillcolor = "lightyellow"; let colors = `style=filled; fillcolor="lightyellow";`; let sourceColor = `"${f( source )}" [${colors} URL="https://stat.ripe.net/${source}"; target="_blank"];`; let targetColor = `"${f( target )}" [${colors} URL="https://stat.ripe.net/${target}"; target="_blank"];`; return `${link}; ${probesConnected.includes(source) ? sourceColor : ""} ${ probesConnected.includes(target) ? targetColor : "" }`; }; return linkRep; }35:T627,{ if (!useStream) return; var ws = new WebSocket( "wss://ris-live.ripe.net/v1/ws/?client=observable-aformoso" ); var params = { moreSpecific: true, // host: "rrc25", prefix: resources, // prefix: "2001:67c:2e8::/48", socketOptions: { includeRaw: true } }; ws.onmessage = function (event) { var message = JSON.parse(event.data); mutable prefixesLive.push(message.data.path); mutable prefixesLive = mutable prefixesLive.slice(-1000); mutable trigger += 1; // Objects look like: // { // "timestamp": 1720512186.25, // "peer": "2401:d20:a::9d0f:fe44", // "peer_asn": "151381", // "id": "2401:d20:a::9d0f:fe44-01909684878a0012", // "host": "rrc25.ripe.net", // "type": "UPDATE", // "path": [ // 151381, // 6939, // 1299, // 20473 // ], // "community": [], // "origin": "IGP", // "announcements": [ // { // "next_hop": "2401:d20:a::9d0f:fe44", // "prefixes": [ // "2a0e:97c4:ac13::/48" // ] // } // ], // "withdrawals": [], // "raw": "FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF0051020000003A900E001C0002011024010D20000A0000000000009D0FFE4400302A0E97C4AC134001010050020012020400024F5500001B1B0000051300004FF9" // } }; ws.onopen = function () { ws.send( JSON.stringify({ type: "ris_subscribe", data: params }) ); }; }36:[{"id":"d0296db56db0550a521739d3238da65b741e15e1bdc5357c3c7678bb060ef6865c20162425d6346281787889f177ef64badacc5b8675d177344ee5f1bcf786ce","href":"https://static.observableusercontent.com/files/d0296db56db0550a521739d3238da65b741e15e1bdc5357c3c7678bb060ef6865c20162425d6346281787889f177ef64badacc5b8675d177344ee5f1bcf786ce","name":"d.png","type":"image/png","lastModified":1720371059097.063,"size":8935},{"id":"d6e31923024c1291935ba4e9491e7f06e196325674b04389fcb33b72292dfd0cba2b71ae8a51d3207056c0c5020176c55154521f32911c95b535a14ae12eb2db","href":"https://static.observableusercontent.com/files/d6e31923024c1291935ba4e9491e7f06e196325674b04389fcb33b72292dfd0cba2b71ae8a51d3207056c0c5020176c55154521f32911c95b535a14ae12eb2db","name":"d@1.png","type":"image/png","lastModified":1720372195258.904,"size":9380},{"id":"f1c16392e7ab968ccd6069104f7b53bd609a7a7758fa9a05a679de8fe0427b1233f5f628693633922c4795a1f32fcf0132ee649fc10a0cd3225b8b3dc229d5f7","href":"https://static.observableusercontent.com/files/f1c16392e7ab968ccd6069104f7b53bd609a7a7758fa9a05a679de8fe0427b1233f5f628693633922c4795a1f32fcf0132ee649fc10a0cd3225b8b3dc229d5f7","name":"d@2.png","type":"image/png","lastModified":1720372411089.618,"size":5997},{"id":"0ec04f4c24392ec10d1594779fe934f6e72722c9c49097d9b478278b304aba986cae09d44d68903211b723ca9e612e2ba1bec6a259676a9e9580ac1cbec6e2a3","href":"https://static.observableusercontent.com/files/0ec04f4c24392ec10d1594779fe934f6e72722c9c49097d9b478278b304aba986cae09d44d68903211b723ca9e612e2ba1bec6a259676a9e9580ac1cbec6e2a3","name":"Screenshot 2024-07-12 at 13.39.14.png","type":"image/png","lastModified":1720784397163.833,"size":5878},{"id":"56859a0f12ec2cf6718ee537670902b289a37292533b3976dadbd1ad92a9fab4b0fb4fa5ba70ddc3a89be749f0184ab716103f846eb5dd13bb6e94f6f1c9333f","href":"https://static.observableusercontent.com/files/56859a0f12ec2cf6718ee537670902b289a37292533b3976dadbd1ad92a9fab4b0fb4fa5ba70ddc3a89be749f0184ab716103f846eb5dd13bb6e94f6f1c9333f","name":"Screenshot 2024-07-12 at 13@1.39.14.png","type":"image/png","lastModified":1720785440659.213,"size":6793},{"id":"9632121a16c8c55233c79871b9d65d9156a1cc009ecb096aae2da5c657e3eedd0ff3dcdf5167dc007d3ed3e9ef63db6390e2cc7d8aedc761a2b3e178dff85722","href":"https://static.observableusercontent.com/files/9632121a16c8c55233c79871b9d65d9156a1cc009ecb096aae2da5c657e3eedd0ff3dcdf5167dc007d3ed3e9ef63db6390e2cc7d8aedc761a2b3e178dff85722","name":"Screenshot 2024-07-12 at 13@2.39.14.png","type":"image/png","lastModified":1720785909438.582,"size":6274}] 2f:{"title":"BPG prefix propagation","cells":[{"id":0,"value":"$31","pinned":false,"hidden":false,"mode":"md"},{"id":182,"value":"$32","pinned":false,"hidden":false,"mode":"ojs"},{"id":2829,"value":"$${graph}\n\n${legend}\n\n${selectedAsns}","pinned":false,"hidden":false,"mode":"html"},{"id":817,"value":"viewof foo = {\n let bin = 15; // bin width\n\n return Plot.plot({\n subtitle: `Announcements (${bin}-minute bins)`,\n width,\n height: 100,\n x: {\n label: \"Time (UTC)\"\n },\n y: {\n label: \"Announcement \\n count\"\n },\n marks: [\n Plot.rectY(\n _events,\n Plot.brushX(\n Plot.binX(\n {\n y: \"count\",\n fill: (s) => updateStateColor,\n stroke: (s) => updateStateColor // thicker stroke hides narrower bins\n },\n {\n x: \"timestamp\",\n thresholds: d3.utcMinute.every(bin), //\"1 minutes\",\n // interval: 10,\n unselected: {\n fill: \"lightgrey\",\n stroke: \"lightgrey\"\n // opacity: 0.2\n }\n }\n )\n )\n ),\n Plot.ruleY([0])\n ]\n });\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":2947,"value":"viewof atlasApiKey = Inputs.text({\n label: \"Atlas API Key\",\n value: query.atlaskey || \"\"\n})","pinned":false,"hidden":false,"mode":"ojs"},{"id":3025,"value":"viewof checkboxes = Inputs.checkbox(\n clipPaths(probesConnected.map((asn) => [asn])).flat(),\n {\n label: \"Select some\",\n format: (asn) => asn\n }\n)","pinned":false,"hidden":false,"mode":"ojs"},{"id":3291,"value":"checkboxes","pinned":false,"hidden":false,"mode":"ojs"},{"id":1294,"value":"graph = {\n return dot`digraph {\n\n rankdir = LR; \n labelloc=\"t\";\n label=\"Graph for ${resources\n .map((r) =>\n userInput.asNames && inputType === \"asn\"\n ? `${getName(r)[0].name} (AS${r})`\n : r\n )\n .join(\", \")} ${inputType === \"asn\" ? `(${userInput.af})` : ``}\"; \n\n subgraph prefix {\n ${initialState}\n ${updateState} ${updateStateDiscarded} ${liveState} // don't leave a trailing colon\n }\n\n subgraph cluster_legend {\n label=\"Org: ${org ? org[0].data[0].orgName : \"\"}\"; ${relatedAsns\n .map((asn) => `\"${f(asn)}\"`)\n .join(\";\")}\n }\n} \n`;\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":3094,"value":"{\n graph;\n\n d3.select(\"svg\") // Or change to #id of your hosting SVG node\n .selectAll(\".node\")\n .on(\"click\", (evt) => {\n let asn = evt.target.innerHTML;\n\n if (selectedAsns.has(asn)) {\n selectedAsns.delete(asn);\n evt.target.innerHTML = `${asn}`.split(\" \")[0];\n } else {\n mutable selectedAsns.add(`${asn} ✔︎`);\n evt.target.innerHTML = `${asn} ✔︎`;\n }\n\n console.log(selectedAsns);\n });\n}","pinned":true,"hidden":false,"mode":"ojs"},{"id":3117,"value":"mutable selectedAsns = new Set()","pinned":false,"hidden":false,"mode":"ojs"},{"id":1677,"value":"$33","pinned":false,"hidden":false,"mode":"ojs"},{"id":2742,"value":"searchValue = query.resources || userPrefix || defaults.prefix","pinned":false,"hidden":false,"mode":"ojs"},{"id":2745,"value":"userAsn = ripestatNetworkInfo.asns[0]","pinned":false,"hidden":false,"mode":"ojs"},{"id":2747,"value":"userPrefix = ripestatNetworkInfo.prefix","pinned":false,"hidden":false,"mode":"ojs"},{"id":2612,"value":"inputType = {\n let resource = searchValue;\n\n if (resource.includes(\"/\")) return \"prefix\";\n else if (parseInt(resource)) return \"asn\";\n\n return \"unknown\";\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":2555,"value":"mutable probes = []","pinned":false,"hidden":false,"mode":"ojs"},{"id":2052,"value":"updateStateColor = query.updatecolor || \"black\"","pinned":false,"hidden":false,"mode":"ojs"},{"id":1234,"value":"_events = bgplay.events\n .filter((e) => e.type === \"A\")\n .map(({ timestamp, attrs: { path } }) => ({ timestamp, path }))\n // we keep those events which are going to be displayed\n .filter((e) => clipPaths([[...e.path].reverse()])[0]?.length)","pinned":false,"hidden":false,"mode":"ojs"},{"id":1577,"value":"events = foo.slice(0).flat()","pinned":false,"hidden":false,"mode":"ojs"},{"id":1520,"value":"eventsDiscarded = {\n let discarded = new Set(_events).difference(new Set(events));\n return [...discarded];\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":921,"value":"filterIsActive = _events.length != events.length","pinned":false,"hidden":false,"mode":"ojs"},{"id":1839,"value":"dateIsNow = now.getTime() - now.getSeconds() * 1000 - now.getMilliseconds() ===\n userInput.date2.getTime()","pinned":false,"hidden":false,"mode":"ojs"},{"id":1856,"value":"useStream = dateIsNow","pinned":false,"hidden":false,"mode":"ojs"},{"id":101,"value":"// from https://en.wikipedia.org/wiki/Tier_1_network\ntier1s = [\n \"7018\",\n \"3320\",\n \"3257\",\n \"6830\",\n \"3356\",\n \"2914\",\n \"5511\",\n \"3491\",\n \"6453\",\n \"6762\",\n \"1299\",\n \"12956\",\n \"701\",\n \"6461\",\n // other major networks\n //\n \"7473\",\n \"174\",\n \"6939\",\n \"9002\",\n \"1273\",\n \"2828\",\n \"4637\",\n \"7922\"\n].map((asn) => parseInt(asn))","pinned":false,"hidden":false,"mode":"ojs"},{"id":1205,"value":"t1s = new Set(tier1s)","pinned":false,"hidden":false,"mode":"ojs"},{"id":2451,"value":"f = (asn) => (userInput.asNames ? getName(asn)[0].name : asn)","pinned":false,"hidden":false,"mode":"ojs"},{"id":588,"value":"$34","pinned":false,"hidden":false,"mode":"ojs"},{"id":1193,"value":"hege\n\npfx -> peers\n\nbetweenness centrality","pinned":false,"hidden":false,"mode":"md"},{"id":1202,"value":"clipPaths = (paths) => {\n let s2 = [];\n for (const path of paths) {\n if (new Set(path).intersection(t1s).size === 0) continue;\n\n for (let idx = 0; idx < path.length; idx++) {\n if (t1s.has(path[idx])) {\n s2.push(path.slice(0, idx + 1));\n break;\n }\n }\n }\n return s2;\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":519,"value":"pathToLinkSummary = (s1) => {\n let s2 = clipPaths(s1); // truncate until 1st tier1\n\n let s3 = s2\n .map((s) => d3.pairs(s).map(([source, target]) => ({ source, target })))\n .flat()\n .filter(({ source, target }) => source != target);\n\n return d3\n .flatGroup(\n s3,\n (l) => l.source,\n (l) => l.target\n )\n .map(([source, target, _]) => ({\n source,\n target,\n count: _.length\n }));\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":195,"value":"import { ripestatNetworkInfo } from \"3c618e916a1c4b87\"","pinned":false,"hidden":false,"mode":"ojs"},{"id":258,"value":"import { getName } from \"@aguformoso/as-names\"","pinned":false,"hidden":false,"mode":"ojs"},{"id":463,"value":"import { query, defaults, getQuery } from \"@aguformoso/utils\"","pinned":false,"hidden":false,"mode":"ojs"},{"id":1571,"value":"import { Plot } from \"@observablehq/brushing-plot--1653\"","pinned":false,"hidden":false,"mode":"ojs"},{"id":2029,"value":"import { calculateHegemonyFromBGPlayJSON } from \"@emileaben/bgp-granular-pfx-visibility@114\"","pinned":false,"hidden":false,"mode":"ojs"},{"id":2319,"value":"import { as2org } from \"@aguformoso/caida-as2org\"","pinned":false,"hidden":false,"mode":"ojs"},{"id":2853,"value":"import { paginated_fetch } from \"@ripencc/internet-outages-as-seen-by-ripe-atlas\"","pinned":false,"hidden":false,"mode":"ojs"},{"id":1177,"value":"mutable prefixesLive = []","pinned":false,"hidden":false,"mode":"ojs"},{"id":2349,"value":"resources_ = userInput.pfx.split(\",\")","pinned":false,"hidden":false,"mode":"ojs"},{"id":2403,"value":"resources = relatedAsns.length ? relatedAsns : resources_","pinned":false,"hidden":false,"mode":"ojs"},{"id":1479,"value":"mutable trigger = 0","pinned":false,"hidden":false,"mode":"ojs"},{"id":1787,"value":"now = new Date()","pinned":false,"hidden":false,"mode":"ojs"},{"id":1180,"value":"$35","pinned":false,"hidden":false,"mode":"ojs"},{"id":2357,"value":"mergeBgplayCalls = async (calls) => {\n let [initial_state, events] = [\n calls.map((call) => call.initial_state).flat(),\n calls.map((call) => call.events).flat()\n ];\n return { initial_state, events };\n // return await calls.map((call) => call.initial_state).flat();\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":2371,"value":"bgplay_ = mergeBgplayCalls(await Promise.all(resources.map(bgplay__)))","pinned":false,"hidden":false,"mode":"ojs"},{"id":2360,"value":"bgplay__ = async (resource) => {\n let [starttime, endtime] = [\n userInput.date1.toISOString().split(\".\")[0],\n userInput.date2.toISOString().split(\".\")[0]\n ];\n let res = await d3.json(\n `https://stat.ripe.net/data/bgplay/data.json?resource=${resource}&starttime=${starttime}&endtime=${endtime}`\n );\n\n let initial_state = res.data.initial_state;\n let events = res.data.events.map((e) => ({\n ...e,\n timestamp: new Date(`${e.timestamp}Z`)\n }));\n\n return { initial_state, events };\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":2242,"value":"bgplay = {\n let initial_state = bgplay_.initial_state.filter((s) =>\n userInput.af === \"v4\"\n ? !s.target_prefix.includes(\":\")\n : s.target_prefix.includes(\":\")\n );\n let events = bgplay_.events.filter((e) =>\n userInput.af === \"v4\"\n ? !e.attrs.target_prefix.includes(\":\")\n : e.attrs.target_prefix.includes(\":\")\n );\n\n return { initial_state, events };\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":1313,"value":"_updateState = {\n let links_ = pathToLinkSummary(events.map((i) => [...i.path].reverse()));\n // mutable links = links.concat(links_);\n\n return [\n ...new Set(\n links_.map(\n // ignoring `count`...\n ({ source, target, count }) => linkRep(source, target)\n )\n ).difference(new Set(_liveState))\n ];\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":1532,"value":"_updateStateDiscarded = [\n ...new Set(\n pathToLinkSummary(eventsDiscarded.map((i) => [...i.path].reverse())).map(\n // ignoring `count`...\n ({ source, target, count }) => linkRep(source, target)\n )\n )\n .difference(new Set(_updateState))\n .difference(new Set(_liveState))\n]","pinned":false,"hidden":false,"mode":"ojs"},{"id":1459,"value":"_liveState = {\n mutable trigger;\n\n // playMusic(soundUrl);\n\n return pathToLinkSummary(\n mutable prefixesLive.filter((p) => p).map((path) => [...path].reverse())\n ).map(\n // ignoring `count`...\n ({ source, target, count }) => linkRep(source, target)\n );\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":1288,"value":"_initialState = [\n ...new Set(\n pathToLinkSummary(\n bgplay.initial_state.map((i) => [...i.path].reverse())\n ).map(\n // ignoring `count`...\n ({ source, target, count }) => linkRep(source, target)\n )\n )\n .difference(new Set(_updateState))\n .difference(new Set(_updateStateDiscarded))\n .difference(new Set(_liveState))\n]","pinned":false,"hidden":false,"mode":"ojs"},{"id":1358,"value":"// aesthetics\nupdateState = _updateState.join(\" \")\n// .map((s) => `${s} [color=${updateStateColor}]`)\n// .join(\" ; \")","pinned":false,"hidden":false,"mode":"ojs"},{"id":1537,"value":"updateStateDiscarded = _updateStateDiscarded\n .map((s) => `${s} [color=lightgrey]`)\n .join(\"; \")","pinned":false,"hidden":false,"mode":"ojs"},{"id":1371,"value":"initialState = _initialState.join(\" \")","pinned":false,"hidden":false,"mode":"ojs"},{"id":1472,"value":"// aesthetics\nliveState = _liveState //.map((s) => `${s} [color=orange]`).join(\"; \")","pinned":false,"hidden":false,"mode":"ojs"},{"id":2040,"value":"bgplay2 = {\n let [starttime, endtime] = [\n userInput.date1.toISOString().split(\".\")[0],\n userInput.date2.toISOString().split(\".\")[0]\n ];\n let res = await d3.json(\n `https://stat.ripe.net/data/bgplay/data.json?resource=${resources}&starttime=${starttime}&endtime=${endtime}`\n );\n\n return res;\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":2042,"value":"hegemony = calculateHegemonyFromBGPlayJSON(bgplay2)","pinned":false,"hidden":false,"mode":"ojs"},{"id":2918,"value":"asnField = userInput.af === \"v4\" ? `asn_v4` : `asn_v6`","pinned":false,"hidden":false,"mode":"ojs"},{"id":2988,"value":"ipField = userInput.af === \"v4\" ? `address_v4` : `address_v6`","pinned":false,"hidden":false,"mode":"ojs"},{"id":2097,"value":"probesConnected_ = {\n if (userInput.atlasProbes != true) return [];\n\n // commenting out as not all ASNs are part of the hegemony calculation... (threshold?)\n // let keys = Object.keys(hegemony);\n\n let keys = bgplay2.data.nodes.map((node) => `${node.as_number}`);\n // let keys = clipPaths(bgplay2.data.nodes.map((node) => [node.as_number])); // not working properly? missing (at least) the origin\n\n let promises = keys.map(\n async (asn) =>\n await paginated_fetch(\n `https://atlas.ripe.net/api/v2/probes/?${asnField}=${asn}&status=1&fields=id,status,tags,${asnField},${ipField}&format=json`\n )\n );\n\n let now = new Date();\n return (await Promise.all(promises))\n .flat()\n .filter(\n // filtering out some faulty probes, just in case\n (p) =>\n !p.tags.some((t) => t.slug == \"system-flash-drive-filesystem-corrupted\")\n )\n .map((p) => ({\n ...p,\n uptime: now.getTime() - new Date(p.status.since).getTime()\n }));\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":2910,"value":"// returns a list of ASNs which have connected RIPE Atlas probes\n\nprobesConnected = {\n let results = probesConnected_.map((p) => p[asnField]).filter((asn) => asn);\n return [...new Set(results)];\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":2926,"value":"asnToProbes = Object.fromEntries(\n d3.flatGroup(probesConnected_, (p) => p[asnField])\n)","pinned":false,"hidden":false,"mode":"ojs"},{"id":2986,"value":"asnToIps = Object.fromEntries(\n d3.flatGroup(\n probesConnected_.map(({ id, asn_v4, asn_v6, address_v4, address_v6 }) => {\n if (asnField === \"asn_v4\") return { asn_v4, address_v4 };\n return { asn_v6, address_v6 };\n }),\n (p) => p[asnField]\n )\n)","pinned":false,"hidden":false,"mode":"ojs"},{"id":2955,"value":"// d3.json(`https://atlas.ripe.net/api/v2/measurements/`, {\n// method: \"POST\",\n// headers: {\n// \"Authorization\": `Key ${atlasApiKey}`,\n// \"Content-Type\": \"application/json\"\n// },\n// body: JSON.stringify(d)\n// })","pinned":true,"hidden":false,"mode":"ojs"},{"id":3174,"value":"// {\n// if (sourceProbes.length === 0) return;\n// return fetch(\n// `https://atlas.ripe.net/api/v2/measurements/?key=${atlasApiKey}`,\n// {\n// method: \"POST\",\n// headers: {\n// \"Content-Type\": \"application/json\"\n// },\n// body: JSON.stringify(d)\n// }\n// );\n// }","pinned":true,"hidden":false,"mode":"ojs"},{"id":3193,"value":"// fetch(`https://atlas.ripe.net/api/v2/measurements/`, {\n// method: \"POST\",\n// headers: {\n// Authorization: `Key ${atlasApiKey}`,\n// Credentials: true,\n// \"Content-Type\": \"application/json\"\n// },\n// body: JSON.stringify(d)\n// })","pinned":true,"hidden":false,"mode":"ojs"},{"id":3204,"value":"// sourceProbes = [...mutable selectedAsns]\n// // .filter((a) => a != undefined)\n// .map((asn) => {\n// let probes = asnToProbes[parseInt(asn.split(\" \")[0])];\n// return d3.reverse(d3.sort(probes, (p) => p.uptime))[0];\n// })\n// .map((p) => p.id)","pinned":true,"hidden":false,"mode":"ojs"},{"id":3177,"value":"// d = {\n// let targetProbe = asnToIps[3333][0];\n// let target =\n// userInput.af === \"v4\" ? targetProbe.address_v4 : targetProbe.address_v6;\n// return {\n// definitions: [\n// {\n// target: target,\n// description: \"Msm from Observable\",\n// resolve_on_probe: true,\n// is_oneoff: true,\n// type: \"traceroute\",\n// af: 4\n// }\n// ],\n// probes: [\n// {\n// requested: sourceProbes.length,\n// type: \"probes\",\n// value: sourceProbes.join(\",\")\n// }\n// ]\n// };\n// }","pinned":true,"hidden":false,"mode":"ojs"},{"id":1952,"value":"styles = ({\n orange: html`orange`,\n grey: html`grey`,\n green: html`${updateStateColor}`,\n black: html`black`\n})","pinned":false,"hidden":false,"mode":"ojs"},{"id":2634,"value":"org = userInput.asRelated && inputType === \"asn\" ? as2org(resources_) : null","pinned":false,"hidden":false,"mode":"ojs"},{"id":2317,"value":"relatedAsns = userInput.asRelated && inputType === \"asn\"\n ? org[0].data[0].members\n : []","pinned":false,"hidden":false,"mode":"ojs"}],"files":"$W36","stdlib":"1","titling":"auto"}