#pragma once
#include "libobsensor/h/ObTypes.h"
#include "IDeviceActivityRecorder.hpp"
#include <chrono>
#include <string>
#include <mutex>
#include <unordered_map>
#include <memory>
namespace libobsensor {
class DeviceActivityManager {
public:
DeviceActivityManager();
virtual ~DeviceActivityManager() = default;
void update(const std::string &deviceId, std::shared_ptr<IDeviceActivityRecorder> activityRecorder);
void removeActivity(const std::string &deviceId);
uint64_t getElapsedSinceLastActive(const std::string &deviceId) const;
private:
uint64_t getNow() const {
return std::chrono::duration_cast<std::chrono::milliseconds>(std::chrono::steady_clock::now().time_since_epoch()).count();
}
private:
mutable std::mutex mutex_;
std::unordered_map<std::string, uint64_t> deviceLastActive_;
};
}