index.test.js

import test from 'ava'
import got from 'got'

import * as app from './index.js'

const HTTP_PORT = 3001
const STATS_BASE_URL = `http://localhost:${HTTP_PORT}`
const SITE_BASE_URL = `http://localhost:${HTTP_PORT}`

let server, memory
test.beforeEach(async () => {
  await new Promise((resolve) => setTimeout(resolve, 200))
  const result = await app.start({ HTTP_PORT, STATS_BASE_URL, SITE_BASE_URL, DATA_PATH: 'data/test.ljson' }, [])
  server = result.server
  memory = result.memory
})
test.afterEach(() => server.close())

test.serial('starts server (port 3001)', async t => {
  t.is(server.address().port, HTTP_PORT)
  const response = await got(`http://localhost:${HTTP_PORT}`)
  t.is(response.statusCode, 200)
  t.is(response.headers['content-type'], 'text/html; charset=UTF-8')
})

test.serial('blocks bot', async t => {
  const response = await got.post(`http://localhost:${HTTP_PORT}/p`, {
    headers: {
      'User-Agent': 'HeadlessChrome User Agent'
    },
    body: JSON.stringify({
      r: undefined,
      p: 'http://foo.bar/baz',
      w: 1280
    })
  })
  t.is(response.statusCode, 200)
  t.deepEqual(memory, [])
})

test.serial('tracks pageview', async t => {
  const response = await got.post(`http://localhost:${HTTP_PORT}/p`, {
    headers: {
      'User-Agent': 'foo-user-agent'
    },
    body: JSON.stringify({
      r: undefined,
      p: 'http://foo.bar/baz',
      w: 1280
    })
  })
  t.is(response.statusCode, 200)
  t.is(memory.length, 1)
  t.is(memory[0].w, 1280)
  t.is(memory[0].p, 'http://foo.bar/baz')
  t.truthy(memory[0].d)
})

test.serial('tracks heartbeat', async t => {
  const response = await got.post(`http://localhost:${HTTP_PORT}/p`, {
    headers: {
      'User-Agent': 'foo-user-agent'
    },
    body: JSON.stringify({
      t: 'heartbeat',
      r: undefined,
      p: 'http://foo.bar/baz',
      w: 1280
    })
  })
  t.is(response.statusCode, 200)
})

test.serial('tracks event', async t => {
  const response = await got.post(`http://localhost:${HTTP_PORT}/e`, {
    headers: {
      'User-Agent': 'foo-user-agent'
    },
    body: JSON.stringify({
      t: 'event',
      r: undefined,
      p: 'http://foo.bar/baz',
      w: 1280,
      e: 'foo'
    })
  })
  t.is(response.statusCode, 200)
  t.is(memory.length, 1)
  t.is(memory[0].w, 1280)
  t.is(memory[0].p, 'http://foo.bar/baz')
  t.truthy(memory[0].d)
  t.is(memory[0].e, 'foo')
})


test.serial('returns pageviews last h', async t => {
  await got.post(`http://localhost:${HTTP_PORT}/p`, {
    headers: {
      'User-Agent': 'foo-user-agent'
    },
    body: JSON.stringify({
      r: undefined,
      p: 'http://foo.bar/baz',
      w: 1280
    })
  })

  const response = await got(`http://localhost:${HTTP_PORT}/api/today`)
  t.is(response.statusCode, 200)
  const body = JSON.parse(response.body)
  t.is(body.data.length, 1)
  t.is(body.pages.length, 1)
  t.is(body.referrers.length, 1)
  t.is(body.chartData.length, 0)
  t.is(Object.keys(body.live).length, 1)
})

test.serial('returns pageviews for url', async t => {
  const response = await got(`http://localhost:${HTTP_PORT}/api/pageviews/baz`)
  t.is(response.statusCode, 200)
  const body = JSON.parse(response.body)
  t.is(body, 0)
})

test.serial('returns live visitors', async t => {
  await got.post(`http://localhost:${HTTP_PORT}/p`, {
    headers: {
      'User-Agent': 'foo-user-agent'
    },
    body: JSON.stringify({
      r: undefined,
      p: 'http://foo.bar/baz',
      w: 1280
    })
  })

  const response = await got(`http://localhost:${HTTP_PORT}/live`)
  t.is(response.statusCode, 200)
  const body = JSON.parse(response.body)
  t.is(Object.keys(body).length, 1)
})

test.serial('returns tracker script', async t => {
  const response = await got(`http://localhost:${HTTP_PORT}/client.js`)
  t.is(response.statusCode, 200)
  t.is(response.headers['content-type'], 'text/javascript')
  t.true(response.body.includes(STATS_BASE_URL))
})