balena-supervisor/src/app.coffee
2015-10-13 13:28:00 -03:00

72 lines
2.1 KiB
CoffeeScript

Promise = require 'bluebird'
fs = Promise.promisifyAll(require('fs'))
os = require 'os'
knex = require './db'
utils = require './utils'
bootstrap = require './bootstrap'
config = require './config'
utils.mixpanelTrack('Supervisor start')
console.log('Starting connectivity check..')
utils.connectivityCheck()
knex('config').select('value').where(key: 'uuid').then ([ uuid ]) ->
if not uuid?.value
console.log('New device detected. Bootstrapping..')
retryingBootstrap = ->
utils.mixpanelTrack('Device bootstrap')
bootstrap().catch (err) ->
utils.mixpanelTrack('Device bootstrap failed, retrying', {error: err, delay: config.bootstrapRetryDelay})
Promise.delay(config.bootstrapRetryDelay)
.then(retryingBootstrap)
retryingBootstrap()
else
uuid.value
.then (uuid) ->
# Persist the uuid in subsequent metrics
utils.mixpanelProperties.uuid = uuid
api = require './api'
application = require './application'
supervisor = require './supervisor-update'
vpn = require './lib/vpn'
console.log('Starting OpenVPN..')
setImmediate(vpn.connect)
console.log('Starting API server..')
api.listen(80)
console.log('Starting Apps..')
knex('app').select()
.then (apps) ->
Promise.all(apps.map(application.start))
.catch (error) ->
console.error('Error starting apps:', error)
.then ->
utils.mixpanelTrack('Start application update poll', {interval: config.appUpdatePollInterval})
setInterval(->
application.update()
, config.appUpdatePollInterval)
application.update()
updateIpAddr = ->
utils.findIpAddrs().then (ipAddrs) ->
application.updateDeviceInfo(
ip_address: ipAddrs.join(' ')
)
console.log('Starting periodic check for IP addresses..')
setInterval(updateIpAddr, 30 * 1000) # Every 30s
updateIpAddr()
# Tell the supervisor updater that we have successfully started, so that it can do whatever it needs to.
supervisor.startupSuccessful()
# Let API know we are running a new version
console.log('Updating supervisor version:', utils.supervisorVersion)
application.updateDeviceInfo(
supervisor_version: utils.supervisorVersion
)