kie-issues#1694: Apache KIE Extended Services extension issues

packages/cors-proxy/package.json

@@ -28,7 +28,7 @@
   "dependencies": {
     "cors": "^2.8.5",
     "express": "^4.21.1",
-    "node-fetch": "^3.3.1"
+    "node-fetch": "^3.3.2"
   },
   "devDependencies": {
     "@babel/core": "^7.16.0",

packages/extended-services-vscode-extension/env/index.js

@@ -17,11 +17,28 @@
  * under the License.
  */
 
-const { varsWithName, composeEnv } = require("@kie-tools-scripts/build-env");
+const { getOrDefault, varsWithName, composeEnv } = require("@kie-tools-scripts/build-env");
 
 module.exports = composeEnv([require("@kie-tools/root-env/env")], {
-  vars: varsWithName({}),
+  vars: varsWithName({
+    EXTENDED_SERVICES_JAVA__host: {
+      default: "0.0.0.0",
+      description:
+        "Quarkus HTTP Host. Configures the IP address or host to which a Quarkus application binds for incoming HTTP requests.",
+    },
+    EXTENDED_SERVICES_JAVA__port: {
+      default: "21345",
+      description:
+        "Quarkus HTTP Port. Configures the network port on which a Quarkus application accepts incoming HTTP requests.",
+    },
+  }),
   get env() {
-    return {};
+    return {
+      extendedServicesJava: {
+        version: require("../package.json").version,
+        host: getOrDefault(this.vars.EXTENDED_SERVICES_JAVA__host),
+        port: getOrDefault(this.vars.EXTENDED_SERVICES_JAVA__port),
+      },
+    };
   },
 });

packages/extended-services-vscode-extension/package.json

@@ -43,7 +43,7 @@
     "@vscode/test-web": "^0.0.30",
     "@vscode/vsce": "^2.22.0",
     "copy-webpack-plugin": "^11.0.0",
-    "node-fetch": "^3.3.1",
+    "node-fetch": "^3.3.2",
     "rimraf": "^3.0.2",
     "webpack": "^5.94.0",
     "webpack-cli": "^4.10.0",
@@ -73,22 +73,23 @@
     ],
     "configuration": {
       "properties": {
-        "extendedServices.connectionHeartbeatIntervalinSecs": {
-          "default": 1,
+        "extendedServices.connectionHeartbeatIntervalInSecs": {
+          "default": 10,
           "description": "Specifies the interval (in seconds) between each connection check.",
           "format": "time",
+          "minimum": 10,
           "order": 2,
           "type": "integer"
         },
         "extendedServices.enableAutorun": {
           "default": true,
-          "description": "Automatically run a local instance of the service.",
+          "description": "Automatically runs a local instance of the Extended Service.",
           "order": 0,
           "type": "boolean"
         },
         "extendedServices.extendedServicesURL": {
           "default": "http://localhost:21345",
-          "description": "Specifies the Exnteded Services URL.",
+          "description": "Specifies the Extended Services URL.",
           "format": "uri",
           "order": 1,
           "type": "string"

packages/extended-services-vscode-extension/src/Connection.ts

@@ -35,6 +35,7 @@ export class Connection {
   }
 
   public stop(): void {
+    console.debug("[Extended Services Extension] Disconnecting from Extended Service");
     if (this.timeout) {
       this.fireDisconnectedEvent();
       clearInterval(this.timeout);

packages/extended-services-vscode-extension/src/LocalExtendedServices.ts

@@ -80,6 +80,7 @@ export class LocalExtendedServices {
   }
 
   public stop(): void {
+    console.debug("[Extended Services Extension] Stopping local instance of Extended Service");
     if (!this.serviceProcess) {
       return;
     }

packages/extended-services-vscode-extension/src/Validator.ts

@@ -49,26 +49,28 @@ function createDMNDiagnostics(validationResponses: validationResponse.DMNValidat
   });
 }
 
-export async function validateBPMN(serviceURL: URL, kieFile: kieFile.KieFile): Promise<vscode.Diagnostic[]> {
+export async function validateBPMN(serviceURL: URL, bpmnFile: kieFile.KieFile): Promise<vscode.Diagnostic[]> {
   try {
     const validationResponses: validationResponse.BPMNValidationResponse[] = await validationRequests.validateBPMN(
       serviceURL,
-      kieFile
+      bpmnFile
     );
     return createBPMNDiagnostics(validationResponses);
   } catch (error) {
-    throw new Error("VALIDATE BPMN ERROR - " + error.message);
+    console.error(`An error occured while trying to validate DMN file: ${bpmnFile} with error: ${error.message}`);
+    throw new Error(`An error occured while trying to validate DMN file: ${bpmnFile} with error: ${error.message}`);
   }
 }
 
-export async function validateDMN(serviceURL: URL, kieFile: kieFile.KieFile): Promise<vscode.Diagnostic[]> {
+export async function validateDMN(serviceURL: URL, dmnFile: kieFile.KieFile): Promise<vscode.Diagnostic[]> {
   try {
     const validationResponses: validationResponse.DMNValidationResponse[] = await validationRequests.validateDMN(
       serviceURL,
-      kieFile
+      dmnFile
     );
     return createDMNDiagnostics(validationResponses);
   } catch (error) {
-    throw new Error("VALIDATE DMN ERROR - " + error.message);
+    console.error(`An error occured while trying to validate DMN file: ${dmnFile} with error: ${error.message}`);
+    throw new Error(`An error occured while trying to validate DMN file: ${dmnFile} with error: ${error.message}`);
   }
 }

packages/extended-services-vscode-extension/src/configurations/Configuration.ts

@@ -19,9 +19,10 @@
 
 import * as vscode from "vscode";
 
-export const enableAutoRunID: string = "extendedServices.enableAutorun";
-export const connectionHeartbeatIntervalinSecsID: string = "extendedServices.connectionHeartbeatIntervalinSecs";
-export const extendedServicesURLID: string = "extendedServices.extendedServicesURL";
+export const enableAutoRunID = "extendedServices.enableAutorun";
+export const connectionHeartbeatIntervalinSecsID = "extendedServices.connectionHeartbeatIntervalinSecs";
+export const extendedServicesURLID = "extendedServices.extendedServicesURL";
+const defaultExtendedServicesURL = "http://localhost:21345";
 
 export class Configuration {
   readonly enableAutoRun: boolean;
@@ -35,65 +36,31 @@ export class Configuration {
   }
 }
 
-function fetchEnableAutoRun(): boolean {
-  const enableAutoRun = vscode.workspace.getConfiguration().get<boolean>(enableAutoRunID);
-  if (!enableAutoRun) {
-    throw new Error("Enable Auto Run configuration not found");
-  }
-  return enableAutoRun;
-}
-
-function fetchConnectionHeartbeatIntervalinSecs(): number {
-  const connectionHeartbeatIntervalinSecs = vscode.workspace
-    .getConfiguration()
-    .get<number>(connectionHeartbeatIntervalinSecsID);
-  if (!connectionHeartbeatIntervalinSecs) {
-    throw new Error("Connection Heartbeat Interval configuration not found");
-  }
-
-  return connectionHeartbeatIntervalinSecs;
-}
-
 function fetchExtendedServicesURL(): URL {
-  const extendedServicesURL = vscode.workspace.getConfiguration().get<string>(extendedServicesURLID);
-  if (!extendedServicesURL) {
-    throw new Error("URL configuration not found");
-  }
-
+  const extendedServicesURL = getConfigurationPropertyValue<string>(extendedServicesURLID, defaultExtendedServicesURL);
   try {
     return new URL(extendedServicesURL);
   } catch (error) {
-    throw new Error("Invalid service URL:" + error.message);
+    throw new Error(`URL configuration ${extendedServicesURL} is invalid: ${error.message}`);
   }
 }
 
-export function fetchConfiguration(): Configuration {
-  let errorMessages: string[] = [];
-  let enableAutoRun: any;
-  let connectionHeartbeatIntervalinSecs: any;
-  let extendedServicesURL: any;
-
-  try {
-    enableAutoRun = fetchEnableAutoRun();
-  } catch (error) {
-    errorMessages.push(error.message);
-  }
-
-  try {
-    connectionHeartbeatIntervalinSecs = fetchConnectionHeartbeatIntervalinSecs();
-  } catch (error) {
-    errorMessages.push(error.message);
+const getConfigurationPropertyValue = <T>(property: string, defaultValue: T): T => {
+  const value = vscode.workspace.getConfiguration().get(property) as T;
+  if (value == null) {
+    console.warn(`Property: ${property} is missing, using the default: ${defaultValue}`);
+    value == defaultValue;
   }
+  return value;
+};
 
-  try {
-    extendedServicesURL = fetchExtendedServicesURL();
-  } catch (error) {
-    errorMessages.push(error.message);
-  }
+export function fetchConfiguration(): Configuration {
+  const enableAutoRun = getConfigurationPropertyValue<boolean>(enableAutoRunID, true);
+  const connectionHeartbeatIntervalinSecs = getConfigurationPropertyValue<number>(
+    connectionHeartbeatIntervalinSecsID,
+    10
+  );
+  const extendedServicesURL = fetchExtendedServicesURL();
 
-  if (errorMessages.length < 0) {
-    throw new Error("CONFIGURATION ERROR - " + errorMessages.join(", "));
-  } else {
-    return new Configuration(enableAutoRun, connectionHeartbeatIntervalinSecs, extendedServicesURL);
-  }
+  return new Configuration(enableAutoRun, connectionHeartbeatIntervalinSecs, extendedServicesURL);
 }