NotificationTransport.hpp

Go to the documentation of this file.

#ifndef DEFAULTNOTIFICATIONTRANSPORT_HPP_
#define DEFAULTNOTIFICATIONTRANSPORT_HPP_

#include <map>
#include <set>
#include <string>

#include "kaa/channel/transport/IKaaTransport.hpp"
#include "kaa/channel/transport/INotificationTransport.hpp"
#include "kaa/channel/transport/AbstractKaaTransport.hpp"
#include "kaa/IKaaClientStateStorage.hpp"
#include "kaa/notification/INotificationProcessor.hpp"
#include "kaa/IKaaClientContext.hpp"

namespace kaa {

class IKaaChannelManager;

class NotificationTransport: public AbstractKaaTransport<TransportType::NOTIFICATION>,
                             public INotificationTransport
{
public:
    NotificationTransport(IKaaChannelManager& manager, IKaaClientContext &context);

    virtual NotificationSyncRequestPtr createEmptyNotificationRequest();

    virtual NotificationSyncRequestPtr createNotificationRequest();

    virtual void onNotificationResponse(const NotificationSyncResponse& response);

    virtual void onSubscriptionChanged(SubscriptionCommands&& commands);

    virtual void setNotificationProcessor(INotificationProcessor* processor) {
        if (processor) {
            notificationProcessor_ = processor;
        }
    }

    virtual void sync() {
        syncByType(type_);
    }

private:
    Notifications getUnicastNotifications(const Notifications & notifications);
    Notifications getMulticastNotifications(const Notifications & notifications);
    std::vector<TopicState> prepareTopicStatesForRequest();

private:
    INotificationProcessor*                         notificationProcessor_;

    std::set<std::string>                  acceptedUnicastNotificationIds_;
    SubscriptionCommands                                    subscriptions_;
};

} /* namespace kaa */

#endif /* DEFAULTNOTIFICATIONTRANSPORT_HPP_ */