// rdaudio_port.cpp
//
// Abstract a Rivendell Audio Port.
//
//   (C) Copyright 2002-2003,2016-2018 Fred Gleason <fredg@paravelsystems.com>
//
//   This program is free software; you can redistribute it and/or modify
//   it under the terms of the GNU General Public License version 2 as
//   published by the Free Software Foundation.
//
//   This program 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., 675 Mass Ave, Cambridge, MA 02139, USA.
//

#include <rddb.h>
#include <rdaudio_port.h>
#include <rdescape_string.h>

//
// Global Classes
//
RDAudioPort::RDAudioPort(QString station,int card)
{
  QString sql;
  RDSqlQuery *q;

  port_station=station;
  port_card=card;

  for(int port=0;port<RD_MAX_PORTS;port++) {
    audio_input_port_level[port]=400;
    audio_input_port_type[port]=RDAudioPort::Analog;
    audio_input_port_mode[port]=RDCae::Normal;
    audio_output_port_level[port]=400;
  }

  sql=QString("select ")+
    "`PORT_NUMBER`,"+  // 00
    "`LEVEL`,"+        // 01
    "`TYPE`,"+         // 02
    "`MODE`,"+         // 03
    "`LABEL` "+        // 04
    "from `AUDIO_INPUTS` where "+
    "`STATION_NAME`='"+RDEscapeString(port_station)+"' && "+
    QString::asprintf("`CARD_NUMBER`=%d",port_card);
  q=new RDSqlQuery(sql);
  while(q->next()) {
    audio_input_port_level[q->value(0).toInt()]=q->value(1).toInt();
    audio_input_port_type[q->value(0).toInt()]=
      (RDAudioPort::PortType)q->value(2).toInt();
    audio_input_port_mode[q->value(0).toInt()]=
      (RDCae::ChannelMode)q->value(3).toInt();
    audio_input_port_labels[q->value(0).toInt()]=q->value(4).toString();
  }
  delete q;

  sql=QString("select ")+
    "`PORT_NUMBER`,"+  // 00
    "`LEVEL`,"+        // 01
    "`LABEL` "+        // 02
    "from `AUDIO_OUTPUTS` where "+
    "`STATION_NAME`='"+RDEscapeString(port_station)+"' && "+
    QString::asprintf("`CARD_NUMBER`=%d",port_card);
  q=new RDSqlQuery(sql);
  while(q->next()) {
    audio_output_port_level[q->value(0).toInt()]=q->value(1).toInt();
    audio_output_port_labels[q->value(0).toInt()]=q->value(2).toString();
  }
  delete q;
}


QString RDAudioPort::station() const
{
  return port_station;
}


int RDAudioPort::card() const
{
  return port_card;
}


RDCae::ClockSource RDAudioPort::clockSource()
{
  RDCae::ClockSource ret=RDCae::InternalClock;
  QString sql=QString("select `CLOCK_SOURCE` from `AUDIO_CARDS` where ")+
    "`STATION_NAME`='"+RDEscapeString(port_station)+"' && "+
    QString::asprintf("`CARD_NUMBER`=%d",port_card);
  RDSqlQuery *q=new RDSqlQuery(sql);
  if(q->first()) {
    ret=(RDCae::ClockSource)q->value(0).toInt();
  }

  return ret;
}


void RDAudioPort::setClockSource(RDCae::ClockSource src)
{
  QString sql=QString("update `AUDIO_CARDS` set ")+
    QString::asprintf("`CLOCK_SOURCE`=%d where ",src)+
    "`STATION_NAME`='"+RDEscapeString(port_station)+"' && "+
    QString::asprintf("`CARD_NUMBER`=%d",port_card);
  RDSqlQuery *q=new RDSqlQuery(sql);
  delete q;
}


QString RDAudioPort::inputPortLabel(int port) const
{
  if(port<0||port>RD_MAX_PORTS) {
    return QObject::tr("ERR");
  }

  return audio_input_port_labels[port];
}


void RDAudioPort::setInputPortLabel(int port,const QString &str)
{
  if(port<0||port>RD_MAX_PORTS) {
    return;
  }
  audio_input_port_labels[port]=str;
  QString sql=QString("update `AUDIO_INPUTS` set ")+
    "`LABEL`='"+RDEscapeString(str)+"' where "+
    "`STATION_NAME`='"+RDEscapeString(port_station)+"' && "+
    QString::asprintf("`CARD_NUMBER`=%d && ",port_card)+
    QString::asprintf("`PORT_NUMBER`=%d",port);
  RDSqlQuery::apply(sql);
}


RDAudioPort::PortType RDAudioPort::inputPortType(int port)
{
  if(port<0||port>RD_MAX_PORTS) {
    return RDAudioPort::Analog;
  }

  return audio_input_port_type[port];
}


void RDAudioPort::setInputPortType(int port,RDAudioPort::PortType type)
{
  if(port<0||port>RD_MAX_PORTS) {
    return;
  }
  audio_input_port_type[port]=type;
  QString sql=QString("update `AUDIO_INPUTS` set ")+
    QString::asprintf("`TYPE`=%d where ",type)+
    "`STATION_NAME`='"+RDEscapeString(port_station)+"' && "+
    QString::asprintf("`CARD_NUMBER`=%d && ",port_card)+
    QString::asprintf("`PORT_NUMBER`=%d",port);
  RDSqlQuery *q=new RDSqlQuery(sql);
  delete q;
}


RDCae::ChannelMode RDAudioPort::inputPortMode(int port)
{
  if(port<0||port>RD_MAX_PORTS) {
    return RDCae::Normal;
  }

  return audio_input_port_mode[port];
}


void RDAudioPort::setInputPortMode(int port,RDCae::ChannelMode mode)
{
  if(port<0||port>RD_MAX_PORTS) {
    return;
  }
  audio_input_port_mode[port]=mode;
  QString sql=QString("update `AUDIO_INPUTS` set ")+
    QString::asprintf("`MODE`=%d where ",mode)+
    "`STATION_NAME`=\""+RDEscapeString(port_station)+"\" && "+
    QString::asprintf("`CARD_NUMBER`=%d && ",port_card)+
    QString::asprintf("`PORT_NUMBER`=%d",port);
  RDSqlQuery *q=new RDSqlQuery(sql);
  delete q;
}


int RDAudioPort::inputPortLevel(int port)
{
  if(port<0||port>RD_MAX_PORTS) {
    return 400;
  }

  return audio_input_port_level[port];
}


void RDAudioPort::setInputPortLevel(int port,int level)
{
  if(port<0||port>RD_MAX_PORTS) {
    return;
  }
  audio_input_port_level[port]=level;
  QString sql=QString("update `AUDIO_INPUTS` set ")+
    QString::asprintf("`LEVEL`=%d where ",level)+
    "`STATION_NAME`='"+RDEscapeString(port_station)+"' && "+
    QString::asprintf("`CARD_NUMBER`=%d && ",port_card)+
    QString::asprintf("`PORT_NUMBER`=%d",port);
  RDSqlQuery *q=new RDSqlQuery(sql);
  delete q;
}


QString RDAudioPort::outputPortLabel(int port) const
{
  if(port<0||port>RD_MAX_PORTS) {
    return QObject::tr("ERR");
  }

  return audio_output_port_labels[port];
}


void RDAudioPort::setOutputPortLabel(int port,const QString &str)
{
  if(port<0||port>RD_MAX_PORTS) {
    return;
  }
  audio_output_port_labels[port]=str;
  QString sql=QString("update `AUDIO_OUTPUTS` set ")+
    "`LABEL`='"+RDEscapeString(str)+"' where "+
    "`STATION_NAME`='"+RDEscapeString(port_station)+"' && "+
    QString::asprintf("`CARD_NUMBER`=%d && ",port_card)+
    QString::asprintf("`PORT_NUMBER`=%d",port);
  RDSqlQuery::apply(sql);
}


int RDAudioPort::outputPortLevel(int port)
{
  if(port<0||port>RD_MAX_PORTS) {
    return 400;
  }

  return audio_output_port_level[port];
}


void RDAudioPort::setOutputPortLevel(int port,int level)
{
  if(port<0||port>RD_MAX_PORTS) {
    return;
  }
  audio_output_port_level[port]=level;
  QString sql=QString("update `AUDIO_OUTPUTS` set ")+
    QString::asprintf("`LEVEL`=%d where ",level)+
    "`STATION_NAME`='"+RDEscapeString(port_station)+"' && "+
    QString::asprintf("`CARD_NUMBER`=%d && ",port_card)+
    QString::asprintf("`PORT_NUMBER`=%d",port);
  RDSqlQuery *q=new RDSqlQuery(sql);
  delete q;
}