c@78: 
c@78: #include <vamp-hostsdk/Plugin.h>
c@78: #include <vamp-hostsdk/PluginLoader.h>
c@78: #include <vamp-hostsdk/PluginStaticData.h>
c@78: #include <vamp-hostsdk/PluginConfiguration.h>
c@78: 
c@78: #include <cstdint>
c@78: 
c@78: namespace piper { //!!! should be something else
c@78: 
c@80: class PiperStubPlugin;
c@78: 
c@78: class PiperClientBase
c@78: {
c@78: public:
c@78:     virtual
c@78:     Vamp::Plugin::OutputList
c@80:     configure(PiperStubPlugin *plugin,
c@78:               Vamp::HostExt::PluginConfiguration config) = 0;
c@78:     
c@78:     virtual
c@78:     Vamp::Plugin::FeatureSet
c@80:     process(PiperStubPlugin *plugin,
c@78:             const float *const *inputBuffers,
c@78:             Vamp::RealTime timestamp) = 0;
c@78: 
c@78:     virtual Vamp::Plugin::FeatureSet
c@80:     finish(PiperStubPlugin *plugin) = 0;
c@78: };
c@78: 
c@78: class PiperStubPlugin : public Vamp::Plugin
c@78: {
c@78:     enum State {
c@78:         Loaded, Configured, Finished
c@78:     };
c@78:     
c@78: public:
c@78:     PiperStubPlugin(PiperClientBase *client,
c@78:                     float inputSampleRate,
c@78:                     Vamp::HostExt::PluginStaticData psd,
c@78:                     Vamp::HostExt::PluginConfiguration defaultConfig) :
c@78:         Plugin(inputSampleRate),
c@78:         m_client(client),
c@78:         m_state(Loaded),
c@78:         m_psd(psd),
c@78:         m_defaultConfig(defaultConfig),
c@78:         m_config(defaultConfig)
c@78:     { }
c@78: 
c@78:     virtual ~PiperStubPlugin() {
c@78:         if (m_state != Finished) {
c@80:             std::cerr << "WARNING: PiperStubPlugin destroyed without finish() call, may be a server-side resource leak" << std::endl;
c@78:         }
c@78:     }
c@78: 
c@78:     virtual std::string getIdentifier() const {
c@78:         return m_psd.basic.identifier;
c@78:     }
c@78: 
c@78:     virtual std::string getName() const {
c@78:         return m_psd.basic.name;
c@78:     }
c@78: 
c@78:     virtual std::string getDescription() const {
c@78:         return m_psd.basic.description;
c@78:     }
c@78: 
c@78:     virtual std::string getMaker() const {
c@78:         return m_psd.maker;
c@78:     }
c@78: 
c@78:     virtual std::string getCopyright() const {
c@78:         return m_psd.copyright;
c@78:     }
c@78: 
c@78:     virtual int getPluginVersion() const {
c@78:         return m_psd.pluginVersion;
c@78:     }
c@78: 
c@78:     virtual ParameterList getParameterDescriptors() const {
c@78:         return m_psd.parameters;
c@78:     }
c@78: 
c@78:     virtual float getParameter(std::string name) const {
c@78:         if (m_config.parameterValues.find(name) != m_config.parameterValues.end()) {
c@78:             return m_config.parameterValues.at(name);
c@78:         } else {
c@78:             return 0.f;
c@78:         }
c@78:     }
c@78: 
c@78:     virtual void setParameter(std::string name, float value) {
c@78:         if (m_state != Loaded) {
c@78:             throw std::logic_error("Can't set parameter after plugin initialised");
c@78:         }
c@78:         m_config.parameterValues[name] = value;
c@78:     }
c@78: 
c@78:     virtual ProgramList getPrograms() const {
c@78:         return m_psd.programs;
c@78:     }
c@78: 
c@78:     virtual std::string getCurrentProgram() const {
c@78:         return m_config.currentProgram;
c@78:     }
c@78:     
c@78:     virtual void selectProgram(std::string program) {
c@78:         if (m_state != Loaded) {
c@78:             throw std::logic_error("Can't select program after plugin initialised");
c@78:         }
c@78:         m_config.currentProgram = program;
c@78:     }
c@78: 
c@78:     virtual bool initialise(size_t inputChannels,
c@78:                             size_t stepSize,
c@78:                             size_t blockSize) {
c@78: 
c@78:         if (m_state != Loaded) {
c@78:             throw std::logic_error("Plugin has already been initialised");
c@78:         }
c@78:         
c@78:         m_config.channelCount = inputChannels;
c@78:         m_config.stepSize = stepSize;
c@78:         m_config.blockSize = blockSize;
c@78: 
c@80:         m_outputs = m_client->configure(this, m_config);
c@78: 
c@78:         if (!m_outputs.empty()) {
c@78:             m_state = Configured;
c@78:             return true;
c@78:         } else {
c@78:             return false;
c@78:         }
c@78:     }
c@78: 
c@78:     virtual void reset() {
c@78:         //!!! hm, how to deal with this? there is no reset() in Piper!
c@78:         throw "Please do not call this function again.";
c@78:     }
c@78: 
c@78:     virtual InputDomain getInputDomain() const {
c@78:         return m_psd.inputDomain;
c@78:     }
c@78: 
c@78:     virtual size_t getPreferredBlockSize() const {
c@78:         return m_defaultConfig.blockSize;
c@78:     }
c@78: 
c@78:     virtual size_t getPreferredStepSize() const {
c@78:         return m_defaultConfig.stepSize;
c@78:     }
c@78: 
c@78:     virtual size_t getMinChannelCount() const {
c@78:         return m_psd.minChannelCount;
c@78:     }
c@78: 
c@78:     virtual size_t getMaxChannelCount() const {
c@78:         return m_psd.maxChannelCount;
c@78:     }
c@78: 
c@78:     virtual OutputList getOutputDescriptors() const {
c@78:         if (m_state == Configured) {
c@78:             return m_outputs;
c@78:         }
c@78: 
c@78:         //!!! todo: figure out for which hosts (and adapters?) it may
c@78:         //!!! be a problem that the output descriptors are incomplete
c@78:         //!!! here. Any such hosts/adapters are broken, but I bet they
c@78:         //!!! exist
c@78:         
c@78:         OutputList staticOutputs;
c@78:         for (const auto &o: m_psd.basicOutputInfo) {
c@78:             OutputDescriptor od;
c@78:             od.identifier = o.identifier;
c@78:             od.name = o.name;
c@78:             od.description = o.description;
c@78:             staticOutputs.push_back(od);
c@78:         }
c@78:         return staticOutputs;
c@78:     }
c@78: 
c@78:     virtual FeatureSet process(const float *const *inputBuffers,
c@78: 			       Vamp::RealTime timestamp) {
c@78: 
c@78:         if (m_state == Loaded) {
c@78:             throw std::logic_error("Plugin has not been initialised");
c@78:         }
c@78:         if (m_state == Finished) {
c@78:             throw std::logic_error("Plugin has already been disposed of");
c@78:         }
c@78: 
c@80:         return m_client->process(this, inputBuffers, timestamp);
c@78:     }
c@78: 
c@78:     virtual FeatureSet getRemainingFeatures() {
c@78: 
c@78:         if (m_state == Loaded) {
c@78:             throw std::logic_error("Plugin has not been configured");
c@78:         }
c@78:         if (m_state == Finished) {
c@78:             throw std::logic_error("Plugin has already been disposed of");
c@78:         }
c@78: 
c@78:         m_state = Finished;
c@78: 
c@80:         return m_client->finish(this);
c@78:     }
c@78:     
c@78: private:
c@78:     PiperClientBase *m_client;
c@78:     State m_state;
c@78:     Vamp::HostExt::PluginStaticData m_psd;
c@78:     OutputList m_outputs;
c@78:     Vamp::HostExt::PluginConfiguration m_defaultConfig;
c@78:     Vamp::HostExt::PluginConfiguration m_config;
c@78: };
c@78: 
c@78: 
c@78: }
c@78: