messageserializer.cpp

Pegasus is an open-source implementationof the DMTF CIM and WBEM standards. It is designed to be por

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
    validateCIMObjectPathArray(inMessage.objectNames, outMessage->objectNames);
}

//
// testCIMGetPropertyResponseMessage
//
void testCIMGetPropertyResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids,
    const CIMValue& val)
{
    CIMGetPropertyResponseMessage inMessage(mid, ex, qids, val);
    inMessage.operationContext = oc;
    AutoPtr<CIMGetPropertyResponseMessage> outMessage(
        dynamic_cast<CIMGetPropertyResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(inMessage.value == outMessage->value);
}

//
// testCIMSetPropertyResponseMessage
//
void testCIMSetPropertyResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids)
{
    CIMSetPropertyResponseMessage inMessage(mid, ex, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMSetPropertyResponseMessage> outMessage(
        dynamic_cast<CIMSetPropertyResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
}

//
// testCIMInvokeMethodResponseMessage
//
void testCIMInvokeMethodResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids,
    const CIMValue& retVal,
    const Array<CIMParamValue>& outParams,
    const CIMName& methName)
{
    CIMInvokeMethodResponseMessage inMessage(
        mid, ex, qids, retVal, outParams, methName);
    inMessage.operationContext = oc;
    AutoPtr<CIMInvokeMethodResponseMessage> outMessage(
        dynamic_cast<CIMInvokeMethodResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(inMessage.retValue == outMessage->retValue);
    validateCIMParamValueArray(
        inMessage.outParameters, outMessage->outParameters);
    PEGASUS_TEST_ASSERT(inMessage.methodName == outMessage->methodName);
}

//
// testCIMCreateSubscriptionResponseMessage
//
void testCIMCreateSubscriptionResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids)
{
    CIMCreateSubscriptionResponseMessage inMessage(mid, ex, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMCreateSubscriptionResponseMessage> outMessage(
        dynamic_cast<CIMCreateSubscriptionResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
}

//
// testCIMModifySubscriptionResponseMessage
//
void testCIMModifySubscriptionResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids)
{
    CIMModifySubscriptionResponseMessage inMessage(mid, ex, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMModifySubscriptionResponseMessage> outMessage(
        dynamic_cast<CIMModifySubscriptionResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
}

//
// testCIMDeleteSubscriptionResponseMessage
//
void testCIMDeleteSubscriptionResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids)
{
    CIMDeleteSubscriptionResponseMessage inMessage(mid, ex, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMDeleteSubscriptionResponseMessage> outMessage(
        dynamic_cast<CIMDeleteSubscriptionResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
}

//
// testCIMExportIndicationResponseMessage
//
void testCIMExportIndicationResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids)
{
    CIMExportIndicationResponseMessage inMessage(mid, ex, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMExportIndicationResponseMessage> outMessage(
        dynamic_cast<CIMExportIndicationResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
}

//
// testCIMProcessIndicationResponseMessage
//
void testCIMProcessIndicationResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids)
{
    CIMProcessIndicationResponseMessage inMessage(mid, ex, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMProcessIndicationResponseMessage> outMessage(
        dynamic_cast<CIMProcessIndicationResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
}

//
// testCIMDisableModuleResponseMessage
//
void testCIMDisableModuleResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids,
    const Array<Uint16>& opStatus)
{
    CIMDisableModuleResponseMessage inMessage(mid, ex, qids, opStatus);
    inMessage.operationContext = oc;
    AutoPtr<CIMDisableModuleResponseMessage> outMessage(
        dynamic_cast<CIMDisableModuleResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(inMessage.operationalStatus.size() ==
        outMessage->operationalStatus.size());
    for (Uint32 i = 0; i < inMessage.operationalStatus.size(); i++)
    {
        PEGASUS_TEST_ASSERT(inMessage.operationalStatus[i] ==
            outMessage->operationalStatus[i]);
    }
}

//
// testCIMEnableModuleResponseMessage
//
void testCIMEnableModuleResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids,
    const Array<Uint16>& opStatus)
{
    CIMEnableModuleResponseMessage inMessage(mid, ex, qids, opStatus);
    inMessage.operationContext = oc;
    AutoPtr<CIMEnableModuleResponseMessage> outMessage(
        dynamic_cast<CIMEnableModuleResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(inMessage.operationalStatus.size() ==
        outMessage->operationalStatus.size());
    for (Uint32 i = 0; i < inMessage.operationalStatus.size(); i++)
    {
        PEGASUS_TEST_ASSERT(inMessage.operationalStatus[i] ==
            outMessage->operationalStatus[i]);
    }
}

//
// testCIMStopAllProvidersResponseMessage
//
void testCIMStopAllProvidersResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids)
{
    CIMStopAllProvidersResponseMessage inMessage(mid, ex, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMStopAllProvidersResponseMessage> outMessage(
        dynamic_cast<CIMStopAllProvidersResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
}

//
// testCIMInitializeProviderResponseMessage
//
void testCIMInitializeProviderResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids)
{
    CIMInitializeProviderResponseMessage inMessage(mid, ex, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMInitializeProviderResponseMessage> outMessage(
        dynamic_cast<CIMInitializeProviderResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
}

//
// testCIMInitializeProviderAgentResponseMessage
//
void testCIMInitializeProviderAgentResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids)
{
    CIMInitializeProviderAgentResponseMessage inMessage(mid, ex, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMInitializeProviderAgentResponseMessage> outMessage(
        dynamic_cast<CIMInitializeProviderAgentResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
}

//
// testCIMNotifyConfigChangeResponseMessage
//
void testCIMNotifyConfigChangeResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids)
{
    CIMNotifyConfigChangeResponseMessage inMessage(mid, ex, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMNotifyConfigChangeResponseMessage> outMessage(
        dynamic_cast<CIMNotifyConfigChangeResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
}

//
// testCIMSubscriptionInitCompleteResponseMessage
//
void testCIMSubscriptionInitCompleteResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids)
{
    CIMSubscriptionInitCompleteResponseMessage inMessage(mid, ex, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMSubscriptionInitCompleteResponseMessage> outMessage(
        dynamic_cast<CIMSubscriptionInitCompleteResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
}

//
// main
//
int main(int argc, char** argv)
{
    verbose = getenv("PEGASUS_TEST_VERBOSE");

    // Message IDs
    String mid1;
    String mid2 = "123";
    String mid3 = "ab: g TEST";
    String mid4 = "2134567890asdjkfhbm,zasdlkfjowiqrup[][]{}{=+-_'.,`~|";

    // QueueIdStacks
    QueueIdStack qids1;
    QueueIdStack qids2;
    qids2.push(10);
    qids2.push(5);
    QueueIdStack qids3;
    qids3.push(0);
    qids3.push(0);
    QueueIdStack qids4;
    qids4.push(1000000);

    // Authorization types
    String auth1;
    String auth2 = "Local";
    String auth3 = "Basic";
    String auth4 = "A very secret authorization scheme";

    // User names
    String user1;
    String user2 = "user:2";
    String user3 = "happy";
    String user4 = "doc!";

    // CIMExceptions
    CIMException ex1;
    CIMException ex2(CIM_ERR_NOT_SUPPORTED, "Unsupported operation");
    CIMException ex3(CIM_ERR_ACCESS_DENIED, "");
    CIMException ex4(CIM_ERR_SUCCESS, "How can you have a \"success\" error?");

    // Operation flags
    Boolean lo1 = false;
    Boolean lo2 = true;
    Boolean di1 = false;
    Boolean di2 = true;
    Boolean iq1 = false;
    Boolean iq2 = true;
    Boolean ico1 = false;
    Boolean ico2 = true;

    // CIMPropertyLists
    CIMPropertyList pl1;
    Array<CIMName> plArray2;
    CIMPropertyList pl2(plArray2);
    Array<CIMName> plArray3;
    plArray3.append("MyMostVeryImportantPropertyTheOnlyOneIWant");
    CIMPropertyList pl3(plArray3);
    Array<CIMName> plArray4;
    plArray4.append("P1");
    plArray4.append("P2");
    plArray4.append("P3");
    plArray4.append("P4");
    plArray4.append("P5");
    plArray4.append("P6");
    plArray4.append("P7");
    plArray4.append("P8");
    CIMPropertyList pl4(plArray4);

    // CIMNamespaceNames
    CIMNamespaceName ns1;
    CIMNamespaceName n