LinearPathTelemetrySimulator.h

Go to the documentation of this file.

#pragma once

#include <swarmio/simulator/SimulatedLocation.h>
#include <swarmio/services/telemetry/Service.h>
#include <chrono>
#include <memory>
#include <thread>

namespace swarmio::simulator 
{
    class LinearPathTelemetrySimulator final
    {
        private:

            std::unique_ptr<std::thread> _thread;

            std::atomic<bool> _shouldStop;

            services::telemetry::Service& _telemetryService;

            std::string _name;

            SimulatedLocation _firstPoint;

            SimulatedLocation _secondPoint;

            std::chrono::seconds _duration;

            void Worker();

        public:

            LinearPathTelemetrySimulator(services::telemetry::Service& telemetryService, const std::string& name, SimulatedLocation firstPoint, SimulatedLocation secondPoint, std::chrono::seconds duration);

            void Stop()
            {
                if (_thread)
                {
                    _shouldStop = true;
                    _thread->join();
                    _thread.reset();
                }
            }

            ~LinearPathTelemetrySimulator()
            {
                Stop();
                _telemetryService.RemoveFieldDefinitionForKey(_name);
                _telemetryService.RemoveValue(_name);
            }
    };
}