v1.1.0

Author: dforsber

dist/cjs/VERSION.d.ts

@@ -1 +1 @@
-export declare const VERSION = "1.0.39";
+export declare const VERSION = "1.1.0";

dist/cjs/VERSION.js

@@ -1,4 +1,4 @@
 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.VERSION = void 0;
-exports.VERSION = "1.0.39";
+exports.VERSION = "1.1.0";

dist/cjs/bdcli/commands/api/bdcli-api-query.d.ts

@@ -0,0 +1 @@
+export {};

dist/cjs/bdcli/commands/api/bdcli-api-query.js

@@ -0,0 +1,58 @@
+"use strict";
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    var desc = Object.getOwnPropertyDescriptor(m, k);
+    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+      desc = { enumerable: true, get: function() { return m[k]; } };
+    }
+    Object.defineProperty(o, k2, desc);
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
+    Object.defineProperty(o, "default", { enumerable: true, value: v });
+}) : function(o, v) {
+    o["default"] = v;
+});
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    __setModuleDefault(result, mod);
+    return result;
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const cmd = __importStar(require("commander"));
+const logger_util_js_1 = require("../../utils/logger_util.js");
+const spinner_util_js_1 = require("../../utils/spinner_util.js");
+const options_util_js_1 = require("../../utils/options_util.js");
+const auth_util_js_1 = require("../../utils/auth_util.js");
+const config_util_js_1 = require("../../utils/config_util.js");
+const output_util_js_1 = require("../../utils/output_util.js");
+const query_js_1 = require("../../../integration/boilingdata/query.js");
+const logger = (0, logger_util_js_1.getLogger)("bdcli-api");
+logger.setLogLevel(logger_util_js_1.ELogLevel.WARN);
+async function query(options, _command) {
+    try {
+        options = await (0, config_util_js_1.combineOptsWithSettings)(options, logger);
+        (0, spinner_util_js_1.updateSpinnerText)("Authenticating");
+        const { idToken: token, cached, region } = await (0, auth_util_js_1.getIdToken)(logger);
+        (0, spinner_util_js_1.updateSpinnerText)(cached ? "Authenticating: cached" : "Authenticating: success");
+        (0, spinner_util_js_1.spinnerSuccess)();
+        (0, spinner_util_js_1.updateSpinnerText)("Sending Query to Boiling API");
+        const results = await (0, query_js_1.runBoilingQuery)(options.sql, token, region, logger);
+        (0, spinner_util_js_1.spinnerSuccess)();
+        await (0, output_util_js_1.outputResults)(results, options.disableSpinner);
+    }
+    catch (err) {
+        (0, spinner_util_js_1.spinnerError)(err?.message);
+    }
+}
+const program = new cmd.Command("bdcli api query")
+    .addOption(new cmd.Option("-s, --sql <sqlQuery>", "SQL clause").makeOptionMandatory())
+    .action(async (options, command) => await query(options, command));
+(async () => {
+    await (0, options_util_js_1.addGlobalOptions)(program, logger);
+    await program.parseAsync(process.argv);
+})();

dist/cjs/bdcli/commands/bdcli-api.js

@@ -3,5 +3,6 @@ Object.defineProperty(exports, "__esModule", { value: true });
 const commander_1 = require("commander");
 const program = new commander_1.Command("bdcli api")
     .executableDir("api")
-    .command("wssurl", "Get signed WebSocket (wss://) URL for connecting to Boiling Data");
+    .command("wssurl", "Get signed WebSocket (wss://) URL for connecting to Boiling Data")
+    .command("query", "Run SQL query on Boiling cloud");
 program.parse(process.argv);

dist/cjs/bdcli/utils/spinner_util.js

@@ -51,8 +51,8 @@ function spinnerWarn(message) {
 }
 exports.spinnerWarn = spinnerWarn;
 function spinnerError(message, forceExit = true) {
-    if (isEnabled)
-        spinner.fail(message ? error(message) : undefined);
+    // We show errors regardless whether the spinner is disabled
+    spinner.fail(message ? error(message) : undefined);
     if (forceExit)
         process.exit(1); // error
 }

dist/cjs/index.js

@@ -35,5 +35,5 @@ program
     .command("aws", "Setup and configure your AWS account integration with BoilingData")
     .command("domain", "Admin setup and configuration for your domain (.e.g @boilingdata.com, @mycompany.com)")
     .command("sandbox", "Managa Boiling S3 Sandboxes with IaC templates")
-    .command("api", "Get signed WSS URL etc.");
+    .command("api", "Boiling query API operations: run SQL, get signed WSS URL etc.");
 program.parse(process.argv);

dist/cjs/integration/boilingdata/query.d.ts

@@ -0,0 +1,2 @@
+import { ILogger } from "../../bdcli/utils/logger_util.js";
+export declare function runBoilingQuery(sql: string, idToken: string, region: string, logger: ILogger): Promise<any[]>;

dist/cjs/integration/boilingdata/query.js

@@ -0,0 +1,29 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.runBoilingQuery = void 0;
+const node_boilingdata_1 = require("@boilingdata/node-boilingdata");
+async function runBoilingQuery(sql, idToken, region, logger) {
+    try {
+        logger.debug({ sql, idToken, region });
+        const bdInstance = new node_boilingdata_1.BoilingData({
+            logLevel: "error",
+            region: region,
+            authcontext: { idToken: { jwtToken: idToken } },
+        });
+        await bdInstance.connect();
+        const start = Date.now();
+        //const sql = `SELECT COUNT(*) FROM parquet_scan('s3://boilingdata-demo/demo.parquet');`;
+        const rows = await bdInstance.execQueryPromise({ sql });
+        const stop = Date.now();
+        const parsedRows = JSON.parse(JSON.stringify(rows));
+        logger.debug(JSON.parse(JSON.stringify(rows)));
+        logger.debug("Query time measured e2e (ms):", stop - start);
+        await bdInstance.close();
+        return parsedRows;
+    }
+    catch (err) {
+        logger.error(err);
+    }
+    return [];
+}
+exports.runBoilingQuery = runBoilingQuery;

dist/esm/VERSION.d.ts

@@ -1 +1 @@
-export declare const VERSION = "1.0.39";
+export declare const VERSION = "1.1.0";