websockets.h

/*
Copyright (C) 2012 Intel Corporation

This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2.1 of the License, or (at your option) any later version.

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
Lesser General Public License for more details.

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

#ifndef _WEBSOCKETS_H_
#define _WEBSOCKETS_H_

#include <map>
#include <memory>
#include <libwebsockets.h>
#include <boost/interprocess/sync/interprocess_recursive_mutex.hpp>
#include <boost/interprocess/sync/scoped_lock.hpp>
#include "abstractpropertytype.h"

using namespace boost::interprocess;

class WebSocketsObserver{
public:
    virtual ~WebSocketsObserver() { } /*LCOV_EXCL_LINE*/

    virtual void dataReceived(lws* socket, const char* data, size_t len) = 0;
};

class WebSockets {
public:
    enum Type {
        Server,
        Client
    };

    WebSockets(WebSocketsObserver& observer, Type t=Server, int port = 23001, std::string ip="");

    WebSockets(const WebSockets&) = delete;
    WebSockets& operator=(const WebSockets&) = delete;
    WebSockets(WebSockets&&) = delete;
    WebSockets& operator=(WebSockets&&) = delete;

    ~WebSockets();

    static int Write(lws *lws, const std::string& strToWrite);

    void addPoll(int fd);

    void removePoll(int fd);

    inline WebSocketsObserver& getObserver() { return observer; }

    inline lws_context* getContext() { return context.get(); }

private:

    WebSocketsObserver& observer;


    struct lws_protocols protocollist[2];

    typedef std::unique_ptr<lws_context, decltype(&lws_context_destroy)> lwsContextPtr;

    lwsContextPtr context;

    std::map<int,GIOChannel*> m_ioChannelMap;

    std::map<int,guint> m_ioSourceMap;

    interprocess_recursive_mutex mutex;
};

#endif // _WEBSOCKETS_H_