baseclient.h

/*******************************************************************************
  Copyright(c) 2011 Jasem Mutlaq. All rights reserved.

 This library is free software; you can redistribute it and/or
 modify it under the terms of the GNU Library General Public
 License version 2 as published by the Free Software Foundation.

 This library 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
 Library General Public License for more details.

 You should have received a copy of the GNU Library General Public License
 along with this library; see the file COPYING.LIB.  If not, write to
 the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
 Boston, MA 02110-1301, USA.
*******************************************************************************/

#ifndef INDIBASECLIENT_H
#define INDIBASECLIENT_H

#include <vector>
#include <map>
#include <string>

#include <pthread.h>

#include "indiapi.h"
#include "indidevapi.h"
#include "indibase.h"

#define MAXRBUF 2048

using namespace std;



class INDI::BaseClient : public INDI::BaseMediator
{
public:
    enum { INDI_DEVICE_NOT_FOUND=-1, INDI_PROPERTY_INVALID=-2, INDI_PROPERTY_DUPLICATED = -3, INDI_DISPATCH_ERROR=-4 };
    //typedef boost::shared_ptr<INDI::BaseDevice> devicePtr;

    BaseClient();
    virtual ~BaseClient();

    void setServer(const char * hostname, unsigned int port);

    void watchDevice(const char * deviceName);


    bool connectServer();

    bool disconnectServer();

    void connectDevice(const char *deviceName);

    void disconnectDevice(const char *deviceName);

    INDI::BaseDevice * getDevice(const char * deviceName);

    const vector<INDI::BaseDevice *> & getDevices() const { return cDevices; }

    void setBLOBMode(BLOBHandling blobH, const char *dev, const char *prop = NULL);

    // Update
    static void * listenHelper(void *context);

    const char * getHost() { return cServer.c_str();}
    int getPort() { return cPort; }

    void sendNewText (ITextVectorProperty *pp);
    void sendNewText (const char * deviceName, const char * propertyName, const char* elementName, const char *text);
    void sendNewNumber (INumberVectorProperty *pp);
    void sendNewNumber (const char * deviceName, const char *propertyName, const char* elementName, double value);
    void sendNewSwitch (ISwitchVectorProperty *pp);
    void sendNewSwitch (const char * deviceName, const char *propertyName, const char *elementName);

    void startBlob( const char *devName, const char *propName, const char *timestamp);
    void sendOneBlob( const char *blobName, unsigned int blobSize, const char *blobFormat, void * blobBuffer);
    void finishBlob();

    void setVerbose(bool enable) { verbose = enable; }

    bool isVerbose() const { return verbose; }

    void setConnectionTimeout(uint32_t seconds, uint32_t microseconds) { timeout_sec = seconds; timeout_us = microseconds;}

protected:

    int dispatchCommand(XMLEle *root, char* errmsg);

    int deleteDevice( const char * devName, char * errmsg );

    int delPropertyCmd (XMLEle *root, char * errmsg);

    INDI::BaseDevice * findDev( const char * devName, char * errmsg);
    INDI::BaseDevice * addDevice (XMLEle *dep, char * errmsg);
    INDI::BaseDevice * findDev (XMLEle *root, int create, char * errmsg);

    int messageCmd (XMLEle *root, char * errmsg);


private:

    void setDriverConnection(bool status, const char *deviceName);

    // Listen to INDI server and process incoming messages
    void listenINDI();

    // Thread for listenINDI()
    pthread_t listen_thread;

    vector<INDI::BaseDevice *> cDevices;
    vector<string> cDeviceNames;

    string cServer;
    unsigned int cPort;
    bool sConnected;
    bool verbose;

    // Parse & FILE buffers for IO
    int sockfd;
    LilXML *lillp;                      /* XML parser context */
    FILE *svrwfp;                       /* FILE * to talk to server */

    int m_receiveFd;
    int m_sendFd;

    uint32_t timeout_sec, timeout_us;

};

#endif // INDIBASECLIENT_H