Event Store Subscription

gistfile1.js

var ges = require('ges-client')
    , connection = ges()
    , shouldSetMetadata = false

connection.on('connect', function() {
  function setMetadata(done) {
    var setData = {
          expectedMetastreamVersion: ges.expectedVersion.emptyStream
        , metadata: ges.createStreamMetadata({
            acl: {
              readRoles: ges.systemRoles.all
            }
          })
        , auth: {
            username: ges.systemUsers.admin
          , password: ges.systemUsers.defaultAdminPassword
          }
        }

    connection.setStreamMetadata('$all', setData, done)
  }

  if(shouldSetMetadata) {
    setMetadata(runSubscription)
  } else {
    runSubscription()
  }

  function runSubscription() {
    var subscription = connection.subscribeToAllFrom()	

    subscription.on('event', function(evt) {
      console.log(evt)
    })

    subscription.on('dropped', function() {
      console.log('dropped')
    })

    subscription.on('error', function(err) {
      console.log(err)
    })
  }
})