seneca-kubernetes.js

const request = require('request')
const find_ip = require('get-ip-address')
const get_credentials = require('kubernetes-pod-auth')


function get_pods (k8s_url, done) {
  get_credentials(function (err, ca, token) {

    if (err) {
      return done(err)
    }

    const options = {
      url: `https://${k8s_url}/api/v1/pods`,
      ca: ca,
      headers: {
        "Authorization": "Bearer " + token
      }
    }

    request.get(options, function (err, res, body) {

      if (err) {
        return done(err)
      }

      body = JSON.parse(body)

      const pods = body.items.map(function (item) {
        return {
          status: item.status.phase,
          ip: item.status.podIP,
          labels: item.metadata.labels
        }
      })

      done(null, pods)
    })
  })
}


function kubernetes_plugin (options) {
  const seneca = this

  if (!options.k8s_url) {
    options.k8s_url = 'kubernetes'
  }

  this.add('init:kubernetes', function (args, done) {

    get_pods(options.k8s_url, function got_pods (err, pods) {
      if (err) {
        return done(err)
      }

      seneca.options().plugin.kubernetes = {
        myip: find_ip(),
        pods: pods
      }

      done()
    })

  })

  return 'kubernetes'
}

module.exports = kubernetes_plugin