Julian Gruber juliangruber

Current Saturn topology, with multi-peer retrieval (TBD) between L1<>L2:

flowchart TB
HttpClient <--> DNS[L1 DNS]
DNS <--> L1'
subgraph L1s[L1s deployed to data centers]
  L1
  L1'
 L1''

L1<>L2 architecture

Naming
- L1: L1 machine
- l1: Individual l1 worker process
The overview graph lists all involved components. In future graphs irrelevant components are omitted for readability, which doesn't mean they have been removed

	import { InfluxDB } from '@influxdata/influxdb-client'

	const client = new InfluxDB({
	url: 'https://eu-central-1-1.aws.cloud2.influxdata.com',
	token: process.env.INFLUX_TOKEN, // julian-station-read
	timeout: 5 * 60 * 1000
	})
	const queryApi = client.getQueryApi('Filecoin Station')
	const query = `
	from(bucket:"station")

	const notaries = await findNotaries()

	const allLdnClients = []
	for (const notaryAddressId of notaries) {
	const clients = await getVerifiedClientsOfNotary(notaryAddressId)
	allLdnClients.push(...clients)
	}
	removeDuplicates(allLdnClients)

	async function findNotaries (filter) {

	$ npm run build

	> [email protected] build
	> aegir build

	[08:47:41] tsc [started]
	src/circuit/auto-relay.ts:54:80 - error TS2345: Argument of type '(evt: CustomEvent<Connection>) => void' is not assignable to parameter of type 'EventHandler<CustomEvent<Connection>> \| null'.
	Type '(evt: CustomEvent<Connection>) => void' is not assignable to type 'EventCallback<CustomEvent<Connection>>'.
	Types of parameters 'evt' and 'evt' are incompatible.
	Type 'CustomEvent<import("/Users/julian/dev/libp2p/js-libp2p/node_modules/@libp2p/interface-connection-manager/node_modules/@libp2p/interface-connection/dist/src/index").Connection>' is not assignable to type 'CustomEvent<import("/Users/julian/dev/libp2p/js-libp2p/node_modules/@libp2p/interface-connection/dist/src/index").Connection>'.

	const dgram = require('node:dgram')
	const util = require('node:util')
	const glossy = require('glossy')

	const syslogProducer = new glossy.Produce()
	const socket = dgram.createSocket('udp4')

	const streams = {
	stdout: process.stdout.write.bind(process.stdout),
	stderr: process.stderr.write.bind(process.stderr)

	const fs = require('fs')
	const hyperdrive = require('hyperdrive')
	const src = `/tmp/${Math.random()}/`
	console.log(src)
	const storage = require('dat-storage')(src)

	const archive = hyperdrive(storage, { latest: true, indexing: true })
	archive.writeFile('/dat.json', 'hi', err => {
	if (err) throw err

	const fs = require('fs')
	const src = `/tmp/${Math.random()}`

	Dat(src, (err, dat) => {
	if (err) throw err
	dat.archive.writeFile('/dat.json', 'hi', err => {
	if (err) throw err

	console.log(fs.readFileSync(`${src}/dat.json`)) // => empty
	dat.archive.readFile('/dat.json', (err, data) => {