Compare commits

..

No commits in common. "master" and "v3.0.0" have entirely different histories.

7 changed files with 36 additions and 55 deletions

View file

@ -26,8 +26,7 @@ export default class Application extends EventEmitter {
getLog: getLog, getLog: getLog,
HttpServer: HttpServer, HttpServer: HttpServer,
request: request, request: request,
}, }
version: '',
} }
this.config = defaults({}, this.ctx.db.config[name]) this.config = defaults({}, this.ctx.db.config[name])
this.provider = provider this.provider = provider
@ -35,6 +34,7 @@ export default class Application extends EventEmitter {
this.updating = false this.updating = false
this.http = new HttpServer(this.config) this.http = new HttpServer(this.config)
this.module = null this.module = null
this.running = ''
this.workers = {} this.workers = {}
// Fresh is used to indicate that when we run the application and it fails, // Fresh is used to indicate that when we run the application and it fails,
@ -390,14 +390,14 @@ export default class Application extends EventEmitter {
runVersion(version) { runVersion(version) {
this.ctx.db.data.core[this.name].active = version this.ctx.db.data.core[this.name].active = version
this.ctx.version = version this.running = version
this.emit('running', this.ctx.version) this.emit('running', this.running)
return this.ctx.db.write().then(() => { return this.ctx.db.write().then(() => {
return this._runVersion(version) return this._runVersion(version)
.catch((err) => { .catch((err) => {
this.ctx.version = '' this.running = ''
this.emit('running', this.ctx.version) this.emit('running', this.running)
return Promise.reject(err) return Promise.reject(err)
}) })
}) })
@ -477,8 +477,8 @@ export default class Application extends EventEmitter {
} }
closeServer() { closeServer() {
this.ctx.version = '' this.running = ''
this.emit('running', this.ctx.version) this.emit('running', this.running)
if (this.config.cluster && !this.isSlave) { if (this.config.cluster && !this.isSlave) {
if (this.__clusterWorkerDied) { if (this.__clusterWorkerDied) {
this.cluster.off('exit', this.__clusterWorkerDied) this.cluster.off('exit', this.__clusterWorkerDied)

View file

@ -29,7 +29,7 @@ export default class GitProvider {
if (this.config.git_required_prefix && !asset.name.startsWith(this.config.git_required_prefix)) continue if (this.config.git_required_prefix && !asset.name.startsWith(this.config.git_required_prefix)) continue
return { return {
version: item.name.replace(/ /g, '_'), version: item.name,
link: asset.browser_download_url, link: asset.browser_download_url,
filename: asset.name, filename: asset.name,
description: item.body, description: item.body,

View file

@ -1,6 +1,6 @@
{ {
"name": "service-core", "name": "service-core",
"version": "3.0.2", "version": "3.0.0",
"description": "Core boiler plate code to install node server as windows service", "description": "Core boiler plate code to install node server as windows service",
"main": "index.mjs", "main": "index.mjs",
"scripts": { "scripts": {

View file

@ -48,11 +48,11 @@ t.describe('#runVersion("static")', function() {
assert.strictEqual(checkCtx.app, app) assert.strictEqual(checkCtx.app, app)
}) })
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.strictEqual(app.fresh, true) assert.strictEqual(app.fresh, true)
let err = await assert.isRejected(app.runVersion('static')) let err = await assert.isRejected(app.runVersion('static'))
assert.strictEqual(app.fresh, false) assert.strictEqual(app.fresh, false)
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.match(err.message, /http/i) assert.match(err.message, /http/i)
assert.match(err.message, /createServer/i) assert.match(err.message, /createServer/i)
@ -64,11 +64,11 @@ t.describe('#runVersion("static")', function() {
app.config.startWaitUntilFail = 50 app.config.startWaitUntilFail = 50
app.registerModule(function() { return new Promise(function() {}) }) app.registerModule(function() { return new Promise(function() {}) })
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.strictEqual(app.fresh, true) assert.strictEqual(app.fresh, true)
let err = await assert.isRejected(app.runVersion('static')) let err = await assert.isRejected(app.runVersion('static'))
assert.strictEqual(app.fresh, false) assert.strictEqual(app.fresh, false)
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.match(err.message, /time/i) assert.match(err.message, /time/i)
assert.match(err.message, /out/i) assert.match(err.message, /out/i)
@ -87,11 +87,11 @@ t.describe('#runVersion("static")', function() {
}) })
}) })
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.strictEqual(app.fresh, true) assert.strictEqual(app.fresh, true)
await app.runVersion('static') await app.runVersion('static')
assert.strictEqual(app.fresh, false) assert.strictEqual(app.fresh, false)
assert.strictEqual(app.ctx.version, 'static') assert.strictEqual(app.running, 'static')
assert.strictEqual(ctx.db.data.core.testapp.active, 'static') assert.strictEqual(ctx.db.data.core.testapp.active, 'static')
}) })
@ -107,11 +107,11 @@ t.describe('#runVersion("static")', function() {
app.config.heartbeatAttemptsWait = 5 app.config.heartbeatAttemptsWait = 5
app.registerModule(defaultHandler(handler)) app.registerModule(defaultHandler(handler))
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.strictEqual(app.fresh, true) assert.strictEqual(app.fresh, true)
let err = await assert.isRejected(app.runVersion('static')) let err = await assert.isRejected(app.runVersion('static'))
assert.strictEqual(app.fresh, false) assert.strictEqual(app.fresh, false)
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.match(err.message, /failed/i) assert.match(err.message, /failed/i)
assert.match(err.message, /400/i) assert.match(err.message, /400/i)
@ -129,13 +129,13 @@ t.describe('#runVersion("static")', function() {
app.config.heartbeatAttemptsWait = 10 app.config.heartbeatAttemptsWait = 10
app.registerModule(defaultHandler(handler)) app.registerModule(defaultHandler(handler))
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.strictEqual(app.fresh, true) assert.strictEqual(app.fresh, true)
let start = performance.now() let start = performance.now()
let err = await assert.isRejected(app.runVersion('static')) let err = await assert.isRejected(app.runVersion('static'))
let end = performance.now() let end = performance.now()
assert.strictEqual(app.fresh, false) assert.strictEqual(app.fresh, false)
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.match(err.message, /failed/i) assert.match(err.message, /failed/i)
assert.match(err.message, /time/i) assert.match(err.message, /time/i)
@ -160,11 +160,11 @@ t.describe('#runVersion("static")', function() {
app.config.heartbeatAttemptsWait = 5 app.config.heartbeatAttemptsWait = 5
app.registerModule(defaultHandler(handler)) app.registerModule(defaultHandler(handler))
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
let err = await assert.isRejected(app.runVersion('static')) let err = await assert.isRejected(app.runVersion('static'))
assert.match(err.message, /failed/i) assert.match(err.message, /failed/i)
assert.match(err.message, /400/i) assert.match(err.message, /400/i)
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
await app.closeServer() await app.closeServer()
app.registerModule(defaultHandler(handler)) app.registerModule(defaultHandler(handler))
@ -185,11 +185,11 @@ t.describe('#runVersion("static")', function() {
app.registerModule(defaultHandler(handler)) app.registerModule(defaultHandler(handler))
app.isSlave = true app.isSlave = true
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.strictEqual(app.fresh, true) assert.strictEqual(app.fresh, true)
await app.runVersion('static') await app.runVersion('static')
assert.strictEqual(app.fresh, false) assert.strictEqual(app.fresh, false)
assert.strictEqual(app.ctx.version, 'static') assert.strictEqual(app.running, 'static')
assert.strictEqual(called, 0) assert.strictEqual(called, 0)
assert.strictEqual(ctx.db.data.core.testapp.active, 'static') assert.strictEqual(ctx.db.data.core.testapp.active, 'static')
@ -240,11 +240,11 @@ t.describe('#runVersion("version")', function() {
app.config.port = assertPort app.config.port = assertPort
stubFsStat.rejects(assertNotError) stubFsStat.rejects(assertNotError)
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.strictEqual(app.fresh, true) assert.strictEqual(app.fresh, true)
let err = await assert.isRejected(app.runVersion('v100')) let err = await assert.isRejected(app.runVersion('v100'))
assert.strictEqual(app.fresh, true) assert.strictEqual(app.fresh, true)
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.notStrictEqual(err, assertNotError) assert.notStrictEqual(err, assertNotError)
assert.match(err.message, new RegExp(assertNotError.message)) assert.match(err.message, new RegExp(assertNotError.message))
@ -262,11 +262,11 @@ t.describe('#runVersion("version")', function() {
await fs.mkdir(util.getPathFromRoot('./testnoexisting/v99'), { recursive: true }) await fs.mkdir(util.getPathFromRoot('./testnoexisting/v99'), { recursive: true })
await fs.writeFile(util.getPathFromRoot('./testnoexisting/v99/index.mjs'), `throw new Error('${assertError.message}')`) await fs.writeFile(util.getPathFromRoot('./testnoexisting/v99/index.mjs'), `throw new Error('${assertError.message}')`)
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.strictEqual(app.fresh, true) assert.strictEqual(app.fresh, true)
let err = await assert.isRejected(app.runVersion('v99')) let err = await assert.isRejected(app.runVersion('v99'))
assert.strictEqual(app.fresh, false) assert.strictEqual(app.fresh, false)
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.notStrictEqual(err, assertError) assert.notStrictEqual(err, assertError)
assert.strictEqual(err.message, assertError.message) assert.strictEqual(err.message, assertError.message)
@ -280,12 +280,12 @@ t.describe('#runVersion("version")', function() {
await fs.mkdir(util.getPathFromRoot('./testnoexisting/v98'), { recursive: true }) await fs.mkdir(util.getPathFromRoot('./testnoexisting/v98'), { recursive: true })
await fs.writeFile(util.getPathFromRoot('./testnoexisting/v98/index.mjs'), ``) await fs.writeFile(util.getPathFromRoot('./testnoexisting/v98/index.mjs'), ``)
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.strictEqual(app.fresh, true) assert.strictEqual(app.fresh, true)
let err = await assert.isRejected(app.runVersion('v98')) let err = await assert.isRejected(app.runVersion('v98'))
assert.strictEqual(app.fresh, false) assert.strictEqual(app.fresh, false)
assert.match(err.message, /start/i) assert.match(err.message, /start/i)
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.strictEqual(app.ctx.db.data.core.testnoexisting.active, 'v98') assert.strictEqual(app.ctx.db.data.core.testnoexisting.active, 'v98')
let checkDb = await lowdb({}, ctx.log, assertConfig) let checkDb = await lowdb({}, ctx.log, assertConfig)
@ -302,11 +302,11 @@ t.describe('#runVersion("version")', function() {
app.ctx.log.info.reset() app.ctx.log.info.reset()
app.ctx.log.event.info.reset() app.ctx.log.event.info.reset()
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.strictEqual(app.fresh, true) assert.strictEqual(app.fresh, true)
await app.runVersion('v97') await app.runVersion('v97')
assert.strictEqual(app.fresh, false) assert.strictEqual(app.fresh, false)
assert.strictEqual(app.ctx.version, 'v97') assert.strictEqual(app.running, 'v97')
assert.ok(app.ctx.log.info.called) assert.ok(app.ctx.log.info.called)
assert.ok(app.ctx.log.event.info.called) assert.ok(app.ctx.log.event.info.called)

View file

@ -74,7 +74,7 @@ t.describe('constructor()', function() {
assert.strictEqual(app.ctx.sc.getLog, getLog) assert.strictEqual(app.ctx.sc.getLog, getLog)
assert.strictEqual(app.name, assertName) assert.strictEqual(app.name, assertName)
assert.strictEqual(app.fresh, true) assert.strictEqual(app.fresh, true)
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.strictEqual(app.monitoringCluster, false) assert.strictEqual(app.monitoringCluster, false)
assert.deepStrictEqual(app.workers, {}) assert.deepStrictEqual(app.workers, {})
assert.strictEqual(app.isSlave, false) assert.strictEqual(app.isSlave, false)
@ -333,9 +333,9 @@ t.describe('#closeServer()', function() {
const assertError = new Error('Moonlight Fiesta') const assertError = new Error('Moonlight Fiesta')
stubCloseServer.rejects(assertError) stubCloseServer.rejects(assertError)
app.ctx.version = assertNotVersion app.running = assertNotVersion
let err = await assert.isRejected(app.closeServer()) let err = await assert.isRejected(app.closeServer())
assert.strictEqual(app.ctx.version, '') assert.strictEqual(app.running, '')
assert.strictEqual(err, assertError) assert.strictEqual(err, assertError)
}) })

View file

@ -16,7 +16,7 @@ t.timeout(5000).describe('#getLatestVersion()', function() {
assert.ok(version.version) assert.ok(version.version)
assert.ok(version.description) assert.ok(version.description)
assert.ok(version.link) assert.ok(version.link)
assert.match(version.link, /\/download\//) assert.match(version.link, /\/attachments\//)
}) })
t.test('should fail if link does not return json repository object', async function() { t.test('should fail if link does not return json repository object', async function() {

View file

@ -20,25 +20,6 @@ t.describe('#getLatestVersion()', function() {
assert.strictEqual(version.log, '') assert.strictEqual(version.log, '')
}) })
t.test('should auto replace spaces with underscores result', async function() {
const assertOriginalName = 'The Smell Of Sea'
const assertCorrectName = 'The_Smell_Of_Sea'
const assertLink = 'Over The Future'
const assertFilename = 'test-sc.7z'
let stubber = stub()
let provider = new GitProvider({}, stubber)
stubber.resolves({ body: [
{ name: assertOriginalName, assets: [{ name: assertFilename, browser_download_url: assertLink }] },
]})
let version = await provider.getLatestVersion()
assert.strictEqual(version.version, assertCorrectName)
assert.strictEqual(version.link, assertLink)
assert.strictEqual(version.filename, assertFilename)
assert.strictEqual(version.log, '')
})
t.test('should skip zip files for now', async function() { t.test('should skip zip files for now', async function() {
const assertName = 'Karen' const assertName = 'Karen'
const assertLink = 'My Wings' const assertLink = 'My Wings'