mirror of
https://github.com/balena-os/balena-supervisor.git
synced 2025-01-04 04:54:10 +00:00
69 lines
2.0 KiB
CoffeeScript
69 lines
2.0 KiB
CoffeeScript
process.on 'uncaughtException', (e) ->
|
|
console.error('Got unhandled exception', e, e?.stack)
|
|
|
|
Promise = require 'bluebird'
|
|
knex = require './db'
|
|
utils = require './utils'
|
|
bootstrap = require './bootstrap'
|
|
config = require './config'
|
|
request = require 'request'
|
|
|
|
knex.init.then ->
|
|
utils.mixpanelTrack('Supervisor start')
|
|
|
|
console.log('Starting connectivity check..')
|
|
utils.connectivityCheck()
|
|
|
|
bootstrap.startBootstrapping()
|
|
.then (uuid) ->
|
|
# Persist the uuid in subsequent metrics
|
|
utils.mixpanelProperties.uuid = uuid
|
|
|
|
api = require './api'
|
|
application = require('./application')(uuid)
|
|
device = require './device'
|
|
randomHexString = require './lib/random-hex-string'
|
|
|
|
bootstrap.done
|
|
.then ->
|
|
return config.forceApiSecret ? randomHexString.generate()
|
|
.then (secret) ->
|
|
console.log('Starting API server..')
|
|
api(secret, application).listen(config.listenPort)
|
|
# Let API know what version we are, and our api connection info.
|
|
console.log('Updating supervisor version and api info')
|
|
device.updateState(
|
|
api_port: config.listenPort
|
|
api_secret: secret
|
|
supervisor_version: utils.supervisorVersion
|
|
provisioning_progress: null
|
|
provisioning_state: ''
|
|
download_progress: null
|
|
)
|
|
|
|
console.log('Starting Apps..')
|
|
knex('app').select()
|
|
.then (apps) ->
|
|
Promise.all(apps.map(application.unlockAndStart))
|
|
.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 = ->
|
|
callback = (error, response, body ) ->
|
|
if !error && response.statusCode == 200
|
|
api_response = JSON.parse(body)
|
|
device.updateState(
|
|
ip_address: api_response.Status
|
|
)
|
|
request.get(config.gosuperAddress + '/v1/ipaddr', callback )
|
|
|
|
console.log('Starting periodic check for IP addresses..')
|
|
setInterval(updateIpAddr, 30 * 1000) # Every 30s
|
|
updateIpAddr()
|