31:T553,// defines the headers for the tables // this is a field-to-teex (or field-to-html) mapping header = { return { // asn: html`

Probe ASN

closest probe ASN

`, id: `IXP id as in PeeringDB`, distinct_origins_in_atlas: html`

ASN count

ASNs with probes
measuring this IXP

`, asns_with_probes_within_threshold: `ASNs within ${threshold}ms`, probes_within_threshold: `Probes within ${threshold}ms`, name_combined: "IXP Name" // min_rtt: "Min. RTT" // prb_id: html`

Probe ID

closest probe
to the IXP

`, // samples: html`

Samples

this probe
measuring this IXP

`, // total_samples: html`

Samples

all probes
measuring this IXP

`, // in_atlas: "In Atlas", // above_threshold: "Above threshold" // `covered` is already implcit in each of the two tables // covered: html`Has at least ${asnsWithinThresholdSelector} ASNs
within ${threshold}ms` }; }32:T882,allIxsTable = allIxs.map((ix) => { // let's apply the filters first if ( !includes.includes("Include IXs not measured by RIPE Atlas") && !resultsIndex.has(ix.id) ) return; if ( !includes.includes(thresholdText) && resultsIndex.get(ix.id) && resultsIndex.get(ix.id).min_rtt > threshold ) return; return { // `covered` needs to be at the begginning of the object // we'll drop it later on by destructuring the object, and that canot happen anywhere else covered: resultsIndex.has(ix.id) ? resultsIndex.get(ix.id).covered : false, id: ix.id, name_combined: ix.name === ix.name_long || ix.name_long === "" ? ix.name : `${ix.name} (${ix.name_long})`, // there's one probe which holds the min. RTT to this IXP. It has a min_rtt, prb_id, and asn: // min_rtt: resultsIndex.has(ix.id) ? resultsIndex.get(ix.id).min_rtt : -1, // prb_id: resultsIndex.has(ix.id) ? resultsIndex.get(ix.id).prb_id : -1, // asn: resultsIndex.has(ix.id) ? resultsIndex.get(ix.id).asn : -1, asns_with_probes_within_threshold: resultsIndex.has(ix.id) ? resultsIndex.get(ix.id).asns_with_probes_within_threshold.length : 0, probes_within_threshold: resultsIndex.has(ix.id) ? resultsIndex.get(ix.id).probes_within_threshold.length : 0, // distinct_origins_in_atlas: resultsIndex.has(ix.id) // ? resultsIndex.get(ix.id).asns_with_probes.length // : 0, // samples: resultsIndex.has(ix.id) ? resultsIndex.get(ix.id).samples : -1, // total_samples: resultsIndex.has(ix.id) // ? resultsIndex.get(ix.id).total_samples // : -1, city: ix.city, country: ix.country // location: `${ix.city}, ${ix.country}` // region_continent: ix.region_continent, // net_count: ix.net_count // fac_count: ix.fac_count // status: ix.status // in_atlas: `atlas=${allIxsMeasured.includes(ix.id)}`, // above_threshold: `threshold=${ // resultsIndex.get(ix.id) && // resultsIndex.get(ix.id).min_rtt > 0.0 && // resultsIndex.get(ix.id).min_rtt > threshold // ? "above" // : "below" // }` }; })33:T786,results = { let n; // amount of distinct ASNs which have probes that measure IX `id` let promises = allIxsMeasured.map((id) => d3 .json(`https://rd-gcp-cdn.ripe.net/${urlPfx}${id}.json`) // d3.least gives us the min for each ix-lan .then((arr) => { let closest = d3.least(arr, (a) => a.min_rtt); // all prb_ids measuring this IXP let probeIds = [...new Set(arr.map((a) => a.prb_id))]; let asns = probeIds.map((prb_id) => { let probeInfo = probeIndex.get(prb_id); console.log(">>>", probeInfo, prb_id); return closest.af === 4 ? probeInfo.asn_v4 : probeInfo.asn_v6; }); // all prb_ids measuring this IXP *within threshold* let probeIdsWithinThreshold = [ ...new Set( arr.filter((a) => a.min_rtt < threshold).map((a) => a.prb_id) ) ]; let asnsWithinThreshold = probeIdsWithinThreshold.map((prb_id) => { let probeInfo = probeIndex.get(prb_id); return closest.af === 4 ? probeInfo.asn_v4 : probeInfo.asn_v6; }); /// we want to keep the set of ASNs asnsWithinThreshold = [...new Set(asnsWithinThreshold)]; closest.total_samples = d3.sum(arr, (a) => a.samples); // samples coming from *all* probes, not only this one closest.asn = probeIndex.get(closest.prb_id).asn_v4; //TODO closest.asns_with_probes = asns; closest.asns_with_probes_within_threshold = asnsWithinThreshold; closest.probes_within_threshold = probeIdsWithinThreshold; closest.ix_id = id; // is this covered according to the selectors? closest.covered = asnsWithinThresholdSelector > 0 ? asnsWithinThreshold.length >= asnsWithinThresholdSelector : true; return closest; }) ); let responses = await Promise.all(promises); return responses; }34:[{"id":"5eba067131320a0efb26214a139ebe6fcc20bf54795d61d220134e091e389b3ef7b7e05c85bf4b99e9495217777c1cd8bf6b00f7870f5d1fe7b0d1af75d86236","href":"https://static.observableusercontent.com/files/5eba067131320a0efb26214a139ebe6fcc20bf54795d61d220134e091e389b3ef7b7e05c85bf4b99e9495217777c1cd8bf6b00f7870f5d1fe7b0d1af75d86236","name":"ix","type":"application/octet-stream","lastModified":1722348248575.553,"size":1271563}] 2f:{"title":"Atlas probe proximity to IXPs","cells":[{"id":437,"value":"md`# Atlas probe proximity to IXPs\n\n## RIPE Atlas min. RTT\n\n