VSReceiver.h

Go to the documentation of this file.

/*
 * Copyright 2014 Martin Hansen
 *
 * This file is part of SPAOP (Spatial Audio Object Positioner).
 * 
 * SPAOP is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 * 
 * SPAOP 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 General Public License for more details.
 * 
 * You should have received a copy of the GNU General Public License
 * along with SPAOP.  If not, see <http://www.gnu.org/licenses/>.
 */

#ifndef VSRECEIVER_H_INCLUDED
#define VSRECEIVER_H_INCLUDED

#include <iostream>
#include <list>
#include <memory>

#include "VisualStreamReceiver.h"
#include "WonderOscServerSender.h"
#include "WonderOscServerSenderThread.h"
#include "ServerThread.h"
#include "GenericServerThreadListener.h"

namespace wonderlo {

class VSReceiver    :   public lowrappers::ServerThread,
                        public wonder::VisualStreamReceiver
{
    
public:
    
    static wonder::VisualStreamReceiver::Factory* getFactory();
    
    VSReceiver(lo_err_handler err_h);
    
    VSReceiver(const std::string &port, lo_err_handler err_h);
    
    VSReceiver(const std::string& group, const std::string &port,
               const std::string& ifaceIp, lo_err_handler err_h);
    
    virtual ~VSReceiver();
    
    wonder::OscSender* createSender(const std::string &host, const std::string &port);
    
    wonder::OscSenderThread* createSenderThread(const std::string &host,
                                                const std::string &port);
    
    void setListener(VisualStreamReceiver::Listener* listener);
    
    void setPingHandler(PingHandler* pingHandler);
    
    void start();
    
    void stop();
    
    void join();
    
    int port();
    
private:
    VSReceiver(const VSReceiver& other);                // copying not allowed
    VSReceiver &operator= (const VSReceiver other);     // assignment not allowed

    
    VisualStreamReceiver::Listener* listener_;
    VisualStreamReceiver::PingHandler* pingHandler_;
    std::list<std::unique_ptr<lowrappers::ServerThread::Listener>> functorList_; // avoids memory leaks
    
    class Factory   :   public wonder::VisualStreamReceiver::Factory
    {
        wonder::VisualStreamReceiver* createVisualStreamReceiver();
        
        wonder::VisualStreamReceiver* createVisualStreamReceiver(const std::string& port);
        
        wonder::VisualStreamReceiver* createVisualStreamMulticastReceiver(const std::string& group,
                                                                          const std::string& port,
                                                                          const std::string& iface);
    };
    
    void addMethods();
    
    void addListenerAndStoreFunctor(const char* path, const char* types,
                                    lowrappers::ServerThread::Listener* listener);
    
    //==============================================================================
    // Wrapper-Methods for wonder::VisualStreamReceiver::Listener:
    
    int onSourceActivateI(const char *path, const char *types,lo_arg **argv,
                                  int argc, lo_message msg);
    
    int onSourceDeactivateI(const char *path, const char *types,lo_arg **argv,
                                    int argc, lo_message msg);
    
    int onSourcePositionIff(const char *path, const char *types,lo_arg **argv,
                                    int argc, lo_message msg);
    
    int onSourceAngleIf(const char *path, const char *types,lo_arg **argv,
                                int argc, lo_message msg);
    
    int onSourceTypeIi(const char *path, const char *types,lo_arg **argv,
                               int argc, lo_message msg);
    
    int onSourceNameIs(const char *path, const char *types,lo_arg **argv,
                               int argc, lo_message msg);
    
    int onSourceColorIiii(const char *path, const char *types,lo_arg **argv,
                                  int argc, lo_message msg);
    
    int onSourceGroupIdIi(const char *path, const char *types,lo_arg **argv,
                                  int argc, lo_message msg);
    
    int onSourceRotatingDirectionIi(const char *path, const char *types,lo_arg **argv,
                                            int argc, lo_message msg);
    
    int onSourceScalingDirectionIi(const char *path, const char *types,lo_arg **argv,
                                           int argc, lo_message msg);
    
    int onSourceDopplerEffectIi(const char *path, const char *types,lo_arg **argv,
                                        int argc, lo_message msg);
    
    int onListenerPositionIff(const char *path, const char *types,lo_arg **argv,
                                int argc, lo_message msg);
    
    int onGlobalMaxNoSourcesI(const char *path, const char *types,lo_arg **argv,
                                      int argc, lo_message msg);
    
    int onGlobalRenderpolygonSiVarFs(const char *path, const char *types,lo_arg **argv,
                                           int argc, lo_message msg);
    
    int onProjectXmlDumpIs(const char *path, const char *types,lo_arg **argv,
                                   int argc, lo_message msg);
    
    int onStreamVisualPongI(const char *path, const char *types,lo_arg **argv,
                            int argc, lo_message msg);
    
    int onStreamVisualConnect(const char *path, const char *types,lo_arg **argv,
                            int argc, lo_message msg);
    
    int onStreamVisualDisconnect(const char *path, const char *types,lo_arg **argv,
                            int argc, lo_message msg);
    
    int onReplySis(const char *path, const char *types,lo_arg **argv,
                           int argc, lo_message msg);
    
    int onPluginStandaloneI(const char *path, const char *types,lo_arg **argv,
                            int argc, lo_message msg);
    
    //==============================================================================
    // Wrapper-Methods for wonder::VisualStreamReceiver::PingHandler:
    
    int onStreamVisualPingI(const char *path, const char *types,lo_arg **argv,
                            int argc, lo_message msg);
};

}


#endif  // VSRECEIVER_H_INCLUDED