spectrumtube.cpp

Go to the documentation of this file.

/**
 * \file pappsomspp/core/processing/cbor/mzcbor/copyreplace/spectrumtube.cpp
 * \date 3/10/2026
 * \author Olivier Langella
 * \brief buffer to store a whole spectrum list
 *  */
 
/*******************************************************************************
 * Copyright (c) 2026 Olivier Langella <Olivier.Langella@cnrs.fr>.
 *
 * This file is part of PAPPSOms-tools.
 *
 *     PAPPSOms-tools 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 3 of the License, or
 *     (at your option) any later version.
 *
 *     PAPPSOms-tools 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 PAPPSOms-tools.  If not, see <http://www.gnu.org/licenses/>.
 *
 ******************************************************************************/
 
 
#include "spectrumtube.h"
#include <QtCore>
#include <qcborarray.h>
#include <qcbormap.h>
#include <qcborvalue.h>
#include <qdebug.h>
#include <qlogging.h>
 
namespace pappso
{
namespace cbor
{
namespace mzcbor
{
SpectrumTube::SpectrumTube()
{
  mpa_buffer = new QTemporaryFile();
  mpa_buffer->open();
  qDebug() << mpa_buffer->fileName();
  mpa_bufferWriter = new pappso::cbor::CborStreamWriter(mpa_buffer);
}
 
SpectrumTube::~SpectrumTube()
{
 
  if(mpa_buffer != nullptr)
    {
      delete mpa_buffer;
    }
  if(mpa_bufferWriter != nullptr)
    {
      delete mpa_bufferWriter;
    }
}
std::size_t
SpectrumTube::size() const
{
  return m_size;
}
const QString
SpectrumTube::push_back(QcborSpectrum &spectrum)
{
  qDebug() << m_size;
  std::size_t index = m_size;
 
  spectrum.setIndex(index);
 
  // replace scan number in native id
  const QString native_id(spectrum.getId());
  QString new_native_id;
  // controllerType=0 controllerNumber=1 scan=2995
  //
  QStringList native_id_list = native_id.split(" scan=");
  if(native_id_list.size() < 2)
    {
      new_native_id = QString("%1 index=%2").arg(native_id).arg(index);
    }
  else
    {
      new_native_id = QString("%1 scan=%2").arg(native_id_list[0]).arg(index + 1);
    }
 
  // spectrum.addUserParam();
 
  spectrum.setId(new_native_id);
 
  qDebug();
 
  writeQcborSpectrumInBuffer(spectrum, native_id);
  // qDebug() << mpa_buffer->data().length();
  m_size++;
  return native_id;
}
 
void
SpectrumTube::writeQcborSpectrumInBuffer(const QcborSpectrum &spectrum,
                                         const QString &old_native_id)
{
 
  // "id": "controllerType=0 controllerNumber=1 scan=3001",
  // "index": 3000,
  // "defaultArrayLength": 235,
  // "cvParam": [],
  // "userParam": [
  //   {
  //     "name": "[PAPPSO]original spectrum native id",
  //     "type": "xsd:string",
  //     "value": old_native_id
  //   }
  // ],
  QCborMap new_user_param;
  new_user_param.insert(QString("name"), "[PAPPSO]original spectrum native id");
  new_user_param.insert(QString("type"), "xsd:string");
  new_user_param.insert(QString("value"), old_native_id);
  //"scanList": {},
  //"precursorList": {},
  //"binaryDataArray": []
  mpa_bufferWriter->startMap();
  bool write_user_param = false;
  for(auto it_cbor = spectrum.begin(); it_cbor != spectrum.end(); it_cbor++)
    {
      QString current_key = it_cbor.key().toString();
 
      if(write_user_param)
        {
          if(current_key == "userParam")
            {
              QCborArray user_param_array = it_cbor.value().toArray();
              user_param_array.append(new_user_param);
              mpa_bufferWriter->writeCborValue(it_cbor.key());
              mpa_bufferWriter->writeCborValue(user_param_array);
              continue;
            }
          else
            {
              mpa_bufferWriter->append("userParam");
              mpa_bufferWriter->startArray();
              mpa_bufferWriter->writeCborMap(new_user_param);
              mpa_bufferWriter->endArray();
            }
          write_user_param = false;
        }
 
      if(current_key == "cvParam")
        {
          // write cvParam
          mpa_bufferWriter->writeCborValue(it_cbor.key());
          mpa_bufferWriter->writeCborValue(it_cbor.value());
          write_user_param = true;
        }
      else
        {
          mpa_bufferWriter->writeCborValue(it_cbor.key());
          mpa_bufferWriter->writeCborValue(it_cbor.value());
        }
    }
  mpa_bufferWriter->endMap();
  // mpa_bufferWriter->writeCborMap(spectrum);
}
 
void
SpectrumTube::flush(pappso::cbor::CborStreamWriter *cbor_writer_p)
{
  mpa_buffer->close();
  mpa_buffer->open();
  while(!mpa_buffer->atEnd())
    {
      cbor_writer_p->device()->write(mpa_buffer->read(1000));
    }
}
} // namespace mzcbor
} // namespace cbor
} // namespace pappso