CTK/Plugins/org.commontk.eventbus/ctkEventHandlerWrapper_p.h

#ifndef CTKEVENTHANDLERWRAPPER_P_H
#define CTKEVENTHANDLERWRAPPER_P_H

#include <QStringList>

#include <EventBus/ctkEventBus.h>
#include <EventBus/ctkEventConstants.h>
#include <ctkLDAPSearchFilter.h>

#include <iostream>

namespace ctk {

  class EventHandlerWrapper : public QObject {

    Q_OBJECT

  private:

    EventBus::Properties properties;
    QStringList topicList;
    LDAPSearchFilter filter;

  public:

    EventHandlerWrapper(const QObject* subscriber, const char* handler, const EventBus::Properties& properties)
      : properties(properties)
    {
      connect(this, SIGNAL(notifySubscriber(Event)), subscriber, handler);
    }

    QStringList topics() const
    {
      return topicList;
    }

    bool init()
    {
      topicList.clear();

      // Get topic names
      QVariant v = properties[EventConstants::EVENT_TOPIC];
      topicList = v.toStringList();

      if (topicList.empty())
      {
        return false;
      }

      v = properties[EventConstants::EVENT_FILTER];
      filter = LDAPSearchFilter(v.toString());
    }

    void handleEvent(const Event& event /*, const Permission& perm */)
    {
      if (!event.matches(filter)) return;

      // should do permissions checks now somehow
      // ...

      try {
        emit notifySubscriber(event);
      }
      catch (const std::exception& e)
      {
        // TODO logging
        std::cerr << "Exception occured during publishing " << qPrintable(event.topic()) << ": " << e.what() << std::endl;
      }

    }

  signals:

    void notifySubscriber(const Event&);

  };

}

#endif // CTKEVENTHANDLERWRAPPER_P_H