simple_receiver.cpp

Go to the documentation of this file.

/*
   INDI Developers Manual
   Tutorial #3
 
   "Simple Receiver Driver"
 
   We develop a simple Receiver driver.
 
   Refer to README, which contains instruction on how to build this driver, and use it
   with an INDI-compatible client.
 
*/
 
#include "simple_receiver.h"
 
#include <memory>
 
/* Macro shortcut to Receiver temperature value */
#define currentReceiverTemperature TemperatureN[0].value
 
std::unique_ptr<SimpleReceiver> simpleReceiver(new SimpleReceiver());
 
/**************************************************************************************
** Client is asking us to establish connection to the device
***************************************************************************************/
bool SimpleReceiver::Connect()
{
    LOG_INFO("Simple Receiver connected successfully!");
 
    // Let's set a timer that checks teleReceivers status every POLLMS milliseconds.
    SetTimer(getCurrentPollingPeriod());
 
    return true;
}
 
/**************************************************************************************
** Client is asking us to terminate connection to the device
***************************************************************************************/
bool SimpleReceiver::Disconnect()
{
    LOG_INFO("Simple Receiver disconnected successfully!");
    return true;
}
 
/**************************************************************************************
** INDI is asking us for our default device name
***************************************************************************************/
const char *SimpleReceiver::getDefaultName()
{
    return "Simple Receiver";
}
 
/**************************************************************************************
** INDI is asking us to init our properties.
***************************************************************************************/
bool SimpleReceiver::initProperties()
{
    // Must init parent properties first!
    INDI::Receiver::initProperties();
 
    // We set the Receiver capabilities
    uint32_t cap = SENSOR_CAN_ABORT | SENSOR_HAS_COOLER | SENSOR_HAS_SHUTTER;
    SetCapability(cap);
 
    // Add Debug, Simulator, and Configuration controls
    addAuxControls();
 
    setDefaultPollingPeriod(500);
 
    return true;
}
 
/********************************************************************************************
** INDI is asking us to update the properties because there is a change in CONNECTION status
** This function is called whenever the device is connected or disconnected.
*********************************************************************************************/
bool SimpleReceiver::updateProperties()
{
    // Call parent update properties first
    INDI::Receiver::updateProperties();
 
    if (isConnected())
    {
        // Let's get parameters now from Receiver
        setupParams();
 
        // Start the timer
        SetTimer(getCurrentPollingPeriod());
    }
 
    return true;
}
 
/**************************************************************************************
** Client is updating capture settings
***************************************************************************************/
bool SimpleReceiver::paramsUpdated(float sr, float freq, float bps, float bw, float gain)
{
    INDI_UNUSED(bps);
    INDI_UNUSED(freq);
    INDI_UNUSED(sr);
    INDI_UNUSED(bw);
    INDI_UNUSED(gain);
    return true;
}
 
/**************************************************************************************
** Setting up Receiver parameters
***************************************************************************************/
void SimpleReceiver::setupParams()
{
    // Our Receiver is an 8 bit Receiver, 100MHz frequency 1MHz samplerate.
    setFrequency(1000000.0);
    setSampleRate(100000000.0);
    setBPS(16);
    setBandwidth(0.0);
    setGain(25.0);
}
 
/**************************************************************************************
** Client is asking us to start an exposure
***************************************************************************************/
bool SimpleReceiver::StartIntegration(double duration)
{
    IntegrationRequest = duration;
 
    // Since we have only have one Receiver with one chip, we set the exposure duration of the primary Receiver
    setIntegrationTime(duration);
 
    gettimeofday(&CapStart, nullptr);
 
    InIntegration = true;
 
    // We're done
    return true;
}
 
/**************************************************************************************
** Client is asking us to abort an exposure
***************************************************************************************/
bool SimpleReceiver::AbortIntegration()
{
    InIntegration = false;
    return true;
}
 
/**************************************************************************************
** Client is asking us to set a new temperature
***************************************************************************************/
int SimpleReceiver::SetTemperature(double temperature)
{
    TemperatureRequest = temperature;
 
    // 0 means it will take a while to change the temperature
    return 0;
}
 
/**************************************************************************************
** How much longer until exposure is done?
***************************************************************************************/
float SimpleReceiver::CalcTimeLeft()
{
    double timesince;
    double timeleft;
    struct timeval now
    {
        0, 0
    };
 
    gettimeofday(&now, nullptr);
 
    timesince = (double)(now.tv_sec * 1000.0 + now.tv_usec / 1000) -
                (double)(CapStart.tv_sec * 1000.0 + CapStart.tv_usec / 1000);
    timesince = timesince / 1000;
 
    timeleft = IntegrationRequest - timesince;
    return timeleft;
}
 
/**************************************************************************************
** Main device loop. We check for exposure and temperature progress here
***************************************************************************************/
void SimpleReceiver::TimerHit()
{
    long timeleft;
 
    if (!isConnected())
        return; //  No need to reset timer if we are not connected anymore
 
    if (InIntegration)
    {
        timeleft = CalcTimeLeft();
 
        // Less than a 0.1 second away from exposure completion
        // This is an over simplified timing method, check ReceiverSimulator and simpleReceiver for better timing checks
        if (timeleft < 0.1)
        {
            /* We're done exposing */
            LOG_INFO("Integration done, downloading image...");
 
            // Set exposure left to zero
            setIntegrationLeft(0);
 
            // We're no longer exposing...
            InIntegration = false;
 
            /* grab and save image */
            grabFrame();
        }
        else
            // Just update time left in client
            setIntegrationLeft(timeleft);
    }
 
    // TemperatureNP is defined in INDI::Receiver
    switch (TemperatureNP.s)
    {
        case IPS_IDLE:
        case IPS_OK:
            break;
 
        case IPS_BUSY:
            /* If target temperature is higher, then increase current Receiver temperature */
            if (currentReceiverTemperature < TemperatureRequest)
                currentReceiverTemperature++;
            /* If target temperature is lower, then decrease current Receiver temperature */
            else if (currentReceiverTemperature > TemperatureRequest)
                currentReceiverTemperature--;
            /* If they're equal, stop updating */
            else
            {
                TemperatureNP.s = IPS_OK;
                LOG_INFO("Target temperature reached.");
                IDSetNumber(&TemperatureNP, nullptr);
 
                break;
            }
 
            IDSetNumber(&TemperatureNP, nullptr);
 
            break;
 
        case IPS_ALERT:
            break;
    }
 
    SetTimer(getCurrentPollingPeriod());
}
 
/**************************************************************************************
** Create a random image and return it to client
***************************************************************************************/
void SimpleReceiver::grabFrame()
{
    // Set length of continuum
    int len  = getSampleRate() * getIntegrationTime() * getBPS() / 8;
    setBufferSize(len);
 
    // Let's get a pointer to the frame buffer
    uint8_t *continuum = getBuffer();
 
    // Fill buffer with random pattern
    for (int i = 0; i < len; i++)
        continuum[i] = rand() % 255;
 
    LOG_INFO("Download complete.");
 
    // Let INDI::Receiver know we're done filling the image buffer
    IntegrationComplete();
}