#include "iwa_bokeh_advancedfx.h"

#include "trop.h"

#include "trasterfx.h"

#include "trasterimage.h"

#include <qreadwritelock></qreadwritelock>

#include <qmutexlocker></qmutexlocker>

#include <qvector></qvector>

#include <qmap></qmap>

#include <qset></qset>

namespace {

QReadWriteLock lock;

QMutex fx_mutex;

bool isFurtherLayer(const QPair<int, double=""> val1,</int,>

                    const QPair<int, double=""> val2) {</int,>

  // if the layers are at the same depth, then put the layer with smaller index

  // above

  if (val1.second == val2.second) return val1.first > val2.first;

  return val1.second > val2.second;

}

template <typename t=""></typename>

TRasterGR8P allocateRasterAndLock(T** buf, TDimensionI dim) {

  TRasterGR8P ras(dim.lx * sizeof(T), dim.ly);

  ras->lock();

  *buf = (T*)ras->getRawData();

  return ras;

}

// release all registered raster memories and free all fft plans

void releaseAllRastersAndPlans(QList<trastergr8p>& rasterList,</trastergr8p>

                               QList<kiss_fftnd_cfg>& planList) {</kiss_fftnd_cfg>

  for (int r = 0; r < rasterList.size(); r++) rasterList.at(r)->unlock();

  for (int p = 0; p < planList.size(); p++) kiss_fft_free(planList.at(p));

}

};  // namespace

//--------------------------------------------

// sort source images

QList<int> Iwa_BokehAdvancedFx::getSortedSourceIndices(double frame) {</int>

  QList<qpair<int, double="">> usedSourceList;</qpair<int,>

  // gather connected sources

  for (int i = 0; i < LAYER_NUM; i++) {

    if (m_layerParams[i].m_source.isConnected())

      usedSourceList.push_back(

          QPair<int, double="">(i, m_layerParams[i].m_distance->getValue(frame)));</int,>

  }

  if (usedSourceList.empty()) return QList<int>();</int>

  // sort by distance

  std::sort(usedSourceList.begin(), usedSourceList.end(), isFurtherLayer);

  QList<int> indicesList;</int>

  for (int i = 0; i < usedSourceList.size(); i++) {

    indicesList.push_back(usedSourceList.at(i).first);

  }

  return indicesList;

}

//--------------------------------------------

// Compute the bokeh size for each layer. The source tile will be enlarged by

// the largest size of them.

QMap<int, double=""> Iwa_BokehAdvancedFx::getIrisSizes(</int,>

    const double frame, const QList<int> sourceIndices,</int>

    const double bokehPixelAmount, double& maxIrisSize) {

  // create a list of available reference image ports

  QList<int> availableCtrPorts;</int>

  for (int i = 0; i < getInputPortCount(); ++i) {

    QString portName = QString::fromStdString(getInputPortName(i));

    if (portName.startsWith("Depth") && getInputPort(i)->isConnected())

      availableCtrPorts.push_back(portName.remove(0, 5).toInt());

  }

  double focus = m_onFocusDistance->getValue(frame);

  double max   = 0.0;

  QMap<int, double=""> irisSizes;</int,>

  for (int s = 0; s < sourceIndices.size(); s++) {

    int index = sourceIndices.at(s);

    double layer  = m_layerParams[index].m_distance->getValue(frame);

    double adjust = m_layerParams[index].m_bokehAdjustment->getValue(frame);

    double irisSize;

    // In case there is no available reference image

    if (m_layerParams[index].m_depth_ref->getValue() == 0 ||

        !availableCtrPorts.contains(

            m_layerParams[index].m_depth_ref->getValue())) {

      irisSize = (focus - layer) * bokehPixelAmount * adjust;

    }

    // in case using the reference image

    else {

      double refRangeHalf =

          m_layerParams[index].m_depthRange->getValue(frame) * 0.5;

      double nearToFocus = focus - layer + refRangeHalf;

      double farToFocus  = focus - layer - refRangeHalf;

      // take further point from the focus distance

      if (std::abs(nearToFocus) > std::abs(farToFocus))

        irisSize = nearToFocus * bokehPixelAmount * adjust;

      else

        irisSize = farToFocus * bokehPixelAmount * adjust;

    }

    irisSizes[index] = irisSize;

    // update the maximum

    if (max < std::abs(irisSize)) max = std::abs(irisSize);

  }

  maxIrisSize = max;

  return irisSizes;

}

//-----------------------------------------------------

// return true if the control image is available and used

bool Iwa_BokehAdvancedFx::portIsUsed(int portIndex) {

  for (int layer = 0; layer < LAYER_NUM; layer++) {

    if (m_layerParams[layer].m_source.isConnected() &&

        m_layerParams[layer].m_depth_ref->getValue() == portIndex)

      return true;

  }

  return false;

}

//--------------------------------------------

Iwa_BokehAdvancedFx::Iwa_BokehAdvancedFx()

    : m_hardnessPerSource(false), m_control("Depth") {

  // Bind common parameters

  bindParam(this, "on_focus_distance", m_onFocusDistance, false);

  bindParam(this, "bokeh_amount", m_bokehAmount, false);

  bindParam(this, "masterHardness", m_hardness, false);

  bindParam(this, "hardnessPerSource", m_hardnessPerSource, false);

  // Bind layer parameters

  for (int layer = 0; layer < LAYER_NUM; layer++) {

    m_layerParams[layer].m_distance        = TDoubleParamP(0.5);

    m_layerParams[layer].m_bokehAdjustment = TDoubleParamP(1);

    m_layerParams[layer].m_hardness   = TDoubleParamP(0.3);

    m_layerParams[layer].m_depth_ref  = TIntParamP(0);

    m_layerParams[layer].m_depthRange = TDoubleParamP(1.0);

    m_layerParams[layer].m_fillGap    = TBoolParamP(true);

    m_layerParams[layer].m_doMedian   = TBoolParamP(false);

    std::string str = QString("Source%1").arg(layer + 1).toStdString();

    addInputPort(str, m_layerParams[layer].m_source);

    bindParam(this, QString("distance%1").arg(layer + 1).toStdString(),

              m_layerParams[layer].m_distance);

    bindParam(this, QString("bokeh_adjustment%1").arg(layer + 1).toStdString(),

              m_layerParams[layer].m_bokehAdjustment);

    bindParam(this, QString("hardness%1").arg(layer + 1).toStdString(),

              m_layerParams[layer].m_hardness);

    bindParam(this, QString("depth_ref%1").arg(layer + 1).toStdString(),

              m_layerParams[layer].m_depth_ref);

    bindParam(this, QString("depthRange%1").arg(layer + 1).toStdString(),

              m_layerParams[layer].m_depthRange);

    bindParam(this, QString("fillGap%1").arg(layer + 1).toStdString(),

              m_layerParams[layer].m_fillGap);

    bindParam(this, QString("doMedian%1").arg(layer + 1).toStdString(),

              m_layerParams[layer].m_doMedian);

    m_layerParams[layer].m_distance->setValueRange(0.0, 1.0);

    m_layerParams[layer].m_bokehAdjustment->setValueRange(0.0, 2.0);

    m_layerParams[layer].m_hardness->setValueRange(0.05, 3.0);

    m_layerParams[layer].m_depthRange->setValueRange(0.0, 1.0);

  }

  addInputPort("Depth1", new TRasterFxPort, 0);

}

//--------------------------------------------

void Iwa_BokehAdvancedFx::doCompute(TTile& tile, double frame,

                                    const TRenderSettings& settings) {

  // If the iris is not connected, then do nothing

  if (!m_iris.isConnected()) {

    tile.getRaster()->clear();

    return;

  }

  // If none of the source ports is connected, then do nothing

  bool sourceIsConnected = false;

  for (int i = 0; i < LAYER_NUM; i++) {

    if (m_layerParams[i].m_source.isConnected()) {

      sourceIsConnected = true;

      break;

    }

  }

  if (!sourceIsConnected) {

    tile.getRaster()->clear();

    return;

  }

  // Sort source layers by distance

  QList<int> sourceIndices = getSortedSourceIndices(frame);</int>

  // Get the pixel size of bokehAmount ( referenced ino_blur.cpp )

  double bokehPixelAmount = BokehUtils::getBokehPixelAmount(

      m_bokehAmount->getValue(frame), settings.m_affine);

  // Compute the bokeh size for each layer. The source tile will be enlarged by

  // the largest size of them.

  double maxIrisSize;

  QMap<int, double=""> irisSizes =</int,>

      getIrisSizes(frame, sourceIndices, bokehPixelAmount, maxIrisSize);

  int margin = (int)std::ceil(maxIrisSize * 0.5);

  TRectD _rectOut(tile.m_pos, TDimensionD(tile.getRaster()->getLx(),

                                          tile.getRaster()->getLy()));

  _rectOut = _rectOut.enlarge(static_cast<double>(margin));</double>

  TDimensionI dimOut(static_cast<int>(_rectOut.getLx() + 0.5),</int>

                     static_cast<int>(_rectOut.getLy() + 0.5));</int>

  // Enlarge the size to the "fast size" for kissfft which has no factors other

  // than 2,3, or 5.

  if (dimOut.lx < 10000 && dimOut.ly < 10000) {

    int new_x = kiss_fft_next_fast_size(dimOut.lx);

    int new_y = kiss_fft_next_fast_size(dimOut.ly);

    // margin should be integer

    while ((new_x - dimOut.lx) % 2 != 0)

      new_x = kiss_fft_next_fast_size(new_x + 1);

    while ((new_y - dimOut.ly) % 2 != 0)

      new_y = kiss_fft_next_fast_size(new_y + 1);

    _rectOut = _rectOut.enlarge(static_cast<double>(new_x - dimOut.lx) / 2.0,</double>

                                static_cast<double>(new_y - dimOut.ly) / 2.0);</double>

    dimOut.lx = new_x;

    dimOut.ly = new_y;

  }

  // compute the input tiles

  QMap<int, ttile*=""> sourceTiles;</int,>

  TRenderSettings infoOnInput(settings);

  infoOnInput.m_bpp = 64;

  for (auto index : sourceIndices) {

    TTile* layerTile = new TTile();

    m_layerParams[index].m_source->allocateAndCompute(

        *layerTile, _rectOut.getP00(), dimOut, 0, frame, infoOnInput);

    sourceTiles[index] = layerTile;

  }

  // obtain pixel size of original iris image

  TRectD irisBBox;

  m_iris->getBBox(frame, irisBBox, settings);

  // compute the iris tile

  TTile irisTile;

  m_iris->allocateAndCompute(

      irisTile, irisBBox.getP00(),

      TDimension(static_cast<int>(irisBBox.getLx() + 0.5),</int>

                 static_cast<int>(irisBBox.getLy() + 0.5)),</int>

      tile.getRaster(), frame, settings);

  // compute the reference image

  std::vector<trastergr8p> ctrl_rasters;  // to be stored in uchar</trastergr8p>

  QMap<int, char*="" unsigned=""></int,>

      ctrls;  // container of [port number, reference image buffer in uchar]

  for (int i = 0; i < getInputPortCount(); ++i) {

    QString portName = QString::fromStdString(getInputPortName(i));

    if (portName.startsWith("Depth") && getInputPort(i)->isConnected()) {

      int portIndex = portName.remove(0, 5).toInt();

      if (portIsUsed(portIndex)) {

        TTile tmpTile;

        TRasterFxPort* tmpCtrl = dynamic_cast<trasterfxport*>(getInputPort(i));</trasterfxport*>

        (*tmpCtrl)->allocateAndCompute(tmpTile, _rectOut.getP00(), dimOut,

                                       tile.getRaster(), frame, settings);

        TRasterGR8P ctrlRas(dimOut.lx, dimOut.ly);

        ctrlRas->lock();

        unsigned char* ctrl_mem = (unsigned char*)ctrlRas->getRawData();

        TRaster32P ras32        = (TRaster32P)tmpTile.getRaster();

        TRaster64P ras64        = (TRaster64P)tmpTile.getRaster();

        lock.lockForRead();

        if (ras32)

          BokehUtils::setDepthRaster<traster32p, tpixel32="">(ras32, ctrl_mem,</traster32p,>

                                                           dimOut);

        else if (ras64)

          BokehUtils::setDepthRaster<traster64p, tpixel64="">(ras64, ctrl_mem,</traster64p,>

                                                           dimOut);

        lock.unlock();

        ctrl_rasters.push_back(ctrlRas);

        ctrls[portIndex] = ctrl_mem;

      }

    }

  }

  double masterHardness = m_hardness->getValue(frame);

  QList<layervalue> layerValues;</layervalue>

  for (auto index : sourceIndices) {

    LayerValue layerValue;

    layerValue.sourceTile = sourceTiles[index];

    layerValue.premultiply =

        false;  // assuming input images are always premultiplied

    layerValue.layerHardness =

        (m_hardnessPerSource->getValue())

            ? m_layerParams[index].m_hardness->getValue(frame)

            : masterHardness;

    layerValue.depth_ref = m_layerParams[index].m_depth_ref->getValue();

    layerValue.irisSize  = irisSizes.value(index);

    layerValue.distance  = m_layerParams[index].m_distance->getValue(frame);

    layerValue.bokehAdjustment =

        m_layerParams[index].m_bokehAdjustment->getValue(frame);

    layerValue.depthRange = m_layerParams[index].m_depthRange->getValue(frame);

    layerValue.distancePrecision = 10;

    layerValue.fillGap           = m_layerParams[index].m_fillGap->getValue();

    layerValue.doMedian          = m_layerParams[index].m_doMedian->getValue();

    layerValues.append(layerValue);

  }

  Iwa_BokehCommonFx::doFx(tile, frame, settings, bokehPixelAmount, margin,

                          dimOut, irisBBox, irisTile, layerValues, ctrls);

  // release control image buffers

  for (int r = 0; r < ctrl_rasters.size(); r++) ctrl_rasters[r]->unlock();

  qDeleteAll(sourceTiles);

}

//--------------------------------------------

FX_PLUGIN_IDENTIFIER(Iwa_BokehAdvancedFx, "iwa_BokehAdvancedFx")