Excalibur.cpp

Go to the documentation of this file.

 
#include "Excalibur.h"
 
#include "indicom.h"
#include "connectionplugins/connectionserial.h"
 
#include <cerrno>
#include <cstring>
#include <memory>
#include <termios.h>
#include <unistd.h>
#include <inttypes.h>
#include <sys/ioctl.h>
#include <math.h>
#define CLOSE_CMD "S1#"
#define OPEN_CMD "S0#"
 
static std::unique_ptr<Excalibur> flatmaster(new Excalibur());
 
 
Excalibur::Excalibur() : LightBoxInterface(this, true)
{
    setVersion(1, 0);
}
 
bool Excalibur::initProperties()
{
    INDI::DefaultDevice::initProperties();
 
    IUFillText(&StatusT[0], "Cover", "Cover", nullptr);
    IUFillText(&StatusT[1], "Light", "Light", nullptr);
    IUFillTextVector(&StatusTP, StatusT, 2, getDeviceName(), "Status", "Status", MAIN_CONTROL_TAB, IP_RO, 60, IPS_IDLE);
 
    initDustCapProperties(getDeviceName(), MAIN_CONTROL_TAB);
    initLightBoxProperties(getDeviceName(), MAIN_CONTROL_TAB);
 
    setDriverInterface(AUX_INTERFACE | LIGHTBOX_INTERFACE | DUSTCAP_INTERFACE);
 
    LightIntensityN[0].min  = 0;
    LightIntensityN[0].max  = 3000;
    LightIntensityN[0].step = 1;
 
    addAuxControls();
 
    serialConnection = new Connection::Serial(this);
    serialConnection->setDefaultBaudRate(Connection::Serial::B_9600);
    serialConnection->registerHandshake([&]()
    {
        return Ack();
    });
 
 
    registerConnection(serialConnection);
    return true;
}
 
 
bool Excalibur::updateProperties()
{
    INDI::DefaultDevice::updateProperties();
 
    if (isConnected())
    {
        defineProperty(&ParkCapSP);
        defineProperty(&LightSP);
        defineProperty(&LightIntensityNP);
        defineProperty(&StatusTP);
 
    }
    else
    {
        deleteProperty(ParkCapSP.name);
        deleteProperty(LightSP.name);
        deleteProperty(LightIntensityNP.name);
        deleteProperty(StatusTP.name);
 
    }
 
    updateLightBoxProperties();
    return true;
}
 
const char *Excalibur::getDefaultName()
{
    return "RBF Excalibur";
}
 
 
 
bool Excalibur::Ack()
{
    PortFD = serialConnection->getPortFD();
 
    char response[16] = {0};
    if(sendCommand("#", response))
    {
        if(strstr("FLAT.FLAP!#", response) != nullptr)
        {
            LightS[1].s = ISS_ON;
            LightS[0].s = ISS_OFF;
            IDSetSwitch(&LightSP, nullptr);
            deviceStatus();
            return true;
 
        }
    }
    else
    {
        LOG_ERROR("Ack failed.");
        return false;
    }
 
    return false;
}
 
bool Excalibur::EnableLightBox(bool enable)
{
    char response[20]= {0};
    char cmd[16] = {0};
    if (!enable){
        snprintf(cmd, 16, "L%d##", 0);
 
                sendCommand(cmd,response);
                IUSaveText(&StatusT[1], "Off");
                IDSetText(&StatusTP, nullptr);
                return true;
 
 
 
    }
    else
    {
 
        snprintf(cmd, 16, "L%d##", (int)LightIntensityN[0].value);
 
                sendCommand(cmd,response);
                IUSaveText(&StatusT[1], "On");
                IDSetText(&StatusTP, nullptr);
                return true;
 
 
    }
 
 
    return false;
}
 
bool Excalibur::SetLightBoxBrightness(uint16_t value)
{
    if(LightS[FLAT_LIGHT_ON].s != ISS_ON)
    {
        LOG_ERROR("You must set On the Flat Light first.");
        return false;
    }
    if( ParkCapS[0].s != ISS_ON)
    {
        LOG_ERROR("You must Park eXcalibur first.");
        return false;
    }
 
    //char response[20] = {0};
     char cmd[DRIVER_RES] = {0};
 
     snprintf(cmd, 30, "L%d##", value);
     sendCommand(cmd);
      return  true;
 
 
 
}
IPState Excalibur::ParkCap()
{
 
    sendCommand("S1#");
 
 
    //IUSaveText(&StatusT[0], "Closed");
     //IUSaveText(&StatusT[1], "On");
    IUResetSwitch(&ParkCapSP);
    ParkCapS[0].s = ISS_ON;
    ParkCapSP.s = IPS_OK;
    LOG_INFO("Cover closed.");
    IDSetSwitch(&ParkCapSP, nullptr);
    IDSetText(&StatusTP, nullptr);
    return IPS_OK;
}
 
IPState Excalibur::UnParkCap()
{
 
    sendCommand("S0#");
 
    // Set cover status to random value outside of range to force it to refresh
    //IUSaveText(&StatusT[0], "Open");
    IUSaveText(&StatusT[1], "Off");
    IUResetSwitch(&ParkCapSP);
    ParkCapS[1].s = ISS_ON;
    ParkCapSP.s = IPS_OK;
    LOG_INFO("Cover open.");
    IDSetSwitch(&ParkCapSP, nullptr);
    IDSetText(&StatusTP, nullptr);
    return IPS_OK;
}
void Excalibur::TimerHit()
{
    if (!isConnected())
        return;
 
    deviceStatus();
 
    // parking or unparking timed out, try again
    if (ParkCapSP.s == IPS_BUSY && !strcmp(StatusT[0].text, "Timed out"))
    {
        if (ParkCapS[0].s == ISS_ON)
            ParkCap();
        else
            UnParkCap();
    }
 
    SetTimer(getCurrentPollingPeriod());
}
 
bool Excalibur::ISNewNumber(const char *dev, const char *name, double values[], char *names[], int n)
{
    if (processLightBoxNumber(dev, name, values, names, n))
        return true;
 
    return INDI::DefaultDevice::ISNewNumber(dev, name, values, names, n);
}
 
bool Excalibur::ISNewText(const char *dev, const char *name, char *texts[], char *names[], int n)
{
    if (dev != nullptr && strcmp(dev, getDeviceName()) == 0)
    {
        if (processLightBoxText(dev, name, texts, names, n))
            return true;
    }
 
    return INDI::DefaultDevice::ISNewText(dev, name, texts, names, n);
}
 
bool Excalibur::ISNewSwitch(const char *dev, const char *name, ISState *states, char *names[], int n)
{
    if (dev != nullptr && strcmp(dev, getDeviceName()) == 0)
    {
        if (processDustCapSwitch(dev, name, states, names, n))
            return true;
        if (processLightBoxSwitch(dev, name, states, names, n))
            return true;
    }
 
    return INDI::DefaultDevice::ISNewSwitch(dev, name, states, names, n);
}
 
bool Excalibur::ISSnoopDevice(XMLEle *root)
{
    snoopLightBox(root);
 
    return INDI::DefaultDevice::ISSnoopDevice(root);
}
 
bool Excalibur::saveConfigItems(FILE *fp)
{
    INDI::DefaultDevice::saveConfigItems(fp);
 
    return saveLightBoxConfigItems(fp);
}
 
bool Excalibur::sendCommand(const char *command, char *res)
{
    int nbytes_written = 0, nbytes_read = 0, rc = -1;
    char errstr[MAXRBUF];
 
    char cmd[20] = {0};
    snprintf(cmd, 20, "%s", command);
 
    LOGF_DEBUG("CMD <%#02X>", cmd[0]);
 
    tcflush(PortFD, TCIOFLUSH);
 
    if ((rc = tty_write_string(PortFD, cmd, &nbytes_written)) != TTY_OK)
    {
        char errstr[MAXRBUF] = {0};
        tty_error_msg(rc, errstr, MAXRBUF);
        LOGF_ERROR("Serial write error: %s.", errstr);
        return false;
    }
    if (res == nullptr)
        return true;
 
    if ((rc = tty_read_section(PortFD, res, DRIVER_DEL, 5, &nbytes_read)) != TTY_OK)
    {
        tty_error_msg(rc, errstr, MAXRBUF);
        LOGF_ERROR("command: %s error: %s.", cmd, errstr);
        return  false;
    }
 
    // Remove the #
    res[nbytes_read - 1] = 0;
 
    LOGF_DEBUG("RES <%s>", res);
 
    tcflush(PortFD, TCIOFLUSH);
 
    return true;
}
void Excalibur::deviceStatus()
{
    char res[DRIVER_RES] = {0};
 
    sendCommand("O#", res);
 
    int32_t pos;
    int rc = sscanf(res, "%d#", &pos);
 
    if (rc > 0)
    {
       LightIntensityN[0].value = pos;
       IDSetNumber(&LightIntensityNP, nullptr);
    }
    if(LightIntensityN[0].value>0)
    {
        IUSaveText(&StatusT[1], "On");
        if (LightS[1].s == ISS_ON)
        {
            LightS[0].s = ISS_ON;
            LightS[1].s = ISS_OFF;
            IDSetSwitch(&LightSP, nullptr);
        }
 
    }
    else
    {
        IUSaveText(&StatusT[1], "Off");
 
    }
 
 
    sendCommand("P#", res);
 
    int32_t pos2;
    sscanf(res, "%d#", &pos2);
 
 
    if(pos2<=0){
    IUSaveText(&StatusT[0], "Closed");
    if ( ParkCapS[0].s == ISS_OFF)
        {
            ParkCapS[0].s = ISS_ON;
            IDSetSwitch(&LightSP, nullptr);
        }
    }
    else
    {
        IUSaveText(&StatusT[0], "Open");
        if ( ParkCapS[1].s == ISS_OFF)
            {
                ParkCapS[1].s = ISS_ON;
                 IUSaveText(&StatusT[1], "Off");
                IDSetSwitch(&LightSP, nullptr);
            }
 
    }
    IDSetText(&StatusTP, nullptr);
 
}