Add sample for Discovery API

Samples/Java/swis-client/src/main/java/com/solarwinds/orionsdk/discovery/CorePluginContext.java

@@ -0,0 +1,35 @@
+package com.solarwinds.orionsdk.discovery;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class CorePluginContext {
+	private final List<IpAddress> bulkList = new ArrayList<IpAddress>();
+	private final List<Credential> credentials = new ArrayList<Credential>();
+	private int wmiRetriesCount = 0;
+	private int wmiRetryIntervalMiliseconds = 1000;
+
+	public int getWmiRetriesCount() {
+		return wmiRetriesCount;
+	}
+
+	public void setWmiRetriesCount(int wmiRetriesCount) {
+		this.wmiRetriesCount = wmiRetriesCount;
+	}
+
+	public int getWmiRetryIntervalMiliseconds() {
+		return wmiRetryIntervalMiliseconds;
+	}
+
+	public void setWmiRetryIntervalMiliseconds(int wmiRetryIntervalMiliseconds) {
+		this.wmiRetryIntervalMiliseconds = wmiRetryIntervalMiliseconds;
+	}
+
+	public List<Credential> getCredentials() {
+		return credentials;
+	}
+
+	public List<IpAddress> getBulkList() {
+		return bulkList;
+	}
+}

Samples/Java/swis-client/src/main/java/com/solarwinds/orionsdk/discovery/Credential.java

@@ -0,0 +1,27 @@
+package com.solarwinds.orionsdk.discovery;
+
+public class Credential {
+	private int credentialId;
+	private int order;
+
+	public Credential(int credentialId, int order) {
+		setCredentialId(credentialId);
+		setOrder(order);
+	}
+
+	public int getCredentialId() {
+		return credentialId;
+	}
+
+	public void setCredentialId(int credentialId) {
+		this.credentialId = credentialId;
+	}
+
+	public int getOrder() {
+		return order;
+	}
+
+	public void setOrder(int order) {
+		this.order = order;
+	}
+}

Samples/Java/swis-client/src/main/java/com/solarwinds/orionsdk/discovery/DiscoveredObject.java

@@ -0,0 +1,31 @@
+package com.solarwinds.orionsdk.discovery;
+
+public class DiscoveredObject {
+	private String entityType;
+	private String displayName;
+	private String netObjectId;
+
+	public String getEntityType() {
+		return entityType;
+	}
+
+	public void setEntityType(String entityType) {
+		this.entityType = entityType;
+	}
+
+	public String getDisplayName() {
+		return displayName;
+	}
+
+	public void setDisplayName(String displayName) {
+		this.displayName = displayName;
+	}
+
+	public String getNetObjectId() {
+		return netObjectId;
+	}
+
+	public void setNetObjectId(String netObjectId) {
+		this.netObjectId = netObjectId;
+	}
+}

Samples/Java/swis-client/src/main/java/com/solarwinds/orionsdk/discovery/DiscoveryResults.java

@@ -0,0 +1,39 @@
+package com.solarwinds.orionsdk.discovery;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class DiscoveryResults {
+	public DiscoveryStatus getResult() {
+		return result;
+	}
+
+	public void setResult(DiscoveryStatus result) {
+		this.result = result;
+	}
+
+	public String getResultDescription() {
+		return resultDescription;
+	}
+
+	public void setResultDescription(String resultDescription) {
+		this.resultDescription = resultDescription;
+	}
+
+	public String getErrorMessage() {
+		return errorMessage;
+	}
+
+	public void setErrorMessage(String errorMessage) {
+		this.errorMessage = errorMessage;
+	}
+
+	public List<DiscoveredObject> getDiscoveredObjects() {
+		return discoveredObjects;
+	}
+
+	private DiscoveryStatus result;
+	private String resultDescription;
+	private String errorMessage;
+	private final List<DiscoveredObject> discoveredObjects = new ArrayList<DiscoveredObject>();
+}

Samples/Java/swis-client/src/main/java/com/solarwinds/orionsdk/discovery/DiscoveryStatus.java

@@ -0,0 +1,5 @@
+package com.solarwinds.orionsdk.discovery;
+
+public enum DiscoveryStatus {
+	Unknown, InProgress, Finished, Error, NotScheduled, Scheduled, NotCompleted, Canceling, ReadyForImport
+}

Samples/Java/swis-client/src/main/java/com/solarwinds/orionsdk/discovery/IpAddress.java

@@ -0,0 +1,17 @@
+package com.solarwinds.orionsdk.discovery;
+
+public class IpAddress {
+	private String address;
+
+	public IpAddress(String address) {
+		setAddress(address);
+	}
+
+	public String getAddress() {
+		return address;
+	}
+
+	public void setAddress(String address) {
+		this.address = address;
+	}
+}

Samples/Java/swis-client/src/main/java/com/solarwinds/orionsdk/discovery/OrionDiscoveryManager.java

@@ -0,0 +1,73 @@
+package com.solarwinds.orionsdk.discovery;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import com.solarwinds.orionsdk.swis_client.ISwisClient;
+
+public class OrionDiscoveryManager {
+	private static final String ORION_DISCOVERY = "Orion.Discovery";
+	private ISwisClient swis;
+
+	public OrionDiscoveryManager(ISwisClient swis) {
+		this.swis = swis;
+	}
+
+	public String createCorePluginConfiguration(CorePluginContext context) {
+		return swis.invoke(ORION_DISCOVERY, "CreateCorePluginConfiguration", context).getAsString();
+	}
+
+	public int startDiscovery(StartDiscoveryContext context) {
+		return swis.invoke(ORION_DISCOVERY, "StartDiscovery", context).getAsInt();
+	}
+
+	public DiscoveryStatus checkDiscoveryStatus(final int profileId) {
+		List<Map<String, Object>> results = swis.query(
+				"SELECT Status FROM Orion.DiscoveryProfiles WHERE ProfileID = @profileId",
+				param("profileId", profileId));
+		if (results.isEmpty())
+			return DiscoveryStatus.Unknown;
+
+		return DiscoveryStatus.values()[(int) (long) (Long) results.get(0).get("Status")];
+	}
+
+	public DiscoveryResults waitForCompletion(final int profileId) throws InterruptedException {
+		DiscoveryStatus status;
+		do {
+			Thread.sleep(1000);
+			status = checkDiscoveryStatus(profileId);
+		} while (status == DiscoveryStatus.InProgress);
+
+		List<Map<String, Object>> log = swis.query(
+				"SELECT Result, ResultDescription, ErrorMessage, BatchID FROM Orion.DiscoveryLogs WHERE ProfileID = @profileId",
+				param("profileId", profileId));
+
+		DiscoveryResults results = new DiscoveryResults();
+		results.setResult(DiscoveryStatus.values()[(int) (long) (Long) log.get(0).get("Result")]);
+		results.setResultDescription((String) log.get(0).get("ResultDescription"));
+		results.setErrorMessage((String) log.get(0).get("ErrorMessage"));
+
+		if (results.getResult() == DiscoveryStatus.Finished) {
+			String batchId = (String) log.get(0).get("BatchID");
+			List<Map<String, Object>> items = swis.query(
+					"SELECT EntityType, DisplayName, NetObjectID FROM Orion.DiscoveryLogItems WHERE BatchID = @batchId",
+					param("batchId", batchId));
+			for (Map<String, Object> item : items) {
+				DiscoveredObject obj = new DiscoveredObject();
+				obj.setEntityType((String) item.get("EntityType"));
+				obj.setDisplayName((String) item.get("DisplayName"));
+				obj.setNetObjectId((String) item.get("NetObjectID"));
+				results.getDiscoveredObjects().add(obj);
+			}
+		}
+
+		return results;
+	}
+
+	private Map<String, Object> param(String name, Object value) {
+		Map<String, Object> data = new HashMap<String, Object>();
+		data.put(name, value);
+		return data;
+	}
+}

Samples/Java/swis-client/src/main/java/com/solarwinds/orionsdk/discovery/PluginConfiguration.java

@@ -0,0 +1,17 @@
+package com.solarwinds.orionsdk.discovery;
+
+public class PluginConfiguration {
+	private String pluginConfigurationItem;
+
+	public PluginConfiguration(String item) {
+		setPluginConfigurationItem(item);
+	}
+
+	public String getPluginConfigurationItem() {
+		return pluginConfigurationItem;
+	}
+
+	public void setPluginConfigurationItem(String pluginConfigurationItem) {
+		this.pluginConfigurationItem = pluginConfigurationItem;
+	}
+}

Samples/Java/swis-client/src/main/java/com/solarwinds/orionsdk/discovery/SnmpVersion.java

@@ -0,0 +1,5 @@
+package com.solarwinds.orionsdk.discovery;
+
+public enum SnmpVersion {
+	None, SNMP1, SNMP2c, SNMP3
+}