cimsubinterop.cpp

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

    {
         String wql("WQL");
         String cql("DMTF:CQL");

        _createCimsubSyslogTests(client, wql);
        //        _delete(client);

#ifndef PEGASUS_DISABLE_CQL
        //        _createCimsubSyslogTests(client, cql);
        //        _delete (client);
#endif
    }
    catch (Exception & e)
    {
        cerr << "setup failed: " << e.getMessage() << endl;
        exit (-1);
    }

    cout << "+++++ setup completed successfully" << endl;
}
#endif

#ifdef PEGASUS_ENABLE_EMAIL_HANDLER

//
//  Creates filters, handlers, and subscriptions for email handler
//
void _createCimsubEmailTests(CIMClient & client, String& qlang)
{
    CIMObjectPath path;
    String query;
    //
    //  Create persistent email handler
    //
    String mailAddr1 = "foo@x.x.x";

    //
    //  Create filter that selects all properties from CIM_ProcessIndication
    //
    CIMInstance emailfilter01(PEGASUS_CLASSNAME_INDFILTER);
    query = "SELECT * FROM CIM_ProcessIndication";
    _addStringProperty(emailfilter01, "SystemCreationClassName",
         System::getSystemCreationClassName());
    _addStringProperty(emailfilter01, "SystemName",
         System::getFullyQualifiedHostName());
    _addStringProperty(emailfilter01,
         PEGASUS_PROPERTYNAME_CREATIONCLASSNAME.getString(),
         PEGASUS_CLASSNAME_INDFILTER.getString());
    _addStringProperty(emailfilter01,
        PEGASUS_PROPERTYNAME_NAME.getString(), "EmailFilter01");
    _addStringProperty(emailfilter01, "SourceNamespace",
        SOURCENAMESPACE.getString());
    _addStringProperty(emailfilter01,
        PEGASUS_PROPERTYNAME_QUERY.getString(),
        query);
    _addStringProperty(emailfilter01, 
        PEGASUS_PROPERTYNAME_QUERYLANGUAGE.getString(), qlang);
    path = client.createInstance(NAMESPACE, emailfilter01);

    CIMInstance emailHandler01(PEGASUS_CLASSNAME_LSTNRDST_EMAIL);
    _addStringProperty(emailHandler01, "SystemCreationClassName",
         System::getSystemCreationClassName());
    _addStringProperty(emailHandler01, "SystemName",
         System::getFullyQualifiedHostName());
    _addStringProperty(emailHandler01,
         PEGASUS_PROPERTYNAME_CREATIONCLASSNAME.getString(),
         PEGASUS_CLASSNAME_LSTNRDST_EMAIL.getString());
    _addStringProperty(emailHandler01,
        PEGASUS_PROPERTYNAME_NAME.getString(), "EmailHandler01");
    _addUint16Property(emailHandler01,
        PEGASUS_PROPERTYNAME_PERSISTENCETYPE.getString(),
        PERSISTENCE_PERMANENT);
    _addStringProperty(emailHandler01, "OtherPersistenceType",
        String::EMPTY, true);
    _addStringProperty(emailHandler01,
        PEGASUS_PROPERTYNAME_LSTNRDST_MAILTO.getString(), mailAddr1,
        false, true );
    _addStringProperty(emailHandler01,
        PEGASUS_PROPERTYNAME_LSTNRDST_MAILCC.getString(),
        "fooCC@x.x.x", false, true);
    _addStringProperty(emailHandler01,
        PEGASUS_PROPERTYNAME_LSTNRDST_MAILSUBJECT.getString(),
        "cimsub test");
    path = client.createInstance(NAMESPACE, emailHandler01);

    CIMInstance emailHandler02(PEGASUS_CLASSNAME_LSTNRDST_EMAIL);
    _addStringProperty(emailHandler02, "SystemCreationClassName",
         System::getSystemCreationClassName());
    _addStringProperty(emailHandler02, "SystemName",
         System::getFullyQualifiedHostName());
    _addStringProperty(emailHandler02,
         PEGASUS_PROPERTYNAME_CREATIONCLASSNAME.getString(),
         PEGASUS_CLASSNAME_LSTNRDST_EMAIL.getString());
    _addStringProperty(emailHandler02,
        PEGASUS_PROPERTYNAME_NAME.getString(), "EmailHandler02");
    _addUint16Property(emailHandler02,
        PEGASUS_PROPERTYNAME_PERSISTENCETYPE.getString(),
        PERSISTENCE_PERMANENT);
    _addStringProperty(emailHandler02, "OtherPersistenceType",
        String::EMPTY, true);
    _addStringProperty(emailHandler02,
        PEGASUS_PROPERTYNAME_LSTNRDST_MAILTO.getString(), mailAddr1,
        false, true );
    _addStringProperty(emailHandler02,
        PEGASUS_PROPERTYNAME_LSTNRDST_MAILSUBJECT.getString(),
        "cimsub test");
    path = client.createInstance(NAMESPACE, emailHandler02);

    //
    //  Create subscription with email handler
    //
    CIMInstance subscription_email1 = _buildSubscriptionInstance(
        _buildFilterOrHandlerPath(PEGASUS_CLASSNAME_INDFILTER,
            "EmailFilter01", String::EMPTY,NAMESPACE),
        PEGASUS_CLASSNAME_LSTNRDST_EMAIL,
        _buildFilterOrHandlerPath(PEGASUS_CLASSNAME_LSTNRDST_EMAIL,
            "EmailHandler01"));
    path = client.createInstance(NAMESPACE, subscription_email1);

    //
    //  Create subscription with email handler
    //
    CIMInstance subscription_email2 = _buildSubscriptionInstance(
        _buildFilterOrHandlerPath(PEGASUS_CLASSNAME_INDFILTER,
            "EmailFilter01", String::EMPTY,NAMESPACE),
        PEGASUS_CLASSNAME_LSTNRDST_EMAIL,
        _buildFilterOrHandlerPath(PEGASUS_CLASSNAME_LSTNRDST_EMAIL,
            "EmailHandler02"));
    path = client.createInstance(NAMESPACE, subscription_email2);
}

void _testEmail(CIMClient & client)
{
    try
    {
         String wql("WQL");
         String cql("DMTF:CQL");

        _createCimsubEmailTests(client, wql);
        //        _delete(client);

#ifndef PEGASUS_DISABLE_CQL
        //        _createCimsubEmailTests(client, cql);
        //        _delete(client);
#endif
    }

    catch (Exception & e)
    {
        cerr << "setup failed: " << e.getMessage() << endl;
        exit (-1);
    }

    cout << "+++++ setup completed successfully" << endl;
}
#endif

//
//  NOTE: the cleanup command line option is provided to clean up the
//  repository in case the test fails and not all objects created by
//  the test were deleted
//  This method attempts to delete each object that could have been created by
//  this test and that still exists in the repository
//  Since the repository could contain none, any or all of the objects, any
//  exceptions thrown are ignored and this method continues to attempt to
//  delete the objects
//
void _cleanup(CIMClient & client)
{
    //
    //  Delete subscription instances
    //
         IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter00",
            PEGASUS_CLASSNAME_INDHANDLER_CIMXML, "Handler00");)
 
        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter01",
            PEGASUS_CLASSNAME_INDHANDLER_CIMXML, "Handler01");)
  
        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter02",
            PEGASUS_CLASSNAME_INDHANDLER_CIMXML, "Handler01");)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter03",
            PEGASUS_CLASSNAME_INDHANDLER_CIMXML, "Handler01");)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter04",
            PEGASUS_CLASSNAME_INDHANDLER_CIMXML, "Handler01");)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter05",
            PEGASUS_CLASSNAME_INDHANDLER_CIMXML, "Handler01");)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter06",
            PEGASUS_CLASSNAME_INDHANDLER_CIMXML, "Handler01");)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter07",
            PEGASUS_CLASSNAME_INDHANDLER_CIMXML, "Handler00");)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter01",
            PEGASUS_CLASSNAME_INDHANDLER_CIMXML, "Handler02");)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter01",
            PEGASUS_CLASSNAME_INDHANDLER_CIMXML, "Handler02p");)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter01",
            PEGASUS_CLASSNAME_INDHANDLER_CIMXML, "Handler02t");)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter01",
            PEGASUS_CLASSNAME_INDHANDLER_SNMP, "Handler03");)

#ifdef PEGASUS_ENABLE_EMAIL_HANDLER

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "EmailFilter01",
            PEGASUS_CLASSNAME_LSTNRDST_EMAIL, "EmailHandler01",
            String::EMPTY, String::EMPTY,
            NAMESPACE, CIMNamespaceName (), NAMESPACE);)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "EmailFilter01",
            PEGASUS_CLASSNAME_LSTNRDST_EMAIL, "EmailHandler02",
            String::EMPTY, String::EMPTY,
            NAMESPACE, CIMNamespaceName (), NAMESPACE);)

#endif

#ifdef PEGASUS_ENABLE_SYSTEM_LOG_HANDLER

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "SyslogFilter01",
            PEGASUS_CLASSNAME_LSTNRDST_SYSTEM_LOG, "SyslogHandler01",
            String::EMPTY, String::EMPTY,
            NAMESPACE, CIMNamespaceName (), NAMESPACE);)

#endif

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter01",
            PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination01t");)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter01",
            PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination01");)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter08",
            PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination02",
            System::getFullyQualifiedHostName(),
            System::getFullyQualifiedHostName(),
            NAMESPACE, NAMESPACE, NAMESPACE);)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter09",
            PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination03",
            String::EMPTY, String::EMPTY, NAMESPACE, NAMESPACE, NAMESPACE);)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter10",
            PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination04",
            System::getFullyQualifiedHostName(),
            System::getFullyQualifiedHostName(),
            NAMESPACE, NAMESPACE, NAMESPACE);)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter11",
            PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination05",
            String::EMPTY, String::EMPTY, NAMESPACE1, NAMESPACE2, NAMESPACE3);)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter11",
            PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination07",
            String::EMPTY, String::EMPTY, NAMESPACE1, NAMESPACE2, NAMESPACE3);)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter12",
            PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination06",
            String::EMPTY, String::EMPTY, NAMESPACE1, NAMESPACE2, NAMESPACE3);)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter12",
            PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination08",
            String::EMPTY, String::EMPTY, NAMESPACE1, NAMESPACE2, NAMESPACE);)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter11",
            PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination05",
            String::EMPTY, String::EMPTY, NAMESPACE2, NAMESPACE1, NAMESPACE3);)

        IGNORE_EXCEPTION(_deleteSubscriptionInstance(client, "Filter15",
            PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "Handler15",
            String::EMPTY, String::EMPTY, NAMESPACE, NAMESPACE, NAMESPACE);)

    //
    //  Delete handler instances
    //
        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
            PEGASUS_CLASSNAME_INDHANDLER_CIMXML, "Handler00");)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client, 
             PEGASUS_CLASSNAME_INDHANDLER_CIMXML, "Handler01");)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
             PEGASUS_CLASSNAME_INDHANDLER_CIMXML, "Handler02");)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
             PEGASUS_CLASSNAME_INDHANDLER_CIMXML, "Handler02t");)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
             PEGASUS_CLASSNAME_INDHANDLER_CIMXML, "Handler02p");)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
             PEGASUS_CLASSNAME_INDHANDLER_SNMP, "Handler03");)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
             PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination01");)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
             PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination01t");)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
             PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination02");)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
             PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination03");)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
             PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination04");)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
             PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination05", NAMESPACE1);)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
             PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination05", NAMESPACE2);)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
             PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination06", NAMESPACE2);)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
             PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination06", NAMESPACE3);)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
             PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination07", NAMESPACE2);)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
             PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "ListenerDestination08", NAMESPACE2);)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
             PEGASUS_CLASSNAME_LSTNRDST_CIMXML, "Handler15", NAMESPACE);)

        IGNORE_EXCEPTION(_deleteHandlerInstance(client,
             PEG