VimџUnDoе—]эѓmBћdн"Уgћ<ю1…5Дpъ>я¤#EЬ@‹К VЫЫЫЫWЃжщn_РvяяяяJVvяяяVСA%хvxy5Ѓ_РwяяяяJVvяяяVСA&хv…zхwxz5Ѓ_Р„яяяяJVvяяяVСA(хѓ„5Ѓ_РyяяяяxJVvяяяVСA3хy{‡ хy{†5Ѓ_РzяяяяxJVvяяяVСLBхy{‡ app.cull5Ѓ_Ряяяя{VСaФх€х‡5Ѓ_Р{яяяя|VСaкхz|€ app.cullTimeout = 5Ѓ_Р zяяяя|VСb*хz|‰ хz|€5Ѓ_Р {яяяя}VСb,хz|‰ /5Ѓ_Р |яяяя}||vVСb/х{}‰ app.cullTimeout = 10005Ѓ_Р {яяяя}||vVСb1хz|‰ //5Ѓ_Р zяяяя}||vVСb7хz|Љ хz|‰5Ѓ_Р yяяяя~}}vVСb@хy{‹ хy{Љ5Ѓ_Р wяяяя~~vVСbCхwyЊ хwy‹5Ѓ_Р{яяяяЂvVСbLхz|Њ kхy|‹( if (err) return api._registryError()хy{Њ( if (err) return api._registryError()хz|Њ5Ѓ_Р|яяяяЂ|‰v)VСbZх{ЉЊ var app = new App(template) app.node = 9 // the app can be culled immediately after deployment app.cullTimeout = 1e self.logger.info('app created with template {0}, deploying with id {1}'.format(template, app.id)) app.save(function (err) { if (err) {! return api._badDatabase() } return api._success({ id: app.id }) }) })5Ѓ_Р‰яяяяЂ|‰v)VСb\х‰‹Ќ х‰‹Њ5Ѓ_Р{яяяяЂ|‰v)VСb`х{}Ћ х{}Ќ5Ѓ_Р„ яяяяЃ}Љv)VСbmх‚„Ћ if (err) {return api._badDatabase()хѓ…Ћ# return api._badDatabase()5Ѓ_Р„яяяяЃ}‰v)VСboхѓ„ }5Ѓ_РeяяяяЃ}€v)VСbzхde }5Ѓ_РdяяяяЂ|‡v)VСb| хbd‹ if (err) {return api._badDatabase()хce‹ return api._badDatabase()5Ѓ_Рs-яяяяs4s-v-VСbЉ хrtЉ8ClusterManager.prototype.preload = function (req, res) {5Ѓ_Рzяяяяs4s-v-VСb‘хy{Љ if (err) 5Ѓ_Р|яяяяs4s-v-VСcіх{}Љ app.node = 5Ѓ_Рzяяяяs4s-v-VСcЅхz|‹ хz|Љ5Ѓ_Р| яяяяЂ| †v(VСcРх{‡‹! var app = new App(template) app.node = node; // the app can be culled immediately after deployment app.cullTimeout = 1g self.logger.info('app created with template {0}, deploying with id {1}'.format(template, app.id)) app.save(function (err) {* if (err) return api._badDatabase() return api._success({ id: app.id }) })5Ѓ_Р{&яяяяЂ| †v(VСcТхz|‹) async.each(nodes, function (node) {5Ѓ_Р‡яяяяЂ| †v(VСcЧх†€‹ })5Ѓ_Р‡яяяяЂ| †v(VСcШх†€‹ })5Ѓ_Р ‡яяяяЂ| †v(VСcЮх‡‰Њ }х†‰‹ }, function (err)5Ѓ_Р! ‡яяяяЂ| †v(VСcб х‡‰Ќ х‡‰Њ5Ѓ_Р "!€,яяяяЂ| †v(VСcшх‡‰Ќ- if (err) return api._unknownFailure()5Ѓ_Р!#"€,яяяяЂ€,€.v.VСdх‡‰Ќ0 if (err) return api._unknownFailure(err)5Ѓ_Р"$#}яяяяЂ€,€.v.VСd,х|~Ќ app.node = node5Ѓ_Р#%$яяяяЂ€,€.v.VСd;хЃЋ хЃЌ5Ѓ_Р$&%ЃяяяяЃ‰,‰.v.VСdTхЂЃi self.logger.info('app created with template {0}, deploying with id {1}'.format(template, app.id))5Ѓ_Р%'&‰яяяяVСiх‰‹Ћ х‰‹Ќ5Ѓ_Р&('uяяяяVСj[хtvЋ$ var template = req.params.template5Ѓ_Р')(uяяяяuu#v#VСj^хtvЋ$ var template = api.params.template5Ѓ_Р(*)wяяяяuu#v#VСjљхvxЋF self.registry.fetchTemplate(templateName, function (err, template) {5Ѓ_Р)+*яяяяuu#v#VСjБхЏхЋ5Ѓ_Р*,+ѓяяяяvv#v#VСkEх‚„Џ, if (err) return api._badDatabase()5Ѓ_Р+.,‰яяяяvv#v#VСktх€ЉЏ- if (err) return api._unknownFailure()5Ѓ_Р,/-.ѓ@яяяяѓ@ѓQvQVСk~х‚„ЏR if (err) return next(new Error('could not save app')) api._badDatabase()5Ѓ_Р.0/ѓ?яяяяѓ@ѓQvQVСk~х‚„Џ@ if (err) return next(new Error('could not save app')) 5Ѓ_Р/10ѓ>яяяяѓ@ѓQvQVСkЂхѓ…ђ хѓ…Џ5Ѓ_Р021‚яяяяѓ@ѓQvQVСk†х‚„‘ х‚„ђ5Ѓ_Р132„ яяяя„@„QvQVСk€хѓ„? if (err) return next(new Error('could not save app'))5Ѓ_Р243„яяяя„@„QvQVСk‰хѓ„5Ѓ_Р354„ яяяя„@„QvQVСkЉхѓ„ return api._success({5Ѓ_Р465„яяяя„@„QvQVСk‹хѓ„ id: app.id5Ѓ_Р576„ яяяя„@„QvQVСk‹хѓ„ })5Ѓ_Р687† яяяя„@„QvQVСkђх†€Ќ х†€Њ5Ѓ_Р798~яяяяVТђ–х~ЂЋ х~ЂЌ5Ѓ_Р8:9sяяяяVШ’хswЏхsuЋ5Ѓ_Р9;:uяяяяVШ’ хtv‘ *5Ѓ_Р:<;‡ яяяяVШ’сх†€‘ return err5Ѓ_Р;=<‡ яяяяVШ’фх†€‘ if err5Ѓ_Р<>=‡ яяяя‡ ‡vVШ’ч"х†€‘ if err5Ѓ_Р=?>‹яяяяVШ”Йх‹Ќ’ })хЉЌ‘ return api._success()5Ѓ_Р>@?ЊяяяяVШ”КхЊЋ’5Ѓ_Р?A@ЌяяяяVШ”МхЊЌ5Ѓ_Р@BA‹яяяяVШ”М%х‹Ќ“ х‹Ќ’5Ѓ_РACBfяяяяVЮѓю&хeg“ return api._noRecord()5Ѓ_РBDCeяяяяVЮ„ 'хdf“ if (!app) {5Ѓ_РCED% яяяяVЮІх$&“# template: match.template,5Ѓ_РDFE% яяяяVЮІх$&“ name: match.template,5Ѓ_РEGF%яяяяVЮІ!(х$&“# template: match.template,5Ѓ_РFHG%яяяяVЮґYх$&“ template: match.name,5Ѓ_РGIH%яяяяVЮґgх“var _ = require('lodash')var async = require('async')%var format = require('string-format')format.extend(String.prototype)#var App = require('./state/app.js')-var RegistryClient = require('./registry.js')'var KubeClient = require('kube-stream')3var getLogger = require('binder-logging').getLogger$function ClusterManager (db, opts) { this.opts = opts this.db = db* this.registry = new RegistryClient(opts) App.initialize(db)5 this.logger = getLogger('binder-deploy-kubernetes')}/**Z * API handler that responds all applications (potentially only those matching a template) * running on the cluster */>ClusterManager.prototype.getAllApplications = function (api) { var self = this2 var template = api.params['template-name'] || {}Q this.logger.info('getting all applications for template: {0}'.format(template)). App.find(template, function (err, matches) { if (err) { return api._badDatabase() } else {] self.logger.info('successfully got all applications for template {0}'.format(template))4 var formatted = matches.map(function (match) { return { id: match.id,# template: match.template,# location: match.location, status: match.state } })$ return api._success(formatted) } })}/**B * API handler that deploys an application on a Kubernetes cluster */=ClusterManager.prototype.createApplication = function (api) { var self = this0 var templateName = api.params['template-name']Q self.logger.info('creating application with template {0}'.format(templateName))= // TODO pooling is currently disabled until further testing /* if (this.opts.pool.enabled) {[ var appPool = _.find(this.pools.find({ templateName: templateName }), function (pool) {! return pool.available() > 0 }) if (appPool) {+ appPool.assign(function (err, slot) { if (err) {V return res.status(500).send('could not create application: {0}').format(err) } var rsp = { id: slot.id,! location: slot.location } res.json(rsp) }) } else {X res.status(500).send('no pools available for template: {0}'.format(template.name)) } } else { */F self.registry.fetchTemplate(templateName, function (err, template) {( if (err) return api._registryError() var app = new App(template)e self.logger.info('app created with template {0}, deploying with id {1}'.format(template, app.id)) app.save(function (err) { if (err) {! return api._badDatabase() } return api._success({ id: app.id }) }) })}/**G * API handler that gets information assicated with a single deployment */:ClusterManager.prototype.getApplication = function (api) { var self = this, var template = api.params['template-name'] var id = api.params.id[ self.logger.info('getting application with template {0} and id {1}'.format(template, id))/ App.findOne({ id: id }, function (err, app) {& if (err) return api._badDatabase() if (!app || (app === {})) { return api.doesNotExist() } else {] self.logger.info('found application with template {0} and id {1}'.format(template, id)) var formatted = { id: app.id, template: app.template, location: app.location, status: app.state } api._success(formatted) } })}/**4 * Preloads a template onto all nodes of the cluster */3ClusterManager.prototype.preload = function (api) { var self = this, var template = api.params['template-name'] var kube = new KubeClient()B self.registry.fetchTemplate(template, function (err, template) {( if (err) return api._registryError()* kube.nodes.get(function (err, nodes) {+ if (err) return api._badKubeRequest()/ async.each(nodes, function (node, next) {# var app = new App(template)% app.node = node.metadata.name! app.pullPolicy = 'Always'= // the app can be culled immediately after deployment app.cullTimeout = 1X self.logger.info('preloading {0} onto {1}'.format(template, node.metadata.name))! app.save(function (err) { return next(err) }) }, function (err) {* if (err) return api._badDatabase() return api._success({ template: template }) }) }) })}module.exports = ClusterManager5Ѓ_РHJI%яяяяVЮґl)х$&” template: match.name,5Ѓ_РIKJЂяяяяVЮґ«*хЂ‚• хЂ‚”5Ѓ_РJLKlяяяяVЮµхkm• template: app.template,5Ѓ_РKMLlяяяяVЮµ хkm• template: app.tem,5Ѓ_РLNMlяяяяVЮµ хkm• 'template: app.tem,5Ѓ_РMONlяяяяVЮµ+хkm• 'template': app.tem,5Ѓ_РNPOlяяяяll(v(VЮµ°,хkm•) 'template': app['template-name'],5Ѓ_РOQPl$яяяяll(v(VЮµґ-хkm•$ 'template': app.templateName5Ѓ_РPSQlяяяяll(v(VЮ¶/хkm•% 'template': app.templateName,5Ѓ_РQTRSlяяяяll(v(VЮ¶Цхkm•* 'template-name': app.templateName,5Ѓ_РSUTlяяяяll(v(VЮ¶Чхkm•) 'template-name': apptemplateName,5Ѓ_РTVUl%яяяяll(v(VЮ¶Ы0хkm•* 'template-name': app['emplateName,5Ѓ_РUWV% яяяяll(v(VЮ·Eх$&•# template: match.template,5Ѓ_РVXW%яяяяll(v(VЮ·Gх$&•$ 'template: match.template,5Ѓ_РWYX%!яяяяll(v(VЮ·Iх$&•* 'template-name': match.template,5Ѓ_РXZY% яяяяll(v(VЮ·Jх$&•) 'template-name': match.emplate,5Ѓ_РY[Z% яяяяll(v(VЮ·Jх$&•( 'template-name': matchemplate,5Ѓ_РZ\[%"яяяяll(v(VЮ·Mх$&•2 'template-name': match['templae-emplate,5Ѓ_Р[]\%+яяяяll(v(VЮ·Pх$&•3 'template-name': match['template-emplate,5Ѓ_Р\^]%0яяяяll(v(VЮ·Q1х$&•1 'template-name': match['template-name',5Ѓ_Р]_^% яяяя% %!v!VЮ·жх$&•2 'template-name': match['template-name'],5Ѓ_Р^`_% яяяя% %!v!VЮ·зх$&•1 'template-name': match'template-name'],5Ѓ_Р_a`%!яяяя%!%0v0VЮ·йх$&•2 'template-name': match.'template-name'],5Ѓ_Р`balяяяя%!%0v0VЮ·цхkm•. 'template-name': app['template-name'],5Ѓ_Рacblяяяя%!%0v0VЮ·цхkm•- 'template-name': app'template-name'],5Ѓ_Рbdclяяяя%!%0v0VЮ·чхkm•, 'template-name': apptemplate-name'],5Ѓ_Рcedlяяяяll+v+VЮ·щ2хkm•- 'template-name': app.template-name'],5Ѓ_Рdfeяяяяll+v+VЮёІ3х•. App.find(template, function (err, matches) {5Ѓ_РegfяяяяVрт»х— tх– х•5Ѓ_РfhgяяяяVртјх thi5Ѓ_РgihяяяяVртЅх5Ѓ_РhjiяяяяVртѕ4х– х•5Ѓ_Рikj яяяяVртСх ™ }х vх —х –5Ѓ_РjlkяяяяVртЦх› sхљ х ™5Ѓ_Рkml яяяяVртзх› 'start-time': Date5Ѓ_Рlnm яяяяVртк5х› 'start-time': { type: Date5Ѓ_Рmon яяяяVру7х› this.preloaded = this.db.model5Ѓ_РnpoЃяяяяVрухЃѓњ хЃѓ›5Ѓ_РoqpЃяяяяVруGхЃѓќ хЃѓњ5Ѓ_РprqѓяяяяVруKх‚„ќ this.preloaded.5Ѓ_РqsrѓяяяяVруKхѓ…ћ хѓ…ќ5Ѓ_Рrts„яяяяVруQх„†џ х„†ћ5Ѓ_Рsut† яяяя† њv Vру^х…ќџB self.registry.fetchTemplate(template, function (err, template) {( if (err) return api._registryError()* kube.nodes.get(function (err, nodes) {+ if (err) return api._badKubeRequest()/ async.each(nodes, function (node, next) {1 template['template-name'] = template.name# var app = new App(template)% app.node = node.metadata.name! app.pullPolicy = 'Always'= // the app can be culled immediately after deployment app.cullTimeout = 1X self.logger.info('preloading {0} onto {1}'.format(template, node.metadata.name))! app.save(function (err) { return next(err) }) }, function (err) {* if (err) return api._badDatabase() return api._success({ template: template }) }) }) })5Ѓ_Рtvuњяяяя† њv Vру`8хњћ хњћџ5Ѓ_Рuwvѓяяяя† њv Vру‡х‚„ this.preloaded.5Ѓ_РvxwЃяяяя† њv Vру®9хЃѓЎ хЃѓ 5Ѓ_Рwyx„#яяяя‡ ќv Vруєхѓ…Ў# this.preloaded.findOneAndUpdate5Ѓ_Рxzy„яяяя‡ ќv VруП:хѓ…ЎS this.preloaded.findOneAndUpdate({ name: template }, updateOpts, function (err, 5Ѓ_Рy{z„Gяяяя‡ ќv VруУхѓ…ЎI this.preloaded.update({ name: template }, updateOpts, function (err, 5Ѓ_Рz|{„Gяяяя‡ ќv VруФхѓ…ЎH this.preloaded.update({ name: template }, updateOpts, function (err 5Ѓ_Р{}|„Gяяяя‡ ќv VруХх„†ў }хѓ†ЎG this.preloaded.update({ name: template }, updateOpts, function (err5Ѓ_Р|~}„яяяя€ ћv VруЦ;х„†Ј х„†ў5Ѓ_Р}~‡яяяя‰ џv VруЫх€ЉҐ }х‡Љ¤ х‡‰Ј5Ѓ_Р~Ђ 1яяяя‹ Ўv Vрут<х ¦ ;хҐ1 'start-time': { type: Date, default: Date.now }5Ѓ_РЃЂ…*яяяяЊ ўv Vрф=х„†¦J this.preloaded.update({ name: template }, updateOpts, function (err) {5Ѓ_РЂ‚Ѓ‰яяяяЊ ўv Vрф х‰‹§ х‰‹¦5Ѓ_РЃѓ‚ЉяяяяЌ Јv Vрфх‰Љ this5Ѓ_Р‚„ѓ‰яяяя…‡vяяяVрфх‰‹¦5Ѓ_Рѓ…„Љяяяя…‡vяяяVрфх‰Ћ§хЉ‹§5Ѓ_Р„†…Ќяяяя…‡vяяяVрфхЊЌ5Ѓ_Р…‡†Љ5яяяя…‡vяяяVрф>х‰‹©] this.preloaded.update({ name: template, status: 'loading' }, updateOpts, function (err) {5Ѓ_Р†€‡¦яяяя…‡vяяяVрфхЁЄ¬ }х§Є« ]х¦©Є х¦Ё©5Ѓ_Р‡‰€Ёяяяя…‡vяяяVрф$хЁЄ хЁЄ¬5Ѓ_Р€Љ‰© яяяя© ©vVрф‰хЁЄ if (err) return api._badKube5Ѓ_Р‰‹Љ© яяяя©© ©vVрфЏ?хЁЄ if (err) 5Ѓ_РЉЊ‹©"яяяя©© ©vVрф“хЄ¬Ї }х©¬® х©«5Ѓ_Р‹ЌЊЄяяяя©© ©vVрф›@хЄ¬° хЄ¬Ї5Ѓ_РЊЋЌ© яяяя©© ©vVрфЛAхЁЄ°# if (err) self.logger.error(err)5Ѓ_РЌЏЋЄяяяя©© ©vVрфРBх©«° api._success({5Ѓ_РЋђЏ§ яяяя©© ©vVрфХCх©«і pхЁ«І pх§Є± х§©°5Ѓ_РЏ‘ђђяяяя¬ђђvVрфзхЏ‘і* if (err) return api._registryError()5Ѓ_Рђ’‘ђяяяя¬ђђvVрфйхЏ’і$ if (err) {api._registryError()5Ѓ_Р‘“’‘яяяяђђvVрфкх‘“µ х‘“ґ5Ѓ_Р’”“‘яяяя®ђђvVрфлDх‘“¶ х‘“µ5Ѓ_Р“•”•яяяяЇ••vVрфщх”–¶- if (err) return api._badKubeRequest()5Ѓ_Р”–••яяяяЇ••vVрфъх”—¶% if (err)api._badKubeRequest()5Ѓ_Р•—–– яяяя°••vVрфых–ё х–·5Ѓ_Р–—–яяяя±••vVрфэFх–№ х–ё5Ѓ_Р—™ҐяяяяІ••vVрхх¤§№, if (err) return api._badDatabase()5Ѓ_Рљ™¦яяяяі¦¦vVрххҐ§є% return api._badDatabase()5Ѓ_Р™›љ¦яяяяі¦¦vVрххҐ§є api._badDatabase()5Ѓ_Рљњ›¦яяяяі¦¦vVрххҐ§є pi._badDatabase()5Ѓ_Р›ќњ¦яяяяі¦¦vVрхх¦Ё» х¦Ёє5Ѓ_Рњћќ¦ яяяяґ¦¦vVрх х¦Ёј х¦Ё»5Ѓ_РќџћЁ яяяяµ¦¦vVрх)хЁЄЅ хЁЄј5Ѓ_Рћ џЄ яяяя¶¦¦vVрх,х©Є return api._success({5Ѓ_РџЎ Єяяяяµ¦¦vVрх,х©Є template: template5Ѓ_Р ўЎЄ яяяяґ¦¦vVрх,Hх©Є })5Ѓ_РЎЈўёяяяяі¦¦vVрх9х№Ѕј/хё»»хёєє5Ѓ_Рў¤Ј»яяяяі¦¦vVрх<хєјѕ *5Ѓ_РЈҐ¤јяяяяі¦¦vVрх@х»ѕї */хјѕїхјѕѕ5Ѓ_Р¤¦Ґјяяяяі¦¦vVрхKхЅїБ }хјїАхјѕї5Ѓ_РҐ§¦Ѕяяяяі¦¦vVрхVхЅїБ5Ѓ_Р¦Ё§…яяяяі¦¦vVрхcх„†В] this.preloaded.update({ name: template, status: 'loading' }, updateOpts, function (err) {5Ѓ_Р§©ЁЉяяяяі¦¦vVрхeIх‰‹В_ this.preloaded.update({ name: template, status: 'completed' }, updateOpts, function (err) {5Ѓ_РЁЄ©ѕяяяяі¦¦vVрхmхѕАГ sхЅАВ5Ѓ_Р©«Єѕяяяяі¦¦vVрхzJхѕАД хѕАГ5Ѓ_РЄ¬«Аяяяяі¦¦vVрх†хАВЕ }хїВД self.preloaded.find5Ѓ_Р«¬Аяяяяі¦¦vVрхЌKхАВЖ хАВЕ5Ѓ_Р¬®Б%яяяяі¦¦vVрх—хБГЖ5Ѓ_РЇ®А8яяяяі¦¦vVрх›LхїБЗ? self.preloaded.findOne({ name: name }, function (err, name) {5Ѓ_Р®°ЇВяяяяі¦¦vVрхџхВДИ }хБДЗ5Ѓ_РЇ±°Вяяяяі¦¦vVрхЈхВДИ5Ѓ_Р°І±Гяяяяі¦¦vVрх©хВГ5Ѓ_Р±іІГяяяяі¦¦vVрх«MхБГЗ return api._success()хБГИ return api._success({)хВДИ })5Ѓ_РІґіЖяяяяі¦¦vVрх°NхЕЖ5Ѓ_РіµґВяяяяVс FхВДЗ })хБДЖ return api._success(status)5Ѓ_Рґ¶µВяяяяVс RPхВДИ хВДЗ5Ѓ_Рµ·¶ГяяяяVс YQхВДИ template: template5Ѓ_Р¶ё·ѓ*яяяяVс хѓ…Й хѓ…И5Ѓ_Р·№ё„яяяяVс Іхѓ„ var 5Ѓ_Рёє№„ яяяяVс іх„†Й х„†И5Ѓ_Р№»є†*яяяя†*†=v=Vс Вх…‡Й] self.preloaded.update({ name: template, status: 'loading' }, updateOpts, function (err) {5Ѓ_Рєј»†*яяяя†*†=v=Vс Гх…‡ЙI self.preloaded.update({ name: template}, updateOpts, function (err) {5Ѓ_Р»Ѕј†-яяяя†*†=v=Vс ДRх…‡ЙJ self.preloaded.update({ name: template }, updateOpts, function (err) {5Ѓ_РјѕЅЉяяяя†*†=v=Vс ИхЉЊК хЉЊЙ5Ѓ_РЅїѕЊ*яяяяЊЊ"v"Vс Фх‹ЌК_ self.preloaded.update({ name: template, status: 'completed' }, updateOpts, function (err) {5Ѓ_РѕАїЊ.яяяяЊ.ЊBvBVс ШTх‹ЌКa self.preloaded.update({ name: template }, status: 'completed' }, updateOpts, function (err) {5Ѓ_РїБАДяяяяЊ.ЊBvBVс $хГЕК return api._success({ 5Ѓ_РАВБДяяяяЊ.ЊBvBVс &хГЕК! return api._success(status { 5Ѓ_РБГВД яяяяЊ.ЊBvBVс 'хГЕК" return api._success(status) { 5Ѓ_РВДГЕяяяяЊ.ЊBvBVс ,хДЕ template: status5Ѓ_РГЕДЕяяяяЊ.ЊBvBVс .хДЖЙ })5Ѓ_РДЖЕЕяяяяЊ.ЊBvBVс /VхДЕ )5Ѓ_РЕЗЖГяяяяЊ.ЊBvBVс fWхГЕЙ хГЕИ5Ѓ_РЖИЗяяяяWГfх Й'var KubeClient = require('kube-stream')5Ѓ_РЗЙИяяяя$v$WГjх Й'var kubeClient = require('kube-stream')5Ѓ_РИКЙ(яяяя*(v(WГnхЙ-var RegistryClient = require('./registry.js')5Ѓ_РЙЛКяяяя vWГpYхЙ#var App = require('./state/app.js')5Ѓ_РКМЛ‚ яяяя‚ ‚vWГx[хЃѓЙ var kube = new KubeClient()5Ѓ_РЛНМ±яяяяW/Щ\х°ІЙ pre, 5Ѓ_РМОН#яяяяWc›Xх"#Q this.logger.info('getting all applications for template: {0}'.format(template))5Ѓ_РНПО'яяяяWc›[]х&'] self.logger.info('successfully got all applications for template {0}'.format(template))5Ѓ_РОРПhяяяяWc›eхgh[ self.logger.info('getting application with template {0} and id {1}'.format(template, id))5Ѓ_РПСРmяяяяWc›f^хlm] self.logger.info('found application with template {0} and id {1}'.format(template, id))5Ѓ_РРТСБ яяяяWh0схАВЕ! return api._success(status) 5Ѓ_РСУТБяяяяWh0с_хАВЕ return api._success(status) 5Ѓ_РТФУ± яяяя± ±vWu=5х°ІЕ* if (err) return self.logger.error(err)5Ѓ_РУХФ± яяяя± ±vWu=6х°іЕ# if (err) self.logger.error(err)5Ѓ_РФЦХІяяяя± ±vWu=7`хІґЗ хІґЖ5Ѓ_РХЧЦІяяяя± ±vWu=9cхІґИ хІґЗ5Ѓ_РЦШЧі!яяяяі#і!v!Wu=ЌhхІґИ% return api._unknownFailure(err)5Ѓ_РЧЩШkяяяяі#і!v!Wu>(iхjlИ return api.doesNotExist()5Ѓ_РШЪЩkяяяяі#і!v!Wu>XkхjlИ return api._doesNotExist()5Ѓ_РЩЫЪ9яяяяWЃжмlх9;Й х9;И5Ѓ_РЪЫUяяяяWЃжшnхUWК хUWЙ5Ѓ_РQSRlяяяяll(v(VЮ¶Ххkm•) 'template-name': apptemplateName,5Ѓ_Р,.-ѓ@яяяяѓ@ѓRvяяяVСk{х‚…Џ_ if (err) return next(new Error('could not save app')) return api._success({5ЃзЄ