Strategies.hpp

Go to the documentation of this file.

/*
 * Copyright 2014 CyberVision, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#ifndef STRATEGIES_HPP_
#define STRATEGIES_HPP_

#include "kaa/KaaDefaults.hpp"

#ifdef KAA_USE_CONFIGURATION

#include "kaa/configuration/manager/AbstractStrategy.hpp"
#include <functional>
#include <list>
#include "kaa/common/types/ICommonArray.hpp"
#include "kaa/common/types/ICommonRecord.hpp"

namespace kaa {

class UuidProcessStrategy : public AbstractStrategy {
public:
    UuidProcessStrategy(
                  std::function<bool (uuid_t)> isSubscribed
                , std::function<void (uuid_t, std::shared_ptr<ICommonRecord>)> subscribe
                , std::function<void (uuid_t)> unsubscribe)
            : isSubscribedFn_(isSubscribed)
            , subscribeFn_(subscribe)
            , unsubscribeFn_(unsubscribe)
        {
        }

    void run(std::shared_ptr<ICommonRecord> parent, const std::string &field, const avro::GenericDatum &datum);

private:
    std::function<bool (uuid_t)> isSubscribedFn_;
    std::function<void (uuid_t, std::shared_ptr<ICommonRecord>)> subscribeFn_;
    std::function<void (uuid_t)> unsubscribeFn_;
};

class RecordProcessStrategy : public AbstractStrategy {
public:
    RecordProcessStrategy(
              std::function<bool (uuid_t)> isSubscribed
            , std::function<void (uuid_t, std::shared_ptr<ICommonRecord>)> subscribe
            , std::function<void (uuid_t)> unsubscribe, bool isRootRecord = false)
        : isSubscribedFn_(isSubscribed)
        , subscribeFn_(subscribe)
        , unsubscribeFn_(unsubscribe)
        , isRootRecord_(isRootRecord)
    {
    }
    void run(std::shared_ptr<ICommonRecord> parent, const std::string &field, const avro::GenericDatum &datum);
private:
    std::function<bool (uuid_t)> isSubscribedFn_;
    std::function<void (uuid_t, std::shared_ptr<ICommonRecord>)> subscribeFn_;
    std::function<void (uuid_t)> unsubscribeFn_;
    std::list<std::pair<uuid_t, std::shared_ptr<ICommonRecord> > > recordToSubscribe;
    std::list<uuid_t> recordToUnSubscribe;

    bool isRootRecord_;
};

class ArrayProcessStrategy : public AbstractStrategy {
public:
    ArrayProcessStrategy(std::function<bool (uuid_t)> isSubscribed
            , std::function<void (uuid_t, std::shared_ptr<ICommonRecord>)> subscribe
            , std::function<void (uuid_t)> unsubscribe)
        : isSubscribedFn_(isSubscribed)
        , subscribeFn_(subscribe)
        , unsubscribeFn_(unsubscribe)
    {
    }
    void run(std::shared_ptr<ICommonRecord> parent, const std::string &field, const avro::GenericDatum &datum);
private:
    static const std::string array_holder_field;
    std::function<bool (uuid_t)> isSubscribedFn_;
    std::function<void (uuid_t, std::shared_ptr<ICommonRecord>)> subscribeFn_;
    std::function<void (uuid_t)> unsubscribeFn_;
};

class ArrayResetStrategy : public AbstractStrategy {
public:
    ArrayResetStrategy(std::function<bool (uuid_t)> isSubscribed
            , std::function<void (uuid_t)> unsubscribe)
        : isSubscribedFn_(isSubscribed)
        , unsubscribeFn_(unsubscribe)
    {
    }
    void run(std::shared_ptr<ICommonRecord> parent, const std::string &field, const avro::GenericDatum &datum);
    void unregisterRecord(ICommonRecord &record);
    void unregisterArray(ICommonArray &record);
private:
    std::function<bool (uuid_t)> isSubscribedFn_;
    std::function<void (uuid_t)> unsubscribeFn_;
};

class NullProcessStrategy : public AbstractStrategy {
public:
    void run(std::shared_ptr<ICommonRecord> parent, const std::string &field, const avro::GenericDatum &datum);
};

class CommonProcessStrategy : public AbstractStrategy {
public:
    void run(std::shared_ptr<ICommonRecord> parent, const std::string &field, const avro::GenericDatum &datum);
};

}  // namespace kaa

#endif

#endif /* STRATEGIES_HPP_ */