fix ds

src/commands/serverCommand.ts

@@ -273,7 +273,6 @@ export async function removeConnection(viewItem: KdbNode | InsightsNode) {
 export async function connect(viewItem: KdbNode | InsightsNode): Promise<void> {
   const connMngService = new ConnectionManagementService();
   commands.executeCommand("kdb-results.focus");
-  await commands.executeCommand("setContext", "kdb.insightsConnected", false);
   ExecutionConsole.start();
   // handle cleaning up existing connection
   if (ext.activeConnection !== undefined) {

src/services/connectionManagerService.ts

@@ -131,6 +131,11 @@ export class ConnectionManagementService {
     ]);
     Telemetry.sendEvent("Connection.Connected.Active");
     ext.activeConnection = connection;
+    if (node instanceof InsightsNode) {
+      commands.executeCommand("setContext", "kdb.insightsConnected", true);
+    } else {
+      commands.executeCommand("setContext", "kdb.insightsConnected", false);
+    }
     ext.serverProvider.reload();
   }
 

src/services/dataSourceTreeProvider.ts

@@ -46,7 +46,7 @@ export class KdbDataSourceProvider implements TreeDataProvider<TreeItem> {
     this.refresh();
     const datasourceFolder = createKdbDataSourcesFolder();
     this.watcher = workspace.createFileSystemWatcher(
-      new RelativePattern(datasourceFolder, ext.kdbDataSourceFileGlob)
+      new RelativePattern(datasourceFolder, ext.kdbDataSourceFileGlob),
     );
     // watch updates in the folder
     this.watcher.onDidChange(() => this.refresh());
@@ -59,7 +59,7 @@ export class KdbDataSourceProvider implements TreeDataProvider<TreeItem> {
   }
 
   getChildren(
-    element?: KdbDataSourceTreeItem
+    element?: KdbDataSourceTreeItem,
   ): Promise<KdbDataSourceTreeItem[]> {
     if (!element) {
       return this.getDsFiles();
@@ -84,7 +84,7 @@ export class KdbDataSourceProvider implements TreeDataProvider<TreeItem> {
       const files = fs.readdirSync(kdbDataSourcesFolderPath);
       const dsFiles = files.filter((file) => {
         const isFromInsightsNode = checkFileFromInsightsNode(
-          path.join(kdbDataSourcesFolderPath, file)
+          path.join(kdbDataSourcesFolderPath, file),
         );
         return (
           path.extname(file) === ext.kdbDataSourceFileExtension &&
@@ -97,9 +97,9 @@ export class KdbDataSourceProvider implements TreeDataProvider<TreeItem> {
           return new KdbDataSourceTreeItem(
             newLabel,
             TreeItemCollapsibleState.None,
-            [Uri.file(path.join(kdbDataSourcesFolderPath, file))]
+            [Uri.file(path.join(kdbDataSourcesFolderPath, file))],
           );
-        })
+        }),
       );
     } else {
       return Promise.resolve([]);
@@ -111,7 +111,7 @@ export class KdbDataSourceTreeItem extends TreeItem {
   constructor(
     public readonly label: string,
     public readonly collapsibleState: TreeItemCollapsibleState,
-    public readonly files: Uri[]
+    public readonly files: Uri[],
   ) {
     super(label, collapsibleState);
     this.iconPath = new ThemeIcon("file");
@@ -125,7 +125,7 @@ export class KdbDataSourceTreeItem extends TreeItem {
       commands.executeCommand(
         "setContext",
         "kdb.dataSourceTreeNodes",
-        ext.kdbDataSourceRootNodes
+        ext.kdbDataSourceRootNodes,
       );
     }
   }

src/utils/dataSource.ts

@@ -16,19 +16,20 @@ import path from "path";
 import { ext } from "../extensionVariables";
 import { DataSourceFiles } from "../models/dataSource";
 import { DataSourcesPanel } from "../panels/datasource";
+import { InsightsConnection } from "../classes/insightsConnection";
 
 export function createKdbDataSourcesFolder(): string {
   const rootPath = ext.context.globalStorageUri.fsPath;
   const kdbDataSourcesFolderPath = path.join(rootPath, ext.kdbDataSourceFolder);
   if (!fs.existsSync(rootPath)) {
     ext.outputChannel.appendLine(
-      `Directory created to the extension folder: ${rootPath}`
+      `Directory created to the extension folder: ${rootPath}`,
     );
     fs.mkdirSync(rootPath);
   }
   if (!fs.existsSync(kdbDataSourcesFolderPath)) {
     ext.outputChannel.appendLine(
-      `Directory created to the extension folder: ${kdbDataSourcesFolderPath}`
+      `Directory created to the extension folder: ${kdbDataSourcesFolderPath}`,
     );
     fs.mkdirSync(kdbDataSourcesFolderPath);
   }
@@ -45,21 +46,16 @@ export function convertTimeToTimestamp(time: string): string {
     return `${datePart}.${timePart}`;
   } catch (error) {
     console.error(
-      `The string param is in an incorrect format. Param: ${time} Error: ${error}`
+      `The string param is in an incorrect format. Param: ${time} Error: ${error}`,
     );
     return "";
   }
 }
 
 export function getConnectedInsightsNode(): string {
-  const connectedNode = ext.kdbinsightsNodes.find((node) =>
-    node.endsWith(" (connected)")
-  );
-  if (connectedNode) {
-    return connectedNode.replace(" (connected)", "");
-  } else {
-    return "";
-  }
+  return ext.activeConnection instanceof InsightsConnection
+    ? ext.activeConnection.connLabel
+    : "";
 }
 
 export function checkFileFromInsightsNode(filePath: string): boolean {
@@ -78,15 +74,15 @@ export function checkFileFromInsightsNode(filePath: string): boolean {
 
 export function checkIfTimeParamIsCorrect(
   startTS: string,
-  endTS: string
+  endTS: string,
 ): boolean {
   try {
     const startDate = new Date(startTS);
     const endDate = new Date(endTS);
     return startDate < endDate;
   } catch (error) {
     console.error(
-      `The string params are in an incorrect format. startTS: ${startTS}, endTS: ${endTS}, Error: ${error}`
+      `The string params are in an incorrect format. startTS: ${startTS}, endTS: ${endTS}, Error: ${error}`,
     );
     return false;
   }
@@ -99,7 +95,7 @@ export function refreshDataSourcesPanel(): void {
 }
 
 export function convertDataSourceFormToDataSourceFile(
-  form: any
+  form: any,
 ): DataSourceFiles {
   return form as DataSourceFiles;
 }