-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* remove term "provenance database" * detect missing and expired cloud cred errors * order wf ids by created_at DESC * minor cleanup * move cloud cli logic to separate file * fix file name convention * ProvenanceDatabaseConfig * fix ssl setting in ProvenanceDatabase.connect * readme * marked extension as preview in package.json * don't include .github files in packed extension * add current dbos logo to extension * update changelog and version for early adopter release * update CHANGELOG
- Loading branch information
Showing
14 changed files
with
279 additions
and
191 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
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
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,106 @@ | ||
| import * as vscode from 'vscode'; | ||
| import { spawn as cpSpawn } from "child_process"; | ||
| import { execFile } from './utils'; | ||
| import { logger } from './extension'; | ||
|
|
||
| export interface DbosCloudApp { | ||
| Name: string; | ||
| ID: string; | ||
| PostgresInstanceName: string; | ||
| ApplicationDatabaseName: string; | ||
| Status: string; | ||
| Version: string; | ||
| } | ||
|
|
||
| export interface DbosCloudDatabase { | ||
| PostgresInstanceName: string; | ||
| HostName: string; | ||
| Status: string; | ||
| Port: number; | ||
| AdminUsername: string; | ||
| } | ||
|
|
||
| async function dbos_cloud_cli<T>(folder: vscode.WorkspaceFolder, ...args: string[]): Promise<T> { | ||
| const { stdout } = await execFile("npx", ["dbos-cloud", ...args, "--json"], { | ||
| cwd: folder.uri.fsPath, | ||
| }); | ||
| return JSON.parse(stdout) as T; | ||
| } | ||
|
|
||
| export async function dbos_cloud_app_status(folder: vscode.WorkspaceFolder) { | ||
| return dbos_cloud_cli<DbosCloudApp>(folder, "application", "status"); | ||
| } | ||
|
|
||
| export async function dbos_cloud_db_status(folder: vscode.WorkspaceFolder, databaseName: string) { | ||
| return dbos_cloud_cli<DbosCloudDatabase>(folder, "database", "status", databaseName); | ||
| } | ||
|
|
||
| export async function dbos_cloud_login(folder: vscode.WorkspaceFolder) { | ||
| logger.debug("dbos_cloud_login", { folder: folder.uri.fsPath }); | ||
|
|
||
| const cts = new vscode.CancellationTokenSource(); | ||
| const loginProc = cpSpawn("npx", ["dbos-cloud", "login"], { cwd: folder.uri.fsPath }); | ||
| const userCodeEmitter = new vscode.EventEmitter<string>(); | ||
|
|
||
| const regexLoginInfo = /Login URL: (http.*\/activate\?user_code=([A-Z][A-Z][A-Z][A-Z]-[A-Z][A-Z][A-Z][A-Z]))/; | ||
| const regexSuccessfulLogin = /Successfully logged in as (.*)!/; | ||
|
|
||
| try { | ||
| const ctsPromise = new Promise<void>(resolve => { | ||
| cts.token.onCancellationRequested(() => resolve()); | ||
| }); | ||
|
|
||
| loginProc.on('exit', (code) => { logger.debug("dbos_cloud_login on proc exit", { code }); cts.cancel(); }); | ||
| loginProc.on('close', (code) => { logger.debug("dbos_cloud_login on proc close", { code }); cts.cancel(); }); | ||
| loginProc.on('error', err => { logger.error("dbos_cloud_login on proc error", err); cts.cancel(); }); | ||
|
|
||
| loginProc.stdout.on("data", async (buffer: Buffer) => { | ||
| const data = buffer.toString().trim(); | ||
| logger.debug("dbos_cloud_login on stdout data", { data }); | ||
|
|
||
| const loginUrlMatch = regexLoginInfo.exec(data); | ||
| if (loginUrlMatch && loginUrlMatch.length === 3) { | ||
| const [, loginUrl, userCode] = loginUrlMatch; | ||
| logger.info("dbos_cloud_login login info", { loginUri: loginUrl, userCode }); | ||
| userCodeEmitter.fire(userCode); | ||
|
|
||
| const openResult = await vscode.env.openExternal(vscode.Uri.parse(loginUrl)); | ||
| if (!openResult) { | ||
| logger.error("dbos_cloud_login openExternal failed", { loginUri: loginUrl, userCode }); | ||
| cts.cancel(); | ||
| } | ||
| } | ||
|
|
||
| const successfulLoginMatch = regexSuccessfulLogin.exec(data); | ||
| if (successfulLoginMatch && successfulLoginMatch.length === 2) { | ||
| const [, user] = successfulLoginMatch; | ||
| logger.info("dbos-dbos_cloud_login successful login", { user }); | ||
| vscode.window.showInformationMessage(`Successfully logged in to DBOS Cloud as ${user}`); | ||
| } | ||
| }); | ||
|
|
||
| await vscode.window.withProgress({ | ||
| cancellable: true, | ||
| location: vscode.ProgressLocation.Notification, | ||
| title: "Launching browser to log into DBOS Cloud" | ||
| }, async (progress, token) => { | ||
| userCodeEmitter.event(userCode => { | ||
| progress.report({ message: `\nUser code: ${userCode}` }); | ||
| }); | ||
|
|
||
| token.onCancellationRequested(() => cts.cancel()); | ||
| await ctsPromise; | ||
| }); | ||
| } finally { | ||
| loginProc.stdout.removeAllListeners(); | ||
| loginProc.stderr.removeAllListeners(); | ||
| loginProc.removeAllListeners(); | ||
|
|
||
| cts.dispose(); | ||
| userCodeEmitter.dispose(); | ||
|
|
||
| const killed = loginProc.killed; | ||
| const killResult = loginProc.kill(); | ||
| logger.debug("dbos_cloud_login exit", { killed, killResult }); | ||
| } | ||
| } |
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
Oops, something went wrong.