o3de-extras/Gems/ROS2Sensors/Code/Source/Camera/CameraPublishers.cpp

/*
 * Copyright (c) Contributors to the Open 3D Engine Project.
 * For complete copyright and license terms please see the LICENSE at the root of this distribution.
 *
 * SPDX-License-Identifier: Apache-2.0 OR MIT
 *
 */

#include "CameraPublishers.h"
#include "CameraSensor.h"
#include <ROS2/Communication/TopicConfiguration.h>
#include <ROS2/ROS2Bus.h>
#include <ROS2/Sensor/SensorConfiguration.h>
#include <ROS2/Utilities/ROS2Names.h>

namespace ROS2Sensors
{
    namespace Internal
    {
        using TopicConfigurations = AZStd::unordered_map<CameraSensorDescription::CameraChannelType, ROS2::TopicConfiguration>;

        ROS2::TopicConfiguration GetTopicConfiguration(const ROS2::SensorConfiguration& sensorConfiguration, const AZStd::string& key)
        {
            auto ipos = sensorConfiguration.m_publishersConfigurations.find(key);
            AZ_Assert(ipos != sensorConfiguration.m_publishersConfigurations.end(), "Missing key in topic configuration!");
            return ipos != sensorConfiguration.m_publishersConfigurations.end() ? ipos->second : ROS2::TopicConfiguration{};
        }

        template<typename CameraType>
        TopicConfigurations GetCameraTopicConfiguration([[maybe_unused]] const ROS2::SensorConfiguration& sensorConfiguration)
        {
            AZ_Error("GetCameraTopicConfiguration", false, "Invalid camera template type!");
            return TopicConfigurations();
        }

        template<typename CameraType>
        TopicConfigurations GetCameraInfoTopicConfiguration([[maybe_unused]] const ROS2::SensorConfiguration& sensorConfiguration)
        {
            AZ_Error("GetCameraInfoTopicConfiguration", false, "Invalid camera template type!");
            return TopicConfigurations();
        }

        template<>
        TopicConfigurations GetCameraTopicConfiguration<CameraColorSensor>(const ROS2::SensorConfiguration& sensorConfiguration)
        {
            return { { CameraSensorDescription::CameraChannelType::RGB,
                       GetTopicConfiguration(sensorConfiguration, CameraConstants::ColorImageConfig) } };
        }

        template<>
        TopicConfigurations GetCameraInfoTopicConfiguration<CameraColorSensor>(const ROS2::SensorConfiguration& sensorConfiguration)
        {
            return { { CameraSensorDescription::CameraChannelType::RGB,
                       GetTopicConfiguration(sensorConfiguration, CameraConstants::ColorInfoConfig) } };
        }

        template<>
        TopicConfigurations GetCameraTopicConfiguration<CameraDepthSensor>(const ROS2::SensorConfiguration& sensorConfiguration)
        {
            return { { CameraSensorDescription::CameraChannelType::DEPTH,
                       GetTopicConfiguration(sensorConfiguration, CameraConstants::DepthImageConfig) } };
        }

        template<>
        TopicConfigurations GetCameraInfoTopicConfiguration<CameraDepthSensor>(const ROS2::SensorConfiguration& sensorConfiguration)
        {
            return { { CameraSensorDescription::CameraChannelType::DEPTH,
                       GetTopicConfiguration(sensorConfiguration, CameraConstants::DepthInfoConfig) } };
        }

        //! Helper that adds publishers based on predefined configuration.
        template<typename PublishedData>
        void AddPublishersFromConfiguration(
            const AZStd::string& cameraNamespace,
            const TopicConfigurations configurations,
            AZStd::unordered_map<CameraSensorDescription::CameraChannelType, std::shared_ptr<rclcpp::Publisher<PublishedData>>>& publishers)
        {
            for (const auto& [channel, configuration] : configurations)
            {
                AZStd::string fullTopic = ROS2::ROS2Names::GetNamespacedName(cameraNamespace, configuration.m_topic);
                auto ros2Node = ROS2::ROS2Interface::Get()->GetNode();
                auto publisher = ros2Node->create_publisher<PublishedData>(fullTopic.data(), configuration.GetQoS());
                publishers[channel] = publisher;
            }
        }

        //! Helper that adds publishers for a camera type.
        //! @tparam CameraType type of camera sensor (eg 'CameraColorSensor').
        //! @param cameraDescription complete information about camera configuration.
        //! @param imagePublishers publishers of raw image formats (color image, depth image, ..).
        //! @param infoPublishers publishers of camera_info messages for each image topic.
        template<typename CameraType>
        void AddCameraPublishers(
            const CameraSensorDescription& cameraDescription,
            AZStd::unordered_map<CameraSensorDescription::CameraChannelType, CameraPublishers::ImagePublisherPtrType>& imagePublishers,
            AZStd::unordered_map<CameraSensorDescription::CameraChannelType, CameraPublishers::CameraInfoPublisherPtrType>& infoPublishers)
        {
            const auto cameraImagePublisherConfigs = GetCameraTopicConfiguration<CameraType>(cameraDescription.m_sensorConfiguration);
            AddPublishersFromConfiguration(cameraDescription.m_cameraNamespace, cameraImagePublisherConfigs, imagePublishers);
            const auto cameraInfoPublisherConfigs = GetCameraInfoTopicConfiguration<CameraType>(cameraDescription.m_sensorConfiguration);
            AddPublishersFromConfiguration(cameraDescription.m_cameraNamespace, cameraInfoPublisherConfigs, infoPublishers);
        }
    } // namespace Internal

    CameraPublishers::CameraPublishers(const CameraSensorDescription& cameraDescription)
    {
        if (cameraDescription.m_cameraConfiguration.m_colorCamera)
        {
            Internal::AddCameraPublishers<CameraColorSensor>(cameraDescription, m_imagePublishers, m_infoPublishers);
        }

        if (cameraDescription.m_cameraConfiguration.m_depthCamera)
        {
            Internal::AddCameraPublishers<CameraDepthSensor>(cameraDescription, m_imagePublishers, m_infoPublishers);
        }
    }

    CameraPublishers::ImagePublisherPtrType CameraPublishers::GetImagePublisher(CameraSensorDescription::CameraChannelType type)
    {
        AZ_Error("GetImagePublisher", m_imagePublishers.count(type) == 1, "No publisher of this type, logic error!");
        return m_imagePublishers.at(type);
    }

    CameraPublishers::CameraInfoPublisherPtrType CameraPublishers::GetInfoPublisher(CameraSensorDescription::CameraChannelType type)
    {
        AZ_Error("GetInfoPublisher", m_infoPublishers.count(type) == 1, "No publisher of this type, logic error!");
        return m_infoPublishers.at(type);
    }
} // namespace ROS2Sensors