index.js

const HyperExpress = require('hyper-express')
let airdropConfig = require('./airdrop-config.json')
const env = require('./env')
const { initDB, getKeys } = require('./db')

const webserver = new HyperExpress.Server()

async function main() {
  const timeKey = 'Airdrop tracker Server init'
  console.time(timeKey)
  webserver.use((_req, res, next) => {
    res.append('Access-Control-Allow-Origin', '*')
    res.append('Access-Control-Allow-Methods', 'GET,PUT,POST,DELETE,OPTIONS')
    next()
  });

  initDB()

  let router = webserver

  /* 
  const subPath = env.API2_SUBPATH
  if (subPath) {
    router = new HyperExpress.Router()
    webserver.use('/' + subPath, router)
  }
  */

  router.get('/config', getAirdropConfig)
  router.get('/check/:keys', getAirdropInfo)
  router.get('/eigen/:key', getAirdropEigen)
  router.get('/eigens/:key', getAirdropEigens)

  webserver.listen(env.PORT)
    .then(() => {
      console.timeEnd(timeKey)
      console.log('Webserver started on port ' + env.PORT)
    })
    .catch((e) => console.log('Failed to start webserver on port ' + env.PORT, e))
}

main()

async function getAirdropConfig(_, res) {
  successResponse(res, airdropConfig)
}

async function getAirdropInfo(req, res) {
  try {
    const keys = req.params.keys.split(',')
    const data = await getKeys(keys)
    successResponse(res, data)
  } catch (e) {
    console.error(e)
    errorResponse(res, e)
  }
}

async function getAirdropEigen(req, res) {
  try {
    const address = req.params.key
    const data = await getEigenData(address)
    successResponse(res, data)
  } catch (e) {
    console.error(e)
    errorResponse(res, e)
  }
}

function getEigenData(address) {
  return fetch(
    `https://claims.eigenfoundation.org/clique-eigenlayer-api/campaign/eigenlayer/credentials?walletAddress=${address.toLowerCase()}`
  )
    .then((r) => r.json())
    .then((r) => r.data.pipelines)

}

async function getAirdropEigens(req, res) {
  try {
    const addresses = req.params.key.split(',')
    const response = {}

    for (const address of addresses) {
      response[address] = await getEigenData(address)
    }
    successResponse(res, response)
  } catch (e) {
    console.error(e)
    errorResponse(res, e)
  }
}

function successResponse(res, data, cacheMinutes = 30, {
  isJson = true,
  isPost = false,
} = {}) {
  res.setHeaders({
    "Expires": getTimeInFutureMinutes(cacheMinutes) // cache for 5 minutes
  })
  if (isPost)
    res.removeHeader("Expires")

  isJson ? res.json(data) : res.send(data)
}

function errorResponse(res, data = 'Internal server error', {
  statusCode = 400,
} = {}) {
  res.status(statusCode)
  res.send(data, true)
}

function getTimeInFutureMinutes(minutes) {
  const date = new Date();
  // add five minutes to the current time
  date.setMinutes(date.getMinutes() + minutes);
  return date.toUTCString()
}

//pulls config from github every 3 hours
setInterval(() => updateConfig, 1000 * 60 * 60 * 3)

function updateConfig() {
  fetch('https://raw.githubusercontent.com/DefiLlama/airdrop-checker/master/airdrop-config.json')
    .then(res => res.json())
    .then((data) => airdropConfig = data)
    .catch((e) => console.error('Failed to fetch airdrop config', e))
}