azure-kusto-data - npm Package Compare versions

Comparing version 6.0.2 to 7.0.0-alpha.0

dist-esm/src/client.js

@@ -1,25 +0,19 @@
-"use strict";
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
-var __importDefault = (this && this.__importDefault) || function (mod) {
-    return (mod && mod.__esModule) ? mod : { "default": mod };
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.KustoClient = void 0;
-const core_util_1 = require("@azure/core-util");
-const axios_1 = __importDefault(require("axios"));
-const http_1 = __importDefault(require("http"));
-const https_1 = __importDefault(require("https"));
-const uuid_1 = require("uuid");
-const clientRequestProperties_1 = __importDefault(require("./clientRequestProperties"));
-const cloudSettings_1 = __importDefault(require("./cloudSettings"));
-const connectionBuilder_1 = __importDefault(require("./connectionBuilder"));
-const errors_1 = require("./errors");
-const kustoTrustedEndpoints_1 = require("./kustoTrustedEndpoints");
-const response_1 = require("./response");
-const security_1 = __importDefault(require("./security"));
-const timeUtils_1 = require("./timeUtils");
-const COMMAND_TIMEOUT_IN_MILLISECS = (0, timeUtils_1.toMilliseconds)(0, 10, 30);
-const QUERY_TIMEOUT_IN_MILLISECS = (0, timeUtils_1.toMilliseconds)(0, 4, 30);
-const CLIENT_SERVER_DELTA_IN_MILLISECS = (0, timeUtils_1.toMilliseconds)(0, 0, 30);
+import { isNode } from "@azure/core-util";
+import axios from "axios";
+import http from "http";
+import https from "https";
+import { v4 as uuidv4 } from "uuid";
+import ClientRequestProperties from "./clientRequestProperties.js";
+import CloudSettings from "./cloudSettings.js";
+import ConnectionStringBuilder from "./connectionBuilder.js";
+import { ThrottlingError } from "./errors.js";
+import { kustoTrustedEndpoints } from "./kustoTrustedEndpoints.js";
+import { KustoResponseDataSetV1, KustoResponseDataSetV2 } from "./response.js";
+import AadHelper from "./security.js";
+import { toMilliseconds } from "./timeUtils.js";
+const COMMAND_TIMEOUT_IN_MILLISECS = toMilliseconds(0, 10, 30);
+const QUERY_TIMEOUT_IN_MILLISECS = toMilliseconds(0, 4, 30);
+const CLIENT_SERVER_DELTA_IN_MILLISECS = toMilliseconds(0, 0, 30);
 const MGMT_PREFIX = ".";
@@ -33,7 +27,7 @@ var ExecutionType;
 })(ExecutionType || (ExecutionType = {}));
-class KustoClient {
+export class KustoClient {
     constructor(kcsb) {
-        this.cancelToken = axios_1.default.CancelToken.source();
+        this.cancelToken = axios.CancelToken.source();
         this._isClosed = false;
-        this.connectionString = typeof kcsb === "string" ? new connectionBuilder_1.default(kcsb) : kcsb;
+        this.connectionString = typeof kcsb === "string" ? new ConnectionStringBuilder(kcsb) : kcsb;
         if (!this.connectionString.dataSource) {
@@ -54,7 +48,7 @@ throw new Error("Cluster url is required");
         };
-        this.aadHelper = new security_1.default(this.connectionString);
+        this.aadHelper = new AadHelper(this.connectionString);
         let headers = {
             Accept: "application/json",
         };
-        if (core_util_1.isNode) {
+        if (isNode) {
             headers = Object.assign(Object.assign({}, headers), { "Accept-Encoding": "gzip,deflate", Connection: "Keep-Alive" });
@@ -70,9 +64,9 @@ }
         // http and https are Node modules and are not found in browsers
-        if (core_util_1.isNode) {
+        if (isNode) {
             // keepAlive pools and reuses TCP connections, so it's faster
-            axiosProps.httpAgent = new http_1.default.Agent({ keepAlive: true });
-            axiosProps.httpsAgent = new https_1.default.Agent({ keepAlive: true });
+            axiosProps.httpAgent = new http.Agent({ keepAlive: true });
+            axiosProps.httpsAgent = new https.Agent({ keepAlive: true });
         }
         axiosProps.cancelToken = this.cancelToken.token;
-        this.axiosInstance = axios_1.default.create(axiosProps);
+        this.axiosInstance = axios.create(axiosProps);
     }
@@ -105,3 +99,3 @@ async execute(db, query, properties) {
         if (clientRequestId) {
-            properties = new clientRequestProperties_1.default();
+            properties = new ClientRequestProperties();
             properties.clientRequestId = clientRequestId;
@@ -113,3 +107,3 @@ }
         this.ensureOpen();
-        kustoTrustedEndpoints_1.kustoTrustedEndpoints.validateTrustedEndpoint(endpoint, (await cloudSettings_1.default.getCloudInfoForCluster(this.cluster)).LoginEndpoint);
+        kustoTrustedEndpoints.validateTrustedEndpoint(endpoint, (await CloudSettings.getCloudInfoForCluster(this.cluster)).LoginEndpoint);
         db = this.getDb(db);
@@ -136,3 +130,3 @@ const headers = {};
             clientRequestPrefix = "KNC.executeStreamingIngest;";
-            if (core_util_1.isNode) {
+            if (isNode) {
                 headers["Content-Encoding"] = "gzip";
@@ -156,3 +150,3 @@ headers["Content-Type"] = "application/octet-stream";
         let kustoHeaders = this.connectionString.clientDetails().getHeaders();
-        kustoHeaders["x-ms-client-request-id"] = `${clientRequestPrefix}${(0, uuid_1.v4)()}`;
+        kustoHeaders["x-ms-client-request-id"] = `${clientRequestPrefix}${uuidv4()}`;
         if (properties != null) {
@@ -196,3 +190,3 @@ kustoHeaders = Object.assign(Object.assign({}, kustoHeaders), properties.getHeaders());
         catch (error) {
-            if (axios_1.default.isAxiosError(error)) {
+            if (axios.isAxiosError(error)) {
                 // Since it's impossible to modify the error request object, the only way to censor the Authorization header is to remove it.
@@ -209,3 +203,3 @@ error.request = undefined;
                 if (error.response && error.response.status === 429) {
-                    throw new errors_1.ThrottlingError("POST request failed with status 429 (Too Many Requests)", error);
+                    throw new ThrottlingError("POST request failed with status 429 (Too Many Requests)", error);
                 }
@@ -225,6 +219,6 @@ }
             if (executionType === ExecutionType.Query) {
-                kustoResponse = new response_1.KustoResponseDataSetV2(response);
+                kustoResponse = new KustoResponseDataSetV2(response);
             }
             else {
-                kustoResponse = new response_1.KustoResponseDataSetV1(response);
+                kustoResponse = new KustoResponseDataSetV1(response);
             }
@@ -265,4 +259,3 @@ }
 }
-exports.KustoClient = KustoClient;
-exports.default = KustoClient;
+export default KustoClient;
 //# sourceMappingURL=client.js.map

dist-esm/src/clientDetails.js

@@ -1,13 +0,10 @@
-"use strict";
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.ClientDetails = void 0;
-const core_util_1 = require("@azure/core-util");
-const os_1 = require("os");
-const version_1 = require("./version");
+import { isNode } from "@azure/core-util";
+import { userInfo } from "os";
+import { SDK_VERSION } from "./version.js";
 // This regex allows all printable ascii, except spaces and chars we use in the format
 const ReplaceRegex = /[^\w.\-()]/g;
 const None = "[none]";
-class ClientDetails {
+export class ClientDetails {
     constructor(applicationNameForTracing, userNameForTracing) {
@@ -26,3 +23,3 @@ this.applicationNameForTracing = applicationNameForTracing;
         var _a, _b;
-        if (core_util_1.isNode) {
+        if (isNode) {
             return ((_a = process === null || process === void 0 ? void 0 : process.env) === null || _a === void 0 ? void 0 : _a.npm_package_name) || (process === null || process === void 0 ? void 0 : process.argv[1]) || None;
@@ -36,6 +33,6 @@ }
         var _a, _b, _c, _d, _e;
-        if (core_util_1.isNode) {
+        if (isNode) {
             let username;
             try {
-                username = (0, os_1.userInfo)().username;
+                username = userInfo().username;
             }
@@ -58,4 +55,4 @@ catch (err) {
         return this.formatHeader([
-            ["Kusto.JavaScript.Client", version_1.SDK_VERSION],
-            ["Runtime." + (core_util_1.isNode ? "Node" : "Browser"), (core_util_1.isNode ? process.version : (_a = window === null || window === void 0 ? void 0 : window.navigator) === null || _a === void 0 ? void 0 : _a.userAgent) || None],
+            ["Kusto.JavaScript.Client", SDK_VERSION],
+            ["Runtime." + (isNode ? "Node" : "Browser"), (isNode ? process.version : (_a = window === null || window === void 0 ? void 0 : window.navigator) === null || _a === void 0 ? void 0 : _a.userAgent) || None],
         ]);
@@ -93,3 +90,2 @@ }
 }
-exports.ClientDetails = ClientDetails;
 //# sourceMappingURL=clientDetails.js.map

dist-esm/src/clientRequestProperties.js

@@ -1,7 +0,4 @@
-"use strict";
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.ClientRequestProperties = void 0;
-class ClientRequestProperties {
+export class ClientRequestProperties {
     constructor(options, parameters, clientRequestId, user, application) {
@@ -72,10 +69,11 @@ this._options = options || {};
     _msToTimespan(duration) {
-        const milliseconds = Math.floor((duration % 1000) / 100);
+        const milliseconds = duration % 1000;
         const seconds = Math.floor((duration / 1000) % 60);
         const minutes = Math.floor((duration / (1000 * 60)) % 60);
         const hours = Math.floor((duration / (1000 * 60 * 60)) % 24);
-        const hoursStr = hours < 10 ? `0${hours}` : String(hours);
-        const minutesStr = minutes < 10 ? `0${minutes}` : String(minutes);
-        const secondsStr = seconds < 10 ? `0${seconds}` : String(seconds);
-        return `${hoursStr}:${minutesStr}:${secondsStr}.${milliseconds}`;
+        const hoursStr = String(hours).padStart(2, "0");
+        const minutesStr = String(minutes).padStart(2, "0");
+        const secondsStr = String(seconds).padStart(2, "0");
+        const millisecondsStr = String(milliseconds).padStart(3, "0");
+        return `${hoursStr}:${minutesStr}:${secondsStr}.${millisecondsStr}`;
     }
@@ -96,4 +94,3 @@ getHeaders() {
 }
-exports.ClientRequestProperties = ClientRequestProperties;
-exports.default = ClientRequestProperties;
+export default ClientRequestProperties;
 //# sourceMappingURL=clientRequestProperties.js.map

dist-esm/src/cloudSettings.js

@@ -1,11 +0,7 @@
-"use strict";
-var __importDefault = (this && this.__importDefault) || function (mod) {
-    return (mod && mod.__esModule) ? mod : { "default": mod };
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.CloudSettings = void 0;
+var _a, _b;
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
-const axios_1 = __importDefault(require("axios"));
-const core_util_1 = require("@azure/core-util");
+import axios from "axios";
+import { isNode } from "@azure/core-util";
+const AXIOS_ERR_NETWORK = (_b = (_a = axios === null || axios === void 0 ? void 0 : axios.AxiosError) === null || _a === void 0 ? void 0 : _a.ERR_NETWORK) !== null && _b !== void 0 ? _b : "ERR_NETWORK";
 /**
@@ -40,3 +36,3 @@ * This class holds data for all cloud instances, and returns the specific data instance by parsing the dns suffix from a URL
         try {
-            const response = await axios_1.default.get(kustoUri + this.METADATA_ENDPOINT, {
+            const response = await axios.get(kustoUri + this.METADATA_ENDPOINT, {
                 headers: {
@@ -63,5 +59,5 @@ "Cache-Control": "no-cache",
         catch (ex) {
-            if (axios_1.default.isAxiosError(ex)) {
+            if (axios.isAxiosError(ex)) {
                 // Axios library has a bug in browser, not propagating the status code, see: https://github.com/axios/axios/issues/5330
-                if ((((_a = ex.response) === null || _a === void 0 ? void 0 : _a.status) === 404 && core_util_1.isNode) || (ex.code === axios_1.default.AxiosError.ERR_NETWORK && !core_util_1.isNode)) {
+                if ((isNode && ((_a = ex.response) === null || _a === void 0 ? void 0 : _a.status) === 404) || (!isNode && (!ex.code || ex.code === AXIOS_ERR_NETWORK))) {
                     // For now as long not all proxies implement the metadata endpoint, if no endpoint exists return public cloud data
@@ -90,4 +86,4 @@ this.cloudCache[kustoUri] = this.defaultCloudInfo;
 const cloudSettings = new CloudSettings();
-exports.CloudSettings = cloudSettings;
-exports.default = cloudSettings;
+export { cloudSettings as CloudSettings };
+export default cloudSettings;
 //# sourceMappingURL=cloudSettings.js.map

dist-esm/src/connectionBuilder.browser.js

@@ -1,12 +0,6 @@
-"use strict";
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
-var __importDefault = (this && this.__importDefault) || function (mod) {
-    return (mod && mod.__esModule) ? mod : { "default": mod };
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.KustoConnectionStringBuilder = void 0;
-const connectionBuilderBase_1 = __importDefault(require("./connectionBuilderBase"));
+import KustoConnectionStringBuilderBase from "./connectionBuilderBase.js";
 /* eslint-disable @typescript-eslint/no-unused-vars */
-class KustoConnectionStringBuilder extends connectionBuilderBase_1.default {
+export class KustoConnectionStringBuilder extends KustoConnectionStringBuilderBase {
     static withAadUserPasswordAuthentication(_connectionString, _userId, _password, _authorityId) {
@@ -79,6 +73,5 @@ throw new Error("Not supported in browser - use withUserPrompt instead");
 }
-exports.KustoConnectionStringBuilder = KustoConnectionStringBuilder;
 KustoConnectionStringBuilder.DefaultDatabaseName = "NetDefaultDB";
 KustoConnectionStringBuilder.SecretReplacement = "****";
-exports.default = KustoConnectionStringBuilder;
+export default KustoConnectionStringBuilder;
 //# sourceMappingURL=connectionBuilder.browser.js.map

dist-esm/src/connectionBuilder.js

@@ -1,7 +0,4 @@
-"use strict";
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.KustoConnectionStringBuilder = void 0;
-const connectionBuilderBase_1 = require("./connectionBuilderBase");
+import { KustoConnectionStringBuilderBase } from "./connectionBuilderBase.js";
 /*
@@ -11,3 +8,3 @@ * A builder for Kusto connection strings
  */
-class KustoConnectionStringBuilder extends connectionBuilderBase_1.KustoConnectionStringBuilderBase {
+export class KustoConnectionStringBuilder extends KustoConnectionStringBuilderBase {
     static withAadUserPasswordAuthentication(connectionString, userId, password, authorityId) {
@@ -147,6 +144,5 @@ if (userId.trim().length === 0)
 }
-exports.KustoConnectionStringBuilder = KustoConnectionStringBuilder;
 KustoConnectionStringBuilder.DefaultDatabaseName = "NetDefaultDB";
 KustoConnectionStringBuilder.SecretReplacement = "****";
-exports.default = KustoConnectionStringBuilder;
+export default KustoConnectionStringBuilder;
 //# sourceMappingURL=connectionBuilder.js.map

dist-esm/src/connectionBuilderBase.js

@@ -1,8 +0,5 @@
-"use strict";
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.KustoConnectionStringBuilderBase = exports.KeywordMapping = void 0;
-const clientDetails_1 = require("./clientDetails");
-exports.KeywordMapping = Object.freeze({
+import { ClientDetails } from "./clientDetails.js";
+export const KeywordMapping = Object.freeze({
     dataSource: {
@@ -56,4 +53,4 @@ mappedTo: "Data Source",
     const _key = key.trim().toLowerCase();
-    for (const keyword of Object.keys(exports.KeywordMapping)) {
-        const k = exports.KeywordMapping[keyword];
+    for (const keyword of Object.keys(KeywordMapping)) {
+        const k = KeywordMapping[keyword];
         if (!k) {
@@ -68,3 +65,3 @@ continue;
 };
-class KustoConnectionStringBuilderBase {
+export class KustoConnectionStringBuilderBase {
     constructor(connectionString) {
@@ -99,3 +96,3 @@ var _a;
     clientDetails() {
-        return new clientDetails_1.ClientDetails(this.applicationNameForTracing, this.userNameForTracing);
+        return new ClientDetails(this.applicationNameForTracing, this.userNameForTracing);
     }
@@ -114,3 +111,3 @@ /**
     setConnectorDetails(name, version, appName, appVersion, sendUser = false, overrideUser, additionalFields) {
-        const clientDetails = clientDetails_1.ClientDetails.setConnectorDetails(name, version, appName, appVersion, sendUser, overrideUser, additionalFields);
+        const clientDetails = ClientDetails.setConnectorDetails(name, version, appName, appVersion, sendUser, overrideUser, additionalFields);
         this.applicationNameForTracing = clientDetails.applicationNameForTracing;
@@ -120,3 +117,3 @@ this.userNameForTracing = clientDetails.userNameForTracing;
     toString(removeSecrets = true) {
-        return Object.entries(exports.KeywordMapping)
+        return Object.entries(KeywordMapping)
             .map(([key, mappingType]) => {
@@ -136,6 +133,5 @@ const value = this[key];
 }
-exports.KustoConnectionStringBuilderBase = KustoConnectionStringBuilderBase;
 KustoConnectionStringBuilderBase.DefaultDatabaseName = "NetDefaultDB";
 KustoConnectionStringBuilderBase.SecretReplacement = "****";
-exports.default = KustoConnectionStringBuilderBase;
+export default KustoConnectionStringBuilderBase;
 //# sourceMappingURL=connectionBuilderBase.js.map

dist-esm/src/errors.js

@@ -1,7 +0,4 @@
-"use strict";
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.ThrottlingError = exports.KustoAuthenticationError = void 0;
-class KustoAuthenticationError extends Error {
+export class KustoAuthenticationError extends Error {
     constructor(message, inner, tokenProviderName, context) {
@@ -15,4 +12,3 @@ super(message);
 }
-exports.KustoAuthenticationError = KustoAuthenticationError;
-class ThrottlingError extends Error {
+export class ThrottlingError extends Error {
     constructor(message, inner) {
@@ -24,3 +20,2 @@ super(message);
 }
-exports.ThrottlingError = ThrottlingError;
 //# sourceMappingURL=errors.js.map

dist-esm/src/index.js

@@ -1,54 +0,14 @@
-"use strict";
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
-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;
-};
-var __importDefault = (this && this.__importDefault) || function (mod) {
-    return (mod && mod.__esModule) ? mod : { "default": mod };
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.TimeUtils = exports.MatchRule = exports.kustoTrustedEndpoints = exports.KustoResultTable = exports.KustoResultRow = exports.KustoResultColumn = exports.KustoResponseDataSet = exports.KustoDataErrors = exports.KustoConnectionStringBuilder = exports.CloudSettings = exports.ClientRequestProperties = exports.Client = void 0;
-const client_1 = __importDefault(require("./client"));
-exports.Client = client_1.default;
-const clientRequestProperties_1 = __importDefault(require("./clientRequestProperties"));
-exports.ClientRequestProperties = clientRequestProperties_1.default;
-const cloudSettings_1 = __importDefault(require("./cloudSettings"));
-exports.CloudSettings = cloudSettings_1.default;
-const connectionBuilder_1 = __importDefault(require("./connectionBuilder"));
-exports.KustoConnectionStringBuilder = connectionBuilder_1.default;
-const KustoDataErrors = __importStar(require("./errors"));
-exports.KustoDataErrors = KustoDataErrors;
-const kustoTrustedEndpoints_1 = require("./kustoTrustedEndpoints");
-Object.defineProperty(exports, "kustoTrustedEndpoints", { enumerable: true, get: function () { return kustoTrustedEndpoints_1.kustoTrustedEndpoints; } });
-Object.defineProperty(exports, "MatchRule", { enumerable: true, get: function () { return kustoTrustedEndpoints_1.MatchRule; } });
-const models_1 = require("./models");
-Object.defineProperty(exports, "KustoResultColumn", { enumerable: true, get: function () { return models_1.KustoResultColumn; } });
-Object.defineProperty(exports, "KustoResultRow", { enumerable: true, get: function () { return models_1.KustoResultRow; } });
-Object.defineProperty(exports, "KustoResultTable", { enumerable: true, get: function () { return models_1.KustoResultTable; } });
-const response_1 = require("./response");
-Object.defineProperty(exports, "KustoResponseDataSet", { enumerable: true, get: function () { return response_1.KustoResponseDataSet; } });
-const timeUtils_1 = require("./timeUtils");
-const TimeUtils = { toMilliseconds: timeUtils_1.toMilliseconds };
-exports.TimeUtils = TimeUtils;
+import KustoClient from "./client.js";
+import ClientRequestProperties from "./clientRequestProperties.js";
+import { CloudSettings } from "./cloudSettings.js";
+import KustoConnectionStringBuilder from "./connectionBuilder.js";
+import * as KustoDataErrors from "./errors.js";
+import { kustoTrustedEndpoints, MatchRule } from "./kustoTrustedEndpoints.js";
+import { KustoResultColumn, KustoResultRow, KustoResultTable } from "./models.js";
+import { KustoResponseDataSet } from "./response.js";
+import { toMilliseconds } from "./timeUtils.js";
+const TimeUtils = { toMilliseconds };
+export { KustoClient as Client, ClientRequestProperties, CloudSettings, KustoConnectionStringBuilder, KustoDataErrors, KustoResponseDataSet, KustoResultColumn, KustoResultRow, KustoResultTable, kustoTrustedEndpoints, MatchRule, TimeUtils, };
 //# sourceMappingURL=index.js.map

dist-esm/src/kustoTrustedEndpoints.js

@@ -1,12 +0,6 @@
-"use strict";
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
-var __importDefault = (this && this.__importDefault) || function (mod) {
-    return (mod && mod.__esModule) ? mod : { "default": mod };
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.kustoTrustedEndpoints = exports.FastSuffixMatcher = exports.MatchRule = void 0;
-const utils_1 = require("./utils");
-const wellKnownKustoEndpoints_json_1 = __importDefault(require("./wellKnownKustoEndpoints.json"));
-class MatchRule {
+import { getStringTailLowerCase } from "./utils.js";
+import { default as endpointsData } from "./wellKnownKustoEndpoints.json";
+export class MatchRule {
     constructor(
@@ -26,4 +20,3 @@ /**
 }
-exports.MatchRule = MatchRule;
-class FastSuffixMatcher {
+export class FastSuffixMatcher {
     constructor(rules) {
@@ -34,3 +27,3 @@ this.rules = {};
         rules === null || rules === void 0 ? void 0 : rules.forEach((rule) => {
-            const suffix = (0, utils_1.getStringTailLowerCase)(rule.suffix, this._suffixLength);
+            const suffix = getStringTailLowerCase(rule.suffix, this._suffixLength);
             if (!processedRules[suffix]) {
@@ -47,3 +40,3 @@ processedRules[suffix] = [];
         }
-        const matchRules = this.rules[(0, utils_1.getStringTailLowerCase)(candidate, this._suffixLength)];
+        const matchRules = this.rules[getStringTailLowerCase(candidate, this._suffixLength)];
         if (matchRules) {
@@ -70,3 +63,2 @@ for (const rule of matchRules) {
 }
-exports.FastSuffixMatcher = FastSuffixMatcher;
 class KustoTrustedEndpointsImpl {
@@ -77,3 +69,3 @@ constructor() {
         this.overrideMatcher = null; // We could unify this with matchers, but separating makes debugging easier
-        const etr = Object.entries(wellKnownKustoEndpoints_json_1.default.AllowedEndpointsByLogin);
+        const etr = Object.entries(endpointsData.AllowedEndpointsByLogin);
         for (const [k, v] of etr) {
@@ -144,3 +136,3 @@ const rules = [];
 }
-exports.kustoTrustedEndpoints = new KustoTrustedEndpointsImpl();
+export const kustoTrustedEndpoints = new KustoTrustedEndpointsImpl();
 //# sourceMappingURL=kustoTrustedEndpoints.js.map

dist-esm/src/models.js

@@ -1,8 +0,5 @@
-"use strict";
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.KustoResultTable = exports.KustoResultColumn = exports.KustoResultRow = exports.WellKnownDataSet = void 0;
-const timeUtils_1 = require("./timeUtils");
-var WellKnownDataSet;
+import { parseKustoTimestampToMillis } from "./timeUtils.js";
+export var WellKnownDataSet;
 (function (WellKnownDataSet) {
@@ -13,5 +10,5 @@ WellKnownDataSet["PrimaryResult"] = "PrimaryResult";
     WellKnownDataSet["QueryProperties"] = "QueryProperties";
-})(WellKnownDataSet || (exports.WellKnownDataSet = WellKnownDataSet = {}));
+})(WellKnownDataSet || (WellKnownDataSet = {}));
 const defaultDatetimeParser = (t) => (t ? new Date(t) : null);
-const defaultTimespanParser = timeUtils_1.parseKustoTimestampToMillis;
+const defaultTimespanParser = parseKustoTimestampToMillis;
 /**
@@ -22,3 +19,3 @@ * Represents a Kusto result row.
  */
-class KustoResultRow {
+export class KustoResultRow {
     constructor(columns, row, dateTimeParser = defaultDatetimeParser, timeSpanParser = defaultTimespanParser) {
@@ -71,4 +68,3 @@ this.columns = columns.sort((a, b) => a.ordinal - b.ordinal);
 }
-exports.KustoResultRow = KustoResultRow;
-class KustoResultColumn {
+export class KustoResultColumn {
     constructor(columnObj, ordinal) {
@@ -82,4 +78,3 @@ var _a, _b;
 }
-exports.KustoResultColumn = KustoResultColumn;
-class KustoResultTable {
+export class KustoResultTable {
     constructor(tableObj) {
@@ -140,3 +135,2 @@ this._dateTimeParser = defaultDatetimeParser;
 }
-exports.KustoResultTable = KustoResultTable;
 //# sourceMappingURL=models.js.map

dist-esm/src/response.js

@@ -1,7 +0,4 @@
-"use strict";
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.KustoResponseDataSetV2 = exports.KustoResponseDataSetV1 = exports.KustoResponseDataSet = void 0;
-const models_1 = require("./models");
+import { KustoResultTable, WellKnownDataSet } from "./models.js";
 var ErrorLevels;
@@ -12,3 +9,3 @@ (function (ErrorLevels) {
 })(ErrorLevels || (ErrorLevels = {}));
-class KustoResponseDataSet {
+export class KustoResponseDataSet {
     constructor(tables) {
@@ -23,9 +20,9 @@ let _tables = tables;
         for (const table of _tables) {
-            const resultTable = new models_1.KustoResultTable(table);
+            const resultTable = new KustoResultTable(table);
             this.tables.push(resultTable);
             this.tableNames.push(resultTable.name);
-            if (resultTable.kind === models_1.WellKnownDataSet.PrimaryResult) {
+            if (resultTable.kind === WellKnownDataSet.PrimaryResult) {
                 this.primaryResults.push(resultTable);
             }
-            else if (resultTable.kind === models_1.WellKnownDataSet.QueryCompletionInformation) {
+            else if (resultTable.kind === WellKnownDataSet.QueryCompletionInformation) {
                 this.statusTable = resultTable;
@@ -88,5 +85,4 @@ }
 }
-exports.KustoResponseDataSet = KustoResponseDataSet;
 // TODO: should only expose 1 response type, versioning should be handled internally
-class KustoResponseDataSetV1 extends KustoResponseDataSet {
+export class KustoResponseDataSetV1 extends KustoResponseDataSet {
     getStatusColumn() {
@@ -103,6 +99,6 @@ return "StatusDescription";
         return {
-            QueryResult: models_1.WellKnownDataSet.PrimaryResult,
-            QueryProperties: models_1.WellKnownDataSet.QueryProperties,
-            QueryStatus: models_1.WellKnownDataSet.QueryCompletionInformation,
-            PrimaryResult: models_1.WellKnownDataSet.PrimaryResult,
+            QueryResult: WellKnownDataSet.PrimaryResult,
+            QueryProperties: WellKnownDataSet.QueryProperties,
+            QueryStatus: WellKnownDataSet.QueryCompletionInformation,
+            PrimaryResult: WellKnownDataSet.PrimaryResult,
         };
@@ -115,3 +111,3 @@ }
             if (this.tables[0].kind === undefined) {
-                this.tables[0].kind = models_1.WellKnownDataSet.PrimaryResult;
+                this.tables[0].kind = WellKnownDataSet.PrimaryResult;
                 this.primaryResults.push(this.tables[0]);
@@ -121,3 +117,3 @@ }
             if (this.tables.length === 2) {
-                this.tables[1].kind = models_1.WellKnownDataSet.QueryProperties;
+                this.tables[1].kind = WellKnownDataSet.QueryProperties;
                 this.tables[1].id = 1;
@@ -128,3 +124,3 @@ }
             const toc = this.tables[this.tables.length - 1];
-            toc.kind = models_1.WellKnownDataSet.TableOfContents;
+            toc.kind = WellKnownDataSet.TableOfContents;
             toc.id = this.tables.length - 1;
@@ -136,3 +132,3 @@ for (let i = 0; i < this.tables.length - 1; i++) {
                 this.tables[i].kind = KustoResponseDataSetV1.getTablesKinds()[current.Kind];
-                if (this.tables[i].kind === models_1.WellKnownDataSet.PrimaryResult) {
+                if (this.tables[i].kind === WellKnownDataSet.PrimaryResult) {
                     this.primaryResults.push(this.tables[i]);
@@ -145,5 +141,4 @@ }
 }
-exports.KustoResponseDataSetV1 = KustoResponseDataSetV1;
 // TODO: should only expose 1 response type, versioning should be handled internally
-class KustoResponseDataSetV2 extends KustoResponseDataSet {
+export class KustoResponseDataSetV2 extends KustoResponseDataSet {
     getStatusColumn() {
@@ -181,3 +176,2 @@ return "Payload";
 }
-exports.KustoResponseDataSetV2 = KustoResponseDataSetV2;
 //# sourceMappingURL=response.js.map

dist-esm/src/security.js

@@ -1,31 +0,5 @@
-"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 });
-exports.AadHelper = void 0;
-const TokenProvider = __importStar(require("./tokenProvider"));
-const errors_1 = require("./errors");
-const tokenProvider_1 = require("./tokenProvider");
-class AadHelper {
+import * as TokenProvider from "./tokenProvider.js";
+import { KustoAuthenticationError } from "./errors.js";
+import { BasicTokenProvider, CallbackTokenProvider, UserPromptProvider, TokenCredentialProvider } from "./tokenProvider.js";
+export class AadHelper {
     constructor(kcsb) {
@@ -51,9 +25,9 @@ if (!kcsb.dataSource) {
         else if (kcsb.accessToken) {
-            this.tokenProvider = new tokenProvider_1.BasicTokenProvider(kcsb.dataSource, kcsb.accessToken);
+            this.tokenProvider = new BasicTokenProvider(kcsb.dataSource, kcsb.accessToken);
         }
         else if (kcsb.useUserPromptAuth) {
-            this.tokenProvider = new tokenProvider_1.UserPromptProvider(kcsb.dataSource, kcsb.interactiveCredentialOptions, kcsb.timeoutMs);
+            this.tokenProvider = new UserPromptProvider(kcsb.dataSource, kcsb.interactiveCredentialOptions, kcsb.timeoutMs);
         }
         else if (kcsb.tokenProvider) {
-            this.tokenProvider = new tokenProvider_1.CallbackTokenProvider(kcsb.dataSource, kcsb.tokenProvider);
+            this.tokenProvider = new CallbackTokenProvider(kcsb.dataSource, kcsb.tokenProvider);
         }
@@ -64,3 +38,3 @@ else if (kcsb.useDeviceCodeAuth) {
         else if (kcsb.tokenCredential) {
-            this.tokenProvider = new tokenProvider_1.TokenCredentialProvider(kcsb.dataSource, kcsb.tokenCredential, kcsb.timeoutMs);
+            this.tokenProvider = new TokenCredentialProvider(kcsb.dataSource, kcsb.tokenCredential, kcsb.timeoutMs);
         }
@@ -77,8 +51,7 @@ }
         catch (e) {
-            throw new errors_1.KustoAuthenticationError(e instanceof Error ? e.message : `${e}`, e instanceof Error ? e : undefined, this.tokenProvider.constructor.name, this.tokenProvider.context());
+            throw new KustoAuthenticationError(e instanceof Error ? e.message : `${e}`, e instanceof Error ? e : undefined, this.tokenProvider.constructor.name, this.tokenProvider.context());
         }
     }
 }
-exports.AadHelper = AadHelper;
-exports.default = AadHelper;
+export default AadHelper;
 //# sourceMappingURL=security.js.map

dist-esm/src/timeUtils.js

@@ -1,13 +0,9 @@
-"use strict";
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.parseKustoTimestampToMillis = exports.toMilliseconds = void 0;
-function toMilliseconds(hours, minutes, seconds) {
+export function toMilliseconds(hours, minutes, seconds) {
     return (hours * 60 * 60 + minutes * 60 + seconds) * 1000;
 }
-exports.toMilliseconds = toMilliseconds;
 // Format: [+|-]d.hh:mm:ss[.fffffff]
 const TimespanRegex = /^(-?)(?:(\d+).)?(\d{2}):(\d{2}):(\d{2}(\.\d+)?$)/;
-function parseKustoTimestampToMillis(t) {
+export function parseKustoTimestampToMillis(t) {
     if (t == null || t === "") {
@@ -27,3 +23,2 @@ return null;
 }
-exports.parseKustoTimestampToMillis = parseKustoTimestampToMillis;
 //# sourceMappingURL=timeUtils.js.map

dist-esm/src/tokenProvider.js

@@ -1,8 +0,5 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.ApplicationKeyTokenProvider = exports.ApplicationCertificateTokenProvider = exports.DeviceLoginTokenProvider = exports.UserPassTokenProvider = exports.AzCliTokenProvider = exports.MsiTokenProvider = exports.UserPromptProvider = exports.TokenCredentialProvider = exports.AzureIdentityProvider = exports.CloudSettingsTokenProvider = exports.CallbackTokenProvider = exports.BasicTokenProvider = exports.TokenProviderBase = void 0;
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
-const identity_1 = require("@azure/identity");
-const cloudSettings_1 = require("./cloudSettings");
+import { AzureCliCredential, ManagedIdentityCredential, ClientSecretCredential, ClientCertificateCredential, DeviceCodeCredential, UsernamePasswordCredential, InteractiveBrowserCredential, } from "@azure/identity";
+import { CloudSettings } from "./cloudSettings.js";
 const BEARER_TYPE = "Bearer";
@@ -13,3 +10,3 @@ /**
  */
-class TokenProviderBase {
+export class TokenProviderBase {
     context() {
@@ -26,7 +23,6 @@ return {};
 }
-exports.TokenProviderBase = TokenProviderBase;
 /**
  * Basic Token Provider keeps and returns a token received on construction
  */
-class BasicTokenProvider extends TokenProviderBase {
+export class BasicTokenProvider extends TokenProviderBase {
     constructor(kustoUri, token) {
@@ -43,7 +39,6 @@ super(kustoUri);
 }
-exports.BasicTokenProvider = BasicTokenProvider;
 /**
  * Callback Token Provider generates a token based on a callback function provided by the caller
  */
-class CallbackTokenProvider extends TokenProviderBase {
+export class CallbackTokenProvider extends TokenProviderBase {
     constructor(kustoUri, callback) {
@@ -58,7 +53,6 @@ super(kustoUri);
 }
-exports.CallbackTokenProvider = CallbackTokenProvider;
 /**
  * Token providers that require cloud settings to be configured - msal and azure identity
  */
-class CloudSettingsTokenProvider extends TokenProviderBase {
+export class CloudSettingsTokenProvider extends TokenProviderBase {
     additionalCloudSettingsInit() { }
@@ -72,3 +66,3 @@ constructor(kustoUri) {
             if (this.cloudInfo == null) {
-                this.cloudInfo = await cloudSettings_1.CloudSettings.getCloudInfoForCluster(this.kustoUri);
+                this.cloudInfo = await CloudSettings.getCloudInfoForCluster(this.kustoUri);
                 let resourceUri = this.cloudInfo.KustoServiceResourceId;
@@ -94,4 +88,3 @@ if (this.cloudInfo.LoginMfaRequired) {
 }
-exports.CloudSettingsTokenProvider = CloudSettingsTokenProvider;
-class AzureIdentityProvider extends CloudSettingsTokenProvider {
+export class AzureIdentityProvider extends CloudSettingsTokenProvider {
     constructor(kustoUri, authorityId, timeoutMs) {
@@ -125,7 +118,6 @@ super(kustoUri);
 }
-exports.AzureIdentityProvider = AzureIdentityProvider;
 /**
  * TokenCredentialProvider receives any TokenCredential to create a token with.
  */
-class TokenCredentialProvider extends AzureIdentityProvider {
+export class TokenCredentialProvider extends AzureIdentityProvider {
     constructor(kustoUri, tokenCredential, timeoutMs) {
@@ -139,7 +131,6 @@ super(kustoUri, undefined, timeoutMs);
 }
-exports.TokenCredentialProvider = TokenCredentialProvider;
 /**
  * UserPromptProvider will pop up a login prompt to acquire a token.
  */
-class UserPromptProvider extends AzureIdentityProvider {
+export class UserPromptProvider extends AzureIdentityProvider {
     constructor(kustoUri, interactiveCredentialOptions, timeoutMs) {
@@ -154,3 +145,3 @@ super(kustoUri, interactiveCredentialOptions === null || interactiveCredentialOptions === void 0 ? void 0 : interactiveCredentialOptions.tenantId, timeoutMs);
         var _a, _b, _c, _d;
-        return new identity_1.InteractiveBrowserCredential(Object.assign(Object.assign({}, this.interactiveCredentialOptions), { tenantId: this.authorityId, clientId: (_b = (_a = this.interactiveCredentialOptions) === null || _a === void 0 ? void 0 : _a.clientId) !== null && _b !== void 0 ? _b : this.cloudInfo.KustoClientAppId, redirectUri: (_d = (_c = this.interactiveCredentialOptions) === null || _c === void 0 ? void 0 : _c.redirectUri) !== null && _d !== void 0 ? _d : `http://localhost:${this.getRandomPortInRange()}/` }));
+        return new InteractiveBrowserCredential(Object.assign(Object.assign({}, this.interactiveCredentialOptions), { tenantId: this.authorityId, clientId: (_b = (_a = this.interactiveCredentialOptions) === null || _a === void 0 ? void 0 : _a.clientId) !== null && _b !== void 0 ? _b : this.cloudInfo.KustoClientAppId, redirectUri: (_d = (_c = this.interactiveCredentialOptions) === null || _c === void 0 ? void 0 : _c.redirectUri) !== null && _d !== void 0 ? _d : `http://localhost:${this.getRandomPortInRange()}/` }));
     }
@@ -169,3 +160,2 @@ getRandomPortInRange() {
 }
-exports.UserPromptProvider = UserPromptProvider;
 /**
@@ -175,3 +165,3 @@ * MSI Token Provider obtains a token from the MSI endpoint
  */
-class MsiTokenProvider extends AzureIdentityProvider {
+export class MsiTokenProvider extends AzureIdentityProvider {
     constructor(kustoUri, clientId, authorityId, timeoutMs) {
@@ -182,3 +172,3 @@ super(kustoUri, authorityId, timeoutMs);
     getCredential() {
-        return this.clientId ? new identity_1.ManagedIdentityCredential(this.clientId) : new identity_1.ManagedIdentityCredential();
+        return this.clientId ? new ManagedIdentityCredential(this.clientId) : new ManagedIdentityCredential();
     }
@@ -189,16 +179,14 @@ context() {
 }
-exports.MsiTokenProvider = MsiTokenProvider;
 /**
  * AzCli Token Provider obtains a refresh token from the AzCli cache and uses it to authenticate with MSAL
  */
-class AzCliTokenProvider extends AzureIdentityProvider {
+export class AzCliTokenProvider extends AzureIdentityProvider {
     getCredential() {
-        return new identity_1.AzureCliCredential();
+        return new AzureCliCredential();
     }
 }
-exports.AzCliTokenProvider = AzCliTokenProvider;
 /**
  * Acquire a token from MSAL with username and password
  */
-class UserPassTokenProvider extends AzureIdentityProvider {
+export class UserPassTokenProvider extends AzureIdentityProvider {
     constructor(kustoUri, userName, password, authorityId, timeoutMs) {
@@ -210,3 +198,3 @@ super(kustoUri, authorityId, timeoutMs);
     getCredential() {
-        return new identity_1.UsernamePasswordCredential(this.authorityId, this.cloudInfo.KustoClientAppId, this.userName, this.password);
+        return new UsernamePasswordCredential(this.authorityId, this.cloudInfo.KustoClientAppId, this.userName, this.password);
     }
@@ -217,7 +205,6 @@ context() {
 }
-exports.UserPassTokenProvider = UserPassTokenProvider;
 /**
  * Acquire a token from  Device Login flow
  */
-class DeviceLoginTokenProvider extends AzureIdentityProvider {
+export class DeviceLoginTokenProvider extends AzureIdentityProvider {
     constructor(kustoUri, deviceCodeCallback, authorityId, timeoutMs) {
@@ -228,3 +215,3 @@ super(kustoUri, authorityId, timeoutMs);
     getCredential() {
-        return new identity_1.DeviceCodeCredential({
+        return new DeviceCodeCredential({
             tenantId: this.authorityId,
@@ -236,3 +223,2 @@ clientId: this.cloudInfo.KustoClientAppId,
 }
-exports.DeviceLoginTokenProvider = DeviceLoginTokenProvider;
 /**
@@ -242,3 +228,3 @@ * Acquire a token from MSAL using application certificate
  */
-class ApplicationCertificateTokenProvider extends AzureIdentityProvider {
+export class ApplicationCertificateTokenProvider extends AzureIdentityProvider {
     constructor(kustoUri, appClientId, certPrivateKey, certPath, sendX5c, authorityId, timeoutMs) {
@@ -253,3 +239,3 @@ super(kustoUri, authorityId, timeoutMs);
         if (this.certPrivateKey) {
-            return new identity_1.ClientCertificateCredential(this.authorityId, this.appClientId, {
+            return new ClientCertificateCredential(this.authorityId, this.appClientId, {
                 certificate: this.certPrivateKey,
@@ -260,3 +246,3 @@ }, {
         }
-        return new identity_1.ClientCertificateCredential(this.authorityId, this.appClientId, this.certPath, {
+        return new ClientCertificateCredential(this.authorityId, this.appClientId, this.certPath, {
             sendCertificateChain: this.sendX5c,
@@ -269,7 +255,6 @@ });
 }
-exports.ApplicationCertificateTokenProvider = ApplicationCertificateTokenProvider;
 /**
  * Acquire a token from MSAL with application id and Key
  */
-class ApplicationKeyTokenProvider extends AzureIdentityProvider {
+export class ApplicationKeyTokenProvider extends AzureIdentityProvider {
     constructor(kustoUri, appClientId, appKey, authorityId, timeoutMs) {
@@ -281,3 +266,3 @@ super(kustoUri, authorityId, timeoutMs);
     getCredential() {
-        return new identity_1.ClientSecretCredential(this.authorityId, // The tenant ID in Azure Active Directory
+        return new ClientSecretCredential(this.authorityId, // The tenant ID in Azure Active Directory
         this.appClientId, // The app registration client Id in the AAD tenant
@@ -291,3 +276,2 @@ this.appKey // The app registration secret for the registered application
 }
-exports.ApplicationKeyTokenProvider = ApplicationKeyTokenProvider;
 //# sourceMappingURL=tokenProvider.js.map

dist-esm/src/typeUtilts.js

@@ -1,5 +0,4 @@
-"use strict";
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
-Object.defineProperty(exports, "__esModule", { value: true });
+export {};
 //# sourceMappingURL=typeUtilts.js.map

dist-esm/src/utils.js

@@ -1,7 +0,4 @@
-"use strict";
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.getStringTailLowerCase = void 0;
-function getStringTailLowerCase(val, tailLength) {
+export function getStringTailLowerCase(val, tailLength) {
     if (tailLength <= 0) {
@@ -15,3 +12,2 @@ return "";
 }
-exports.getStringTailLowerCase = getStringTailLowerCase;
 //# sourceMappingURL=utils.js.map

dist-esm/src/version.js

@@ -1,8 +0,5 @@
-"use strict";
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.SDK_VERSION = void 0;
 // SDK_VERSION should be updated in all 3 package.json and lerna.json(by running lerna version)
-exports.SDK_VERSION = "5.2.1";
+export const SDK_VERSION = "5.2.1";
 //# sourceMappingURL=version.js.map

dist-esm/src/wellKnownKustoEndpoints.json

@@ -23,3 +23,5 @@ {
                 ".kusto.data.microsoft.com",
-                ".kusto.fabric.microsoft.com"
+                ".kusto.fabric.microsoft.com",
+                ".api.securityplatform.microsoft.com",
+                ".securitycenter.windows.com"
             ],
@@ -26,0 +28,0 @@ "AllowedKustoHostnames": [

package.json

 {
     "name": "azure-kusto-data",
-    "version": "6.0.2",
+    "version": "7.0.0-alpha.0",
     "description": "Azure Data Explorer Query SDK",
-    "module": "dist-esm/src/index.js",
-    "types": "./types/src/index.d.ts",
-    "main": "dist-esm/src/index",
+    "type": "module",
+    "exports": {
+        ".": {
+            "import": "./dist-esm/src/index.js",
+            "types": "./types/src/index.d.ts"
+        }
+    },
     "scripts": {
@@ -67,3 +71,3 @@ "clean": "rimraf dist/* dist-esm/* types/*",
     },
-    "gitHead": "591383875554bad2b3382806c06d6850e83e97b6"
+    "gitHead": "e09b5fe882833ca9890bbd332e80206701c28f85"
 }

types/src/client.d.ts

 import { AxiosInstance } from "axios";
-import ClientRequestProperties from "./clientRequestProperties";
-import ConnectionStringBuilder from "./connectionBuilder";
-import { KustoResponseDataSet } from "./response";
-import AadHelper from "./security";
+import ClientRequestProperties from "./clientRequestProperties.js";
+import ConnectionStringBuilder from "./connectionBuilder.js";
+import { KustoResponseDataSet } from "./response.js";
+import AadHelper from "./security.js";
 declare enum ExecutionType {
@@ -7,0 +7,0 @@ Mgmt = "mgmt",

types/src/clientRequestProperties.d.ts

@@ -1,2 +0,2 @@
-import { KustoHeaders } from "./clientDetails";
+import { KustoHeaders } from "./clientDetails.js";
 export declare class ClientRequestProperties {
@@ -3,0 +3,0 @@ private _options;

types/src/connectionBuilder.browser.d.ts

 import { DeviceCodeInfo, InteractiveBrowserCredentialInBrowserOptions, InteractiveBrowserCredentialNodeOptions, TokenCredential } from "@azure/identity";
-import KustoConnectionStringBuilderBase from "./connectionBuilderBase";
+import KustoConnectionStringBuilderBase from "./connectionBuilderBase.js";
 export declare class KustoConnectionStringBuilder extends KustoConnectionStringBuilderBase {
@@ -4,0 +4,0 @@ static readonly DefaultDatabaseName = "NetDefaultDB";

types/src/connectionBuilder.d.ts

 import { DeviceCodeInfo, InteractiveBrowserCredentialInBrowserOptions, InteractiveBrowserCredentialNodeOptions, TokenCredential } from "@azure/identity";
-import { KustoConnectionStringBuilderBase } from "./connectionBuilderBase";
+import { KustoConnectionStringBuilderBase } from "./connectionBuilderBase.js";
 export declare class KustoConnectionStringBuilder extends KustoConnectionStringBuilderBase {
@@ -4,0 +4,0 @@ static readonly DefaultDatabaseName = "NetDefaultDB";

types/src/connectionBuilderBase.d.ts

 import { DeviceCodeInfo, InteractiveBrowserCredentialInBrowserOptions, InteractiveBrowserCredentialNodeOptions, TokenCredential } from "@azure/identity";
-import { KeyOfType } from "./typeUtilts";
-import { ClientDetails } from "./clientDetails";
+import { KeyOfType } from "./typeUtilts.js";
+import { ClientDetails } from "./clientDetails.js";
 interface MappingType {
@@ -5,0 +5,0 @@ mappedTo: string;

types/src/index.d.ts

@@ -1,14 +0,14 @@
-import KustoClient from "./client";
-import ClientRequestProperties from "./clientRequestProperties";
-import CloudSettings from "./cloudSettings";
-import KustoConnectionStringBuilder from "./connectionBuilder";
-import * as KustoDataErrors from "./errors";
-import { kustoTrustedEndpoints, MatchRule } from "./kustoTrustedEndpoints";
-import { KustoResultColumn, KustoResultRow, KustoResultTable } from "./models";
-import { KustoResponseDataSet } from "./response";
-import { toMilliseconds } from "./timeUtils";
+import KustoClient from "./client.js";
+import ClientRequestProperties from "./clientRequestProperties.js";
+import { CloudSettings, CloudInfo } from "./cloudSettings.js";
+import KustoConnectionStringBuilder from "./connectionBuilder.js";
+import * as KustoDataErrors from "./errors.js";
+import { kustoTrustedEndpoints, MatchRule } from "./kustoTrustedEndpoints.js";
+import { KustoResultColumn, KustoResultRow, KustoResultTable } from "./models.js";
+import { KustoResponseDataSet } from "./response.js";
+import { toMilliseconds } from "./timeUtils.js";
 declare const TimeUtils: {
     toMilliseconds: typeof toMilliseconds;
 };
-export { KustoClient as Client, ClientRequestProperties, CloudSettings, KustoConnectionStringBuilder, KustoDataErrors, KustoResponseDataSet, KustoResultColumn, KustoResultRow, KustoResultTable, kustoTrustedEndpoints, MatchRule, TimeUtils, };
+export { KustoClient as Client, ClientRequestProperties, CloudSettings, KustoConnectionStringBuilder, KustoDataErrors, KustoResponseDataSet, KustoResultColumn, KustoResultRow, KustoResultTable, kustoTrustedEndpoints, MatchRule, TimeUtils, type CloudInfo, };
 //# sourceMappingURL=index.d.ts.map

types/src/response.d.ts

@@ -1,2 +0,2 @@
-import { KustoResultTable, Table, WellKnownDataSet } from "./models";
+import { KustoResultTable, Table, WellKnownDataSet } from "./models.js";
 interface V2DataSetHeaderFrame {
@@ -3,0 +3,0 @@ FrameType: "DataSetHeader";

types/src/security.d.ts

@@ -1,3 +0,3 @@
-import KustoConnectionStringBuilder from "./connectionBuilder";
-import { TokenProviderBase } from "./tokenProvider";
+import KustoConnectionStringBuilder from "./connectionBuilder.js";
+import { TokenProviderBase } from "./tokenProvider.js";
 export declare class AadHelper {
@@ -4,0 +4,0 @@ tokenProvider?: TokenProviderBase;

types/src/tokenProvider.d.ts

 import { DeviceCodeInfo, InteractiveBrowserCredentialInBrowserOptions, InteractiveBrowserCredentialNodeOptions } from "@azure/identity";
 import { TokenCredential } from "@azure/core-auth";
-import { CloudInfo } from "./cloudSettings";
+import { CloudInfo } from "./cloudSettings.js";
 export declare type TokenResponse = {
@@ -5,0 +5,0 @@ tokenType: string;

New alerts

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

Found 1 instance in 1 package

Improved metrics

Is type module

Yes

Worsened metrics

Total package byte prevSize

249966

decreased by-2.81%

Lines of code

2342

decreased by-6.17%

Number of low quality alerts

2

increased by100%

No dependency changes