interfaceServer.h

#ifndef _INTERFACESERVER_H_
#define _INTERFACESERVER_H_

#include "configure.h"
#include "debug.h"
#include "pagelist.h"
#include "packetmag.h"
#include "ttxpagestream.h"
#include "packet.h"
#include "packetDatacast.h"

#ifdef WIN32
#include <winsock2.h>
#else
#include <fcntl.h>
#include <sys/socket.h> /* for socket(), bind(), and connect() */
#include <sys/select.h> /* for fd_set() */
#include <arpa/inet.h>  /* for sockaddr_in and inet_ntoa() */
#include <unistd.h>     /* for close() */
#endif

/* interface server command numbers */
#define SETCHAN     0x00    /* set channel number for subsequent commands */
#define DBCASTAPI   0x01    /* databroadcast API command */
#define CONFIGAPI   0x02    /* vbit2 configuration API command */
#define PAGESAPI    0x03    /* page data API */
#define GETAPIVER   0x04    /* get API version number */

/* interface server response codes */
#define CMDOK       0x00    /* command successful */
#define CMDTRUNC    0xfc    /* command completed but data was truncated */
#define CMDNOENT    0xfd    /* command failed because entity doesn't exist */
#define CMDBUSY     0xfe    /* command failed because operation is blocked */
#define CMDERR      0xff    /* command failed */

/* command numbers for databroadcast API */
#define DCRAW       0x00    /* push raw packet data to datacast buffer */
#define DCFORMATA   0x01    /* push format A packet to datacast buffer */
#define DCFORMATB   0x02    /* placeholder - may never implement */

/* command numbers for vbit2 configuration API */
#define CONFRAFLAG  0x00    /* get/set row adaptive flag */
#define CONFRBYTES  0x01    /* get/set BSDP reserved bytes */
#define CONFSTATUS  0x02    /* get/set 20 byte BSDP status message */
#define CONFHEADER  0x03    /* get/set 32 byte header template */
#define CONFENHANC  0x04    /* Get/Set/Delete magazine enhancements */

/* command numbers for page data API */
#define PAGEDELETE  0x00    /* remove a page from the service */
#define PAGEOPEN    0x01    /* open a page for updating */
#define PAGESETSUB  0x02    /* select subpage */
#define PAGEDELSUB  0x03    /* delete subpage */
#define PAGECLOSE   0x04    /* close updated page */
#define PAGEFANDC   0x05    /* get/set page function and coding */
#define PAGEOPTNS   0x06    /* get/set subpage options */
#define PAGEROW     0x07    /* read/write/delete subpage row data */
#define PAGELINKS   0x08    /* get/set fastext link values */

namespace vbit

{
    class ClientState
    {
        public:
            int socket = -1;
            int channel = -1;
            std::shared_ptr<TTXPageStream> page = nullptr;
            std::shared_ptr<Subpage> subpage = nullptr;
    };
    class InterfaceServer
    {
        public:
            InterfaceServer(Configure *configure, Debug *debug, PageList *pageList);
            ~InterfaceServer();
            
            void run();
            bool GetIsActive(){return _isActive;}; /* is interface server in use? */
            
            
            PacketDatacast** GetDatachannels() { PacketDatacast **channels=_datachannel; return channels; };
            
        private:
            const uint8_t APIVERSION[3] = {1,0,0}; // Version number for interface API.
            
            Configure* _configure;
            Debug* _debug;
            PageList* _pageList;
            PacketDatacast* _datachannel[16]; /* array of datacast sources */
            
            static const uint16_t MAXPENDING=5;
            
            int _portNumber;
            int _serverSock;
            
            std::list<ClientState> _clients;
            uint16_t _maxClients;
            
            bool _isActive;
            
            void SocketError(std::string errorMessage); // handle fatal socket errors
            void CloseClient(ClientState *client); // clean up after a connected client
    };
}

#endif