Test for the splunk adapter

Splunk adapter test

    @Test
    public void test_count() throws Exception{
        BridgeError error = null;

        BridgeRequest request = new BridgeRequest();
        
        List<String> fields = Arrays.asList("id");
        request.setFields(fields);
        
        request.setStructure("Search Jobs");
        request.setFields(fields);
        request.setQuery("services/search/jobs?search=<%=parameter[\"Search\"]%>");
        
        Map parameters = new HashMap();
        parameters.put("Search", "eventCount>100");
        request.setParameters(parameters);
        
        Count count = null;
        try {
            count = getAdapter().count(request);
        } catch (BridgeError e) {
            error = e;
        }
        
        assertNull(error);
        assertTrue(count.getValue() > 0);
    }
    
    @Test
    public void test_count_param() throws Exception{
        BridgeError error = null;

        BridgeRequest request = new BridgeRequest();
        
        List<String> fields = Arrays.asList("id");
        request.setFields(fields);
        
        request.setStructure("servicesNS");
        request.setFields(fields);
        request.setQuery("servicesNS/nobody/search/storage/collections/data/"
            + "vlm_aivid?query={\"CIName\":\"<%=parameter[\"Value\"]%>\"}");        
        
        Map parameters = new HashMap();
        parameters.put("Value", "nrcqaxx0181");
        request.setParameters(parameters);
        
        Count count = null;
        try {
            count = getAdapter().count(request);
        } catch (BridgeError e) {
            error = e;
        }
        
        assertNull(error);
        assertTrue(count.getValue() > 0);
    }
    
    @Test
    public void test_count_temp() throws Exception{
        BridgeError error = null;
        
        assertNull(error);
        
        // Create the Bridge Request
        List<String> fields = new ArrayList<String>();
        fields.add("id");
        
        BridgeRequest request = new BridgeRequest();
        request.setStructure("Search Jobs");
        request.setFields(fields);
        request.setQuery("services/scheduled/views");
        
        Count count = null;
        try {
            count = getAdapter().count(request);
        } catch (BridgeError e) {
            error = e;
        }
        
        assertNull(error);
        assertTrue(count.getValue() > 0);
    }
    
    @Test
    public void test_search() throws Exception{
        BridgeError error = null;
        
        assertNull(error);
        
        BridgeRequest request = new BridgeRequest();
        
        List<String> fields = Arrays.asList("id","sid");
        request.setFields(fields);
        
        request.setStructure("Search Jobs");
        request.setFields(fields);
        request.setQuery("services/search/jobs?search=eventCount>"
            + "<%=parameter[\"Event Count\"]%>");
        
        Map parameters = new HashMap();
        parameters.put("Event Count", "100");
        request.setParameters(parameters);
        
        RecordList list = null;
        try {
            list = getAdapter().search(request);
        } catch (BridgeError e) {
            error = e;
        }
        
        assertNull(error);
        assertTrue(list.getRecords().size() > 0);
    }
    
    @Test
    public void test_search_kvstore() throws Exception{
        BridgeError error = null;

        BridgeRequest request = new BridgeRequest();
        
        List<String> fields = Arrays.asList("ip");
        request.setFields(fields);
        
        request.setStructure("servicesNS");
        request.setFields(fields);
        request.setQuery("servicesNS/nobody/search/storage/collections/data/"
            + "vlm_aivid?query={\"CIName\":\"<%=parameter[\"Value\"]%>\"}");        
        
        Map parameters = new HashMap();
        parameters.put("Value", "nrcqaxx0181");
        request.setParameters(parameters);
        
        RecordList list = null;
        try {
            list = getAdapter().search(request);
        } catch (BridgeError e) {
            error = e;
        }
        
        assertNull(error);
        assertTrue(list.getRecords().size() > 0);
    }
    
    @Test
    public void test_search_vlm_aivid_kvstore() throws Exception{
        BridgeError error = null;
        
        BridgeRequest request = new BridgeRequest();
        
        List<String> fields = Arrays.asList("ip");
        request.setFields(fields);
        
        request.setStructure("servicesNS");
        request.setFields(fields);
        request.setQuery("servicesNS/nobody/search/storage/collections/data/vlm_aivid"
            + "?query={\"$and\":[{\"CIName\":\"<%=parameter[\"CI Name\"]%>\"},"
            + "{\"Status\":\"<%=parameter[\"Status\"]%>\"}]}");
        
        Map parameters = new HashMap();
        // {"$and":[{"CIName":"nrcqaxx0181"},{"Status":"Deployed"}]}
        parameters.put("CI Name", "nrcqaxx0181");
        parameters.put("Status", "Deployed");
        request.setParameters(parameters);
        
        RecordList list = null;
        try {
            list = getAdapter().search(request);
        } catch (BridgeError e) {
            error = e;
        }
        
        assertNull(error);
        assertTrue(list.getRecords().size() > 0);
    }
    
    // This test will fail.
    @Test
    public void test_retrieve_kvstore() throws Exception{
        BridgeError error = null;
        
        BridgeRequest request = new BridgeRequest();
        
        List<String> fields = Arrays.asList("ip");
        request.setFields(fields);
        
        request.setStructure("servicesNS");
        request.setFields(fields);
        request.setQuery("servicesNS/nobody/search/storage/collections/data/vlm_aivid"
            + "?query={\"$and\":[{\"CIName\":\"<%=parameter[\"CI Name\"]%>\"},"
            + "{\"Status\":\"<%=parameter[\"Status\"]%>\"}]}");
        
        Map parameters = new HashMap();
        // {"$and":[{"CIName":"nrcqaxx0181"},{"Status":"Deployed"}]}
        parameters.put("CI Name", "nrcqaxx0181");
        parameters.put("Status", "Deployed");
        request.setParameters(parameters);
        
        Record record = null;
        try {
            record = getAdapter().retrieve(request);
        } catch (BridgeError e) {
            error = e;
        }
        
        assertNull(error);
        assertTrue(record.getRecord().containsKey("ip"));
    }
    
    @Test
    public void test_retrieve_job() throws Exception{
        BridgeError error = null;
        
        BridgeRequest request = new BridgeRequest();
        
        List<String> fields = Arrays.asList("label");
        request.setFields(fields);
        
        request.setStructure("Search Job");
        request.setFields(fields);
        request.setQuery("services/search/jobs/<%=parameter[\"Search Id\"]%>");
        
        Map parameters = new HashMap();
        parameters.put("Search Id", 
            "scheduler__admin_REEtRVNTLU5ldHdvcmtQcm90ZWN0aW9u__RMD55882e714f7fd5be2_at_1562768100_18829");
        request.setParameters(parameters);
        
        Record record = null;
        try {
            record = getAdapter().retrieve(request);
        } catch (BridgeError e) {
            error = e;
        }
        
        assertNull(error);
        assertTrue(record.getRecord().containsKey("id"));