A node-based HTTP API query buffer for Keen.io

keen_client.js.coffee

KeenIO = require 'keen-js'
Q = require 'q'

class KeenClient
  constructor: ->
    @client = new KeenIO(
      projectId: process.env.KEEN_PROJECT_ID
      readKey: process.env.KEEN_READ_KEY
    )
    @started = false
    @queries = []

  start: ->
    unless @started
      setInterval =>
        if @queries.length > 0
          [query, cb] = @queries.shift()
          @client.run(query, cb)
      , 1000
      @started = true

  schedule: (query, cb) ->
    @queries = @queries.concat [[query, cb]]

  scheduleWithPromise: (query) ->
    deferred = Q.defer()
    @schedule(query, (err, response) ->
      if err
        console.log "Query error #{err}"
        deferred.reject(err)
      else
        deferred.resolve(response)
    )
    deferred.promise

KeenClient.Query = KeenIO.Query
module.exports = KeenClient