SkillManagerComponentPluginUser.h

Go to the documentation of this file.

#pragma once
 
#include <memory>
#include <vector>
 
#include <Ice/Current.h>
 
#include <RobotAPI/interface/aron/Aron.h>
#include <RobotAPI/interface/skills/SkillManagerInterface.h>
#include <RobotAPI/libraries/skills/core/aron/FluxioSkill.aron.generated.h>
 
#include "SkillManagerComponentPlugin.h"
 
namespace armarx::plugins
{
    class SkillManagerComponentPlugin; // forward declaration
}
 
namespace armarx
{
    class SkillManagerComponentPluginUser :
        virtual public ManagedIceObject,
        virtual public skills::manager::dti::SkillManagerInterface
    {
    public:
        SkillManagerComponentPluginUser();
 
        void addProvider(const skills::manager::dto::ProviderInfo& providerInfo,
                         const Ice::Current& current) override;
 
        void removeProvider(const skills::manager::dto::ProviderID& provider,
                            const Ice::Current& current) override;
 
        skills::manager::dto::SkillStatusUpdate
        executeSkill(const skills::manager::dto::SkillExecutionRequest& info,
                     const Ice::Current& current) override;
 
        skills::manager::dto::SkillExecutionID
        executeSkillAsync(const skills::manager::dto::SkillExecutionRequest& skillExecutionRequest,
                          const Ice::Current& current) override;
 
        skills::provider::dto::ParameterUpdateResult
        updateSkillParameters(const skills::manager::dto::SkillExecutionID& executionId,
                              const aron::data::dto::DictPtr& params,
                              const Ice::Current& current) override;
 
        void updateStatusForSkill(const skills::provider::dto::SkillStatusUpdate& update,
                                  const skills::callback::dto::ProviderID& id,
                                  const Ice::Current& current) override;
 
        skills::provider::dto::AbortSkillResult
        abortSkill(const skills::manager::dto::SkillExecutionID& id,
                   const Ice::Current& current) override;
 
        skills::provider::dto::AbortSkillResult
        abortSkillAsync(const skills::manager::dto::SkillExecutionID& id,
                        const Ice::Current& current) override;
 
        std::vector<skills::provider::dto::AbortSkillResult>
        abortAllSkills(const Ice::Current& current) override;
 
        std::vector<skills::provider::dto::AbortSkillResult>
        abortAllSkillsAsync(const Ice::Current& current) override;
 
        skills::manager::dto::SkillDescriptionMap
        getSkillDescriptions(const Ice::Current& current) override;
 
        IceUtil::Optional<skills::manager::dto::SkillDescription>
        getSkillDescription(const skills::manager::dto::SkillID& id,
                            const Ice::Current& current) override;
 
        IceUtil::Optional<skills::manager::dto::SkillStatusUpdate>
        getSkillExecutionStatus(const skills::manager::dto::SkillExecutionID& executionId,
                                const Ice::Current& current) override;
 
        skills::manager::dto::SkillStatusUpdateMap
        getSkillExecutionStatuses(const Ice::Current& current) override;
 
        //****************************//
        //** Fluxio related methods **//
        //****************************//
 
        aron::type::dto::AronObjectPtr getTypes(const Ice::Current& current) override;
 
        IceUtil::Optional<std::string> executeFluxioSkill(const std::string& skillId,
                                                          const std::string& profileId,
                                                          const Ice::Current& current) override;
 
        IceUtil::Optional<std::string>
        executeFluxioSkillLegacy(const std::string& skillId,
                                 const std::string& executionArgs,
                                 const Ice::Current& current) override;
 
        void abortFluxioSkill(const std::string& executionId, const Ice::Current& current) override;
 
        IceUtil::Optional<skills::manager::dto::FluxioSkillStatusUpdateList>
        getFluxioSkillExecutionStatus(const std::string& executionId,
                                      const Ice::Current& current) override;
 
        skills::manager::dto::FluxioSkillList getSkillList(const Ice::Current& current) override;
 
        IceUtil::Optional<skills::manager::dto::FluxioSkill>
        getSkill(const std::string& id, const Ice::Current& current) override;
 
        bool updateSkill(const std::string& userId,
                         const skills::manager::dto::FluxioSkill& skill,
                         const Ice::Current& current) override;
 
        bool updateSkillValues(const std::string& userId,
                               const std::string& skillId,
                               const skills::manager::dto::FluxioParameterList& parameters,
                               const Ice::Current& current) override;
 
        bool updateSkillParameterValues(const std::string& userId,
                                        const std::string& skillId,
                                        const std::string& parameterId,
                                        const skills::manager::dto::FluxioValueList& values,
                                        const Ice::Current& current) override;
 
        IceUtil::Optional<skills::manager::dto::FluxioIdentificatorList>
        deleteSkill(const std::string& skillId,
                    const std::string& userId,
                    bool dryRun,
                    const Ice::Current& current) override;
 
        bool getSkillMutex(const std::string& skillId,
                           const std::string& userId,
                           const Ice::Current& current) override;
 
        void deleteSkillMutex(const std::string& skillId,
                              const std::string& userId,
                              const Ice::Current& current) override;
 
        IceUtil::Optional<skills::manager::dto::FluxioIdentificatorList>
        deleteSkillParameter(const std::string& skillId,
                             const std::string& parameterId,
                             const std::string& userId,
                             bool dryRun,
                             const Ice::Current& current) override;
 
        IceUtil::Optional<skills::manager::dto::FluxioIdentificatorList>
        updateSkillParameter(const std::string& skillId,
                             const skills::manager::dto::FluxioParameter& parameter,
                             const std::string& userId,
                             bool dryRun,
                             const Ice::Current& current) override;
 
        skills::manager::dto::FluxioProfileList
        getProfileList(const Ice::Current& current) override;
 
        IceUtil::Optional<skills::manager::dto::FluxioProfile>
        getProfile(const std::string& id, const Ice::Current& current) override;
 
        skills::manager::dto::FluxioProfile
        createProfile(const skills::manager::dto::FluxioProfile& profile,
                      const Ice::Current& current) override;
 
        void updateProfile(const skills::manager::dto::FluxioProfile& profile,
                           const Ice::Current& current) override;
 
        skills::manager::dto::FluxioProviderList
        getProviderList(const Ice::Current& current) override;
 
        IceUtil::Optional<skills::manager::dto::FluxioProvider>
        getProvider(const std::string& id, const Ice::Current& current) override;
 
        IceUtil::Optional<skills::manager::dto::FluxioSkillList>
        getSkillsOfProvider(const std::string& id, const Ice::Current& current) override;
 
        IceUtil::Optional<skills::manager::dto::FluxioSkill>
        addSkillToProvider(const std::string& userId,
                           const std::string& providerId,
                           const skills::manager::dto::FluxioSkill& skill,
                           const Ice::Current& current) override;
 
        virtual void saveSkill(const skills::manager::arondto::FluxioSkill& skill);
        virtual std::optional<std::vector<skills::manager::arondto::FluxioSkill>>
        loadCompositeSkills();
        virtual std::optional<std::vector<skills::manager::arondto::FluxioSkill>>
        loadCompositeSkillsOfProvider(const std::string& providerId);
 
        virtual void addProfile(const skills::manager::arondto::FluxioProfile& profile);
        virtual std::optional<std::vector<skills::manager::arondto::FluxioProfile>> loadProfiles();
 
    private:
        armarx::plugins::SkillManagerComponentPlugin* plugin = nullptr;
    };
} // namespace armarx