aimcp server changes

Author: cx-atish-jadhav

src/main/java/com/checkmarx/ast/wrapper/CxConstants.java

@@ -61,6 +61,8 @@ public final class CxConstants {
     static final String ADDITONAL_PARAMS = "--additional-params";
     static final String ENGINE = "--engine";
     static final String SUB_CMD_KICS_REALTIME = "kics-realtime";
+    static final String SUB_CMD_OSS_REALTIME = "oss-realtime";
+    static final String IGNORED_FILE_PATH = "--ignored-file-path";
     static final String SCA_REMEDIATION_PACKAGE_FILES = "--package-files";
     static final String SCA_REMEDIATION_PACKAGE = "--package";
     static final String SCA_REMEDIATION_PACKAGE_VERSION = "--package-version";
@@ -74,4 +76,5 @@ public final class CxConstants {
     static final String SUB_CMD_LEARN_MORE = "learn-more";
     static final String SUB_CMD_TENANT = "tenant";
     static final String IDE_SCANS_KEY = "scan.config.plugins.ideScans";
+    static final String AI_MCP_SERVER_KEY = "scan.config.plugins.aiMcpServer";
 }

src/main/java/com/checkmarx/ast/wrapper/CxWrapper.java

@@ -404,6 +404,26 @@ public KicsRealtimeResults kicsRealtimeScan(@NonNull String fileSources, String
         return Execution.executeCommand(withConfigArguments(arguments), logger, KicsRealtimeResults::fromLine);
     }
 
+    public String ossRealtimeScan(@NonNull String sourcePath, String ignoredFilePath)
+            throws IOException, InterruptedException, CxException {
+        this.logger.info("Executing 'scan oss-realtime' command using the CLI.");
+        this.logger.info("Source: {} IgnoredFilePath: {}", sourcePath, ignoredFilePath);
+        List<String> arguments = new ArrayList<>();
+        arguments.add(CxConstants.CMD_SCAN);
+        arguments.add(CxConstants.SUB_CMD_OSS_REALTIME);
+        arguments.add(CxConstants.SOURCE);
+        arguments.add(sourcePath);
+        if (StringUtils.isNotBlank(ignoredFilePath)) {
+            arguments.add(CxConstants.IGNORED_FILE_PATH);
+            arguments.add(ignoredFilePath);
+        }
+        return Execution.executeCommand(withConfigArguments(arguments), logger, line -> line);
+    }
+
+    public String ossRealtimeScan(@NonNull String sourcePath)
+            throws IOException, InterruptedException, CxException {
+        return ossRealtimeScan(sourcePath, null);
+    }
     public KicsRemediation kicsRemediate(@NonNull String resultsFile, String kicsFile, String engine,String similarityIds)
             throws IOException, InterruptedException, CxException {
         this.logger.info("Executing 'remediation kics' command using the CLI.");
@@ -455,6 +475,18 @@ public boolean ideScansEnabled() throws CxException, IOException, InterruptedExc
                              .orElse(false);
     }
 
+    public boolean aiMcpServerEnabled() throws CxException, IOException, InterruptedException {
+        List<TenantSetting> tenantSettings = tenantSettings();
+        if (tenantSettings == null) {
+            throw new CxException(1, "Unable to parse tenant settings");
+        }
+        return tenantSettings.stream()
+                .filter(t -> t.getKey().equals(CxConstants.AI_MCP_SERVER_KEY))
+                .findFirst()
+                .map(t -> Boolean.parseBoolean(t.getValue()))
+                .orElse(false);
+    }
+
     public List<TenantSetting> tenantSettings() throws CxException, IOException, InterruptedException {
         List<String> arguments = jsonArguments();