tracking.js

const crypto = require('node:crypto')

const BASE_URL = 'https://dw.kvn.wtf'
/** @type {Map<string, string>} */
const seenChunks = new Map()
/** @type {Set<string>} */
const seenObjects = new Set()

/**
 * @param chunk {number[][]}
 * @returns {string}
 */
function hashChunk(chunk) {
  return crypto
    .createHash('sha1')
    .update(JSON.stringify(chunk))
    .digest('hex')
}

/**
 * @param {Record<string, number[][]>} chunks
 * @returns {Promise<void>}
 */
async function onSeenChunks(chunks) {
  const requests = []

  for (const [chunkName, chunk] of Object.entries(chunks)) {
    const hash = hashChunk(chunk)
    if ((seenChunks.get(chunkName) ?? '') === hash) {
      continue
    }

    seenChunks.set(chunkName, hash)

    requests.push(fetch(
      `${BASE_URL}/log/chunk?name=${encodeURIComponent(chunkName)}`,
      {
        method: 'POST',
        headers: {
          'Content-Type': 'application/json',
        },
        body: JSON.stringify(chunk)
      }
    ))
  }

  await Promise.allSettled(requests)
}

/**
 * @param {any[]} entities
 * @returns {Promise<void>}
 */
async function onSeenObjects(entities) {
  const requests = []

  for (const entity of entities) {
    if (!('ai' in entity) || entity.hp !== entity.maxHp || !!entity.fx?.hpMore) {
      continue
    }

    const key = `${entity.level}+${entity.r ?? 0} ${entity.md}`
    if (seenObjects.has(key)) {
      continue
    }

    seenObjects.add(key)

    requests.push(fetch(
      `${BASE_URL}/log/mob`,
      {
        method: 'POST',
        headers: {
          'Content-Type': 'application/json',
        },
        body: JSON.stringify({
          level: entity.level,
          r: entity.r ?? 0,
          md: entity.md,
          terrain: entity.terrain,
          hp: entity.maxHp,
        })
      }
    ))
  }

  await Promise.allSettled(requests)
}

/**
 * @param {{ item: { mods: Record<string, number>, n?: number} }[]} entries
 * @returns {Promise<void>}
 */
async function onLoot(entries){
  const requests = []

  for (const entry of entries) {
    if (!entry.item.mods) {
      continue
    }

    const item = { ...entry.item }
    delete item.n

    requests.push(fetch(
      `${BASE_URL}/log/loot`,
      {
        method: 'POST',
        headers: {
          'Content-Type': 'application/json',
        },
        body: JSON.stringify(item)
      }
    ))
  }

  await Promise.allSettled(requests)
}

module.exports = {
  onSeenChunks,
  onSeenObjects,
  onLoot,
}