implemented agent requests streams

pom.xml

@@ -9,7 +9,7 @@
 
     <groupId>org.whitesource</groupId>
     <artifactId>wss-agent-parent</artifactId>
-    <version>2.9.9.82-SNAPSHOT</version>
+    <version>2.9.9.90-SNAPSHOT</version>
     <packaging>pom</packaging>
 
     <name>White Source agent API</name>
@@ -29,7 +29,7 @@
         <connection>scm:git:git@github.com:whitesource/agents.git</connection>
         <developerConnection>scm:git:git@github.com:whitesource/agents.git</developerConnection>
         <url>git@github.com:whitesource/agents.git</url>
-      <tag>release-tag-2.9.9.44</tag>
+      <tag>release-tag-2.9.9.86</tag>
   </scm>
     <issueManagement>
         <url>https://github.com/whitesource/agents/issues</url>
@@ -59,7 +59,7 @@
         <httpclient.version>4.5.13</httpclient.version>
 		    <commonscodec.version>1.13</commonscodec.version>
 		    <commonsio.version>2.9.0</commonsio.version>
-        <gson.version>2.9.0</gson.version>
+        <gson.version>2.10.1</gson.version>
         <junit.version>4.13.2</junit.version>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     </properties>

wss-agent-api/pom.xml

@@ -4,7 +4,7 @@
     <parent>
         <groupId>org.whitesource</groupId>
         <artifactId>wss-agent-parent</artifactId>
-        <version>2.9.9.82-SNAPSHOT</version>
+        <version>2.9.9.90-SNAPSHOT</version>
     </parent>
     <artifactId>wss-agent-api</artifactId>
     <packaging>jar</packaging>
@@ -63,4 +63,4 @@
         </profile>
     </profiles>
 
-</project>
+</project>

wss-agent-api/src/main/java/org/whitesource/agent/api/APIConstants.java

@@ -52,6 +52,7 @@ public final class APIConstants {
     public static final String EXTRA_PROPERTIES = "extraProperties";
     public static final String SCAN_SUMMARY_INFO = "scanSummaryInfo";
     public static final String CONTRIBUTIONS = "contributions";
+    public static final String IDENTIFIER = "identifier";
     public static final int MAX_POST_SIZE = 209715200;     //= 200 MegaByte;
 
     /* --- Messages --- */

wss-agent-api/src/main/java/org/whitesource/agent/api/dispatch/AppFlags.java

@@ -0,0 +1,20 @@
+package org.whitesource.agent.api.dispatch;
+
+public enum AppFlags {
+    UPLOAD_SCA_LOGS("UPLOAD_SCA_LOGS"),
+    ASYNC_CHECK_POLICIES_ENABLED("ASYNC_CHECK_POLICIES_ENABLED"),
+    SBT_SUPPORT_ENABLED("SBT_SUPPORT_ENABLED"),
+    AI_BOM_SUPPORT_ENABLED("AI_BOM_SUPPORT_ENABLED"),
+    SWIFT_SUPPORT_ENABLED("SWIFT_SUPPORT_ENABLED"),
+    REACHABILITY_SUPPORT_ENABLED("REACHABILITY_SUPPORT_ENABLED"),
+    REACHABILITY_SUPPORT_LANGUAGES("REACHABILITY_SUPPORT_LANGUAGES");
+    private final String value;
+
+    AppFlags(String value) {
+        this.value = value;
+    }
+
+    public String getValue() {
+        return value;
+    }
+}

wss-agent-api/src/main/java/org/whitesource/agent/api/dispatch/AsyncCheckPolicyComplianceRequest.java

@@ -0,0 +1,185 @@
+package org.whitesource.agent.api.dispatch;
+
+import org.whitesource.agent.api.model.AgentProjectInfo;
+import org.whitesource.agent.api.model.ScanSummaryInfo;
+
+import java.util.Collection;
+
+public class AsyncCheckPolicyComplianceRequest extends BaseRequest<AsyncCheckPolicyComplianceResult> {
+
+    /* --- Static Members --- */
+
+    private static final long serialVersionUID = 925625972820830788L;
+
+    /* --- Members --- */
+
+    /**
+     * When set to true, check that all dependencies sent to WhiteSource comply with organization policies.
+     * When set to false, check that the added dependencies sent to WhiteSource comply with organization policies.
+     */
+    protected boolean forceCheckAllDependencies;
+    /**
+     * When set to true, get vulnerabilities for all dependencies without updating project.
+     * When set to false, will not get vulnerabilities for all dependencies.
+     */
+    protected boolean populateVulnerabilities;
+
+    /* --- Constructors --- */
+
+    /**
+     * Default constructor
+     */
+    public AsyncCheckPolicyComplianceRequest() {
+        super(RequestType.ASYNC_CHECK_POLICY_COMPLIANCE);
+        forceCheckAllDependencies = false;
+        populateVulnerabilities = false;
+    }
+
+    /**
+     * Constructor
+     *
+     * @param projects                  Open Source usage statement to check against policies.
+     * @param forceCheckAllDependencies Check policies for the all the Inventory or just for the new one.
+     */
+    public AsyncCheckPolicyComplianceRequest(Collection<AgentProjectInfo> projects, boolean forceCheckAllDependencies) {
+        this();
+        this.projects = projects;
+        this.forceCheckAllDependencies = forceCheckAllDependencies;
+    }
+
+    /**
+     * Constructor
+     *
+     * @param projects                  Open Source usage statement to check against policies.
+     * @param forceCheckAllDependencies Check policies for the all the Inventory or just for the new one.
+     * @param populateVulnerabilities   get vulnerabilities for each dependency without updating project
+     */
+    public AsyncCheckPolicyComplianceRequest(Collection<AgentProjectInfo> projects, boolean forceCheckAllDependencies, boolean populateVulnerabilities) {
+        this();
+        this.projects = projects;
+        this.forceCheckAllDependencies = forceCheckAllDependencies;
+        this.populateVulnerabilities = populateVulnerabilities;
+    }
+
+    /**
+     * Constructor
+     *
+     * @param orgToken                  WhiteSource organization token.
+     * @param projects                  Open Source usage statement to check against policies.
+     * @param forceCheckAllDependencies Check policies for the all the Inventory or just for the new one.
+     * @param populateVulnerabilities   get vulnerabilities for each dependency without updating project
+     */
+    public AsyncCheckPolicyComplianceRequest(String orgToken, Collection<AgentProjectInfo> projects, boolean forceCheckAllDependencies, boolean populateVulnerabilities) {
+        this(projects, forceCheckAllDependencies, populateVulnerabilities);
+        this.orgToken = orgToken;
+
+    }
+
+    /**
+     * Constructor
+     *
+     * @param orgToken                  WhiteSource organization token.
+     * @param projects                  Open Source usage statement to check against policies.
+     * @param forceCheckAllDependencies Check policies for the all the Inventory or just for the new one.
+     */
+    public AsyncCheckPolicyComplianceRequest(String orgToken, Collection<AgentProjectInfo> projects, boolean forceCheckAllDependencies) {
+        this(projects, forceCheckAllDependencies);
+        this.orgToken = orgToken;
+    }
+
+    /**
+     * Constructor
+     *
+     * @param orgToken                  Organization token uniquely identifying the account at white source.
+     * @param product                   The product name or token to update.
+     * @param productVersion            The product version.
+     * @param projects                  Open Source usage statement to check against policies.
+     * @param forceCheckAllDependencies Boolean to check new data only or not.
+     * @param userKey                   user key uniquely identifying the account at white source.
+     * @param requesterEmail            Email of the WhiteSource user that requests to update WhiteSource.
+     * @param logData                   list of FSA's log data events
+     * @param productToken              The product token
+     */
+    public AsyncCheckPolicyComplianceRequest(String orgToken, String product, String productVersion, Collection<AgentProjectInfo> projects, boolean forceCheckAllDependencies,
+                                        String userKey, String requesterEmail, String logData, String productToken) {
+        this(orgToken, projects, forceCheckAllDependencies);
+        this.product = product;
+        this.productVersion = productVersion;
+        this.userKey = userKey;
+        this.requesterEmail = requesterEmail;
+        this.logData = logData;
+        this.productToken = productToken;
+    }
+
+    /**
+     * Constructor
+     *
+     * @param orgToken                  Organization token uniquely identifying the account at white source.
+     * @param product                   The product name or token to update.
+     * @param productVersion            The product version.
+     * @param projects                  Open Source usage statement to check against policies.
+     * @param forceCheckAllDependencies Boolean to check new data only or not.
+     * @param userKey                   user key uniquely identifying the account at white source.
+     * @param requesterEmail            Email of the WhiteSource user that requests to update WhiteSource.
+     * @param logData                   list of FSA's log data events
+     * @param productToken              The product token
+     * @param scanSummaryInfo           Summary statistics for each step in Unified Agent
+     */
+    public AsyncCheckPolicyComplianceRequest(String orgToken, String product, String productVersion, Collection<AgentProjectInfo> projects, boolean forceCheckAllDependencies,
+                                        String userKey, String requesterEmail, String logData, String productToken, ScanSummaryInfo scanSummaryInfo) {
+        this(orgToken, projects, forceCheckAllDependencies);
+        this.product = product;
+        this.productVersion = productVersion;
+        this.userKey = userKey;
+        this.requesterEmail = requesterEmail;
+        this.logData = logData;
+        this.productToken = productToken;
+        this.scanSummaryInfo = scanSummaryInfo;
+    }
+
+    /**
+     * Constructor
+     *
+     * @param orgToken                  Organization token uniquely identifying the account at white source.
+     * @param product                   The product name or token to update.
+     * @param productVersion            The product version.
+     * @param projects                  Open Source usage statement to check against policies.
+     * @param forceCheckAllDependencies Boolean to check new data only or not.
+     * @param userKey                   user key uniquely identifying the account at white source.
+     * @param requesterEmail            Email of the WhiteSource user that requests to update WhiteSource.
+     * @param logData                   list of FSA's log data events
+     * @param productToken              The product token
+     * @param scanSummaryInfo           Summary statistics for each step in Unified Agent
+     * @param populateVulnerabilities   get vulnerabilities for each dependency without updating project
+     */
+    public AsyncCheckPolicyComplianceRequest(String orgToken, String product, String productVersion, Collection<AgentProjectInfo> projects, boolean forceCheckAllDependencies,
+                                        boolean populateVulnerabilities, String userKey, String requesterEmail, String logData, String productToken, ScanSummaryInfo scanSummaryInfo) {
+        this(orgToken, projects, forceCheckAllDependencies);
+        this.product = product;
+        this.productVersion = productVersion;
+        this.userKey = userKey;
+        this.requesterEmail = requesterEmail;
+        this.logData = logData;
+        this.productToken = productToken;
+        this.scanSummaryInfo = scanSummaryInfo;
+        this.populateVulnerabilities = populateVulnerabilities;
+    }
+
+    /* --- Getters / Setters --- */
+
+    public boolean isForceCheckAllDependencies() {
+        return forceCheckAllDependencies;
+    }
+
+    public void setForceCheckAllDependencies(boolean forceCheckAllDependencies) {
+        this.forceCheckAllDependencies = forceCheckAllDependencies;
+    }
+
+    public boolean isPopulateVulnerabilities() {
+        return populateVulnerabilities;
+    }
+
+    public void setPopulateVulnerabilities(boolean populateVulnerabilities) {
+        this.populateVulnerabilities = populateVulnerabilities;
+    }
+}

wss-agent-api/src/main/java/org/whitesource/agent/api/dispatch/AsyncCheckPolicyComplianceResponseRequest.java

@@ -0,0 +1,30 @@
+package org.whitesource.agent.api.dispatch;
+
+public class AsyncCheckPolicyComplianceResponseRequest extends BaseRequest<AsyncCheckPolicyComplianceResponseResult> {
+
+    /* --- Static Members --- */
+
+    private static final long serialVersionUID = 7267771318691275351L;
+
+    /* --- Members --- */
+
+    protected String identifier;
+
+    /**
+     * Default constructor
+     */
+    public AsyncCheckPolicyComplianceResponseRequest(String identifier) {
+        super(RequestType.ASYNC_CHECK_POLICY_COMPLIANCE_RESPONSE);
+        this.identifier = identifier;
+    }
+
+    public AsyncCheckPolicyComplianceResponseRequest() {super(RequestType.ASYNC_CHECK_POLICY_COMPLIANCE_RESPONSE);}
+
+    public String getIdentifier() {
+        return identifier;
+    }
+
+    public void setIdentifier(String identifier) {
+        this.identifier = identifier;
+    }
+}

wss-agent-api/src/main/java/org/whitesource/agent/api/dispatch/AsyncCheckPolicyComplianceResponseResult.java

@@ -0,0 +1,17 @@
+package org.whitesource.agent.api.dispatch;
+
+public class AsyncCheckPolicyComplianceResponseResult extends CheckPolicyComplianceResult {
+
+    /* --- Static Members --- */
+
+    private static final long serialVersionUID = -9005803185728108040L;
+
+    /* --- Members --- */
+
+
+    /**
+     * Default constructor
+     */
+    public AsyncCheckPolicyComplianceResponseResult() {
+    }
+}

wss-agent-api/src/main/java/org/whitesource/agent/api/dispatch/AsyncCheckPolicyComplianceResult.java

@@ -0,0 +1,28 @@
+package org.whitesource.agent.api.dispatch;
+
+import java.io.Serializable;
+
+public class AsyncCheckPolicyComplianceResult extends BaseResult {
+
+    /* --- Static Members --- */
+
+    private static final long serialVersionUID = 7236121775887105115L;
+
+    /* --- Members --- */
+
+    private String identifier;
+
+    /**
+     * Default constructor
+     */
+    public AsyncCheckPolicyComplianceResult() {
+    }
+
+    public String getIdentifier() {
+        return identifier;
+    }
+
+    public void setIdentifier(String identifier) {
+        this.identifier = identifier;
+    }
+}

wss-agent-api/src/main/java/org/whitesource/agent/api/dispatch/AsyncCheckPolicyComplianceStatusRequest.java

@@ -0,0 +1,32 @@
+package org.whitesource.agent.api.dispatch;
+
+public class AsyncCheckPolicyComplianceStatusRequest extends BaseRequest<AsyncCheckPolicyComplianceStatusResult> {
+
+    /* --- Static Members --- */
+
+    private static final long serialVersionUID = -3011749510680068374L;
+
+    /* --- Members --- */
+
+    protected String identifier;
+
+    /**
+     * Default constructor
+     */
+    public AsyncCheckPolicyComplianceStatusRequest(String identifier) {
+        super(RequestType.ASYNC_CHECK_POLICY_COMPLIANCE_STATUS);
+        this.identifier = identifier;
+    }
+
+    public AsyncCheckPolicyComplianceStatusRequest() {
+        super(RequestType.ASYNC_CHECK_POLICY_COMPLIANCE_STATUS);
+    }
+
+    public String getIdentifier() {
+        return identifier;
+    }
+
+    public void setIdentifier(String identifier) {
+        this.identifier = identifier;
+    }
+}