MPSessionMemory.hpp

/*
 *  This file is part of the AiBO+ project
 *
 *  Copyright (C) 2005-2016 Csaba Kertész (csaba.kertesz@gmail.com)
 *
 *  AiBO+ is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  AiBO+ is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Street #330, Boston, MA 02111-1307, USA.
 *
 */

#pragma once

#include "MPTypes.hpp"

#include <MSElement.hpp>

#include <boost/scoped_ptr.hpp>
#include <boost/serialization/access.hpp>

class MCBinaryData;
class MCDataStorage;

struct MPVariableDescriptor
{
  int Min;
  int Max;
  float Magnitude;
  QString DisplayName;
  MP::FloatList Values;
};

namespace MP
{
typedef QMap<QString, MPVariableDescriptor> VariableMap;
}

class MPSessionMemory : public MSElement
{
  Q_OBJECT

  friend class boost::serialization::access;

public:
  explicit MPSessionMemory(const QString& session_directory = "");
  virtual ~MPSessionMemory();

  std::string GetVariableMapStr() const;
  QString GetSessionDirectory() const;
  void SetSessionDirectory(const QString& directory);
  void SyncQueryCache();
  void OptimizeQueryCache();
  MCBinaryData* Encode();
  static MPSessionMemory* Decode(const MCBinaryData& data);
  static QString GetSessionCacheFileName(const QString& directory);
  static MPSessionMemory* Load(const QString& directory, bool only_cache = false);
  void SaveToFile(const QString& file_name);
  void EnableAnsiToQtMarkup();
  bool IsAnsiConvertedToQtMarkup();
  int GetMinCursorPosition();
  int GetMaxCursorPosition();
  int GetFirstSecond();
  int GetLastSecond();
  int GetCursorPosition();
  const MP::LogEntryMap& GetFullAiboLog();
  const MA::IntIntSortedMap& GetStreamMarkers();
  QStringList GetVariableMap();
  const MPVariableDescriptor* GetVariableDescriptor(const QString& variable_name);
  MC::IntList GetMissingTimestamps();
  MCBinaryData* GetAiboImage(int milliseconds);
  MARobotState* GetRobotState(int milliseconds);
  MP::RobotStatePtrList GetRobotStates();
  MP::RobotStatePtrList GetRobotStates(int start_time, int end_time);
  MC::BinaryDataSPtr GetAudioData(int start_time, int end_time);
  MA::BinaryDataSPtrList GetRobotStatesData(int start_time, int end_time);
  void GetStateTimeSerie(const QString& variable, int start, int end,
                         MP::DoubleList& times, MP::DoubleList& serie, int upscale_value = 0);
  bool IsMissingDataInRange(int StartTime, int EndTime);
  MP::DoubleTable GetSamples(const QString& variable, const QString& log_start, const QString& log_end,
                             MP::BooleanList& validity);
  MP::DoubleTable GetValidSamples(const QString& variable, const QString& log_start,
                                  const QString& log_end);
  MP::RobotStatePtrTable GetRobotStates(const QString& log_start, const QString& log_end,
                                        MP::BooleanList& validity);
  MP::RobotStatePtrTable GetValidRobotStates(const QString& log_start, const QString& log_end);

public Q_SLOTS:
  void SetCursorPosition(int milliseconds);
  void IncrementCursor();
  void DecrementCursor();

Q_SIGNALS:
  void FirstRobotStatesArrived();

private:
  virtual bool ProgressTasks(bool be_hurry) override;

  template<class Archive>
  void serialize(Archive& archive, const unsigned int version);

  QString SessionDirectory;
  QString QueryCacheFileName;
  boost::scoped_ptr<MCDataStorage> CacheStorage;
  MPRecordsContainer InputStates;
  MPMissingPackets MissingPackets;
  MPMissingPackets InputMissingPackets;
  MPRecoveredPackets InputRecoveredPackets;
  MPTimestampList NewMissingTimestamps;
  MPTimestampList NewRecoveredTimestamps;
  MPStreamMarkers NewStreamMarkers;
  MA::IntIntSortedMap StreamMarkers;
  QStringList VariableMap;
  std::string VariableMapStr;
  MP::IntList RobotStateTimestamps;
  MP::BinaryDataList ImageCache;
  MP::BinaryDataList RobotStateCache;
  MP::VariableMap VariableCache;
  MP::LogEntryMap LogCache;
  MP::BinaryDataList SoundDataCache;
  MPLogEntryMap NewLogEntries;
  int CursorPosition;
  MPCursorPosition NewCursorPosition;
  int LastCursorPosition;
  bool CursorPositionChanged;
  bool ConvertAnsiToQtMarkup;
};