testoperationcontext.cpp

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

        if((filterCondition != container.getFilterCondition()) ||
           (queryLanguage != container.getQueryLanguage()))
        {
            cout << "----- SubscriptionFilterCondition Container copy constructor failed" << endl;

            throw 0;
        }
    }

    context.clear();

    {
        String filterCondition("AlertType = 5");
        String queryLanguage("WQL1");

        context.insert(
            SubscriptionFilterConditionContainer(filterCondition, queryLanguage));

        //
        //  This test exercises the SubscriptionFilterConditionContainer
        //  assignment operator
        //
        SubscriptionFilterConditionContainer container =
            SubscriptionFilterConditionContainer(" ", " ");

        container = context.get(SubscriptionFilterConditionContainer::NAME);

        if((filterCondition != container.getFilterCondition()) ||
           (queryLanguage != container.getQueryLanguage()))
        {
            cout << "----- SubscriptionFilterCondition Container assignment operator failed" << endl;

            throw 0;
        }
    }
}

//
//  SubscriptionFilterQueryContainer
//
void Test4(void)
{
    if(verbose)
    {
        cout << "Test4()" << endl;
    }

    OperationContext context;

    {
        String filterQuery("SELECT * FROM CIM_AlertIndication WHERE AlertType = 5");
        String queryLanguage("WQL1");
        CIMNamespaceName sourceNamespace("root/sampleprovider");

        context.insert(
            SubscriptionFilterQueryContainer(filterQuery, queryLanguage, sourceNamespace));

        SubscriptionFilterQueryContainer container =
            context.get(SubscriptionFilterQueryContainer::NAME);

        if((filterQuery != container.getFilterQuery()) ||
           (queryLanguage != container.getQueryLanguage()) ||
           (!(sourceNamespace == container.getSourceNameSpace())))
        {
            cout << "----- Subscription Filter Query Container failed" << endl;

            throw 0;
        }
    }

    context.clear();

    {
        String filterQuery("SELECT * FROM CIM_AlertIndication WHERE AlertType = 5");
        String queryLanguage("WQL1");
        CIMNamespaceName sourceNamespace("root/sampleprovider");

        context.insert(
            SubscriptionFilterQueryContainer(filterQuery, queryLanguage, sourceNamespace));

        //
        //  This test exercises the SubscriptionFilterQueryContainer copy
        //  constructor
        //
        SubscriptionFilterQueryContainer container =
            (SubscriptionFilterQueryContainer)context.get
            (SubscriptionFilterQueryContainer::NAME);

        if((filterQuery != container.getFilterQuery()) ||
           (queryLanguage != container.getQueryLanguage()) ||
           (!(sourceNamespace == container.getSourceNameSpace())))
        {
            cout << "----- SubscriptionFilterQuery Container copy constructor failed" << endl;

            throw 0;
        }
    }

    context.clear();

    {
        String filterQuery("SELECT * FROM CIM_AlertIndication WHERE AlertType = 5");
        String queryLanguage("WQL1");
        CIMNamespaceName sourceNamespace("root/sampleprovider");
        CIMNamespaceName junkNamespace("root/junk");

        context.insert(
            SubscriptionFilterQueryContainer(filterQuery, queryLanguage, sourceNamespace));

        //
        //  This test exercises the SubscriptionFilterQueryContainer
        //  assignment operator
        //
        SubscriptionFilterQueryContainer container =
            SubscriptionFilterQueryContainer(" ", " ", junkNamespace);

        container = context.get(SubscriptionFilterQueryContainer::NAME);

        if((filterQuery != container.getFilterQuery()) ||
           (queryLanguage != container.getQueryLanguage()) ||
           (!(sourceNamespace == container.getSourceNameSpace())))
        {
            cout << "----- SubscriptionFilterQuery Container assignment operator failed" << endl;

            throw 0;
        }
    }
}

//
//  SubscriptionInstanceNamesContainer
//
void Test5(void)
{
    if(verbose)
    {
        cout << "Test5()" << endl;
    }

    OperationContext context;

    CIMInstance subscriptionInstance1 = _createSubscriptionInstance1();
    CIMInstance subscriptionInstance2 = _createSubscriptionInstance2();

    Array<CIMObjectPath> subscriptionInstanceNames;

    subscriptionInstanceNames.append(subscriptionInstance1.getPath());
    subscriptionInstanceNames.append(subscriptionInstance2.getPath());

    {
        context.insert(
            SubscriptionInstanceNamesContainer(subscriptionInstanceNames));

        SubscriptionInstanceNamesContainer container =
            context.get(SubscriptionInstanceNamesContainer::NAME);

        Array<CIMObjectPath> returnedInstanceNames =
            container.getInstanceNames();

        for(Uint8 i = 0, n = subscriptionInstanceNames.size(); i < n; i++)
        {
            if(!subscriptionInstanceNames[i].identical(returnedInstanceNames[i]))
            {
                cout << "----- Subscription Instance Names Container failed" << endl;

                throw 0;
            }
        }
    }

    context.clear();

    {
        context.insert(
            SubscriptionInstanceNamesContainer(subscriptionInstanceNames));

        //
        //  This test exercises the SubscriptionInstanceNamesContainer copy
        //  constructor
        //
        SubscriptionInstanceNamesContainer container =
            context.get(SubscriptionInstanceNamesContainer::NAME);

        Array<CIMObjectPath> returnedInstanceNames =
            container.getInstanceNames();

        for(Uint8 i = 0, n = subscriptionInstanceNames.size(); i < n; i++)
        {
            if(!subscriptionInstanceNames[i].identical(returnedInstanceNames[i]))
            {
                cout << "----- Subscription Instance Names Container copy constructor failed" << endl;

                throw 0;
            }
        }
    }

    context.clear();

    {
        context.insert(
            SubscriptionInstanceNamesContainer(subscriptionInstanceNames));

        //
        //  This test exercises the SubscriptionInstanceNamesContainer
        //  assignment operator
        //
        Array<CIMObjectPath> returnedInstanceNames;

        SubscriptionInstanceNamesContainer container =
            SubscriptionInstanceNamesContainer(returnedInstanceNames);

        container = context.get(SubscriptionInstanceNamesContainer::NAME);

        returnedInstanceNames = container.getInstanceNames();

        for(Uint8 i = 0, n = subscriptionInstanceNames.size(); i < n; i++)
        {
            if(!subscriptionInstanceNames[i].identical(returnedInstanceNames[i]))
            {
                cout << "----- Subscription Instance Names Container assignment operator failed" << endl;

                throw 0;
            }
        }
    }
}

void Test6(void)
{
    if(verbose)
    {
        cout << "Test6()" << endl;
    }

    OperationContext context;

    String languageId("en-US");

    context.insert(LocaleContainer(languageId));

    LocaleContainer container = context.get(LocaleContainer::NAME);

    if(languageId != container.getLanguageId())
    {
        cout << "----- Locale Container failed" << endl;

        throw 0;
    }
}

void Test7(void)
{
    if(verbose)
    {
        cout << "Test7()" << endl;
    }

    OperationContext context;

    CIMInstance module("PG_ProviderModule");
    CIMInstance provider("PG_Provider");
    Boolean isRemoteNameSpace = true;
    String remoteInfo("remote_info");

    context.insert(ProviderIdContainer(module, provider, isRemoteNameSpace, remoteInfo));

    ProviderIdContainer container = context.get(ProviderIdContainer::NAME);

    if(!module.identical(container.getModule()) ||
       !provider.identical(container.getProvider()) ||
       (isRemoteNameSpace != container.isRemoteNameSpace()) ||
       (remoteInfo != container.getRemoteInfo()))
    {
        cout << "----- Provider Id Container failed" << endl;

        throw 0;
    }
}

void Test8(void)
{
    if(verbose)
    {
        cout << "Test8()" << endl;
    }

    OperationContext context;

    try
    {
        OperationContext scopeContext;

        scopeContext = context;

        scopeContext.remove(IdentityContainer::NAME);
        scopeContext.remove(SubscriptionInstanceContainer::NAME);
        scopeContext.remove(SubscriptionFilterConditionContainer::NAME);
        scopeContext.remove(SubscriptionFilterQueryContainer::NAME);
        scopeContext.remove(LocaleContainer::NAME);
        scopeContext.remove(ProviderIdContainer::NAME);
    }
    catch(...)
    {
    }
}

//
//  SnmpTrapOidContainer
//
void Test9(void)
{
    if(verbose)
    {
        cout << "Test9()" << endl;
    }

    OperationContext context;

    {
        String snmpTrapOid ("1.3.6.1.4.1.992.2.3.9210.8400");

        context.insert(SnmpTrapOidContainer(snmpTrapOid));

        SnmpTrapOidContainer container = context.get(SnmpTrapOidContainer::NAME);

        if(snmpTrapOid != container.getSnmpTrapOid())
        {
            cout << "----- Snmp Trap Oid Container failed" << endl;

            throw 0;
        }
    }

    context.clear();

    {
        String snmpTrapOid ("1.3.6.1.4.1.992.2.3.9210.8400");

        context.insert(SnmpTrapOidContainer(snmpTrapOid));

        //
        //  This test exercises the SnmpTrapOidContainer copy
        //  constructor
        //
        SnmpTrapOidContainer container = context.get(SnmpTrapOidContainer::NAME);

        if(snmpTrapOid != container.getSnmpTrapOid())
        {
            cout << "----- SnmpTrapOid Container copy constructor failed" << endl;

            throw 0;
        }
    }

    context.clear();

    {
        String snmpTrapOid ("1.3.6.1.4.1.992.2.3.9210.8400");

        context.insert(SnmpTrapOidContainer(snmpTrapOid));

        //
        //  This test exercises the SnmpTrapOidContainer
        //  assignment operator
        //
        SnmpTrapOidContainer container = SnmpTrapOidContainer(" ");

        container = context.get(SnmpTrapOidContainer::NAME);

        if(snmpTrapOid != container.getSnmpTrapOid())
        {
            cout << "----- SnmpTrapOid Container assignment operator failed" << endl;

            throw 0;
        }
    }
}

void Test10(void)
{
    if(verbose)
    {
        cout << "Test10()" << endl;
    }

    OperationContext context;

    CIMClass cimClass("CachedClass");

    context.insert(CachedClassDefinitionContainer(cimClass));

    CachedClassDefinitionContainer container =
        context.get(CachedClassDefinitionContainer::NAME);

    if(cimClass.getClassName().getString() != container.getClass().getClassName().getString())
    {
        cout << "----- CachedClassDefinitionContainer failed" << endl;

        throw 0;
    }
}

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

    try
    {
        Test1();
        Test2();
        Test3();
        Test4();
        Test5();
        Test6();
        Test7();
        Test8();
        Test9();
        Test10();

        cout << argv[0] << " +++++ passed all tests" << endl;
    }
    catch(CIMException & e)
    {
        cout << argv[0] << " ----- failed with CIMException(" << e.getCode() << "):" << e.getMessage() << endl;
    }
    catch(Exception & e)
    {
        cout << argv[0] << " ----- failed with Exception:" << e.getMessage() << endl;
    }
    catch(...)
    {
        cout << argv[0] << " ----- failed with unknown exception" <<  endl;
    }

    return(0);
}