PublishMachinesList.cpp

 /* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/.
 * 
 * Copyright 2021 (c) Christian von Arnim, ISW University of Stuttgart (for umati and VDW e.V.)
 * Copyright 2021 (c) Moritz Walker, ISW University of Stuttgart (for umati and VDW e.V.)
 */

#include "PublishMachinesList.hpp"
#include <Topics.hpp>

namespace Umati
{
	namespace MachineObserver
	{
		PublishMachinesList::PublishMachinesList(std::shared_ptr<Umati::Dashboard::IPublisher> pPublisher, std::vector<std::string> &specifications, std::function<std::string(const std::string&)> getTopic)
		:m_pPublisher(pPublisher), m_Specifications(specifications), m_getTopic(getTopic)
		{}

		void PublishMachinesList::AddMachine(std::string specification, nlohmann::json data)
		{
			m_Machines[specification].push_back(data);
		}

		void PublishMachinesList::Publish()
		{
			for(auto el : m_Machines)
			{
				nlohmann::json publishData = nlohmann::json::array();
				for(auto machineData : el.second)
				{
					publishData.push_back(machineData);
				}
				m_pPublisher->Publish(m_getTopic(el.first), publishData.dump(0));
			}

			for(auto spec : m_Specifications)
			{
				if(m_Machines.count(spec) == 0)
				{
					m_pPublisher->Publish(m_getTopic(spec), nlohmann::json::array().dump(0));
				}
			}
		}
	}
}