94 lines
2.8 KiB
JavaScript
94 lines
2.8 KiB
JavaScript
'use strict'
|
|
|
|
const path = require('path')
|
|
const githubAuth = require('../../lib/github-auth')
|
|
const serverSecrets = require('../../lib/server-secrets')
|
|
const log = require('../../lib/log')
|
|
const RedisTokenPersistence = require('../../lib/redis-token-persistence')
|
|
const FsTokenPersistence = require('../../lib/fs-token-persistence')
|
|
const GithubApiProvider = require('./github-api-provider')
|
|
const { setRoutes: setAdminRoutes } = require('./auth/admin')
|
|
const { setRoutes: setAcceptorRoutes } = require('./auth/acceptor')
|
|
|
|
// Convenience class with all the stuff related to the Github API and its
|
|
// authorization tokens, to simplify server initialization.
|
|
class GithubConstellation {
|
|
constructor(config) {
|
|
this._debugEnabled = config.service.debug.enabled
|
|
this._debugIntervalSeconds = config.service.debug.intervalSeconds
|
|
|
|
const { redisUrl, dir: persistenceDir } = config.persistence
|
|
if (config.persistence.redisUrl) {
|
|
log(`RedisTokenPersistence configured with ${redisUrl}`)
|
|
this.persistence = new RedisTokenPersistence({
|
|
url: redisUrl,
|
|
key: 'githubUserTokens',
|
|
})
|
|
} else {
|
|
const userTokensPath = path.resolve(
|
|
persistenceDir,
|
|
'github-user-tokens.json'
|
|
)
|
|
log(`FsTokenPersistence configured with ${userTokensPath}`)
|
|
this.persistence = new FsTokenPersistence({ path: userTokensPath })
|
|
}
|
|
|
|
const baseUrl = process.env.GITHUB_URL || 'https://api.github.com'
|
|
this.apiProvider = new GithubApiProvider({ baseUrl })
|
|
}
|
|
|
|
scheduleDebugLogging() {
|
|
if (this._debugEnabled) {
|
|
this.debugInterval = setInterval(() => {
|
|
log(githubAuth.serializeDebugInfo())
|
|
}, 1000 * this._debugIntervalSeconds)
|
|
}
|
|
}
|
|
|
|
async initialize(server) {
|
|
this.scheduleDebugLogging()
|
|
|
|
try {
|
|
await this.persistence.initialize()
|
|
} catch (e) {
|
|
log.error(e)
|
|
}
|
|
|
|
// Register for this event after `initialize()` finishes, so we don't
|
|
// catch `token-added` events for the initial tokens, which would be
|
|
// inefficient, though it wouldn't break anything.
|
|
githubAuth.emitter.on('token-added', this.persistence.noteTokenAdded)
|
|
githubAuth.emitter.on('token-removed', this.persistence.noteTokenRemoved)
|
|
|
|
setAdminRoutes(server)
|
|
|
|
if (serverSecrets.gh_client_id && serverSecrets.gh_client_secret) {
|
|
setAcceptorRoutes(server)
|
|
}
|
|
}
|
|
|
|
async stop() {
|
|
if (this.debugInterval) {
|
|
clearInterval(this.debugInterval)
|
|
this.debugInterval = undefined
|
|
}
|
|
|
|
githubAuth.emitter.removeListener(
|
|
'token-added',
|
|
this.persistence.noteTokenAdded
|
|
)
|
|
githubAuth.emitter.removeListener(
|
|
'token-removed',
|
|
this.persistence.noteTokenRemoved
|
|
)
|
|
|
|
try {
|
|
await this.persistence.stop()
|
|
} catch (e) {
|
|
log.error(e)
|
|
}
|
|
}
|
|
}
|
|
|
|
module.exports = GithubConstellation
|