indidriver.cpp

/*
    SPDX-FileCopyrightText: 2001 Jasem Mutlaq <mutlaqja@ikarustech.com>
 
    SPDX-License-Identifier: GPL-2.0-or-later
*/
 
#include "indidriver.h"
 
#include "config-kstars.h"
 
#include "devicemanager.h"
#include "indidevice.h"
#include "indimenu.h"
#include "kstars.h"
#include "kstarsdata.h"
#include "ksutils.h"
#include "Options.h"
#include "ui_indihostconf.h"
#include "oal/log.h"
#include "oal/scope.h"
 
#include <KMessageBox>
#include <KProcess>
#include <KActionCollection>
 
#include <QRadioButton>
#include <QFile>
#include <QDir>
#include <QTextStream>
#include <QTreeWidget>
#include <QIcon>
#include <QDialog>
#include <QTcpServer>
#include <QMenu>
#include <QPushButton>
#include <QLineEdit>
#include <QAction>
#include <QStandardPaths>
 
#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
 
#define MAX_RETRIES 3
#define ERRMSG_SIZE 1024
 
DeviceManagerUI::DeviceManagerUI(QWidget *parent) : QFrame(parent)
{
#ifdef Q_OS_OSX
    setWindowFlags(Qt::Tool | Qt::WindowStaysOnTopHint);
#endif
    setupUi(this);
 
    localTreeWidget->setSortingEnabled(false);
    localTreeWidget->setRootIsDecorated(true);
 
    clientTreeWidget->setSortingEnabled(false);
 
    runningPix = QIcon::fromTheme("system-run");
    stopPix    = QIcon::fromTheme("dialog-cancel");
    localMode  = QIcon::fromTheme("computer");
    serverMode = QIcon::fromTheme("network-server");
 
    connected    = QIcon::fromTheme("network-connect");
    disconnected = QIcon::fromTheme("network-disconnect");
 
    connect(localTreeWidget, SIGNAL(itemDoubleClicked(QTreeWidgetItem*,int)), this,
            SLOT(makePortEditable(QTreeWidgetItem*,int)));
}
 
void DeviceManagerUI::makePortEditable(QTreeWidgetItem *selectedItem, int column)
{
    // If it's the port column, then make it user-editable
    if (column == INDIDriver::LOCAL_PORT_COLUMN)
        selectedItem->setFlags(Qt::ItemIsSelectable | Qt::ItemIsEditable | Qt::ItemIsEnabled);
 
    localTreeWidget->editItem(selectedItem, INDIDriver::LOCAL_PORT_COLUMN);
}
 
INDIDriver::INDIDriver(KStars *_ks) : QDialog(_ks), ksw(_ks)
{
    currentPort = Options::serverPortStart().toInt() - 1;
    lastGroup   = nullptr;
    lastDevice  = nullptr;
 
    ui = new DeviceManagerUI(this);
    setMainWidget(ui);
    setCaption(xi18n("Device Manager"));
    setButtons(QDialog::Close);
 
    foreach (INDIHostsInfo *host, ksw->data()->INDIHostsList)
    {
        QTreeWidgetItem *item = new QTreeWidgetItem(ui->clientTreeWidget, lastGroup);
        lastGroup             = item;
        item->setIcon(HOST_STATUS_COLUMN, ui->disconnected);
        item->setText(HOST_NAME_COLUMN, host->name);
        item->setText(HOST_PORT_COLUMN, host->portnumber);
    }
 
    lastGroup = nullptr;
 
    QObject::connect(ui->addB, SIGNAL(clicked()), this, SLOT(addINDIHost()));
    QObject::connect(ui->modifyB, SIGNAL(clicked()), this, SLOT(modifyINDIHost()));
    QObject::connect(ui->removeB, SIGNAL(clicked()), this, SLOT(removeINDIHost()));
 
    //QObject::connect(ksw->indiMenu(), SIGNAL(driverDisconnected(int)), this, SLOT(shutdownHost(int)));
    QObject::connect(ui->connectHostB, SIGNAL(clicked()), this, SLOT(activateHostConnection()));
    QObject::connect(ui->disconnectHostB, SIGNAL(clicked()), this, SLOT(activateHostDisconnection()));
    QObject::connect(ui->runServiceB, SIGNAL(clicked()), this, SLOT(activateRunService()));
    QObject::connect(ui->stopServiceB, SIGNAL(clicked()), this, SLOT(activateStopService()));
    QObject::connect(ui->localTreeWidget, SIGNAL(itemClicked(QTreeWidgetItem*,int)), this, SLOT(updateLocalTab()));
    QObject::connect(ui->clientTreeWidget, SIGNAL(itemClicked(QTreeWidgetItem*,int)), this, SLOT(updateClientTab()));
    QObject::connect(ui->localTreeWidget, SIGNAL(expanded(QModelIndex)), this, SLOT(resizeDeviceColumn()));
 
    readXMLDrivers();
}
 
/*
void INDIDriver::enableDevice(INDI_D *indi_device)
{
   if (indi_device == nullptr)
    return;
 
   if (indi_device->deviceManager->mode == DeviceManager::M_CLIENT)
   {
    foreach (INDIHostsInfo * host, ksw->data()->INDIHostsList)
        {
 
            if (host->deviceManager == indi_device->deviceManager && host->isConnected == false)
            {
                foreach (QTreeWidgetItem *item, ui->clientTreeWidget->findItems(host->name, Qt::MatchExactly, 1))
                                item->setIcon(HOST_STATUS_COLUMN, ui->connected);
 
                    host->isConnected = true;
            updateClientTab();
            updateMenuActions();
            ksw->indiMenu()->show();
                    return;
            }
        }
    }
    else
      {
    foreach (IDevice *device, devices)
        {
        if (device->unique_label == indi_device->label)
        {
            foreach (QTreeWidgetItem *item, ui->localTreeWidget->findItems(device->tree_label, Qt::MatchExactly |  Qt::MatchRecursive))
            {
                                item->setIcon(LOCAL_STATUS_COLUMN, ui->runningPix);
                                item->setText(LOCAL_PORT_COLUMN, QString::number(indi_device->deviceManager->port));
            }
 
            updateLocalTab();
            updateMenuActions();
            ksw->indiMenu()->show();
            return;
        }
    }
      }
 
}
 
void INDIDriver::disableDevice(INDI_D *indi_device)
{
    if (indi_device == nullptr)
    return;
 
   if (indi_device->deviceManager->mode == DeviceManager::M_CLIENT)
   {
    foreach (INDIHostsInfo * host, ksw->data()->INDIHostsList)
        {
            if (host->deviceManager == indi_device->deviceManager && host->isConnected == true)
            {
                foreach (QTreeWidgetItem *item, ui->clientTreeWidget->findItems(host->name, Qt::MatchExactly,1))
                                item->setIcon(HOST_STATUS_COLUMN, ui->disconnected);
 
            host->deviceManager = nullptr;
                host->isConnected = false;
 
                updateClientTab();
                    return;
            }
        }
    }
    else
      {
    foreach (IDevice *device, devices)
        {
        if (device->unique_label == indi_device->label)
        {
            foreach (QTreeWidgetItem *item, ui->localTreeWidget->findItems(device->tree_label, Qt::MatchExactly |  Qt::MatchRecursive))
            {
                                item->setIcon(LOCAL_STATUS_COLUMN, ui->stopPix);
                                item->setIcon(LOCAL_MODE_COLUMN, QIcon());
                                item->setText(LOCAL_PORT_COLUMN, device->port);
            }
 
            device->clear();
            updateLocalTab();
 
            return;
        }
    }
      }
  }
  */
void INDIDriver::activateRunService()
{
    processLocalTree(IDevice::DEV_START);
}
 
void INDIDriver::activateStopService()
{
    processLocalTree(IDevice::DEV_TERMINATE);
}
 
void INDIDriver::activateHostConnection()
{
    processRemoteTree(IDevice::DEV_START);
}
 
void INDIDriver::activateHostDisconnection()
{
    processRemoteTree(IDevice::DEV_TERMINATE);
}
 
void INDIDriver::updateLocalTab()
{
    if (ui->localTreeWidget->currentItem() == nullptr)
        return;
 
    foreach (IDevice *device, devices)
    {
        if (ui->localTreeWidget->currentItem()->text(LOCAL_NAME_COLUMN) == device->tree_label)
        {
            ui->runServiceB->setEnabled(device->state == IDevice::DEV_TERMINATE);
            ui->stopServiceB->setEnabled(device->state == IDevice::DEV_START);
 
            ui->serverLogText->clear();
            ui->serverLogText->append(device->getServerBuffer());
 
            return;
        }
    }
}
 
void INDIDriver::updateClientTab()
{
    if (ui->clientTreeWidget->currentItem() == nullptr)
        return;
 
    foreach (INDIHostsInfo *host, ksw->data()->INDIHostsList)
    {
        if (ui->clientTreeWidget->currentItem()->text(HOST_NAME_COLUMN) == host->name &&
            ui->clientTreeWidget->currentItem()->text(HOST_PORT_COLUMN) == host->portnumber)
        {
            ui->connectHostB->setEnabled(!host->isConnected);
            ui->disconnectHostB->setEnabled(host->isConnected);
            break;
        }
    }
}
 
void INDIDriver::processLocalTree(IDevice::DeviceStatus dev_request)
{
    QList<IDevice *> processed_devices;
    DeviceManager *deviceManager = nullptr;
    int port                     = 0;
    bool portOK                  = false;
 
    foreach (QTreeWidgetItem *item, ui->localTreeWidget->selectedItems())
    {
        foreach (IDevice *device, devices)
        {
            //device->state = (dev_request == IDevice::DEV_TERMINATE) ? IDevice::DEV_START : IDevice::DEV_TERMINATE;
            if (item->text(LOCAL_NAME_COLUMN) == device->tree_label && device->state != dev_request)
            {
                processed_devices.append(device);
 
                // N.B. If multiple devices are selected to run under one device manager
                // then we select the port for the first device that has a valid port
                // entry, the rest are ignored.
                if (port == 0 && item->text(LOCAL_PORT_COLUMN).isEmpty() == false)
                {
                    port = item->text(LOCAL_PORT_COLUMN).toInt(&portOK);
                    // If we encounter conversion error, we abort
                    if (portOK == false)
                    {
                        KMessageBox::error(0, xi18n("Invalid port entry: %1", item->text(LOCAL_PORT_COLUMN)));
                        return;
                    }
                }
            }
        }
    }
 
    if (processed_devices.empty())
        return;
 
    // Select random port within range is none specified.
    port = getINDIPort(port);
 
    if (dev_request == IDevice::DEV_START)
    {
        if (port <= 0)
        {
            KMessageBox::error(0, xi18n("Cannot start INDI server: port error."));
            return;
        }
 
        //deviceManager = ksw->indiMenu()->startDeviceManager(processed_devices, ui->localR->isChecked() ? DeviceManager::M_LOCAL : DeviceManager::M_SERVER, ((uint) port));
        deviceManager = ksw->indiMenu()->initDeviceManager(
            "localhost", ((uint)port), ui->localR->isChecked() ? DeviceManager::M_LOCAL : DeviceManager::M_SERVER);
 
        if (deviceManager == nullptr)
        {
            kWarning() << "Warning: device manager has not been established properly";
            return;
        }
 
        deviceManager->appendManagedDevices(processed_devices);
        deviceManager->startServer();
        connect(deviceManager, SIGNAL(newServerInput()), this, SLOT(updateLocalTab()));
    }
    else
        ksw->indiMenu()->stopDeviceManager(processed_devices);
}
 
void INDIDriver::processRemoteTree(IDevice::DeviceStatus dev_request)
{
    DeviceManager *deviceManager = nullptr;
    QTreeWidgetItem *currentItem = ui->clientTreeWidget->currentItem();
    if (!currentItem)
        return;
    bool toConnect = (dev_request == IDevice::DEV_START);
 
    foreach (INDIHostsInfo *host, ksw->data()->INDIHostsList)
    {
        if (currentItem->text(HOST_NAME_COLUMN) == host->name &&
            currentItem->text(HOST_PORT_COLUMN) == host->portnumber)
        {
            // Nothing changed, return
            if (host->isConnected == toConnect)
                return;
 
            // connect to host
            if (toConnect)
            {
                deviceManager = ksw->indiMenu()->initDeviceManager(host->hostname, host->portnumber.toUInt(),
                                                                   DeviceManager::M_CLIENT);
 
                if (deviceManager == nullptr)
                {
                    // msgbox after freeze
                    kWarning() << "Warning: device manager has not been established properly";
                    return;
                }
 
                host->deviceManager = deviceManager;
                deviceManager->connectToServer();
            }
            else
                ksw->indiMenu()->removeDeviceManager(host->deviceManager);
 
            return;
        }
    }
}
 
void INDIDriver::newTelescopeDiscovered()
{
    emit newTelescope();
}
 
void INDIDriver::newCCDDiscovered()
{
    emit newCCD();
}
 
void INDIDriver::resizeDeviceColumn()
{
    ui->localTreeWidget->resizeColumnToContents(0);
}
 
void INDIDriver::updateMenuActions()
{
    // We iterate over devices, we enable INDI Control Panel if we have any active device
    // We enable capture image sequence if we have any imaging device
 
    QAction *tmpAction = nullptr;
    INDIMenu *devMenu  = ksw->indiMenu();
    bool activeDevice  = false;
    bool activeImaging = false;
    INDI_P *imgProp    = nullptr;
 
    if (devMenu == nullptr)
        return;
 
    if (devMenu->managers.count() > 0)
        activeDevice = true;
 
    foreach (DeviceManager *dev_managers, devMenu->managers)
    {
        foreach (INDI_D *device, dev_managers->indi_dev)
        {
            imgProp = device->findProp("CCD_EXPOSURE");
            if (imgProp && device->isOn())
            {
                activeImaging = true;
                break;
            }
        }
    }
 
    tmpAction = ksw->actionCollection()->action("capture_sequence");
 
    if (tmpAction != nullptr)
        tmpAction->setEnabled(activeImaging);
 
    tmpAction = ksw->actionCollection()->action("indi_cpl");
    if (tmpAction != nullptr)
        tmpAction->setEnabled(activeDevice);
}
 
bool INDIDriver::isDeviceRunning(const QString &deviceLabel)
{
    foreach (IDevice *dev, devices)
    {
        if (deviceLabel == dev->tree_label)
            return dev->state == IDevice::DEV_START;
    }
    return false;
}
 
int INDIDriver::getINDIPort(int customPort)
{
    int lastPort = Options::serverPortEnd().toInt();
    ;
    bool success = false;
    currentPort++;
 
    // recycle
    if (currentPort > lastPort)
        currentPort = Options::serverPortStart().toInt();
 
    QTcpServer temp_server;
 
    if (customPort != 0)
    {
        success = temp_server.listen(QHostAddress::LocalHost, customPort);
        if (success)
        {
            temp_server.close();
            return customPort;
        }
        else
            return -1;
    }
 
    for (; currentPort <= lastPort; currentPort++)
    {
        success = temp_server.listen(QHostAddress::LocalHost, currentPort);
        if (success)
        {
            temp_server.close();
            return currentPort;
        }
    }
    return -1;
}
 
bool INDIDriver::readXMLDrivers()
{
    QDir indiDir;
    QString driverName;
 
    QString driversDir = Options::indiDriversDir();
#ifdef Q_OS_OSX
    if (Options::indiDriversAreInternal())
        QCoreApplication::applicationDirPath() + "/../Resources/DriverSupport";
#endif
 
    if (indiDir.cd(driversDir) == false)
    {
        KMessageBox::error(0, xi18n("Unable to find INDI drivers directory: %1\nPlease make sure to set the correct "
                                    "path in KStars configuration",
                                    driversDir));
        return false;
    }
 
    indiDir.setNameFilters(QStringList("*.xml"));
    indiDir.setFilter(QDir::Files | QDir::NoSymLinks);
    QFileInfoList list = indiDir.entryInfoList();
 
    foreach (QFileInfo fileInfo, list)
    {
        // libindi 0.7.1: Skip skeleton files
        if (fileInfo.fileName().endsWith(QLatin1String("_sk.xml")))
            continue;
 
        if (fileInfo.fileName() == "drivers.xml")
        {
            // Let first attempt to load the local version of drivers.xml
            driverName = QDir(KSPaths::writableLocation(QStandardPaths::AppDataLocation)).filePath("drivers.xml");
 
            // If found, we continue, otherwise, we load the system file
            if (driverName.isEmpty() == false && QFile(driverName).exists())
            {
                processXMLDriver(driverName);
                continue;
            }
        }
 
        driverName = QString("%1/%2").arg(driversDir).arg(fileInfo.fileName());
        processXMLDriver(driverName);
    }
 
    return true;
}
 
void INDIDriver::processXMLDriver(QString &driverName)
{
    QFile file(driverName);
    if (!file.open(QIODevice::ReadOnly | QIODevice::Text))
    {
        KMessageBox::error(0, xi18n("Failed to open INDI Driver file: %1", driverName));
        return;
    }
 
    char errmsg[ERRMSG_SIZE];
    char c;
    LilXML *xmlParser = newLilXML();
    XMLEle *root      = nullptr;
 
    if (driverName.endsWith(QLatin1String("drivers.xml")))
        xmlSource = IDevice::PRIMARY_XML;
    else
        xmlSource = IDevice::THIRD_PARTY_XML;
 
    while (file.getChar(&c))
    {
        root = readXMLEle(xmlParser, c, errmsg);
 
        if (root)
        {
            if (!buildDeviceGroup(root, errmsg))
                prXMLEle(stderr, root, 0);
 
            delXMLEle(root);
        }
        else if (errmsg[0])
        {
            kDebug() << QString(errmsg) << endl;
            delLilXML(xmlParser);
            return;
        }
    }
 
    delLilXML(xmlParser);
}
 
bool INDIDriver::buildDeviceGroup(XMLEle *root, char errmsg[])
{
    XMLAtt *ap;
    XMLEle *ep;
    QString groupName;
    QTreeWidgetItem *group;
    int groupType = KSTARS_TELESCOPE;
 
    // avoid overflow
    if (strlen(tagXMLEle(root)) > 1024)
        return false;
 
    // Get device grouping name
    ap = findXMLAtt(root, "group");
 
    if (!ap)
    {
        snprintf(errmsg, ERRMSG_SIZE, "Tag %.64s does not have a group attribute", tagXMLEle(root));
        return false;
    }
 
    groupName = valuXMLAtt(ap);
 
    if (groupName.indexOf("Telescopes") != -1)
        groupType = KSTARS_TELESCOPE;
    else if (groupName.indexOf("CCDs") != -1)
        groupType = KSTARS_CCD;
    else if (groupName.indexOf("Filter") != -1)
        groupType = KSTARS_FILTER;
    else if (groupName.indexOf("Video") != -1)
        groupType = KSTARS_VIDEO;
    else if (groupName.indexOf("Focusers") != -1)
        groupType = KSTARS_FOCUSER;
    else if (groupName.indexOf("Domes") != -1)
        groupType = KSTARS_DOME;
    else if (groupName.indexOf("Receivers") != -1)
        groupType = KSTARS_RECEIVERS;
    else if (groupName.indexOf("GPS") != -1)
        groupType = KSTARS_GPS;
 
#ifndef HAVE_CFITSIO_H
    // We do not create these groups if we don't have CFITSIO support
    if (groupType == KSTARS_CCD || groupType == KSTARS_VIDEO)
        return true;
#endif
 
    // Find if the group already exists
    QList<QTreeWidgetItem *> treeList = ui->localTreeWidget->findItems(groupName, Qt::MatchExactly);
    if (!treeList.isEmpty())
        group = treeList[0];
    else
        group = new QTreeWidgetItem(ui->localTreeWidget, lastGroup);
 
    group->setText(0, groupName);
    lastGroup = group;
 
    for (ep = nextXMLEle(root, 1); ep != nullptr; ep = nextXMLEle(root, 0))
        if (!buildDriverElement(ep, group, groupType, errmsg))
            return false;
 
    return true;
}
 
bool INDIDriver::buildDriverElement(XMLEle *root, QTreeWidgetItem *DGroup, int groupType, char errmsg[])
{
    XMLAtt *ap;
    XMLEle *el;
    IDevice *dv;
    QString label;
    QString driver;
    QString version;
    QString name;
    QString port;
    double focal_length(-1), aperture(-1);
 
    ap = findXMLAtt(root, "label");
    if (!ap)
    {
        snprintf(errmsg, ERRMSG_SIZE, "Tag %.64s does not have a label attribute", tagXMLEle(root));
        return false;
    }
 
    label = valuXMLAtt(ap);
 
    // Search for optional port attribute
    ap = findXMLAtt(root, "port");
    if (ap)
        port = valuXMLAtt(ap);
 
    // Let's look for telescope-specific attributes: focal length and aperture
    ap = findXMLAtt(root, "focal_length");
    if (ap)
        focal_length = QString(valuXMLAtt(ap)).toDouble();
 
    ap = findXMLAtt(root, "aperture");
    if (ap)
        aperture = QString(valuXMLAtt(ap)).toDouble();
 
    el = findXMLEle(root, "driver");
 
    if (!el)
        return false;
 
    driver = pcdataXMLEle(el);
 
    ap = findXMLAtt(el, "name");
    if (!ap)
    {
        snprintf(errmsg, ERRMSG_SIZE, "Tag %.64s does not have a name attribute", tagXMLEle(el));
        return false;
    }
 
    name = valuXMLAtt(ap);
 
    el = findXMLEle(root, "version");
 
    if (!el)
        return false;
 
    version = pcdataXMLEle(el);
 
    QTreeWidgetItem *device = new QTreeWidgetItem(DGroup, lastDevice);
 
    device->setText(LOCAL_NAME_COLUMN, label);
    device->setIcon(LOCAL_STATUS_COLUMN, ui->stopPix);
    device->setText(LOCAL_VERSION_COLUMN, version);
    device->setText(LOCAL_PORT_COLUMN, port);
 
    lastDevice = device;
 
    if ((xmlSource == IDevice::PRIMARY_XML) && driversList.contains(driver) == false)
        driversList.insert(driver, name);
 
    dv            = new IDevice(name, label, driver, version);
    dv->type      = groupType;
    dv->xmlSource = xmlSource;
    //connect(dv, SIGNAL(newServerInput()), this, SLOT(updateLocalTab()));
    if (focal_length > 0)
        dv->focal_length = focal_length;
    if (aperture > 0)
        dv->aperture = aperture;
    dv->port = port;
 
    devices.append(dv);
 
    // SLOTS/SIGNAL, pop menu, indi server logic
    return true;
}
 
void INDIDriver::updateCustomDrivers()
{
    QString label;
    QString driver;
    QString version;
    QString name;
    IDevice *dv;
    QTreeWidgetItem *group, *widgetDev;
    double focal_length(-1), aperture(-1);
 
    // Find if the group already exists
    QList<QTreeWidgetItem *> treeList = ui->localTreeWidget->findItems("Telescopes", Qt::MatchExactly);
    if (!treeList.isEmpty())
        group = treeList[0];
    else
        return;
 
    // Find custom telescope to ADD
    foreach (OAL::Scope *s, *(KStarsData::Instance()->logObject()->scopeList()))
    {
        label = s->vendor() + ' ' + s->model();
 
        if (s->driver() == xi18n("None") || findDeviceByLabel(label))
            continue;
 
        QHash<QString, QString>::const_iterator i = driversList.constFind(s->driver());
        if (i != driversList.constEnd() && i.key() == s->driver())
            name = i.value();
        else
            return;
        focal_length = s->focalLength();
        aperture     = s->aperture();
        driver       = s->driver();
        version      = QString("1.0");
 
        QTreeWidgetItem *device = new QTreeWidgetItem(group, lastDevice);
        device->setText(LOCAL_NAME_COLUMN, QString(label));
        device->setIcon(LOCAL_STATUS_COLUMN, ui->stopPix);
        device->setText(LOCAL_VERSION_COLUMN, QString(version));
 
        lastDevice = device;
 
        dv               = new IDevice(name, label, driver, version);
        dv->type         = KSTARS_TELESCOPE;
        dv->xmlSource    = IDevice::EM_XML;
        dv->focal_length = focal_length;
        dv->aperture     = aperture;
        dv->id           = s->id();
        devices.append(dv);
    }
 
    // Find custom telescope to REMOVE
    foreach (IDevice *dev, devices)
    {
        // If it's from primary xml file or it is in a running state, continue.
        if (dev->xmlSource != IDevice::EM_XML || dev->state == IDevice::DEV_START)
            continue;
 
        // See if log object has the device, if not delete it
        if (KStarsData::Instance()->logObject()->findScopeById(dev->id))
            continue;
 
        // Find if the group already exists
        QList<QTreeWidgetItem *> devList =
            ui->localTreeWidget->findItems(dev->tree_label, Qt::MatchExactly | Qt::MatchRecursive);
        if (!devList.isEmpty())
        {
            widgetDev = devList[0];
            group->removeChild(widgetDev);
        }
        else
            return;
 
        devices.removeOne(dev);
        delete (dev);
    }
}
 
void INDIDriver::addINDIHost()
{
    QDialog hostConfDialog;
    Ui::INDIHostConf hostConf;
    hostConf.setupUi(&hostConfDialog);
    hostConfDialog.setWindowTitle(xi18n("Add Host"));
    bool portOk = false;
 
    if (hostConfDialog.exec() == QDialog::Accepted)
    {
        INDIHostsInfo *hostItem = new INDIHostsInfo;
        hostItem->name          = hostConf.nameIN->text();
        hostItem->hostname      = hostConf.hostname->text();
        hostItem->portnumber    = hostConf.portnumber->text();
        hostItem->isConnected   = false;
        hostItem->deviceManager = nullptr;
 
        hostItem->portnumber.toInt(&portOk);
 
        if (portOk == false)
        {
            KMessageBox::error(0, xi18n("Error: the port number is invalid."));
            delete hostItem;
            return;
        }
 
        //search for duplicates
        //for (uint i=0; i < ksw->data()->INDIHostsList.count(); i++)
        foreach (INDIHostsInfo *host, ksw->data()->INDIHostsList)
            if (hostItem->name == host->name && hostItem->portnumber == host->portnumber)
            {
                KMessageBox::error(0, xi18n("Host: %1 Port: %2 already exists.", hostItem->name, hostItem->portnumber));
                delete hostItem;
                return;
            }
 
        ksw->data()->INDIHostsList.append(hostItem);
 
        QTreeWidgetItem *item = new QTreeWidgetItem(ui->clientTreeWidget);
        item->setIcon(HOST_STATUS_COLUMN, ui->disconnected);
        item->setText(HOST_NAME_COLUMN, hostConf.nameIN->text());
        item->setText(HOST_PORT_COLUMN, hostConf.portnumber->text());
    }
 
    saveHosts();
}
 
void INDIDriver::modifyINDIHost()
{
    QDialog hostConfDialog;
    Ui::INDIHostConf hostConf;
    hostConf.setupUi(&hostConfDialog);
    hostConfDialog.setWindowTitle(xi18n("Modify Host"));
 
    QTreeWidgetItem *currentItem = ui->clientTreeWidget->currentItem();
 
    if (currentItem == nullptr)
        return;
 
    foreach (INDIHostsInfo *host, ksw->data()->INDIHostsList)
    {
        if (currentItem->text(HOST_NAME_COLUMN) == host->name &&
            currentItem->text(HOST_PORT_COLUMN) == host->portnumber)
        {
            hostConf.nameIN->setText(host->name);
            hostConf.hostname->setText(host->hostname);
            hostConf.portnumber->setText(host->portnumber);
 
            if (hostConfDialog.exec() == QDialog::Accepted)
            {
                //INDIHostsInfo *hostItem = new INDIHostsInfo;
                host->name       = hostConf.nameIN->text();
                host->hostname   = hostConf.hostname->text();
                host->portnumber = hostConf.portnumber->text();
 
                currentItem->setText(HOST_NAME_COLUMN, hostConf.nameIN->text());
                currentItem->setText(HOST_PORT_COLUMN, hostConf.portnumber->text());
 
                //ksw->data()->INDIHostsList.replace(i, hostItem);
 
                saveHosts();
                return;
            }
        }
    }
}
 
void INDIDriver::removeINDIHost()
{
    if (ui->clientTreeWidget->currentItem() == nullptr)
        return;
 
    for (int i = 0; i < ksw->data()->INDIHostsList.count(); i++)
    {
        if (ui->clientTreeWidget->currentItem()->text(HOST_NAME_COLUMN) == ksw->data()->INDIHostsList[i]->name &&
            ui->clientTreeWidget->currentItem()->text(HOST_PORT_COLUMN) == ksw->data()->INDIHostsList[i]->portnumber)
        {
            if (ksw->data()->INDIHostsList[i]->isConnected)
            {
                KMessageBox::error(0, xi18n("You need to disconnect the client before removing it."));
                return;
            }
 
            if (KMessageBox::warningContinueCancel(0,
                                                   xi18n("Are you sure you want to remove the %1 client?",
                                                         ui->clientTreeWidget->currentItem()->text(HOST_NAME_COLUMN)),
                                                   xi18n("Delete Confirmation"),
                                                   KStandardGuiItem::del()) != KMessageBox::Continue)
                return;
 
            delete ksw->data()->INDIHostsList.takeAt(i);
            delete (ui->clientTreeWidget->currentItem());
            break;
        }
    }
    saveHosts();
}
 
void INDIDriver::saveHosts()
{
    QFile file;
    QString hostData;
 
    //determine filename in local user KDE directory tree.
    file.setFileName(QDir(KSPaths::writableLocation(QStandardPaths::AppDataLocation)).filePath("indihosts.xml"));
 
    if (!file.open(QIODevice::WriteOnly))
    {
        QString message = xi18n(
            "Unable to write to file 'indihosts.xml'\nAny changes to INDI hosts configurations will not be saved.");
        KMessageBox::sorry(0, message, xi18n("Could Not Open File"));
        return;
    }
 
    QTextStream outstream(&file);
 
    //for (uint i= 0; i < ksw->data()->INDIHostsList.count(); i++)
    foreach (INDIHostsInfo *host, ksw->data()->INDIHostsList)
    {
        hostData = "<INDIHost name='";
        hostData += host->name;
        hostData += "' hostname='";
        hostData += host->hostname;
        hostData += "' port='";
        hostData += host->portnumber;
        hostData += "' />\n";
 
        outstream << hostData;
    }
 
    file.close();
}
 
IDevice *INDIDriver::findDeviceByLabel(const QString &label)
{
    foreach (IDevice *dev, devices)
    {
        if (dev->tree_label == label)
            return dev;
    }
    return nullptr;
}
 
INDIDriver::~INDIDriver()
{
    //for (uint i=0; i < devices.size(); i++)
    //delete (devices[i]);
    while (!devices.isEmpty())
        delete devices.takeFirst();
}
 
IDevice::IDevice(const QString &inName, const QString &inLabel, const QString &inDriver, const QString &inVersion)
{
    tree_label = inLabel;
    unique_label.clear();
    name    = inName;
    driver  = inDriver;
    version = inVersion;
 
    xmlSource = PRIMARY_XML;
 
    // Initially off
    state = IDevice::DEV_TERMINATE;
 
    // No port initially
    //indiPort = -1;
 
    // not yet managed by DeviceManager
    //managed = false;
 
    deviceManager = nullptr;
 
    focal_length = -1;
    aperture     = -1;
 
    //proc = nullptr;
}
 
IDevice::~IDevice()
{
}
 
void IDevice::clear()
{
    //managed = false;
    state         = IDevice::DEV_TERMINATE;
    deviceManager = nullptr;
 
    unique_label.clear();
}
 
QString IDevice::getServerBuffer()
{
    if (deviceManager != nullptr)
        return deviceManager->getServerBuffer();
 
    return QString();
}
 
#include "indidriver.moc"