-
Notifications
You must be signed in to change notification settings - Fork 1.8k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat(cubejs-cli): Save deploy credentials
- Loading branch information
1 parent
c523bbb
commit af7e930
Showing
5 changed files
with
204 additions
and
24 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,160 @@ | ||
| const inquirer = require('inquirer'); | ||
| const fs = require('fs-extra'); | ||
| const os = require('os'); | ||
| const path = require('path'); | ||
| const jwt = require('jsonwebtoken'); | ||
| const rp = require('request-promise'); | ||
|
|
||
| class Config { | ||
| async loadConfig() { | ||
| const { configFile } = this.configFile(); | ||
| if (await fs.exists(configFile)) { | ||
| return await fs.readJson(configFile); | ||
| } | ||
| return {}; | ||
| } | ||
|
|
||
| async writeConfig(config) { | ||
| const { cubeCloudConfigPath, configFile } = this.configFile(); | ||
| await fs.mkdirp(cubeCloudConfigPath); | ||
| await fs.writeJson(configFile, config); | ||
| } | ||
|
|
||
| configFile() { | ||
| const cubeCloudConfigPath = this.cubeCloudConfigPath(); | ||
| const configFile = path.join(cubeCloudConfigPath, `config.json`); | ||
| return { cubeCloudConfigPath, configFile }; | ||
| } | ||
|
|
||
| cubeCloudConfigPath() { | ||
| return path.join(os.homedir(), '.cubecloud'); | ||
| } | ||
|
|
||
| async deployAuth(url) { | ||
| if (process.env.CUBE_CLOUD_DEPLOY_AUTH) { | ||
| const payload = jwt.decode(process.env.CUBE_CLOUD_DEPLOY_AUTH); | ||
| if (!payload.url) { | ||
| throw new Error(`Malformed token in CUBE_CLOUD_DEPLOY_AUTH`); | ||
| } | ||
| if (url && payload.url !== url) { | ||
| throw new Error(`CUBE_CLOUD_DEPLOY_AUTH token doesn't match url in .cubecloud`); | ||
| } | ||
| return { | ||
| [payload.url]: { | ||
| auth: process.env.CUBE_CLOUD_DEPLOY_AUTH | ||
| } | ||
| }; | ||
| } | ||
| const config = await this.loadConfig(); | ||
| if (config.auth) { | ||
| return config.auth; | ||
| } else { | ||
| const auth = await inquirer.prompt([{ | ||
| name: 'auth', | ||
| message: `Cube Cloud Auth Token${url ? ` for ${url}` : ''}` | ||
| }]); | ||
| const authToken = auth.auth; | ||
| return (await this.addAuthToken(authToken, config)).auth; | ||
| } | ||
| } | ||
|
|
||
| async addAuthToken(authToken, config) { | ||
| if (!config) { | ||
| config = await this.loadConfig(); | ||
| } | ||
| const payload = jwt.decode(authToken); | ||
| if (!payload || !payload.url) { | ||
| throw `Malformed Cube Cloud token`; | ||
| } | ||
| config.auth = config.auth || {}; | ||
| config.auth[payload.url] = { | ||
| auth: authToken | ||
| }; | ||
| await this.writeConfig(config); | ||
| return config; | ||
| } | ||
|
|
||
| async deployAuthForCurrentDir() { | ||
| const dotCubeCloud = await this.loadDotCubeCloud(); | ||
| if (dotCubeCloud.url && dotCubeCloud.deploymentId) { | ||
| const deployAuth = await this.deployAuth(dotCubeCloud.url); | ||
| if (!deployAuth[dotCubeCloud.url]) { | ||
| throw new Error(`Provided token isn't for ${dotCubeCloud.url}`); | ||
| } | ||
| return { | ||
| ...deployAuth[dotCubeCloud.url], | ||
| url: dotCubeCloud.url, | ||
| deploymentId: dotCubeCloud.deploymentId | ||
| } | ||
| } | ||
| const auth = await this.deployAuth(); | ||
| let url = Object.keys(auth)[0]; | ||
| if (Object.keys(auth).length > 1) { | ||
| url = (await inquirer.prompt([{ | ||
| type: 'list', | ||
| name: 'url', | ||
| message: 'Please select an organization', | ||
| choices: Object.keys(auth) | ||
| }])).url; | ||
| } | ||
| const authToken = auth[url]; | ||
| const deployments = await this.cloudReq({ | ||
| url: () => `build/deploy/deployments`, | ||
| method: 'GET', | ||
| auth: { ...authToken, url } | ||
| }); | ||
| const { deployment } = await inquirer.prompt([{ | ||
| type: 'list', | ||
| name: 'deployment', | ||
| message: 'Please select a deployment to deploy to', | ||
| choices: deployments | ||
| }]); | ||
| const deploymentId = deployments.find(d => d.name === deployment).id; | ||
| await this.writeDotCubeCloud({ | ||
| url, | ||
| deploymentId | ||
| }); | ||
| return { | ||
| ...authToken, | ||
| url, | ||
| deploymentId | ||
| } | ||
| } | ||
|
|
||
| async loadDeployAuth() { | ||
| this.preLoadDeployAuth = await this.deployAuthForCurrentDir(); | ||
| } | ||
|
|
||
| dotCubeCloudFile() { | ||
| return '.cubecloud'; | ||
| } | ||
|
|
||
| async loadDotCubeCloud() { | ||
| if (await fs.exists(this.dotCubeCloudFile())) { | ||
| return await fs.readJson(this.dotCubeCloudFile()); | ||
| } | ||
| return {}; | ||
| } | ||
|
|
||
| async writeDotCubeCloud(config) { | ||
| await fs.writeJson(this.dotCubeCloudFile(), config); | ||
| } | ||
|
|
||
| async cloudReq(options) { | ||
| const { url, auth, ...restOptions } = options; | ||
| const authorization = auth || this.preLoadDeployAuth; | ||
| if (!authorization) { | ||
| throw new Error('Auth isn\'t set'); | ||
| } | ||
| return rp({ | ||
| headers: { | ||
| authorization: authorization.auth | ||
| }, | ||
| ...restOptions, | ||
| url: `${authorization.url}/${url(authorization.deploymentId)}`, | ||
| json: true | ||
| }); | ||
| } | ||
| } | ||
|
|
||
| module.exports = Config; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters