'use strict'

const http = require('http')
const { Tags, FORMAT_HTTP_HEADERS } = require('opentracing')
const MetricsTracer = require('../src')

const prometheusReporter = new MetricsTracer.PrometheusReporter()
const metricsTracer = new MetricsTracer('my-server', [prometheusReporter])
const PORT = process.env.PORT || 3000

const server = http.createServer((req, res) => {
  // Instrumentation
  const requestSpan = metricsTracer.startSpan('http_request', {
    childOf: metricsTracer.extract(FORMAT_HTTP_HEADERS, req.headers)
  })
  const headers = {}

  metricsTracer.inject(requestSpan, FORMAT_HTTP_HEADERS, headers)

  requestSpan.setTag(Tags.HTTP_URL, req.url)
  requestSpan.setTag(Tags.HTTP_METHOD, req.method || 'GET')
  requestSpan.setTag(Tags.HTTP_STATUS_CODE, 200)
  requestSpan.setTag(Tags.SPAN_KIND_RPC_CLIENT, true)

  // Dummy router: GET /metrics
  if (req.url === '/metrics') {
    requestSpan.finish()

    res.writeHead(200, {
      'Content-Type': MetricsTracer.PrometheusReporter.Prometheus.register.contentType
    })
    res.end(prometheusReporter.metrics())
    return
  }

  // My child operation like DB access
  const childOperationSpan = metricsTracer.startSpan('my_operation', {
    childOf: requestSpan
  })

  setTimeout(() => {
    childOperationSpan.finish()

    res.writeHead(200, headers)
    res.end('Ok')

    requestSpan.finish()
  }, 30)
})

server.listen(PORT, (err) => {
  // eslint-disable-next-line
  console.log(err || `Server is listening on ${PORT}`)
})