connections.js

const fetch = require("node-fetch")
const jsonfile = require("jsonfile")
const fs = require("fs")

const { SLEEP_TIME, apiDomains, namespaces } = require("./constants.js")

const sleep = ms => new Promise(resolve => setTimeout(resolve, ms))

const getConnection = async (requestOptions, region, id) => {
	const filename = `cache/connection-${region}-${id}.json`

	// Get JSON file from cache
	if (fs.existsSync(filename)) {
		return jsonfile.readFileSync(filename)
	}

	// Fetch new connection data
	await sleep(SLEEP_TIME)

	const url = "https://" + apiDomains[region] + "/data/wow/connected-realm/" + id
	const res = await fetch(url, requestOptions)
	const json = await res.json()

	if (!json.realms && json.code !== 404) return console.log("ERROR: response missing realms:", json)

	const connectionData = {
		id    : id,
		region: region.toUpperCase(),
		realms: json.realms ? json.realms.map(realm => realm.id) : [],
	}

	jsonfile.writeFileSync(filename, connectionData, { spaces: "\t" }, (err) => console.error(err))

	return connectionData
}

const getConnectionIDsForRegion = async (requestOptions, region) => {
	await sleep(SLEEP_TIME)

	const url = "https://" + apiDomains[region] + "/data/wow/connected-realm/"
	const res = await fetch(url, requestOptions)
	const json = await res.json()
	if (!json.connected_realms) return console.log("ERROR: response missing connected_realms:", json)

	return json.connected_realms.map(connection => {
		const id = connection.href.replace(/.+\/connected-realm\/(\d+).*/, "$1")
		return parseInt(id, 10)
	})
}

const getConnectionsForRegion = async (accessToken, region, namespace) => {
	const list = []
	const requestOptions = {
		headers: {
			"Authorization": "Bearer " + accessToken,
			"Battlenet-Namespace": namespace + "-" + region,
		}
	}

	console.log(" ")
	console.log("Getting connection IDs for region", region)

	const ids = await getConnectionIDsForRegion(requestOptions, region)
	if (!ids) return

	console.log("   Found   :", ids.length)

	for (const id of ids) {
		console.log(" ")
		console.log("Getting info for connection", id)

		const item = await getConnection(requestOptions, region, id)

		console.log("   Count :", item.realms.length)
		console.log("   Realms:", item.realms.join(", "))

		list.push(item)
	}

	console.log(" ")
	console.log("Got data for", list.length, "connections")

	return list
}

module.exports = getConnectionsForRegion