CnetDisplayProperties.cpp

#include "IsisDebug.h"

#include "CnetDisplayProperties.h"

#include <iostream>

#include <QAtomicInt>
#include <QFile>
#include <QFileInfo>
#include <QFuture>
#include <QFutureWatcher>
#include <QMap>
#include <QReadWriteLock>
#include <QString>
#include <QStringList>
#include <QTextStream>
#include <QTimer>
#include <QtConcurrentRun>

#include "ControlNet.h"
#include "Cube.h"
#include "IException.h"
#include "IString.h"
#include "SerialNumber.h"


namespace Isis {
  CnetDisplayProperties *CnetDisplayProperties::m_instance = NULL;


  CnetDisplayProperties *CnetDisplayProperties::getInstance() {
    return m_instance ? m_instance : m_instance = new CnetDisplayProperties;
  }


  CnetDisplayProperties::CnetDisplayProperties() {
    nullify();

    useFileNames = true;
    m_curComposing = false;
    m_showFullPath = false;

    m_readWriteLock = new QReadWriteLock;

    m_serialNumberToFileNameMap = new QMap< QString, QString >;

    m_composedCount = new QAtomicInt;
    m_interruptFlag = new QAtomicInt;
    m_interruptFlag->fetchAndStoreRelaxed(0);

    m_composeStatusPoller = new QTimer;
    connect(m_composeStatusPoller, SIGNAL(timeout()),
        this, SLOT(composeStatusUpdated()));

    m_composeWatcher = new QFutureWatcher< QMap< QString, QString > >;
    connect(m_composeWatcher, SIGNAL(finished()),
        this, SLOT(serialNumbersComposed()));
  }


//   CnetDisplayProperties::CnetDisplayProperties(
//       CnetDisplayProperties const & other)
//   {
//     nullify();
//
//     useFileNames = other.useFileNames;
//     m_serialNumberToFileNameMap = new QMap< QString, QString >(
//         *other.m_serialNumberToFileNameMap);
//
//     m_composeStatusPoller = new QTimer;
//
//     m_composeWatcher = new QFutureWatcher< QMap< QString, QString > >;
//     connect(m_composeWatcher, SIGNAL(finished()),
//             this, SLOT(serialNumbersComposed()));
//   }


  CnetDisplayProperties::~CnetDisplayProperties() {
    delete m_serialNumberToFileNameMap;
    m_serialNumberToFileNameMap = NULL;

    delete m_composeWatcher;
    m_composeWatcher = NULL;

    delete m_composedCount;
    m_composedCount = NULL;

    delete m_interruptFlag;
    m_interruptFlag = NULL;
  }


  bool CnetDisplayProperties::currentlyComposing() const {
    return m_curComposing;
  }


  QList<QString> CnetDisplayProperties::getCubeList(ControlNet *cnet) const {
    QList<QString> results;

    if (!currentlyComposing()) {
      foreach (QString serialNumber, cnet->GetCubeSerials()) {
        QString possibleFileName = getImageName(serialNumber, true);

        if (possibleFileName != serialNumber)
          results.append(possibleFileName);
      }
    }

    return results;
  }


  QString CnetDisplayProperties::getFileName(QString fileName,
      bool forceFullPaths) const {
    QString result;

    if (forceFullPaths || getShowsFullPaths())
      result = fileName;
    else
      result = QFileInfo(fileName).fileName();

    return result;
  }


  QString CnetDisplayProperties::getImageName(QString cubeSerialNumber,
      bool forceFullPaths) const {
    ASSERT(m_serialNumberToFileNameMap);

    QString imageName = cubeSerialNumber;

    m_readWriteLock->lockForRead();

    if (m_serialNumberToFileNameMap && useFileNames &&
        m_serialNumberToFileNameMap->contains(cubeSerialNumber)) {
      QString value = m_serialNumberToFileNameMap->value(cubeSerialNumber);
      m_readWriteLock->unlock();

      if (value.toLower() != "unknown")
        imageName = getFileName(value, forceFullPaths);
    }
    else {
      m_readWriteLock->unlock();
    }

    return imageName;
  }


  QString CnetDisplayProperties::getSerialNumber(QString imageId) {
    ASSERT(m_serialNumberToFileNameMap);

    QString sn = imageId;

    if (m_serialNumberToFileNameMap && useFileNames) {
      m_readWriteLock->lockForRead();
      QMapIterator< QString, QString > i(*m_serialNumberToFileNameMap);

      bool found = false;
      while (!found && i.hasNext()) {
        i.next();
        if (i.value() == imageId) {
          found = true;
          sn = i.key();
        }
      }

      m_readWriteLock->unlock();
    }

    return sn;
  }


  bool CnetDisplayProperties::getShowsFullPaths() const {
    return m_showFullPath;
  }


  void CnetDisplayProperties::setCubeList(QString fileName) {
    QFile imageListFile(fileName);

    if (!imageListFile.exists()) {
      IString msg = "The file [";
      msg += (IString) fileName;
      msg += "] does not exist.\n";
      throw IException(IException::Programmer, msg, _FILEINFO_);
    }

    if (!imageListFile.open(QIODevice::ReadOnly | QIODevice::Text)) {
      IString msg = "The file [";
      msg += (IString) fileName;
      msg += "] failed to open.\n";
      throw IException(IException::Programmer, msg, _FILEINFO_);
    }

    QStringList imageFileNames;
    QTextStream ts(&imageListFile);

    while (!ts.atEnd())
      imageFileNames << ts.readLine();

    imageListFile.close();

    m_curComposing = true;

    QFuture< QMap< QString, QString > > future = QtConcurrent::run(
        this, &CnetDisplayProperties::composeSerialNumbers, imageFileNames);

    m_composeWatcher->setFuture(future);
  }


  void CnetDisplayProperties::setFileNameUsage(bool preferFileNames) {
    useFileNames = preferFileNames;
  }


//   CnetDisplayProperties & CnetDisplayProperties::operator=(
//       CnetDisplayProperties const & other)
//   {
//     if (this != &other)
//     {
//       m_composeWatcher->waitForFinished();
//       useFileNames = other.useFileNames;
//     }
//
//     return *this;
//   }


  void CnetDisplayProperties::setShowsFullPaths(bool newState) {
    m_showFullPath = newState;
  }


  QMap< QString, QString > CnetDisplayProperties::composeSerialNumbers(
    QStringList fileNames) {
    emit composeProgressRangeChanged(0, fileNames.size() - 1);
    m_composedCount->fetchAndStoreRelaxed(0);

    QMap< QString, QString > newMap;

    for (int i = 0; *m_interruptFlag == 0 && i < fileNames.size(); i++) {
      QString fileName = fileNames[i];

      Cube cube;
      cube.open(fileName);

      newMap.insert(SerialNumber::Compose(fileName), fileNames[i]);

      m_composedCount->fetchAndAddRelaxed(1);
    }

    return newMap;
  }


  void CnetDisplayProperties::nullify() {
    m_serialNumberToFileNameMap = NULL;
    m_composeWatcher = NULL;

    m_composedCount = NULL;
    m_interruptFlag = NULL;

    m_readWriteLock = NULL;
  }


  void CnetDisplayProperties::composeStatusUpdated() {
    emit composeProgressChanged(*m_composedCount);
  }


  void CnetDisplayProperties::serialNumbersComposed() {
    if (*m_interruptFlag) {
      m_interruptFlag->fetchAndStoreRelaxed(0);
    }
    else {
      m_readWriteLock->lockForWrite();
      *m_serialNumberToFileNameMap = m_composeWatcher->result();

      m_readWriteLock->unlock();
    }

    m_curComposing = false;
    m_composeStatusPoller->stop();
    emit composeProgressRangeChanged(0, 0);
    emit composeProgressChanged(0);
    emit compositionFinished();
  }
}