added pull test

4 files changed, 283 insertions, 0 deletions

diff --git a/tests/cunit/Makefile.am b/tests/cunit/Makefile.am
index 79ec42a..f282adc 100644
--- a/tests/cunit/Makefile.am
+++ b/tests/cunit/Makefile.am
@@ -15,6 +15,7 @@ wsman_cunit_tests_SOURCES = run_tests.c \
 		    invoke.c \
 		    enumeration.c \
 		    transfer_get.c \
+		    pull.c \
 		    transfer_put.c 
 
 noinst_PROGRAMS = wsman_cunit_tests 
diff --git a/tests/cunit/common.h b/tests/cunit/common.h
index beac564..33ac369 100644
--- a/tests/cunit/common.h
+++ b/tests/cunit/common.h
@@ -53,5 +53,6 @@ int add_identify_tests(CU_pSuite ps);
 int add_transfer_get_tests(CU_pSuite ps);
 int add_transfer_put_tests(CU_pSuite ps);
 int add_invoke_tests(CU_pSuite ps);
+int add_pull_tests(CU_pSuite ps);
 
 #endif
diff --git a/tests/cunit/pull.c b/tests/cunit/pull.c
new file mode 100644
index 0000000..60155b9
--- /dev/null
+++ b/tests/cunit/pull.c
@@ -0,0 +1,280 @@
+/*******************************************************************************
+ * Copyright (C) 2004-2006 Intel Corp. All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ *  - Redistributions of source code must retain the above copyright notice,
+ *    this list of conditions and the following disclaimer.
+ *
+ *  - Redistributions in binary form must reproduce the above copyright notice,
+ *    this list of conditions and the following disclaimer in the documentation
+ *    and/or other materials provided with the distribution.
+ *
+ *  - Neither the name of Intel Corp. nor the names of its
+ *    contributors may be used to endorse or promote products derived from this
+ *    software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS ``AS IS''
+ * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED. IN NO EVENT SHALL Intel Corp. OR THE CONTRIBUTORS
+ * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
+ * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
+ * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
+ * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
+ * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
+ * POSSIBILITY OF SUCH DAMAGE.
+ *******************************************************************************/
+
+/**
+ * @author Anas Nashif
+ * @author Nathan Rakoff
+ */
+#include "wsman_config.h"
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
+#include <errno.h>
+#include <time.h>
+
+#include "u/libu.h"
+
+#include "wsman-client-api.h"
+#include "wsman-client-transport.h"
+#include "wsman-debug.h"
+#include "common.h"
+
+
+
+
+
+
+static TestData pull_tests[] = {
+  {
+    "Enumeration with non existent Resource URI.", 
+    "http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_ComputerSystemxx", 
+    NULL, 
+    NULL, 
+    NULL, 
+    "/s:Envelope/s:Body/s:Fault/s:Code/s:Subcode/s:Value",
+    "wsa:DestinationUnreachable",
+    "/s:Envelope/s:Body/s:Fault/s:Detail/wsman:FaultDetail",
+    "http://schemas.dmtf.org/wbem/wsman/1/wsman/faultDetail/InvalidResourceURI",
+    500,
+    FLAG_NONE,
+    0
+  },
+  {
+    "Enumeration with non existent Resource URI. (Optimized)", 
+    "http://schema.omc-project.org/wbem/wscim/1/cim-schema/2/OMC_InitdService", 
+    NULL, 
+    NULL, 
+    NULL, 
+    NULL, 
+    NULL, 
+    NULL, 
+    NULL, 
+    200,
+    FLAG_ENUMERATION_OPTIMIZATION,
+    200
+  },
+  {
+    "Enumeration with non existent Resource URI. (Optimized/EPR/Count)", 
+    "http://schema.omc-project.org/wbem/wscim/1/cim-schema/2/OMC_InitdService", 
+    NULL, 
+    NULL, 
+    NULL, 
+    NULL, 
+    NULL, 
+    NULL, 
+    NULL, 
+    200,
+    FLAG_ENUMERATION_OPTIMIZATION | FLAG_ENUMERATION_ENUM_EPR | FLAG_ENUMERATION_COUNT_ESTIMATION ,
+    200
+  },
+  {
+    "Enumeration with non existent Resource URI. (Optimized/EPR)", 
+    "http://schema.omc-project.org/wbem/wscim/1/cim-schema/2/OMC_InitdService", 
+    NULL, 
+    NULL, 
+    NULL, 
+    NULL, 
+    NULL, 
+    NULL, 
+    NULL, 
+    200,
+    FLAG_ENUMERATION_OPTIMIZATION | FLAG_ENUMERATION_ENUM_EPR,
+    200
+  },
+  {
+    "Enumeration with non existent Resource URI. (Optimized/ObjEPR)", 
+    "http://schema.omc-project.org/wbem/wscim/1/cim-schema/2/OMC_InitdService", 
+    NULL, 
+    NULL, 
+    NULL, 
+    NULL, 
+    NULL, 
+    NULL, 
+    NULL, 
+    200,
+    FLAG_ENUMERATION_OPTIMIZATION | FLAG_ENUMERATION_ENUM_OBJ_AND_EPR,
+    200
+  },
+  {
+    "Enumeration with valid Resource URI and Items Count Estimation.",
+    "http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_ComputerSystem",
+    NULL, 
+    NULL, 
+    NULL, 
+    "/s:Envelope/s:Header/wsman:TotalItemsCountEstimate",
+    "3",
+    NULL,
+    NULL,
+    200,
+    FLAG_ENUMERATION_COUNT_ESTIMATION,
+    0
+  }, /*
+     {
+     "Enumeration with valid Resource URI.",
+     "http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_ComputerSystem",
+     NULL, 
+     200,
+     FLAG_NONE,
+     0
+     },
+     {
+     "Enumeration with valid Resource URI and additional invalid selectors.",
+     "http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_ComputerSystem",
+     NULL, 
+     200,
+     FLAG_NONE,
+     1
+     },	
+     {
+     "Enumeration with valid Resource URI/Count Estimation.",
+     "http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_ComputerSystem",
+     NULL, 
+     200,
+     FLAG_ENUMERATION_COUNT_ESTIMATION,
+     0
+     },
+     {
+     "Enumeration with valid Resource URI/Optimization.",
+     "http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_ComputerSystem",
+     NULL, 
+     200,
+     FLAG_ENUMERATION_OPTIMIZATION,
+     0
+     },	
+     {
+     "Enumeration with Count Estimation/Optimzation and get all elements.",
+     "http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_ComputerSystem",
+     NULL, 
+     200,
+     FLAG_ENUMERATION_OPTIMIZATION | FLAG_ENUMERATION_COUNT_ESTIMATION,
+     10
+
+     },
+     {
+     "Enumeration with Count Estimation/Optimzation/Epr and get all elements.",
+     "http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_ComputerSystem",
+     NULL, 
+     200,
+     FLAG_ENUMERATION_OPTIMIZATION | FLAG_ENUMERATION_COUNT_ESTIMATION | FLAG_ENUMERATION_ENUM_EPR,
+     10
+
+     },	
+     {
+     "Enumeration with Count Estimation/Optimzation/ObjAndEpr and get all elements.",
+     "http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_ComputerSystem",
+     NULL, 
+     200,
+     FLAG_ENUMERATION_OPTIMIZATION | FLAG_ENUMERATION_COUNT_ESTIMATION | FLAG_ENUMERATION_ENUM_OBJ_AND_EPR,
+     10
+
+     }	*/
+};
+
+
+static int ntests = sizeof (pull_tests) / sizeof (pull_tests[0]);
+
+
+extern WsManClient *cl;
+
+actionOptions options;
+
+static void pull_test() {
+    char *enumContext = NULL;
+    static int i = 0;
+    char *xp = NULL;
+
+    reinit_client_connection(cl);
+    initialize_action_options(&options);
+
+    options.flags = pull_tests[i].flags;
+
+    if (pull_tests[i].selectors != NULL)
+         wsman_add_selectors_from_query_string(&options, pull_tests[i].selectors);
+
+    options.max_elements = pull_tests[i].max_elements;
+    WsXmlDocH enum_response = wsenum_enumerate(cl,
+                                (char *)pull_tests[i].resource_uri, options);
+    CU_ASSERT_TRUE(wsman_get_client_response_code(cl) == pull_tests[i].final_status );
+    CU_ASSERT_PTR_NOT_NULL(enum_response);
+
+    if (enum_response) {
+        enumContext = wsenum_get_enum_context(enum_response);
+    } else {
+        enumContext = NULL;
+    }
+
+    while (enumContext != NULL)
+    {                       
+        WsXmlDocH docp = wsenum_pull(cl, (char *)pull_tests[i].resource_uri, enumContext,
+                options);
+        CU_ASSERT_PTR_NOT_NULL(docp);
+        if (!docp) {
+            break;
+        }
+        if (pull_tests[i].expr1 == NULL) {
+            goto RETURN;
+        }
+        xp = ws_xml_get_xpath_value(docp, pull_tests[i].expr1);
+        CU_ASSERT_PTR_NOT_NULL(xp);
+        if (!xp) {
+            goto RETURN;
+        }
+        CU_ASSERT_STRING_EQUAL(xp, pull_tests[i].value1 );
+        enumContext = wsenum_get_enum_context(docp);
+        ws_xml_destroy_doc(docp);
+    }
+
+
+
+RETURN:
+    if (enum_response) {
+        ws_xml_destroy_doc(enum_response);
+    }
+    u_free(xp);
+    destroy_action_options(&options);
+    i++; // decrease executed test number
+}
+
+
+int add_pull_tests(CU_pSuite ps) {
+    int found_test = 0;
+    int i;
+
+        /* add the tests to the suite */
+    for (i = 0; i < ntests; i++) {
+        found_test += (NULL != CU_add_test(ps,
+                            pull_tests[i].explanation, pull_test));
+    }
+    return (found_test > 0);
+}
+
+
diff --git a/tests/cunit/run_tests.c b/tests/cunit/run_tests.c
index b581d78..ed0e52b 100644
--- a/tests/cunit/run_tests.c
+++ b/tests/cunit/run_tests.c
@@ -53,6 +53,7 @@ setup_client_suite(void) {
 
    /* add the tests to the suite */
    num_tests += add_enumeration_tests(ps);
+   num_tests += add_pull_tests(ps);
    num_tests += add_identify_tests(ps);
    num_tests += add_transfer_get_tests(ps);
    num_tests += add_transfer_put_tests(ps);