server.js

import './env.js'
import './jobs/index.js'
import transcript from './api/transcript.js'
import { getTotalHosts, getOpenHosts, getCurrentlyActiveUsers } from "./api/state.js";
import express from 'express'
import responseTime from 'response-time'
import bugsnag from './bugsnag.js'
import metrics from './metrics.js'
import routes from './routes.js'

const app = express()

app.use(bugsnag().requestHandler)
app.use(express.json())
app.use(express.urlencoded({extended: true}))
app.use(responseTime(function (req, res, time) {
app.use(express.static('public'))
app.use(bugsnag().errorHandler)
  const stat = (req.method + req.url.split('?')[0]).toLowerCase()
    .replace(/[:.]/g, '')
    .replace(/\//g, '_')
  const httpCode = res.statusCode
  const timingStatKey = `http.response.${stat}`
  const codeStatKey = `http.response.${stat}.${httpCode}`
  metrics.timing(timingStatKey, time)
  metrics.increment(codeStatKey, 1)
}))

app.use(responseTime(function (req, res, time) {
  const stat = (req.method + req.url.split('?')[0]).toLowerCase()
    .replace(/[:.]/g, '')
    .replace(/\//g, '_')
  const httpCode = res.statusCode
  const timingStatKey = `http.response.${stat}`
  const codeStatKey = `http.response.${stat}.${httpCode}`
  metrics.timing(timingStatKey, time)
  metrics.increment(codeStatKey, 1)
}))

app.get('/ping', (req, res) => {
  res.send('pong!')
})

// create endpoints for all files in the /api directory
routes(app)

const port = process.env.PORT || 0
const listener = app.listen(port, () => {
  console.log(transcript('startup', {port: listener.address().port}))
})


// Spit out global metrics every 1s
setInterval(async () => {
  const total = await getTotalHosts()
  const open = await getOpenHosts()
  const active_users = await getCurrentlyActiveUsers();

  metrics.gauge("hosts.open", open)
  metrics.gauge("hosts.total", total)
  metrics.gauge("app.active_users", active_users);
}, 1000 * 60);