plugins/websocket/websocketsinkmanager.h

   1 /*
   2         Copyright (C) 2012  Intel Corporation
   3
   4         This library is free software; you can redistribute it and/or
   5         modify it under the terms of the GNU Lesser General Public
   6         License as published by the Free Software Foundation; either
   7         version 2.1 of the License, or (at your option) any later version.
   8
   9         This library is distributed in the hope that it will be useful,
  10         but WITHOUT ANY WARRANTY; without even the implied warranty of
  11         MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  12         Lesser General Public License for more details.
  13
  14         You should have received a copy of the GNU Lesser General Public
  15         License along with this library; if not, write to the Free Software
  16         Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
  17 */
  18
  19 #ifndef WEBSOCKETSINKMANAGER_H
  20 #define WEBSOCKETSINKMANAGER_H
  21
  22 #include <abstractroutingengine.h>
  23 #include <abstractsink.h>
  24 #include "websocketsink.h"
  25 #include <gio/gio.h>
  26 #include <map>
  27 #include <libwebsockets.h>
  28 #include "debugout.h"
  29 #include <stdexcept>
  30 #include "sys/types.h"
  31 #include <stdlib.h>
  32 #include <QByteArray>
  33
  34 class WebSocketSinkManager
  35 {
  36 public:
  37         WebSocketSinkManager(AbstractRoutingEngine* engine, map<string, string> config);
  38         void addSingleShotSink(libwebsocket* socket, VehicleProperty::Property property, Zone::Type zone, string id);
  39         void addSingleShotRangedSink(libwebsocket* socket, PropertyList properties,double start, double end, double seqstart,double seqend, string id);
  40         void addSink(libwebsocket* socket, VehicleProperty::Property property, string uuid);
  41         void disconnectAll(libwebsocket* socket);
  42         void removeSink(libwebsocket* socket, VehicleProperty::Property property, string uuid);
  43         void addPoll(int fd);
  44         void removePoll(int fd);
  45         void init();
  46         std::map<std::string, list<WebSocketSink*> > m_sinkMap;
  47         void setConfiguration(map<string, string> config);
  48         void setValue(libwebsocket* socket,VehicleProperty::Property property,string value, Zone::Type zone, string uuid);
  49         PropertyList getSupportedProperties();
  50
  51         AbstractRoutingEngine * router() { return routingEngine; }
  52
  53         int partialMessageIndex;
  54         QByteArray incompleteMessage;
  55         int expectedMessageFrames;
  56
  57 private:
  58         std::map<int, GIOChannel*> m_ioChannelMap;
  59         std::map<int, guint> m_ioSourceMap;
  60         AbstractRoutingEngine *m_engine;
  61         struct libwebsocket_protocols protocollist[2];
  62
  63         AbstractRoutingEngine * routingEngine;
  64         std::map<std::string, std::string> configuration;
  65
  66 };
  67
  68 #endif // WEBSOCKETSINKMANAGER_H