messageserializer.cpp

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

    PEGASUS_TEST_ASSERT(inMessage.objectName == outMessage->objectName);
    PEGASUS_TEST_ASSERT(inMessage.assocClass == outMessage->assocClass);
    PEGASUS_TEST_ASSERT(inMessage.resultClass == outMessage->resultClass);
    PEGASUS_TEST_ASSERT(inMessage.role == outMessage->role);
    PEGASUS_TEST_ASSERT(inMessage.resultRole == outMessage->resultRole);
    PEGASUS_TEST_ASSERT(
        inMessage.includeQualifiers == outMessage->includeQualifiers);
    PEGASUS_TEST_ASSERT(
        inMessage.includeClassOrigin == outMessage->includeClassOrigin);
    validateCIMPropertyList(inMessage.propertyList, outMessage->propertyList);
    PEGASUS_TEST_ASSERT(inMessage.authType == outMessage->authType);
    PEGASUS_TEST_ASSERT(inMessage.userName == outMessage->userName);
}

//
// testCIMAssociatorNamesRequestMessage
//
void testCIMAssociatorNamesRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMNamespaceName& ns,
    const CIMObjectPath& path,
    const CIMName& assocClass,
    const CIMName& resultClass,
    const String& role,
    const String& resultRole,
    const QueueIdStack& qids,
    const String& auth,
    const String& user)
{
    CIMAssociatorNamesRequestMessage inMessage(
        mid, ns, path, assocClass, resultClass, role, resultRole,
        qids, auth, user);
    inMessage.operationContext = oc;
    AutoPtr<CIMAssociatorNamesRequestMessage> outMessage(
        dynamic_cast<CIMAssociatorNamesRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMOperationRequestMessageAttributes(&inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(inMessage.objectName == outMessage->objectName);
    PEGASUS_TEST_ASSERT(inMessage.assocClass == outMessage->assocClass);
    PEGASUS_TEST_ASSERT(inMessage.resultClass == outMessage->resultClass);
    PEGASUS_TEST_ASSERT(inMessage.role == outMessage->role);
    PEGASUS_TEST_ASSERT(inMessage.resultRole == outMessage->resultRole);
    PEGASUS_TEST_ASSERT(inMessage.authType == outMessage->authType);
    PEGASUS_TEST_ASSERT(inMessage.userName == outMessage->userName);
}

//
// testCIMReferencesRequestMessage
//
void testCIMReferencesRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMNamespaceName& ns,
    const CIMObjectPath& path,
    const CIMName& resultClass,
    const String& role,
    Boolean iq,
    Boolean ico,
    const CIMPropertyList& pl,
    const QueueIdStack& qids,
    const String& auth,
    const String& user)
{
    CIMReferencesRequestMessage inMessage(
        mid, ns, path, resultClass, role, iq, ico, pl, qids, auth, user);
    inMessage.operationContext = oc;
    AutoPtr<CIMReferencesRequestMessage> outMessage(
        dynamic_cast<CIMReferencesRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMOperationRequestMessageAttributes(&inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(inMessage.objectName == outMessage->objectName);
    PEGASUS_TEST_ASSERT(inMessage.resultClass == outMessage->resultClass);
    PEGASUS_TEST_ASSERT(inMessage.role == outMessage->role);
    PEGASUS_TEST_ASSERT(
        inMessage.includeQualifiers == outMessage->includeQualifiers);
    PEGASUS_TEST_ASSERT(
        inMessage.includeClassOrigin == outMessage->includeClassOrigin);
    validateCIMPropertyList(inMessage.propertyList, outMessage->propertyList);
    PEGASUS_TEST_ASSERT(inMessage.authType == outMessage->authType);
    PEGASUS_TEST_ASSERT(inMessage.userName == outMessage->userName);
}

//
// testCIMReferenceNamesRequestMessage
//
void testCIMReferenceNamesRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMNamespaceName& ns,
    const CIMObjectPath& path,
    const CIMName& resultClass,
    const String& role,
    const QueueIdStack& qids,
    const String& auth,
    const String& user)
{
    CIMReferenceNamesRequestMessage inMessage(
        mid, ns, path, resultClass, role, qids, auth, user);
    inMessage.operationContext = oc;
    AutoPtr<CIMReferenceNamesRequestMessage> outMessage(
        dynamic_cast<CIMReferenceNamesRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMOperationRequestMessageAttributes(&inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(inMessage.objectName == outMessage->objectName);
    PEGASUS_TEST_ASSERT(inMessage.resultClass == outMessage->resultClass);
    PEGASUS_TEST_ASSERT(inMessage.role == outMessage->role);
    PEGASUS_TEST_ASSERT(inMessage.authType == outMessage->authType);
    PEGASUS_TEST_ASSERT(inMessage.userName == outMessage->userName);
}

//
// testCIMGetPropertyRequestMessage
//
void testCIMGetPropertyRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMNamespaceName& ns,
    const CIMObjectPath& path,
    const CIMName& propName,
    const QueueIdStack& qids,
    const String& auth,
    const String& user)
{
    CIMGetPropertyRequestMessage inMessage(
        mid, ns, path, propName, qids, auth, user);
    inMessage.operationContext = oc;
    AutoPtr<CIMGetPropertyRequestMessage> outMessage(
        dynamic_cast<CIMGetPropertyRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMOperationRequestMessageAttributes(&inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(inMessage.instanceName == outMessage->instanceName);
    PEGASUS_TEST_ASSERT(inMessage.propertyName == outMessage->propertyName);
    PEGASUS_TEST_ASSERT(inMessage.authType == outMessage->authType);
    PEGASUS_TEST_ASSERT(inMessage.userName == outMessage->userName);
}

//
// testCIMSetPropertyRequestMessage
//
void testCIMSetPropertyRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMNamespaceName& ns,
    const CIMObjectPath& path,
    const CIMName& propName,
    const CIMValue& newValue,
    const QueueIdStack& qids,
    const String& auth,
    const String& user)
{
    CIMSetPropertyRequestMessage inMessage(
        mid, ns, path, propName, newValue, qids, auth, user);
    inMessage.operationContext = oc;
    AutoPtr<CIMSetPropertyRequestMessage> outMessage(
        dynamic_cast<CIMSetPropertyRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMOperationRequestMessageAttributes(&inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(inMessage.instanceName == outMessage->instanceName);
    PEGASUS_TEST_ASSERT(inMessage.propertyName == outMessage->propertyName);
    PEGASUS_TEST_ASSERT(inMessage.newValue == outMessage->newValue);
    PEGASUS_TEST_ASSERT(inMessage.authType == outMessage->authType);
    PEGASUS_TEST_ASSERT(inMessage.userName == outMessage->userName);
}

//
// testCIMInvokeMethodRequestMessage
//
void testCIMInvokeMethodRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMNamespaceName& ns,
    const CIMObjectPath& path,
    const CIMName& methName,
    const Array<CIMParamValue>& pvArray,
    const QueueIdStack& qids,
    const String& auth,
    const String& user)
{
    CIMInvokeMethodRequestMessage inMessage(
        mid, ns, path, methName, pvArray, qids, auth, user);
    inMessage.operationContext = oc;
    AutoPtr<CIMInvokeMethodRequestMessage> outMessage(
        dynamic_cast<CIMInvokeMethodRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMOperationRequestMessageAttributes(&inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(inMessage.instanceName == outMessage->instanceName);
    PEGASUS_TEST_ASSERT(inMessage.methodName == outMessage->methodName);
    validateCIMParamValueArray(
        inMessage.inParameters, outMessage->inParameters);
    PEGASUS_TEST_ASSERT(inMessage.authType == outMessage->authType);
    PEGASUS_TEST_ASSERT(inMessage.userName == outMessage->userName);
}

//
// testCIMCreateSubscriptionRequestMessage
//
void testCIMCreateSubscriptionRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMNamespaceName& ns,
    const CIMInstance& inst,
    const Array<CIMName>& nameArray,
    const CIMPropertyList& pl,
    Uint16 rnp,
    const String& qs,
    const QueueIdStack& qids,
    const String& auth,
    const String& user)
{
    CIMCreateSubscriptionRequestMessage inMessage(
        mid, ns, inst, nameArray, pl, rnp, qs, qids, auth, user);
    inMessage.operationContext = oc;
    AutoPtr<CIMCreateSubscriptionRequestMessage> outMessage(
        dynamic_cast<CIMCreateSubscriptionRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMIndicationRequestMessageAttributes(
        &inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(inMessage.nameSpace == outMessage->nameSpace);
    validateCIMInstance(
        inMessage.subscriptionInstance, outMessage->subscriptionInstance);
    validateCIMNameArray(inMessage.classNames, outMessage->classNames);
    validateCIMPropertyList(inMessage.propertyList, outMessage->propertyList);
    PEGASUS_TEST_ASSERT(inMessage.repeatNotificationPolicy ==
        outMessage->repeatNotificationPolicy);
    PEGASUS_TEST_ASSERT(inMessage.query == outMessage->query);
    PEGASUS_TEST_ASSERT(inMessage.authType == outMessage->authType);
    PEGASUS_TEST_ASSERT(inMessage.userName == outMessage->userName);
}

//
// testCIMModifySubscriptionRequestMessage
//
void testCIMModifySubscriptionRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMNamespaceName& ns,
    const CIMInstance& inst,
    const Array<CIMName>& nameArray,
    const CIMPropertyList& pl,
    Uint16 rnp,
    const String& qs,
    const QueueIdStack& qids,
    const String& auth,
    const String& user)
{
    CIMModifySubscriptionRequestMessage inMessage(
        mid, ns, inst, nameArray, pl, rnp, qs, qids, auth, user);
    inMessage.operationContext = oc;
    AutoPtr<CIMModifySubscriptionRequestMessage> outMessage(
        dynamic_cast<CIMModifySubscriptionRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMIndicationRequestMessageAttributes(
        &inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(inMessage.nameSpace == outMessage->nameSpace);
    validateCIMInstance(
        inMessage.subscriptionInstance, outMessage->subscriptionInstance);
    validateCIMNameArray(inMessage.classNames, outMessage->classNames);
    validateCIMPropertyList(inMessage.propertyList, outMessage->propertyList);
    PEGASUS_TEST_ASSERT(inMessage.repeatNotificationPolicy ==
        outMessage->repeatNotificationPolicy);
    PEGASUS_TEST_ASSERT(inMessage.query == outMessage->query);
    PEGASUS_TEST_ASSERT(inMessage.authType == outMessage->authType);
    PEGASUS_TEST_ASSERT(inMessage.userName == outMessage->userName);
}

//
// testCIMDeleteSubscriptionRequestMessage
//
void testCIMDeleteSubscriptionRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMNamespaceName& ns,
    const CIMInstance& inst,
    const Array<CIMName>& nameArray,
    const QueueIdStack& qids,
    const String& auth,
    const String& user)
{
    CIMDeleteSubscriptionRequestMessage inMessage(
        mid, ns, inst, nameArray, qids, auth, user);
    inMessage.operationContext = oc;
    AutoPtr<CIMDeleteSubscriptionRequestMessage> outMessage(
        dynamic_cast<CIMDeleteSubscriptionRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMIndicationRequestMessageAttributes(
        &inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(inMessage.nameSpace == outMessage->nameSpace);
    validateCIMInstance(
        inMessage.subscriptionInstance, outMessage->subscriptionInstance);
    validateCIMNameArray(inMessage.classNames, outMessage->classNames);
    PEGASUS_TEST_ASSERT(inMessage.authType == outMessage->authType);
    PEGASUS_TEST_ASSERT(inMessage.userName == outMessage->userName);
}

//
// testCIMExportIndicationRequestMessage
//
void testCIMExportIndicationRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const String& dest,
    const CIMInstance& inst,
    const QueueIdStack& qids,
    const String& auth,
    const String& user)
{
    CIMExportIndicationRequestMessage inMessage(
        mid, dest, inst, qids, auth, user);
    inMessage.operationContext = oc;
    AutoPtr<CIMExportIndicationRequestMessage> outMessage(
        dynamic_cast<CIMExportIndicationRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMRequestMessageAttributes(&inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(
        inMessage.destinationPath == outMessage->destinationPath);
    validateCIMInstance(
        inMessage.indicationInstance, outMessage->indicationInstance);
    PEGASUS_TEST_ASSERT(inMessage.authType == outMessage->authType);
    PEGASUS_TEST_ASSERT(inMessage.userName == outMessage->userName);
}

//
// testCIMProcessIndicationRequestMessage
//
void testCIMProcessIndicationRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMNamespaceName& ns,
    const CIMInstance& inst,
    const Array<CIMObjectPath>& subsInstArray,
    const CIMInstance& provider,
    const QueueIdStack& qids)
{
    CIMProcessIndicationRequestMessage inMessage(
        mid, ns, inst, subsInstArray, provider, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMProcessIndicationRequestMessage> outMessage(
        dynamic_cast<CIMProcessIndicationRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMRequestMessageAttributes(&inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(inMessage.nameSpace == outMessage->nameSpace);
    validateCIMInstance(
        inMessage.indicationInstance, outMessage->indicationInstance);
    validateCIMObjectPathArray(inMessage.subscriptionInstanceNames,
        outMessage->subscriptionInstanceNames);
    validateCIMInstance(inMessage.provider, outMessage->provider);
}

//
// testCIMDisableModuleRequestMessage
//
void testCIMDisableModuleRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMInstance& provModule,
    const Array<CIMInstance>& providers,
    Boolean providerOnly,
    const Array<Boolean>& indProv,
    const QueueIdStack& qids,
    const String& auth,
    const String& user)
{
    CIMDisableModuleRequestMessage inMessage(
        mid, provModule, providers, providerOnly, indProv, qids, auth, user);
    inMessage.operationContext = oc;
    AutoPtr<CIMDisableModuleRequestMessage> outMessage(