MemaProcessor.cpp

Go to the documentation of this file.

/* Copyright (c) 2024, Christian Ahrens
 *
 * This file is part of Mema <https://github.com/ChristianAhrens/Mema>
 *
 * This tool is free software; you can redistribute it and/or modify it under
 * the terms of the GNU Lesser General Public License version 3.0 as published
 * by the Free Software Foundation.
 *
 * This tool 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 tool; if not, write to the Free Software Foundation, Inc.,
 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 */
 
#include "MemaProcessor.h"
 
#include "InterprocessConnection.h"
#include "MemaCommanders.h"
#include "MemaServiceData.h"
#include "../MemaAppConfiguration.h"
 
#include <CustomLookAndFeel.h>
 
namespace Mema
{
 
 
//==============================================================================
class MemaNetworkClientCommanderWrapper : public MemaInputCommander, public MemaOutputCommander, public MemaCrosspointCommander, public MemaPluginCommander
{
public:
    void setInputMute(std::uint16_t channel, bool muteState, int userId) override
    {
        if (m_networkServer && m_networkServer->hasActiveConnections())
        {
            std::map<std::uint16_t, bool> inputMuteStates;
            std::map<std::uint16_t, bool> outputMuteStates;
            std::map<std::uint16_t, std::map<std::uint16_t, bool>> crosspointStates;
            std::map<std::uint16_t, std::map<std::uint16_t, float>> crosspointValues;
 
            inputMuteStates[channel] = muteState;
 
            auto sendIds = m_networkServer->getActiveConnectionIds();
            sendIds.erase(std::remove(sendIds.begin(), sendIds.end(), userId), sendIds.end());
            m_networkServer->enqueueMessage(std::make_unique<ControlParametersMessage>(inputMuteStates, outputMuteStates, crosspointStates, crosspointValues)->getSerializedMessage(), sendIds);
        }
    };
 
    void setOutputMute(std::uint16_t channel, bool muteState, int userId) override
    {
        if (m_networkServer && m_networkServer->hasActiveConnections())
        {
            std::map<std::uint16_t, bool> inputMuteStates;
            std::map<std::uint16_t, bool> outputMuteStates;
            std::map<std::uint16_t, std::map<std::uint16_t, bool>> crosspointStates;
            std::map<std::uint16_t, std::map<std::uint16_t, float>> crosspointValues;
 
            outputMuteStates[channel] = muteState;
 
            auto sendIds = m_networkServer->getActiveConnectionIds();
            sendIds.erase(std::remove(sendIds.begin(), sendIds.end(), userId), sendIds.end());
            m_networkServer->enqueueMessage(std::make_unique<ControlParametersMessage>(inputMuteStates, outputMuteStates, crosspointStates, crosspointValues)->getSerializedMessage(), sendIds);
        }
    };
 
    void setCrosspointEnabledValue(std::uint16_t input, std::uint16_t output, bool enabledState, int userId) override
    {
        if (m_networkServer && m_networkServer->hasActiveConnections())
        {
            std::map<std::uint16_t, bool> inputMuteStates;
            std::map<std::uint16_t, bool> outputMuteStates;
            std::map<std::uint16_t, std::map<std::uint16_t, bool>> crosspointStates;
            std::map<std::uint16_t, std::map<std::uint16_t, float>> crosspointValues;
 
            crosspointStates[input][output] = enabledState;
 
            auto sendIds = m_networkServer->getActiveConnectionIds();
            sendIds.erase(std::remove(sendIds.begin(), sendIds.end(), userId), sendIds.end());
            m_networkServer->enqueueMessage(std::make_unique<ControlParametersMessage>(inputMuteStates, outputMuteStates, crosspointStates, crosspointValues)->getSerializedMessage(), sendIds);
        }
    };
 
    void setCrosspointFactorValue(std::uint16_t input, std::uint16_t output, float factor, int userId) override
    {
        if (m_networkServer && m_networkServer->hasActiveConnections())
        {
            std::map<std::uint16_t, bool> inputMuteStates;
            std::map<std::uint16_t, bool> outputMuteStates;
            std::map<std::uint16_t, std::map<std::uint16_t, bool>> crosspointStates;
            std::map<std::uint16_t, std::map<std::uint16_t, float>> crosspointValues;
 
            crosspointValues[input][output] = factor;
 
            auto sendIds = m_networkServer->getActiveConnectionIds();
            sendIds.erase(std::remove(sendIds.begin(), sendIds.end(), userId), sendIds.end());
            m_networkServer->enqueueMessage(std::make_unique<ControlParametersMessage>(inputMuteStates, outputMuteStates, crosspointStates, crosspointValues)->getSerializedMessage(), sendIds);
        }
    };
 
    void setPluginParameterInfos(const std::vector<PluginParameterInfo>& parameterInfos, const std::string& name, bool enabled, bool post, int userId = -1) override
    {
        if (m_networkServer && m_networkServer->hasActiveConnections())
        {
            auto sendIds = m_networkServer->getActiveConnectionIds();
            sendIds.erase(std::remove(sendIds.begin(), sendIds.end(), userId), sendIds.end());
            m_networkServer->enqueueMessage(std::make_unique<PluginParameterInfosMessage>(name, enabled, post, parameterInfos)->getSerializedMessage(), sendIds);
        }
    }
 
    void setPluginProcessingState(bool enabled, bool post, int userId = -1) override
    {
        if (m_networkServer && m_networkServer->hasActiveConnections())
        {
            auto sendIds = m_networkServer->getActiveConnectionIds();
            sendIds.erase(std::remove(sendIds.begin(), sendIds.end(), userId), sendIds.end());
            m_networkServer->enqueueMessage(std::make_unique<PluginProcessingStateMessage>(enabled, post)->getSerializedMessage(), sendIds);
        }
    }
 
    void setPluginParameterValue(std::uint16_t index, std::string id, float currentValue, int userId = -1) override
    {
        if (m_networkServer && m_networkServer->hasActiveConnections())
        {
            DBG(juce::String(__FUNCTION__) << " sending to net: " << int(index) << " > " << currentValue);
            auto sendIds = m_networkServer->getActiveConnectionIds();
            sendIds.erase(std::remove(sendIds.begin(), sendIds.end(), userId), sendIds.end());
            m_networkServer->enqueueMessage(std::make_unique<PluginParameterValueMessage>(index, id, currentValue)->getSerializedMessage(), sendIds);
        }
    }
 
    void setIOCount(std::uint16_t inputCount, std::uint16_t outputCount) override
    {
        if (m_networkServer && m_networkServer->hasActiveConnections())
        {
            m_networkServer->enqueueMessage(std::make_unique<ReinitIOCountMessage>(inputCount, outputCount)->getSerializedMessage());
        }
    };
 
    void setNetworkConnection(const std::shared_ptr<InterprocessConnectionServerImpl>& networkServer)
    {
        m_networkServer = networkServer;
    }
 
private:
    void setChannelCount(std::uint16_t channelCount) override { ignoreUnused(channelCount); };
 
private:
    std::shared_ptr<InterprocessConnectionServerImpl> m_networkServer;
 
};
 
//==============================================================================
MemaProcessor::MemaProcessor(XmlElement* stateXml) :
    juce::AudioProcessor()
{
#ifdef RUN_MESSAGE_TESTS
    runTests();
#endif
 
    // prepare max sized processing data buffer
    m_processorChannels = new float* [s_maxChannelCount];
    for (auto i = 0; i < s_maxChannelCount; i++)
    {
        m_processorChannels[i] = new float[s_maxNumSamples];
        for (auto j = 0; j < s_maxNumSamples; j++)
        {
            m_processorChannels[i][j] = 0.0f;
        }
    }
 
    m_inputDataAnalyzer = std::make_unique<ProcessorDataAnalyzer>();
    m_inputDataAnalyzer->setUseProcessingTypes(true, false, false);
    m_outputDataAnalyzer = std::make_unique<ProcessorDataAnalyzer>();
    m_outputDataAnalyzer->setUseProcessingTypes(true, false, false);
 
    m_deviceManager = std::make_unique<AudioDeviceManager>();
    m_deviceManager->addAudioCallback(this);
    m_deviceManager->addChangeListener(this);
    
    if (!setStateXml(stateXml))
    {
        setStateXml(nullptr); // call without actual xml config causes default init
        triggerConfigurationUpdate(false);
    }
 
    // init the announcement of this app instance as discoverable service
    m_serviceTopologyManager = std::make_unique<JUCEAppBasics::ServiceTopologyManager>(
        Mema::ServiceData::getServiceTypeUIDBase(),
        Mema::ServiceData::getMasterServiceTypeUID(),
        JUCEAppBasics::ServiceTopologyManager::getServiceDescription(),
        JUCEAppBasics::ServiceTopologyManager::getServiceDescription(),
        Mema::ServiceData::getBroadcastPort(),
        Mema::ServiceData::getConnectionPort());
 
    m_networkServer = std::make_shared<InterprocessConnectionServerImpl>();
    m_networkServer->beginWaitingForSocket(Mema::ServiceData::getConnectionPort());
    m_networkServer->onConnectionCreated = [=](int connectionId) {
        auto connection = dynamic_cast<InterprocessConnectionImpl*>(m_networkServer->getActiveConnection(connectionId).get());
        if (connection)
        {
            connection->onConnectionLost = [=](int connectionId) { DBG(juce::String(__FUNCTION__) << " connection " << connectionId << " lost");
                m_trafficTypesPerConnection.erase(connectionId);
            };
            connection->onConnectionMade = [=](int connectionId ) { DBG(juce::String(__FUNCTION__) << " connection " << connectionId << " made");
                m_trafficTypesPerConnection[connectionId].clear();
                if (m_networkServer && m_networkServer->hasActiveConnection(connectionId))
                {
                    auto paletteStyle = JUCEAppBasics::CustomLookAndFeel::PaletteStyle::PS_Dark;
                    if (getActiveEditor())
                        if (auto claf = dynamic_cast<JUCEAppBasics::CustomLookAndFeel*>(&getActiveEditor()->getLookAndFeel()))
                            paletteStyle = claf->getPaletteStyle();
 
                    std::map<std::uint16_t, bool> inputMuteStates;
                    std::map<std::uint16_t, bool> outputMuteStates;
                    std::map<std::uint16_t, std::map<std::uint16_t, bool>> matrixCrosspointStates;
                    std::map<std::uint16_t, std::map<std::uint16_t, float>> matrixCrosspointValues;
                    {
                        const ScopedLock sl(m_audioDeviceIOCallbackLock);
                        inputMuteStates = m_inputMuteStates;
                        outputMuteStates = m_outputMuteStates;
                        matrixCrosspointStates = m_matrixCrosspointStates;
                        matrixCrosspointValues = m_matrixCrosspointValues;
                    }
 
                    auto sendIds = std::vector<int>{ connectionId };
                    auto success = true;
                    success = success && m_networkServer->enqueueMessage(std::make_unique<AnalyzerParametersMessage>(int(getSampleRate()), getBlockSize())->getSerializedMessage(), sendIds);
                    success = success && m_networkServer->enqueueMessage(std::make_unique<ReinitIOCountMessage>(m_inputChannelCount, m_outputChannelCount)->getSerializedMessage(), sendIds);
                    success = success && m_networkServer->enqueueMessage(std::make_unique<EnvironmentParametersMessage>(paletteStyle)->getSerializedMessage(), sendIds);
                    success = success && m_networkServer->enqueueMessage(std::make_unique<ControlParametersMessage>(inputMuteStates, outputMuteStates, matrixCrosspointStates, matrixCrosspointValues)->getSerializedMessage(), sendIds);
                    {
                        auto orderedParams = m_pluginParameterInfos;
                        if (!m_pluginParameterDisplayOrder.empty() && m_pluginParameterDisplayOrder.size() == m_pluginParameterInfos.size())
                        {
                            orderedParams.clear();
                            for (int idx : m_pluginParameterDisplayOrder)
                                if (idx >= 0 && idx < static_cast<int>(m_pluginParameterInfos.size()))
                                    orderedParams.push_back(m_pluginParameterInfos[idx]);
                            if (orderedParams.size() != m_pluginParameterInfos.size())
                                orderedParams = m_pluginParameterInfos;
                        }
                        success = success && m_networkServer->enqueueMessage(std::make_unique<PluginParameterInfosMessage>(m_pluginInstance ? m_pluginInstance->getName().toStdString() : "", m_pluginEnabled, m_pluginPost, orderedParams)->getSerializedMessage(), sendIds);
                    }
                    if (!success)
                        m_networkServer->cleanupDeadConnections();
                }
            };
            connection->onMessageReceived = [=](int connectionId, const juce::MemoryBlock& message) {
                if (auto knownMessage = Mema::SerializableMessage::initFromMemoryBlock(message))
                {
                    knownMessage->setId(connectionId);
                    postMessage(knownMessage);
                }
                else
                    DBG(juce::String(__FUNCTION__) + " ignoring unknown message");
            };
        }
    };
    m_networkCommanderWrapper = std::make_unique<MemaNetworkClientCommanderWrapper>();
    m_networkCommanderWrapper->setNetworkConnection(m_networkServer);
    addInputCommander(static_cast<MemaInputCommander*>(m_networkCommanderWrapper.get()));
    addOutputCommander(static_cast<MemaOutputCommander*>(m_networkCommanderWrapper.get()));
    addCrosspointCommander(static_cast<MemaCrosspointCommander*>(m_networkCommanderWrapper.get()));
    addPluginCommander(static_cast<MemaPluginCommander*>(m_networkCommanderWrapper.get()));
 
    m_timedConfigurationDumper = std::make_unique<juce::TimedCallback>([=]() {
        if (isTimedConfigurationDumpPending())
        {
            auto config = JUCEAppBasics::AppConfigurationBase::getInstance();
            if (config != nullptr)
                config->triggerConfigurationDump(false);
            resetTimedConfigurationDumpPending();
        }
    });
    m_timedConfigurationDumper->startTimer(100);
}
 
MemaProcessor::~MemaProcessor()
{
    m_timedConfigurationDumper->stopTimer();
    if (isTimedConfigurationDumpPending())
    {
        auto config = JUCEAppBasics::AppConfigurationBase::getInstance();
        if (config != nullptr)
            config->triggerConfigurationDump(false);
        resetTimedConfigurationDumpPending();
    }
 
    m_networkServer->stop();
 
    m_deviceManager->removeAudioCallback(this);
 
    // cleanup processing data buffer
    for (auto i = 0; i < s_maxChannelCount; i++)
        delete[] m_processorChannels[i];
    delete[] m_processorChannels;
}
 
std::unique_ptr<juce::XmlElement> MemaProcessor::createStateXml()
{
    auto stateXml = std::make_unique<juce::XmlElement>(MemaAppConfiguration::getTagName(MemaAppConfiguration::TagID::PROCESSORCONFIG));
 
    auto devConfElm = std::make_unique<juce::XmlElement>(MemaAppConfiguration::getTagName(MemaAppConfiguration::TagID::DEVCONFIG));
    if (m_deviceManager)
        devConfElm->addChildElement(m_deviceManager->createStateXml().release());
    stateXml->addChildElement(devConfElm.release());
 
    auto plgConfElm = std::make_unique<juce::XmlElement>(MemaAppConfiguration::getTagName(MemaAppConfiguration::TagID::PLUGINCONFIG));
    plgConfElm->setAttribute(MemaAppConfiguration::getAttributeName(MemaAppConfiguration::AttributeID::ENABLED), m_pluginEnabled ? 1 : 0);
    plgConfElm->setAttribute(MemaAppConfiguration::getAttributeName(MemaAppConfiguration::AttributeID::POST), m_pluginPost ? 1 : 0);
    if (m_pluginInstance)
    {
        plgConfElm->addChildElement(m_pluginInstance->getPluginDescription().createXml().release());
 
        juce::MemoryBlock destData;
        m_pluginInstance->getStateInformation(destData);
        plgConfElm->addTextElement(juce::Base64::toBase64(destData.getData(), destData.getSize()));
    }
    for (auto const& plgParam : getPluginParameterInfos())
    {
        auto plgParamElm = std::make_unique<juce::XmlElement>(MemaAppConfiguration::getTagName(MemaAppConfiguration::TagID::PLUGINPARAM));
        plgParamElm->setAttribute(MemaAppConfiguration::getAttributeName(MemaAppConfiguration::AttributeID::IDX), plgParam.index);
        plgParamElm->setAttribute(MemaAppConfiguration::getAttributeName(MemaAppConfiguration::AttributeID::CONTROLLABLE), isPluginParameterRemoteControllable(plgParam.index));
        plgParamElm->addTextElement(plgParam.toString());
        plgConfElm->addChildElement(plgParamElm.release());
    }
    if (!m_pluginParameterDisplayOrder.empty())
    {
        juce::StringArray orderStrs;
        for (int idx : m_pluginParameterDisplayOrder)
            orderStrs.add(juce::String(idx));
        plgConfElm->setAttribute(MemaAppConfiguration::getAttributeName(MemaAppConfiguration::AttributeID::PARAMORDER), orderStrs.joinIntoString(","));
    }
    stateXml->addChildElement(plgConfElm.release());
 
    std::map<std::uint16_t, bool> inputMuteStates;
    std::map<std::uint16_t, bool> outputMuteStates;
    std::map<std::uint16_t, std::map<std::uint16_t, bool>> matrixCrosspointStates;
    std::map<std::uint16_t, std::map<std::uint16_t, float>> matrixCrosspointValues;
    {
        // copy the processing relevant variables to not block audio thread during all the xml handling
        const ScopedLock sl(m_audioDeviceIOCallbackLock);
        inputMuteStates = m_inputMuteStates;
        outputMuteStates = m_outputMuteStates;
        matrixCrosspointStates = m_matrixCrosspointStates;
        matrixCrosspointValues = m_matrixCrosspointValues;
    }
 
    auto inputMutesElm = std::make_unique<juce::XmlElement>(MemaAppConfiguration::getTagName(MemaAppConfiguration::TagID::INPUTMUTES));
    juce::StringArray imutestatestr;
    for (auto const& mutestate : inputMuteStates)
        imutestatestr.add(juce::String(mutestate.first) + "," + juce::String(mutestate.second ? 1 : 0));
    inputMutesElm->addTextElement(imutestatestr.joinIntoString(";"));
    stateXml->addChildElement(inputMutesElm.release());
 
    auto outputMutesElm = std::make_unique<juce::XmlElement>(MemaAppConfiguration::getTagName(MemaAppConfiguration::TagID::OUTPUTMUTES));
    juce::StringArray omutestatestr;
    for (auto const& mutestate : outputMuteStates)
        omutestatestr.add(juce::String(mutestate.first) + "," + juce::String(mutestate.second ? 1 : 0));
    outputMutesElm->addTextElement(omutestatestr.joinIntoString(";"));
    stateXml->addChildElement(outputMutesElm.release());
 
    auto crosspointGainsElm = std::make_unique<juce::XmlElement>(MemaAppConfiguration::getTagName(MemaAppConfiguration::TagID::CROSSPOINTGAINS));
    juce::StringArray cgainstatestr;
    for (auto const& insKV : matrixCrosspointStates)
        for (auto const& outsKV : insKV.second)
            cgainstatestr.add(juce::String(insKV.first) + "," + juce::String(outsKV.first) + "," + juce::String(outsKV.second ? 1 : 0) + "," + juce::String(matrixCrosspointValues[insKV.first][outsKV.first])); // "in,out,enabled,gain;"
    crosspointGainsElm->addTextElement(cgainstatestr.joinIntoString(";"));
    stateXml->addChildElement(crosspointGainsElm.release());
 
    return stateXml;
}
 
bool MemaProcessor::setStateXml(juce::XmlElement* stateXml)
{
    if (nullptr == stateXml || stateXml->getTagName() != MemaAppConfiguration::getTagName(MemaAppConfiguration::TagID::PROCESSORCONFIG))
    {
        jassertfalse;
        return false;
    }
 
    juce::XmlElement* deviceSetupXml = nullptr;
    auto devConfElm = stateXml->getChildByName(MemaAppConfiguration::getTagName(MemaAppConfiguration::TagID::DEVCONFIG));
    if (nullptr != devConfElm)
        deviceSetupXml = devConfElm->getChildByName("DEVICESETUP");
    
    if (m_deviceManager)
    {
        // Skip the (expensive, audio-interrupting) device manager re-initialisation when the
        // DEVCONFIG section of the config is identical to the one that was last successfully
        // applied.  This prevents audio dropouts caused by non-audio config changes (e.g.
        // UI colour / LookAndFeel) that trigger a full config dump+reload cycle.
        bool deviceConfigChanged = true;
        if (m_lastAppliedDeviceConfigXml && devConfElm)
            deviceConfigChanged = !devConfElm->isEquivalentTo(m_lastAppliedDeviceConfigXml.get(), true);
        else if (!m_lastAppliedDeviceConfigXml && !devConfElm)
            deviceConfigChanged = false; // both absent — nothing to change
 
        if (deviceConfigChanged)
        {
            // Hacky bit of device manager initialization:
            // We first intialize it to be able to get a valid device setup,
            // then initialize with a dummy xml config to trigger the internal xml structure being reset
            // and finally apply the original initialized device setup again to have the audio running correctly.
            // If we did not do so, either the internal xml would not be present as long as the first configuration change was made
            // and therefor no valid config file could be written by the application or the audio would not be running
            // on first start and manual config would be required.
            m_deviceManager->initialiseWithDefaultDevices(s_maxChannelCount, s_maxChannelCount);
            auto audioDeviceSetup = m_deviceManager->getAudioDeviceSetup();
            auto result = m_deviceManager->initialise(s_maxChannelCount, s_maxChannelCount, deviceSetupXml, true, {}, &audioDeviceSetup);
            if (result.isNotEmpty())
            {
                // The saved audio device is unavailable; the device manager has already fallen back
                // to the system default via initialiseWithDefaultDevices above.  Warn the user but
                // continue restoring plugin and routing state from the config — those are independent
                // of which audio device is active and must not be discarded just because the
                // preferred interface is currently unplugged.
                juce::AlertWindow::showMessageBoxAsync(juce::MessageBoxIconType::WarningIcon, juce::JUCEApplication::getInstance()->getApplicationName() + " device init failed", result);
            }
#if JUCE_IOS
            if (audioDeviceSetup.bufferSize < 512)
                audioDeviceSetup.bufferSize = 512; // temp. workaround for iOS where buffersizes <512 lead to no sample data being delivered?
            m_deviceManager->setAudioDeviceSetup(audioDeviceSetup, true);
#endif
            m_lastAppliedDeviceConfigXml = devConfElm ? std::make_unique<juce::XmlElement>(*devConfElm) : nullptr;
        }
    }
    else
        return false;
 
 
    auto plgConfElm = stateXml->getChildByName(MemaAppConfiguration::getTagName(MemaAppConfiguration::TagID::PLUGINCONFIG));
    if (nullptr != plgConfElm)
    {
        setPluginEnabledState(plgConfElm->getBoolAttribute(MemaAppConfiguration::getAttributeName(MemaAppConfiguration::AttributeID::ENABLED)));
        setPluginPrePostState(plgConfElm->getBoolAttribute(MemaAppConfiguration::getAttributeName(MemaAppConfiguration::AttributeID::POST)));
        auto pluginDescriptionXml = plgConfElm->getChildByName("PLUGIN");
        if (nullptr != pluginDescriptionXml)
        {
            auto pluginDescription = juce::PluginDescription();
            pluginDescription.loadFromXml(*pluginDescriptionXml);
            setPlugin(pluginDescription);
            if (m_pluginInstance)
            {
                juce::MemoryOutputStream destDataStream;
                juce::Base64::convertFromBase64(destDataStream, pluginDescriptionXml->getAllSubText());
                m_pluginInstance->setStateInformation(destDataStream.getData(), int(destDataStream.getDataSize()));
            }
        }
 
        auto orderAttr = plgConfElm->getStringAttribute(MemaAppConfiguration::getAttributeName(MemaAppConfiguration::AttributeID::PARAMORDER));
        if (orderAttr.isNotEmpty())
        {
            m_pluginParameterDisplayOrder.clear();
            juce::StringArray orderStrs;
            orderStrs.addTokens(orderAttr, ",", "");
            for (auto const& s : orderStrs)
                m_pluginParameterDisplayOrder.push_back(s.getIntValue());
        }
 
        for (auto* plgParamElm : plgConfElm->getChildWithTagNameIterator(MemaAppConfiguration::getTagName(MemaAppConfiguration::TagID::PLUGINPARAM)))
        {
            if (nullptr != plgParamElm)
            {
                auto index = plgParamElm->getIntAttribute(MemaAppConfiguration::getAttributeName(MemaAppConfiguration::AttributeID::IDX));
                auto paramString = plgParamElm->getAllSubText();
                auto paramInfo = PluginParameterInfo::fromString(paramString);
                paramInfo.isRemoteControllable = (plgParamElm->getIntAttribute(MemaAppConfiguration::getAttributeName(MemaAppConfiguration::AttributeID::CONTROLLABLE)) == 1);
                jassert(paramInfo.index == index);
                // update the pluginparameterinfo
                auto iter = std::find_if(getPluginParameterInfos().begin(), getPluginParameterInfos().end(), [=](const auto& info) { return info.index == index; });
                if (iter != getPluginParameterInfos().end())
                    iter->initializeFromString(paramString);
                // set the parameter
                auto* param = getPluginParameter(index);
                if (param)
                {
                    jassert(paramInfo.name == param->getName(100));
                    jassert(paramInfo.label == param->getLabel());
                    //jassert(paramInfo.defaultValue == param->getDefaultValue()); //float rounding issue prevents this from making sense
                    jassert(paramInfo.isAutomatable == param->isAutomatable());
                    jassert(paramInfo.category == param->getCategory());
                    if (auto* rangedParam = dynamic_cast<const juce::RangedAudioParameter*>(param))
                    {
                        auto range = rangedParam->getNormalisableRange();
                        jassert(paramInfo.minValue == range.start);
                        jassert(paramInfo.maxValue == range.end);
                        jassert(paramInfo.stepSize == range.interval);
                        jassert(paramInfo.isDiscrete == range.interval > 0.0f);
                    }
 
                    setPluginParameterRemoteControlInfos(paramInfo.index, paramInfo.isRemoteControllable, paramInfo.type, paramInfo.stepCount);
                    param->setValue(paramInfo.currentValue);
                }
            }
        }
    }
 
    std::map<std::uint16_t, bool> inputMuteStates;
    std::map<std::uint16_t, bool> outputMuteStates;
    std::map<std::uint16_t, std::map<std::uint16_t, bool>> matrixCrosspointStates;
    std::map<std::uint16_t, std::map<std::uint16_t, float>> matrixCrosspointValues;
    auto inputMutesElm = stateXml->getChildByName(MemaAppConfiguration::getTagName(MemaAppConfiguration::TagID::INPUTMUTES));
    if (nullptr != inputMutesElm)
    {
        juce::StringArray inMutestateStrList;
        auto inputMutesElmTxt = inputMutesElm->getAllSubText();
        inMutestateStrList.addTokens(inputMutesElmTxt, ";", "");
        jassert(inMutestateStrList.size() == m_inputChannelCount);
        if (inMutestateStrList.size() != m_inputChannelCount)
        {
            // if the config data is insane, initialize with defaults
            DBG(juce::String(__FUNCTION__) + " config data for input mutes is insane -> resetting to default.");
            for (auto in = std::uint16_t(1); in <= m_inputChannelCount; in++)
                inputMuteStates[in] = false;
        }
        else
        {
            // otherwise use what is available from config
            for (auto const& inMutestateStr : inMutestateStrList)
            {
                juce::StringArray inMutestateStrSplit;
                inMutestateStrSplit.addTokens(inMutestateStr, ",", "");
                jassert(2 == inMutestateStrSplit.size());
                if (2 == inMutestateStrSplit.size())
                    inputMuteStates[std::uint16_t(inMutestateStrSplit[0].getIntValue())] = (1 == std::uint16_t(inMutestateStrSplit[1].getIntValue()));
            }
        }
    }
    auto outputMutesElm = stateXml->getChildByName(MemaAppConfiguration::getTagName(MemaAppConfiguration::TagID::OUTPUTMUTES));
    if (nullptr != outputMutesElm)
    {
        juce::StringArray outMutestateStrList;
        auto outputMutesElmTxt = outputMutesElm->getAllSubText();
        outMutestateStrList.addTokens(outputMutesElmTxt, ";", "");
        jassert(outMutestateStrList.size() == m_outputChannelCount);
        if (outMutestateStrList.size() != m_outputChannelCount)
        {
            // if the config data is insane, initialize with defaults
            DBG(juce::String(__FUNCTION__) + " config data for output mutes is insane -> resetting to default.");
            for (auto out = std::uint16_t(1); out <= m_outputChannelCount; out++)
                outputMuteStates[out] = false;
        }
        else
        {
            // otherwise use what is available from config
            for (auto const& outMutestateStr : outMutestateStrList)
            {
                juce::StringArray outMutestateStrSplit;
                outMutestateStrSplit.addTokens(outMutestateStr, ",", "");
                jassert(2 == outMutestateStrSplit.size());
                if (2 == outMutestateStrSplit.size())
                    outputMuteStates[std::uint16_t(outMutestateStrSplit[0].getIntValue())] = (1 == std::uint16_t(outMutestateStrSplit[1].getIntValue()));
            }
        }
    }
    auto crosspointGainsElm = stateXml->getChildByName(MemaAppConfiguration::getTagName(MemaAppConfiguration::TagID::CROSSPOINTGAINS));
    if (nullptr != crosspointGainsElm)
    {
        juce::StringArray crossGainstateStrList;
        auto crossGainsElmTxt = crosspointGainsElm->getAllSubText();
        crossGainstateStrList.addTokens(crossGainsElmTxt, ";", "");
        jassert(crossGainstateStrList.size() == (m_inputChannelCount * m_outputChannelCount));
        if (crossGainstateStrList.size() != (m_inputChannelCount * m_outputChannelCount))
        {
            // if the config data is insane, initialize with defaults
            DBG(juce::String(__FUNCTION__) + " config data for crosspoints is insane -> resetting to default.");
            for (auto in = std::uint16_t(1); in <= m_inputChannelCount; in++)
            {
                for (auto out = std::uint16_t(1); out <= m_outputChannelCount; out++)
                {
                    auto state = false;
                    auto value = 0.0f;
                    if (in == out)
                    {
                        state = true;
                        value = 1.0f;
                    }
                    matrixCrosspointStates[in][out] = state;
                    matrixCrosspointValues[in][out] = value;
                }
            }
        }
        else
        {
            // otherwise use what is available from config
            for (auto const& crossGainstateStr : crossGainstateStrList)
            {
                juce::StringArray crossGainstateStrSplit;
                crossGainstateStrSplit.addTokens(crossGainstateStr, ",", "");
                jassert(4 == crossGainstateStrSplit.size());
                if (4 == crossGainstateStrSplit.size())
                {
                    matrixCrosspointStates[std::uint16_t(crossGainstateStrSplit[0].getIntValue())][std::uint16_t(crossGainstateStrSplit[1].getIntValue())] = 1 == std::uint16_t(crossGainstateStrSplit[2].getIntValue());
                    matrixCrosspointValues[std::uint16_t(crossGainstateStrSplit[0].getIntValue())][std::uint16_t(crossGainstateStrSplit[1].getIntValue())] = crossGainstateStrSplit[3].getFloatValue();
                }
            }
        }
    }
#ifdef DEBUG
    // sanity check symmetry of crosspoint states
    auto crosspointStateOutCount = size_t(0);
    if (0 != matrixCrosspointStates.size())
    {
        crosspointStateOutCount = matrixCrosspointStates.begin()->second.size();
        for (auto const& cpStatKV : matrixCrosspointStates)
        {
            jassert(crosspointStateOutCount == cpStatKV.second.size());
        }
    }
    else
        jassertfalse; // empty crosspoint matrix ?!
 
    // sanity check symmetry of crosspoint values
    auto crosspointValOutCount = size_t(0);
    if (0 != matrixCrosspointValues.size())
    {
        crosspointValOutCount = matrixCrosspointValues.begin()->second.size();
        for (auto const& cpValKV : matrixCrosspointValues)
        {
            jassert(crosspointValOutCount == cpValKV.second.size());
        }
    }
    else
        jassertfalse; // empty crosspoint matrix ?!
#endif
    {
        // copy the processing relevant variables from temp vars here to not block audio thread during all the xml handling above
        const ScopedLock sl(m_audioDeviceIOCallbackLock);
        m_inputMuteStates = inputMuteStates;
        m_outputMuteStates = outputMuteStates;
        m_matrixCrosspointStates = matrixCrosspointStates;
        m_matrixCrosspointValues = matrixCrosspointValues;
    }
 
    return true;
}
 
void MemaProcessor::environmentChanged()
{
    auto paletteStyle = JUCEAppBasics::CustomLookAndFeel::PaletteStyle::PS_Dark;
    if (getActiveEditor())
        if (auto claf = dynamic_cast<JUCEAppBasics::CustomLookAndFeel*>(&getActiveEditor()->getLookAndFeel()))
            paletteStyle = claf->getPaletteStyle();
 
    postMessage(std::make_unique<EnvironmentParametersMessage>(paletteStyle).release());
}
 
void MemaProcessor::triggerIOUpdate()
{
    postMessage(std::make_unique<ReinitIOCountMessage>(m_inputChannelCount, m_outputChannelCount).release());
}
 
void MemaProcessor::addInputListener(ProcessorDataAnalyzer::Listener* listener)
{
    if (m_inputDataAnalyzer)
        m_inputDataAnalyzer->addListener(listener);
}
 
void MemaProcessor::removeInputListener(ProcessorDataAnalyzer::Listener* listener)
{
    if (m_inputDataAnalyzer)
        m_inputDataAnalyzer->removeListener(listener);
}
 
void MemaProcessor::addOutputListener(ProcessorDataAnalyzer::Listener* listener)
{
    if (m_outputDataAnalyzer)
        m_outputDataAnalyzer->addListener(listener);
}
 
void MemaProcessor::removeOutputListener(ProcessorDataAnalyzer::Listener* listener)
{
    if (m_outputDataAnalyzer)
        m_outputDataAnalyzer->removeListener(listener);
}
 
void MemaProcessor::addInputCommander(MemaInputCommander* commander)
{
    if (commander == nullptr)
        return;
 
    if (std::find(m_inputCommanders.begin(), m_inputCommanders.end(), commander) == m_inputCommanders.end())
    {
        initializeInputCommander(commander);
 
        m_inputCommanders.push_back(commander);
        commander->setInputMuteChangeCallback([=](MemaChannelCommander* sender, int channel, bool state) { return setInputMuteState(std::uint16_t(channel), state, sender); } );
    }
}
 
void MemaProcessor::initializeInputCommander(MemaInputCommander* commander)
{
    if (nullptr != commander)
    {
        const ScopedLock sl(m_audioDeviceIOCallbackLock);
        for (auto const& inputMuteStatesKV : m_inputMuteStates)
            commander->setInputMute(inputMuteStatesKV.first, inputMuteStatesKV.second);
    }
}
 
void MemaProcessor::removeInputCommander(MemaInputCommander* commander)
{
    if (commander == nullptr)
        return;
 
    auto existingInputCommander = std::find(m_inputCommanders.begin(), m_inputCommanders.end(), commander);
    if (existingInputCommander != m_inputCommanders.end())
        m_inputCommanders.erase(existingInputCommander);
}
 
void MemaProcessor::addOutputCommander(MemaOutputCommander* commander)
{
    if (commander == nullptr)
        return;
 
    if (std::find(m_outputCommanders.begin(), m_outputCommanders.end(), commander) == m_outputCommanders.end())
    {
        initializeOutputCommander(commander);
 
        m_outputCommanders.push_back(commander);
        commander->setOutputMuteChangeCallback([=](MemaChannelCommander* sender, int channel, bool state) { return setOutputMuteState(std::uint16_t(channel), state, sender); });
    }
}
 
void MemaProcessor::initializeOutputCommander(MemaOutputCommander* commander)
{
    if (nullptr != commander)
    {
        const ScopedLock sl(m_audioDeviceIOCallbackLock);
        for (auto const& outputMuteStatesKV : m_outputMuteStates)
            commander->setOutputMute(outputMuteStatesKV.first, outputMuteStatesKV.second);
    }
}
 
void MemaProcessor::removeOutputCommander(MemaOutputCommander* commander)
{
    if (commander == nullptr)
        return;
 
    auto existingOutputCommander = std::find(m_outputCommanders.begin(), m_outputCommanders.end(), commander);
    if (existingOutputCommander != m_outputCommanders.end())
        m_outputCommanders.erase(existingOutputCommander);
}
 
void MemaProcessor::addCrosspointCommander(MemaCrosspointCommander* commander)
{
    if (commander == nullptr)
        return;
 
    if (std::find(m_crosspointCommanders.begin(), m_crosspointCommanders.end(), commander) == m_crosspointCommanders.end())
    {
        initializeCrosspointCommander(commander);
 
        m_crosspointCommanders.push_back(commander);
        commander->setCrosspointEnabledChangeCallback([=](MemaChannelCommander* sender, int input, int output, bool state) { return setMatrixCrosspointEnabledValue(std::uint16_t(input), std::uint16_t(output), state, sender); });
        commander->setCrosspointFactorChangeCallback([=](MemaChannelCommander* sender, int input, int output, float factor) { return setMatrixCrosspointFactorValue(std::uint16_t(input), std::uint16_t(output), factor, sender); });
    }
}
 
void MemaProcessor::initializeCrosspointCommander(MemaCrosspointCommander* commander)
{
    if (nullptr != commander)
    {
        auto matrixCrosspointStates = std::map<std::uint16_t, std::map<std::uint16_t, bool>>();
        auto matrixCrosspointValues = std::map<std::uint16_t, std::map<std::uint16_t, float>>();
        {
            const ScopedLock sl(m_audioDeviceIOCallbackLock);
            matrixCrosspointStates = m_matrixCrosspointStates;
            matrixCrosspointValues = m_matrixCrosspointValues;
        }
        for (auto const& matrixCrosspointStateKV : matrixCrosspointStates)
        {
            for (auto const& matrixCrosspointStateNodeKV : matrixCrosspointStateKV.second)
            {
                auto& input = matrixCrosspointStateKV.first;
                auto& output = matrixCrosspointStateNodeKV.first;
                auto& enabled = matrixCrosspointStateNodeKV.second;
                commander->setCrosspointEnabledValue(input, output, enabled);
            }
        }
        for (auto const& matrixCrosspointValKV : matrixCrosspointValues)
        {
            for (auto const& matrixCrosspointValNodeKV : matrixCrosspointValKV.second)
            {
                auto& input = matrixCrosspointValKV.first;
                auto& output = matrixCrosspointValNodeKV.first;
                auto& val = matrixCrosspointValNodeKV.second;
                commander->setCrosspointFactorValue(input, output, val);
            }
        }
    }
}
 
void MemaProcessor::removeCrosspointCommander(MemaCrosspointCommander* commander)
{
    if (commander == nullptr)
        return;
 
    auto existingCrosspointCommander = std::find(m_crosspointCommanders.begin(), m_crosspointCommanders.end(), commander);
    if (existingCrosspointCommander != m_crosspointCommanders.end())
        m_crosspointCommanders.erase(existingCrosspointCommander);
}
 
void MemaProcessor::addPluginCommander(MemaPluginCommander* commander)
{
    if (commander == nullptr)
        return;
 
    if (std::find(m_pluginCommanders.begin(), m_pluginCommanders.end(), commander) == m_pluginCommanders.end())
    {
        initializePluginCommander(commander);
 
        m_pluginCommanders.push_back(commander);
        commander->setPluginParameterValueChangeCallback([=](MemaPluginCommander* sender, std::uint16_t index, std::string id, float value) { return setPluginParameterValue(index, id, value, sender); });
    }
}
 
void MemaProcessor::initializePluginCommander(MemaPluginCommander* commander)
{
    if (nullptr != commander)
    {
        //for (auto const& inputMuteStatesKV : m_inputMuteStates)
        //  commander->setInputMute(inputMuteStatesKV.first, inputMuteStatesKV.second);
    }
}
 
void MemaProcessor::removePluginCommander(MemaPluginCommander* commander)
{
    if (commander == nullptr)
        return;
 
    auto existingPluginCommander = std::find(m_pluginCommanders.begin(), m_pluginCommanders.end(), commander);
    if (existingPluginCommander != m_pluginCommanders.end())
        m_pluginCommanders.erase(existingPluginCommander);
}
 
void MemaProcessor::updateCommanders()
{
    for (auto const& ic : m_inputCommanders)
    {
        ic->setChannelCount(m_inputChannelCount > 0 ? std::uint16_t(m_inputChannelCount) : 0);
        initializeInputCommander(ic);
    }
    for (auto const& cc : m_crosspointCommanders)
    {
        cc->setIOCount(m_inputChannelCount > 0 ? std::uint16_t(m_inputChannelCount) : 0, m_outputChannelCount > 0 ? std::uint16_t(m_outputChannelCount) : 0);
        initializeCrosspointCommander(cc);
    }
    for (auto const& oc : m_outputCommanders)
    {
        oc->setChannelCount(m_outputChannelCount > 0 ? std::uint16_t(m_outputChannelCount) : 0);
        initializeOutputCommander(oc);
    }
    for (auto const& pc : m_pluginCommanders)
    {
        initializePluginCommander(pc);
    }
}
 
bool MemaProcessor::getInputMuteState(std::uint16_t inputChannelNumber)
{
    jassert(inputChannelNumber > 0);
    const ScopedLock sl(m_audioDeviceIOCallbackLock);
    return m_inputMuteStates[inputChannelNumber];
}
 
void MemaProcessor::setInputMuteState(std::uint16_t inputChannelNumber, bool muted, MemaChannelCommander* sender, int userId)
{
    jassert(inputChannelNumber > 0);
 
    for (auto const& inputCommander : m_inputCommanders)
    {
        if (inputCommander != reinterpret_cast<MemaInputCommander*>(sender) || nullptr != reinterpret_cast<MemaNetworkClientCommanderWrapper*>(sender))
            inputCommander->setInputMute(inputChannelNumber, muted, userId);
    }
 
    {
        const ScopedLock sl(m_audioDeviceIOCallbackLock);
        m_inputMuteStates[inputChannelNumber] = muted;
    }
 
    setTimedConfigurationDumpPending();
}
 
bool MemaProcessor::getMatrixCrosspointEnabledValue(std::uint16_t inputNumber, std::uint16_t outputNumber)
{
    jassert(inputNumber > 0 && outputNumber > 0);
    {
        const ScopedLock sl(m_audioDeviceIOCallbackLock);
        if (m_matrixCrosspointStates.count(inputNumber) != 0)
            if (m_matrixCrosspointStates.at(inputNumber).count(outputNumber) != 0)
                return m_matrixCrosspointStates.at(inputNumber).at(outputNumber);
    }
    jassertfalse;
    return false;
}
 
void MemaProcessor::setMatrixCrosspointEnabledValue(std::uint16_t inputNumber, std::uint16_t outputNumber, bool enabled, MemaChannelCommander* sender, int userId)
{
    jassert(inputNumber > 0 && outputNumber > 0);
 
    for (auto const& crosspointCommander : m_crosspointCommanders)
    {
        if (crosspointCommander != reinterpret_cast<MemaCrosspointCommander*>(sender) || nullptr != reinterpret_cast<MemaNetworkClientCommanderWrapper*>(sender))
            crosspointCommander->setCrosspointEnabledValue(inputNumber, outputNumber, enabled, userId);
    }
 
    {
        const ScopedLock sl(m_audioDeviceIOCallbackLock);
#ifdef DEBUG
        // check crosspoint existance - if it is not existing, we should somehow verify afterwards that the matrix symmetry is still given...
        jassert(0 != m_matrixCrosspointStates.count(inputNumber));
        if (0 != m_matrixCrosspointStates.count(inputNumber))
        {
            jassert(0 != m_matrixCrosspointStates.at(inputNumber).count(outputNumber));
        }
#endif
        m_matrixCrosspointStates[inputNumber][outputNumber] = enabled;
    }
 
    setTimedConfigurationDumpPending();
}
 
float MemaProcessor::getMatrixCrosspointFactorValue(std::uint16_t inputNumber, std::uint16_t outputNumber)
{
    jassert(inputNumber > 0 && outputNumber > 0);
    {
        const ScopedLock sl(m_audioDeviceIOCallbackLock);
        if (m_matrixCrosspointValues.count(inputNumber) != 0)
            if (m_matrixCrosspointValues.at(inputNumber).count(outputNumber) != 0)
                return m_matrixCrosspointValues.at(inputNumber).at(outputNumber);
    }
    jassertfalse;
    return 0.0f;
}
 
void MemaProcessor::setMatrixCrosspointFactorValue(std::uint16_t inputNumber, std::uint16_t outputNumber, float factor, MemaChannelCommander* sender, int userId)
{
    jassert(inputNumber > 0 && outputNumber > 0);
 
    for (auto const& crosspointCommander : m_crosspointCommanders)
    {
        if (crosspointCommander != reinterpret_cast<MemaCrosspointCommander*>(sender) || nullptr != reinterpret_cast<MemaNetworkClientCommanderWrapper*>(sender))
            crosspointCommander->setCrosspointFactorValue(inputNumber, outputNumber, factor, userId);
    }
 
    {
        const ScopedLock sl(m_audioDeviceIOCallbackLock);
#ifdef DEBUG
        // check crosspoint existance - if it is not existing, we should somehow verify afterwards that the matrix symmetry is still given...
        jassert(0 != m_matrixCrosspointValues.count(inputNumber));
        if (0 != m_matrixCrosspointValues.count(inputNumber))
        {
            jassert(0 != m_matrixCrosspointValues.at(inputNumber).count(outputNumber));
        }
#endif
        m_matrixCrosspointValues[inputNumber][outputNumber] = factor;
    }
 
    setTimedConfigurationDumpPending();
}
 
bool MemaProcessor::getOutputMuteState(std::uint16_t outputChannelNumber)
{
    jassert(outputChannelNumber > 0);
    const ScopedLock sl(m_audioDeviceIOCallbackLock);
    return m_outputMuteStates[outputChannelNumber];
}
 
void MemaProcessor::setOutputMuteState(std::uint16_t outputChannelNumber, bool muted, MemaChannelCommander* sender, int userId)
{
    jassert(outputChannelNumber > 0);
 
    for (auto const& outputCommander : m_outputCommanders)
    {
        if (outputCommander != reinterpret_cast<MemaOutputCommander*>(sender) || nullptr != reinterpret_cast<MemaNetworkClientCommanderWrapper*>(sender))
            outputCommander->setOutputMute(outputChannelNumber, muted, userId);
    }
 
    {
        const ScopedLock sl(m_audioDeviceIOCallbackLock);
        m_outputMuteStates[outputChannelNumber] = muted;
    }
 
    setTimedConfigurationDumpPending();
}
 
void MemaProcessor::setChannelCounts(std::uint16_t inputChannelCount, std::uint16_t outputChannelCount)
{
    auto reinitRequired = false;
    if (m_inputChannelCount != inputChannelCount)
    {
        m_inputChannelCount = inputChannelCount;
        reinitRequired = true;
    }
    if (m_outputChannelCount != outputChannelCount)
    {
        m_outputChannelCount = outputChannelCount;
        reinitRequired = true;
    }
    if (reinitRequired)
    {
        // Reconfigure plugin channel layout whenever either count changes: the correct
        // count depends on the current pre/post position (see configurePluginForCurrentPosition).
        {
            const ScopedLock sl(m_pluginProcessingLock);
            configurePluginForCurrentPosition();
        }
        postMessage(new ReinitIOCountMessage(m_inputChannelCount, m_outputChannelCount));
    }
}
 
void MemaProcessor::configurePluginForCurrentPosition()
{
    // Must be called under m_pluginProcessingLock.
    if (!m_pluginInstance)
        return;
 
    // AU plugins assert inside canApplyBusesLayout if setBusesLayout is called
    // while the plugin is in the prepared state. Release first so negotiation
    // always starts from a clean slate; prepareToPlay() re-prepares at the end.
    m_pluginInstance->releaseResources();
 
    // Pre-matrix: device input count is the upper bound for plugin I/O.
    // Post-matrix: device output count is the upper bound for plugin I/O.
    auto channelLimit = m_pluginPost ? m_outputChannelCount : m_inputChannelCount;
 
    // Walk from the widest possible count down to mono. At each count, all
    // named sets (speaker-labelled, including Atmos, ambisonics, etc.) are
    // offered first via channelSetsWithNumberOfChannels(), which covers every
    // format JUCE knows about for that count without requiring a hand-written
    // list. A generic discrete fallback is tried last for counts that have no
    // named set or whose named sets were all rejected.
    // This works correctly for any device channel count — 12, 32, 128, or more.
    auto tryLayout = [&](const juce::AudioChannelSet& candidate) -> bool
    {
        juce::AudioProcessor::BusesLayout layout;
        layout.inputBuses.add(candidate);
        layout.outputBuses.add(candidate);
 
        if (m_pluginInstance->setBusesLayout(layout))
        {
            m_pluginConfiguredChannelCount = candidate.size();
            m_pluginInstance->prepareToPlay(getSampleRate(), getBlockSize());
            return true;
        }
        return false;
    };
 
    for (int count = channelLimit; count >= 1; --count)
    {
        for (auto const& named : juce::AudioChannelSet::channelSetsWithNumberOfChannels(count))
            if (tryLayout(named))
                return;
 
        if (tryLayout(juce::AudioChannelSet::discreteChannels(count)))
            return;
    }
 
    // Absolute fallback: no layout was accepted at all — use the legacy API.
    m_pluginInstance->setPlayConfigDetails(channelLimit, channelLimit, getSampleRate(), getBlockSize());
    m_pluginConfiguredChannelCount = channelLimit;
    m_pluginInstance->prepareToPlay(getSampleRate(), getBlockSize());
}
 
bool MemaProcessor::setPlugin(const juce::PluginDescription& pluginDescription)
{
    juce::AudioPluginFormatManager formatManager;
    addDefaultFormatsToManager(formatManager);
    auto registeredFormats = formatManager.getFormats();
 
    auto success = false;
    juce::String errorMessage = "Unsupported plug-in format.";
 
    for (auto const& format : registeredFormats)
    {
        if (format->getName() == pluginDescription.pluginFormatName)
        {
            closePluginEditor();
 
            // threadsafe locking in scope to access plugin
            {
                const ScopedLock sl(m_pluginProcessingLock);
 
                // Detach listeners from the outgoing plugin instance before replacing it
                if (m_pluginInstance)
                {
                    for (auto const& param : m_pluginInstance->getParameters())
                        param->removeListener(this);
                }
 
                m_pluginParameterInfos.clear();
                m_pluginParameterDisplayOrder.clear();
 
                m_pluginInstance = format->createInstanceFromDescription(pluginDescription, getSampleRate(), getBlockSize(), errorMessage);
                if (m_pluginInstance)
                {
                    // Size the plugin correctly for its current pre/post position:
                    // pre-matrix → inputChannelCount × inputChannelCount
                    // post-matrix → outputChannelCount × outputChannelCount
                    configurePluginForCurrentPosition();
 
                    // Extract parameters here
                    m_pluginParameterInfos.clear();
                    for (auto const& param : m_pluginInstance->getParameters())
                        m_pluginParameterInfos.push_back(PluginParameterInfo::fromAudioProcessorParameter(*param));
                    postMessage(std::make_unique<PluginParameterInfosChangedMessage>().release());
 
                    // Attach listeners to track parameter changes
                    for (auto const& param : m_pluginInstance->getParameters())
                        param->addListener(this);
                }
            }
            success = errorMessage.isEmpty();
            break;
        }
    }
 
    if (!success)
        juce::AlertWindow::showMessageBoxAsync(juce::MessageBoxIconType::WarningIcon, "Loading error", "Loading of the selected plug-in " + pluginDescription.name + " failed.\n" + errorMessage);
    else if (onPluginSet)
        onPluginSet(pluginDescription);
 
    triggerConfigurationUpdate(false);
 
    return success;
}
 
juce::PluginDescription MemaProcessor::getPluginDescription()
{
    if (m_pluginInstance)
        return m_pluginInstance->getPluginDescription();
 
    return {};
}
 
void MemaProcessor::setPluginEnabledState(bool enabled)
{
    // threadsafe locking in scope to access plugin enabled
    {
        const ScopedLock sl(m_pluginProcessingLock);
        m_pluginEnabled = enabled;
    }
 
    for (auto& pluginCommander : m_pluginCommanders)
        pluginCommander->setPluginProcessingState(m_pluginEnabled, m_pluginPost);
 
    triggerConfigurationUpdate(false);
}
 
bool MemaProcessor::isPluginEnabled()
{
    return m_pluginEnabled;
}
 
void MemaProcessor::setPluginPrePostState(bool post)
{
    // threadsafe locking in scope to access plugin
    {
        const ScopedLock sl(m_pluginProcessingLock);
        if (m_pluginPost != post)
        {
            m_pluginPost = post;
            // Reconfigure channel layout for the new position before the audio thread
            // can route any buffers through the plugin:
            // pre-matrix → inputChannelCount × inputChannelCount
            // post-matrix → outputChannelCount × outputChannelCount
            configurePluginForCurrentPosition();
        }
    }
 
    for (auto& pluginCommander : m_pluginCommanders)
        pluginCommander->setPluginProcessingState(m_pluginEnabled, m_pluginPost);
 
    triggerConfigurationUpdate(false);
}
 
bool MemaProcessor::isPluginPost()
{
    return m_pluginPost;
}
 
void MemaProcessor::clearPlugin()
{
    closePluginEditor();
 
    // threadsafe locking in scope to access plugin
    {
        const ScopedLock sl(m_pluginProcessingLock);
        m_pluginInstance.reset();
        m_pluginParameterInfos.clear();
        m_pluginParameterDisplayOrder.clear();
    }
 
    postMessage(std::make_unique<PluginParameterInfosChangedMessage>().release());
 
    if (onPluginSet)
        onPluginSet(juce::PluginDescription());
 
    setPluginEnabledState(false);
}
 
void MemaProcessor::openPluginEditor()
{
    if (m_pluginInstance)
    {
        auto pluginEditorInstance = m_pluginInstance->createEditorIfNeeded();
        if (pluginEditorInstance && !m_pluginEditorWindow)
        {
            m_pluginEditorWindow = std::make_unique<ResizeableWindowWithTitleBarAndCloseCallback>(juce::JUCEApplication::getInstance()->getApplicationName() + " : " + m_pluginInstance->getName(), true);
            m_pluginEditorWindow->setResizable(false, false);
            m_pluginEditorWindow->setContentOwned(pluginEditorInstance, true);
            m_pluginEditorWindow->onClosed = [=]() { closePluginEditor(true); };
            m_pluginEditorWindow->setVisible(true);
        }
    }
}
 
void MemaProcessor::closePluginEditor(bool deleteEditorWindow)
{
    if (m_pluginInstance)
        std::unique_ptr<juce::AudioProcessorEditor>(m_pluginInstance->getActiveEditor()).reset();
    if (deleteEditorWindow)
        m_pluginEditorWindow.reset();
}
 
std::vector<PluginParameterInfo>& MemaProcessor::getPluginParameterInfos()
{
    return m_pluginParameterInfos;
}
 
void MemaProcessor::setPluginParameterRemoteControlInfos(int parameterIndex, bool remoteControllable, ParameterControlType type, int steps)
{
    if (parameterIndex >= 0 && parameterIndex < m_pluginParameterInfos.size())
    {
        m_pluginParameterInfos[parameterIndex].isRemoteControllable = remoteControllable;
        m_pluginParameterInfos[parameterIndex].type = type;
        m_pluginParameterInfos[parameterIndex].stepCount = steps;
 
        jassert(m_pluginInstance);
        if (m_pluginInstance)
        {
            m_pluginParameterInfos[parameterIndex].stepNames.clear();
            auto param = m_pluginInstance->getParameters()[parameterIndex];
            if (param && steps > 1)
            {
                auto stepSize = 1.0f / (steps - 1);
                for (int i = 0; i < steps; i++)
                {
                    m_pluginParameterInfos[parameterIndex].stepNames.push_back(param->getText(i * stepSize, 100).toStdString());
                }
            }
        }
 
        triggerConfigurationUpdate(false);
        postMessage(std::make_unique<PluginParameterInfosChangedMessage>().release());
    }
}
 
void MemaProcessor::setPluginParameterDisplayOrder(const std::vector<int>& order)
{
    m_pluginParameterDisplayOrder = order;
    triggerConfigurationUpdate(false);
    postMessage(std::make_unique<PluginParameterInfosChangedMessage>().release());
}
 
const std::vector<int>& MemaProcessor::getPluginParameterDisplayOrder() const
{
    return m_pluginParameterDisplayOrder;
}
 
bool MemaProcessor::isPluginParameterRemoteControllable(int parameterIndex)
{
    if (parameterIndex >= 0 && parameterIndex < m_pluginParameterInfos.size())
        return m_pluginParameterInfos[parameterIndex].isRemoteControllable;
    else
        return false;
}
 
float MemaProcessor::getPluginParameterValue(std::uint16_t parameterIndex) const
{
    if (!m_pluginInstance)
        return 0.0f;
 
    auto& parameters = m_pluginInstance->getParameters();
    auto idxInRange = parameterIndex >= 0 && parameterIndex < parameters.size();
    jassert(idxInRange);
    if (!idxInRange)
        return 0.0f;
 
    const ScopedLock sl(m_pluginProcessingLock);
    return parameters[parameterIndex]->getValue();
}
 
void MemaProcessor::setPluginParameterValue(std::uint16_t parameterIndex, std::string id, float normalizedValue, MemaPluginCommander* sender, int userId)
{
    if (!m_pluginInstance)
        return;
 
    auto& parameters = m_pluginInstance->getParameters();
    auto idxInRange = parameterIndex >= 0 && parameterIndex < parameters.size();
    jassert(idxInRange);
    if (!idxInRange)
        return;
 
    for (auto const& pluginCommander : m_pluginCommanders)
    {
        if (pluginCommander != reinterpret_cast<MemaPluginCommander*>(sender) || nullptr != static_cast<MemaNetworkClientCommanderWrapper*>(sender))
            pluginCommander->setPluginParameterValue(parameterIndex, id, normalizedValue, userId);
    }
 
 
    {
        const ScopedLock sl(m_pluginProcessingLock);
 
        parameters[parameterIndex]->setValue(normalizedValue);
 
        // Update cached value
        if (parameterIndex < m_pluginParameterInfos.size())
            m_pluginParameterInfos[parameterIndex].currentValue = normalizedValue;
    }
 
    setTimedConfigurationDumpPending();
}
 
juce::AudioProcessorParameter* MemaProcessor::getPluginParameter(int parameterIndex) const
{
    const ScopedLock sl(m_pluginProcessingLock);
 
    if (!m_pluginInstance)
        return nullptr;
 
    auto& parameters = m_pluginInstance->getParameters();
 
    if (parameterIndex >= 0 && parameterIndex < parameters.size())
        return parameters[parameterIndex];
 
    return nullptr;
}
 
AudioDeviceManager* MemaProcessor::getDeviceManager()
{
    if (m_deviceManager)
        return m_deviceManager.get();
    else
        return nullptr;
}
 
std::map<int, std::pair<double, bool>> MemaProcessor::getNetworkHealth()
{
    if (m_networkServer)
        return m_networkServer->getListHealth();
    else
        return {};
}
 
JUCEAppBasics::SessionServiceTopology MemaProcessor::getDiscoveredServicesTopology()
{
    if (m_serviceTopologyManager)
        return m_serviceTopologyManager->getDiscoveredServiceTopology();
    else
        return {};
}
 
//==============================================================================
const String MemaProcessor::getName() const
{
    return m_Name;
}
 
void MemaProcessor::prepareToPlay(double sampleRate, int maximumExpectedSamplesPerBlock)
{
    setRateAndBufferSizeDetails(sampleRate, maximumExpectedSamplesPerBlock);
 
    // threadsafe locking in scope to access plugin
    {
        const ScopedLock sl(m_pluginProcessingLock);
        // configurePluginForCurrentPosition calls setPlayConfigDetails before prepareToPlay,
        // ensuring the AU plugin's bus layout (and thus preparedChannels) matches the buffer
        // channel count. Calling prepareToPlay directly risks the AU reinitializing with its
        // default layout (e.g. stereo), causing a preparedChannels mismatch assertion.
        configurePluginForCurrentPosition();
    }
 
    if (m_inputDataAnalyzer)
        m_inputDataAnalyzer->initializeParameters(sampleRate, maximumExpectedSamplesPerBlock);
    if (m_outputDataAnalyzer)
        m_outputDataAnalyzer->initializeParameters(sampleRate, maximumExpectedSamplesPerBlock);
 
    postMessage(std::make_unique<AnalyzerParametersMessage>(int(sampleRate), maximumExpectedSamplesPerBlock).release());
}
 
void MemaProcessor::releaseResources()
{
    // threadsafe locking in scope to access plugin
    {
        const ScopedLock sl(m_pluginProcessingLock);
        if (m_pluginInstance)
            m_pluginInstance->releaseResources();
    }
 
    if (m_inputDataAnalyzer)
        m_inputDataAnalyzer->clearParameters();
    if (m_outputDataAnalyzer)
        m_outputDataAnalyzer->clearParameters();
}
 
void MemaProcessor::processBlock(AudioBuffer<float>& buffer, MidiBuffer& midiMessages)
{
    ignoreUnused(midiMessages);
 
    // the lock is currently gloablly taken in audioDeviceIOCallback which is calling this method
    //const ScopedLock sl(m_audioDeviceIOCallbackLock);
 
    auto reinitRequired = false;
 
    jassert(s_minInputsCount <= m_inputChannelCount);
    jassert(s_minOutputsCount <= m_outputChannelCount);
 
    if (m_inputChannelCount > m_inputMuteStates.size())
        reinitRequired = true;
 
    for (std::uint16_t input = 1; input <= m_inputChannelCount; input++)
    {
        if (m_inputMuteStates.count(input) != 0 && m_inputMuteStates.at(input))
        {
            auto channelIdx = input - 1;
            buffer.clear(channelIdx, 0, buffer.getNumSamples());
        }
    }
 
    postMessage(std::make_unique<AudioInputBufferMessage>(buffer).release());
 
    // threadsafe locking in scope to access plugin - processing only takes place if NOT set to post matrix
    {
        const ScopedLock sl(m_pluginProcessingLock);
        if (m_pluginInstance && m_pluginEnabled && !m_pluginPost)
        {
            // Pass a sub-buffer view sized to the negotiated plugin channel count.
            // This may be narrower than m_inputChannelCount when the plugin only
            // accepted a layout smaller than the device input count.
            juce::AudioBuffer<float> pluginBuffer(buffer.getArrayOfWritePointers(), m_pluginConfiguredChannelCount, buffer.getNumSamples());
            m_pluginInstance->processBlock(pluginBuffer, midiMessages);
        }
    }
 
    // process data in buffer to be what shall be used as output
    juce::AudioBuffer<float> processedBuffer;
    processedBuffer.setSize(m_outputChannelCount, buffer.getNumSamples(), false, true, true);
    for (std::uint16_t inputIdx = 0; inputIdx < m_inputChannelCount; inputIdx++)
    {
        for (std::uint16_t outputIdx = 0; outputIdx < m_outputChannelCount; outputIdx++)
        {
            if (0 != m_matrixCrosspointStates.count(inputIdx + 1) && 0 != m_matrixCrosspointValues.count(inputIdx + 1))
            {
                if (0 != m_matrixCrosspointStates[inputIdx + 1].count(outputIdx + 1) && 0 != m_matrixCrosspointValues[inputIdx + 1].count(outputIdx + 1))
                {
                    auto& enabled = m_matrixCrosspointStates.at(inputIdx + 1).at(outputIdx + 1);
                    auto& factor = m_matrixCrosspointValues.at(inputIdx + 1).at(outputIdx + 1);
                    auto gain = !enabled ? 0.0f : factor;
                    processedBuffer.addFrom(outputIdx, 0, buffer.getReadPointer(inputIdx), buffer.getNumSamples(), gain);
                }
            }
        }
    }
    buffer.makeCopyOf(processedBuffer, true);
 
    if (m_outputChannelCount > m_outputMuteStates.size())
        reinitRequired = true;
 
    // threadsafe locking in scope to access plugin - processing only takes place if set to post matrix
    {
        const ScopedLock sl(m_pluginProcessingLock);
        if (m_pluginInstance && m_pluginEnabled && m_pluginPost)
        {
            // Pass a sub-buffer view sized to the negotiated plugin channel count.
            // This may be narrower than m_outputChannelCount when the plugin only
            // accepted a layout smaller than the device output count.
            juce::AudioBuffer<float> pluginBuffer(buffer.getArrayOfWritePointers(), m_pluginConfiguredChannelCount, buffer.getNumSamples());
            m_pluginInstance->processBlock(pluginBuffer, midiMessages);
        }
    }
 
    for (std::uint16_t output = 1; output <= m_outputChannelCount; output++)
    {
        if (m_outputMuteStates.count(output) != 0 && m_outputMuteStates.at(output))
        {
            auto channelIdx = output - 1;
            buffer.clear(channelIdx, 0, buffer.getNumSamples());
        }
    }
 
    postMessage(std::make_unique<AudioOutputBufferMessage>(buffer).release());
 
    if (reinitRequired)
        postMessage(std::make_unique<ReinitIOCountMessage>(m_inputChannelCount, m_outputChannelCount).release());
}
 
void MemaProcessor::handleMessage(const Message& message)
{
    auto tId = SerializableMessage::SerializableMessageType::None;
    juce::MemoryBlock serializedMessageMemoryBlock;
 
    auto origId = -1;
    if (auto const sm = dynamic_cast<const SerializableMessage*>(&message))
        origId = sm->getId();
 
    if (auto const epm = dynamic_cast<const EnvironmentParametersMessage*>(&message))
    {
        serializedMessageMemoryBlock = epm->getSerializedMessage();
        tId = epm->getType();
    }
    else if (auto const apm = dynamic_cast<const AnalyzerParametersMessage*>(&message))
    {
        serializedMessageMemoryBlock = apm->getSerializedMessage();
        tId = apm->getType();
    }
    else if (auto const iom = dynamic_cast<const ReinitIOCountMessage*> (&message))
    {
        auto inputCount = iom->getInputCount();
        jassert(inputCount > 0);
        auto outputCount = iom->getOutputCount();
        jassert(outputCount > 0);
 
        for (auto const& inputCommander : m_inputCommanders)
            inputCommander->setChannelCount(inputCount);
        
        for (auto const& outputCommander : m_outputCommanders)
            outputCommander->setChannelCount(outputCount);
 
        for (auto const& crosspointCommander : m_crosspointCommanders)
            crosspointCommander->setIOCount(inputCount, outputCount);
 
        initializeCtrlValues(iom->getInputCount(), iom->getOutputCount());
 
        serializedMessageMemoryBlock = iom->getSerializedMessage();
 
        tId = iom->getType();
    }
    else if (auto m = dynamic_cast<const AudioBufferMessage*> (&message))
    {
        if (m->getFlowDirection() == AudioBufferMessage::FlowDirection::Input && m_inputDataAnalyzer)
        {
            m_inputDataAnalyzer->analyzeData(m->getAudioBuffer());
        }
        else if (m->getFlowDirection() == AudioBufferMessage::FlowDirection::Output && m_outputDataAnalyzer)
        {
            m_outputDataAnalyzer->analyzeData(m->getAudioBuffer());
        }
 
        serializedMessageMemoryBlock = m->getSerializedMessage();
 
        tId = m->getType();
    }
    else if (auto const cpm = dynamic_cast<const Mema::ControlParametersMessage*>(&message))
    {
        DBG(juce::String(__FUNCTION__) << " i:" << cpm->getInputMuteStates().size() << " o:" << cpm->getOutputMuteStates().size() << " c:" << cpm->getCrosspointStates().size());
        for (auto const& inputMuteState : cpm->getInputMuteStates())
            setInputMuteState(inputMuteState.first, inputMuteState.second, static_cast<MemaInputCommander*>(m_networkCommanderWrapper.get()));
        for (auto const& outputMuteState : cpm->getOutputMuteStates())
            setOutputMuteState(outputMuteState.first, outputMuteState.second, static_cast<MemaOutputCommander*>(m_networkCommanderWrapper.get()));
        for (auto const& crosspointStateKV : cpm->getCrosspointStates())
        {
            auto& inputNumber = crosspointStateKV.first;
            for (auto const& crosspointOStateKV : crosspointStateKV.second)
            {
                auto& outputNumber = crosspointOStateKV.first;
                setMatrixCrosspointEnabledValue(inputNumber, outputNumber, crosspointOStateKV.second, static_cast<MemaCrosspointCommander*>(m_networkCommanderWrapper.get()), origId);
            }
        }
        for (auto const& crosspointValueKV : cpm->getCrosspointValues())
        {
            auto& inputNumber = crosspointValueKV.first;
            for (auto const& crosspointOValueKV : crosspointValueKV.second)
            {
                auto& outputNumber = crosspointOValueKV.first;
                setMatrixCrosspointFactorValue(inputNumber, outputNumber, crosspointOValueKV.second, static_cast<MemaCrosspointCommander*>(m_networkCommanderWrapper.get()), origId);
            }
        }
 
        tId = cpm->getType();
    }
    else if (auto const dtsm = dynamic_cast<const Mema::DataTrafficTypeSelectionMessage*>(&message))
    {
        if (!dtsm->hasUserId())
            DBG("Incoming DataTrafficTypeSelecitonMessage cannot be associated with a connection");
        else
            setTrafficTypesForConnectionId(dtsm->getTrafficTypes(), origId);
 
        tId = dtsm->getType();
    }
    else if (auto const ppim = dynamic_cast<const PluginParameterInfosMessage*>(&message))
    {
        DBG(juce::String(__FUNCTION__) << " ppiCnt:" << ppim->getParameterInfos().size());
        
        jassertfalse; // why would parameterinfos of a plugin loaded in mema be changed externally?
 
        serializedMessageMemoryBlock = ppim->getSerializedMessage();
 
        tId = ppim->getType();
    }
    else if (auto const ppvm = dynamic_cast<const PluginParameterValueMessage*>(&message))
    {
        DBG(juce::String(__FUNCTION__) << " ppvIdx:" << int(ppvm->getParameterIndex()) << " > " << ppvm->getCurrentValue());
 
        setPluginParameterValue(ppvm->getParameterIndex(), ppvm->getParameterId().toStdString(), ppvm->getCurrentValue(), static_cast<MemaPluginCommander*>(m_networkCommanderWrapper.get()), origId);
 
        serializedMessageMemoryBlock = ppvm->getSerializedMessage();
 
        tId = ppvm->getType();
    }
    else if (auto const pesm = dynamic_cast<const PluginProcessingStateMessage*>(&message))
    {
        DBG(juce::String(__FUNCTION__) << " pluginEnabled:" << int(pesm->isEnabled()) << " pluginPost:" << int(pesm->isPost()));
 
        // Update state directly to avoid triggering the commander broadcasts (which would double-relay to other clients).
        // The fallthrough sendMessageToClients below handles relaying to other Mema.Re clients.
        {
            const ScopedLock sl(m_pluginProcessingLock);
            m_pluginEnabled = pesm->isEnabled();
            if (m_pluginPost != pesm->isPost())
            {
                m_pluginPost = pesm->isPost();
                configurePluginForCurrentPosition();
            }
        }
        triggerConfigurationUpdate(false);
 
        if (onPluginProcessingStateChanged)
            onPluginProcessingStateChanged(m_pluginEnabled, m_pluginPost);
 
        serializedMessageMemoryBlock = pesm->getSerializedMessage();
 
        tId = pesm->getType();
    }
    // exception - totally different message type, to decouple callback from processing asynchronously...
    else if (auto const ppicm = dynamic_cast<const PluginParameterInfosChangedMessage*>(&message))
    {
        // Build a copy of the parameter list in user-defined display order (falls back to natural order)
        auto orderedParams = m_pluginParameterInfos;
        if (!m_pluginParameterDisplayOrder.empty() && m_pluginParameterDisplayOrder.size() == m_pluginParameterInfos.size())
        {
            orderedParams.clear();
            for (int idx : m_pluginParameterDisplayOrder)
                if (idx >= 0 && idx < static_cast<int>(m_pluginParameterInfos.size()))
                    orderedParams.push_back(m_pluginParameterInfos[idx]);
            if (orderedParams.size() != m_pluginParameterInfos.size())
                orderedParams = m_pluginParameterInfos; // safety fallback
        }
 
        // Broadcast updated parameter infos to all connected network clients
        for (auto& pluginCommander : m_pluginCommanders)
            pluginCommander->setPluginParameterInfos(orderedParams,
                m_pluginInstance ? m_pluginInstance->getName().toStdString() : "",
                m_pluginEnabled, m_pluginPost);
 
        if (onPluginParameterInfosChanged)
            onPluginParameterInfosChanged();
 
        return; // ...abort further handling below here therefor
    }
 
    std::vector<int> sendIds;
    for (auto const& cId : m_trafficTypesPerConnection)
    {
        if (cId.first != origId) // avoid spamming the originator of the data with a resend
        {
            // if the connection did not define relevant traffic types, add its connectionId to list of recipients
            if (cId.second.empty())
                sendIds.push_back(cId.first);
            // if the traffic type is active for a connection, add the connectionId to list of recipients
            else if (cId.second.end() != std::find(cId.second.begin(), cId.second.end(), tId))
                sendIds.push_back(cId.first);
        }
    }
    if (!sendIds.empty())
        sendMessageToClients(serializedMessageMemoryBlock, sendIds);
}
 
void MemaProcessor::parameterValueChanged(int parameterIndex, float newValue)
{
    auto iter = std::find_if(getPluginParameterInfos().begin(), getPluginParameterInfos().end(), [=](const auto& info) { return info.index == parameterIndex; });
    if (iter != getPluginParameterInfos().end())
    {
        // Update commanders (UIs and Remotes)
        for (auto const& pluginCommander : m_pluginCommanders)
            pluginCommander->setPluginParameterValue(static_cast<std::uint16_t>(parameterIndex), iter->id.toStdString(), newValue);
 
        // Update cached value
        if (parameterIndex < m_pluginParameterInfos.size())
            m_pluginParameterInfos[parameterIndex].currentValue = newValue;
    }
}
 
void MemaProcessor::parameterGestureChanged(int parameterIndex, bool gestureIsStarting)
{
    ignoreUnused(parameterIndex);
    ignoreUnused(gestureIsStarting);
}
 
void MemaProcessor::sendMessageToClients(const MemoryBlock& messageMemoryBlock, const std::vector<int>& sendIds)
{
    if (m_networkServer && m_networkServer->hasActiveConnections())
    {
        if (!messageMemoryBlock.isEmpty() && !m_networkServer->enqueueMessage(messageMemoryBlock, sendIds))
        {
            auto deadConnectionIds = m_networkServer->cleanupDeadConnections();
            if (!deadConnectionIds.empty())
            {
                for (auto const& dcId : deadConnectionIds)
                    m_trafficTypesPerConnection.erase(dcId);
            }
        }
    }
}
 
double MemaProcessor::getTailLengthSeconds() const
{
    /*dbg*/return 0.0;
}
 
bool MemaProcessor::acceptsMidi() const
{
    return false;
}
 
bool MemaProcessor::producesMidi() const
{
    return false;
}
 
AudioProcessorEditor* MemaProcessor::createEditor()
{
    if (!m_processorEditor)
        m_processorEditor = std::make_unique<MemaProcessorEditor>(this);
 
    m_processorEditor->onResetToUnity = [=]() { initializeCtrlValuesToUnity(m_inputChannelCount, m_outputChannelCount); };
 
    return m_processorEditor.get();
}
 
bool MemaProcessor::hasEditor() const
{
    return !!m_processorEditor;
}
 
int MemaProcessor::getNumPrograms()
{
    /*dbg*/return 0;
}
 
int MemaProcessor::getCurrentProgram()
{
    /*dbg*/return 0;
}
 
void MemaProcessor::setCurrentProgram(int index)
{
    /*dbg*/ignoreUnused(index);
}
 
const String MemaProcessor::getProgramName(int index)
{
    /*dbg*/ignoreUnused(index);
    /*dbg*/return String();
}
 
void MemaProcessor::changeProgramName(int index, const String& newName)
{
    /*dbg*/ignoreUnused(index);
    /*dbg*/ignoreUnused(newName);
}
 
void MemaProcessor::getStateInformation(juce::MemoryBlock& destData)
{
    /*dbg*/ignoreUnused(destData);
}
 
void MemaProcessor::setStateInformation(const void* data, int sizeInBytes)
{
    /*dbg*/ignoreUnused(data);
    /*dbg*/ignoreUnused(sizeInBytes);
}
 
void MemaProcessor::audioDeviceIOCallbackWithContext(const float* const* inputChannelData, int numInputChannels,
    float* const* outputChannelData, int numOutputChannels, int numSamples, const AudioIODeviceCallbackContext& context)
{
    ignoreUnused(context);
    
    const juce::ScopedLock sl(m_audioDeviceIOCallbackLock);
 
    if (m_inputChannelCount != numInputChannels || m_outputChannelCount != numOutputChannels)
    {
        m_inputChannelCount = numInputChannels;
        m_outputChannelCount = numOutputChannels;
        postMessage(std::make_unique<ReinitIOCountMessage>(m_inputChannelCount, m_outputChannelCount).release());
    }
 
    auto maxActiveChannels = std::max(numInputChannels, numOutputChannels);
 
    if (s_maxChannelCount < maxActiveChannels)
    {
        jassertfalse;
        return;
    }
 
    // copy incoming data to processing data buffer
    for (auto i = 0; i < numInputChannels && i < maxActiveChannels; i++)
    {
        memcpy(m_processorChannels[i], inputChannelData[i], (size_t)numSamples * sizeof(float));
    }
 
    // from juce doxygen: buffer must be the size of max(inCh, outCh) and feeds the input data into the method and is returned with output data
    juce::AudioBuffer<float> audioBufferToProcess(m_processorChannels, maxActiveChannels, numSamples);
    juce::MidiBuffer midiBufferToProcess;
    processBlock(audioBufferToProcess, midiBufferToProcess);
 
    // copy the processed data buffer data to outgoing data
    auto processedChannelCount = audioBufferToProcess.getNumChannels();
    auto processedSampleCount = audioBufferToProcess.getNumSamples();
    auto processedData = audioBufferToProcess.getArrayOfReadPointers();
    jassert(processedSampleCount == numSamples);
    for (auto i = 0; i < numOutputChannels && i < processedChannelCount; i++)
    {
        memcpy(outputChannelData[i], processedData[i], (size_t)processedSampleCount * sizeof(float));
    }
 
}
 
void MemaProcessor::audioDeviceAboutToStart(AudioIODevice* device)
{
    if (device)
    {
        auto activeInputs = device->getActiveInputChannels();
        auto inputChannelCnt  = std::uint16_t(activeInputs.getHighestBit() + 1); // from JUCE documentation
        auto activeOutputs = device->getActiveOutputChannels();
        auto outputChannelCnt = std::uint16_t(activeOutputs.getHighestBit() + 1); // from JUCE documentation
        auto sampleRate = device->getCurrentSampleRate();
        auto bufferSize = device->getCurrentBufferSizeSamples();
        //auto bitDepth = device->getCurrentBitDepth();
        
        setPlayConfigDetails(inputChannelCnt, outputChannelCnt, sampleRate, bufferSize); // redundant to what happens in prepareToPlay to some extent...harmful?
        setChannelCounts(inputChannelCnt, outputChannelCnt);
        prepareToPlay(sampleRate, bufferSize);
    }
}
 
void MemaProcessor::audioDeviceStopped()
{
    releaseResources();
}
 
void MemaProcessor::changeListenerCallback(ChangeBroadcaster* source)
{
    if (source == m_deviceManager.get())
        setTimedConfigurationDumpPending();
}
 
void MemaProcessor::initializeCtrlValues(int inputCount, int outputCount)
{
    std::map<std::uint16_t, bool> inputMuteStates;
    std::map<std::uint16_t, bool> outputMuteStates;
    std::map<std::uint16_t, std::map<std::uint16_t, bool>> matrixCrosspointStates;
    std::map<std::uint16_t, std::map<std::uint16_t, float>> matrixCrosspointValues;
    {
        // copy the processing relevant variables to not block audio thread during all the xml handling
        const ScopedLock sl(m_audioDeviceIOCallbackLock);
        inputMuteStates = m_inputMuteStates;
        outputMuteStates = m_outputMuteStates;
        matrixCrosspointValues = m_matrixCrosspointValues;
        matrixCrosspointStates = m_matrixCrosspointStates;
    }
 
    auto inputChannelCount = std::uint16_t((inputCount > s_minInputsCount) ? inputCount : s_minInputsCount);
    for (std::uint16_t channel = 1; channel <= inputChannelCount; channel++)
        for (auto& inputCommander : m_inputCommanders)
            inputCommander->setInputMute(channel, inputMuteStates[channel]);
 
    auto outputChannelCount = std::uint16_t((outputCount > s_minOutputsCount) ? outputCount : s_minOutputsCount);
    for (std::uint16_t channel = 1; channel <= outputChannelCount; channel++)
        for (auto& outputCommander : m_outputCommanders)
            outputCommander->setOutputMute(channel, outputMuteStates[channel]);
 
    for (std::uint16_t in = 1; in <= inputChannelCount; in++)
    {
        for (std::uint16_t out = 1; out <= outputChannelCount; out++)
        {
            for (auto& crosspointCommander : m_crosspointCommanders)
            {
                crosspointCommander->setCrosspointEnabledValue(in, out, matrixCrosspointStates[in][out]);
                crosspointCommander->setCrosspointFactorValue(in, out, matrixCrosspointValues[in][out]);
            }
        }
    }
 
    juce::Array<juce::AudioProcessorParameter*> pluginParameters;
    juce::String pluginName;
    if (m_pluginInstance)
    {
        // copy the processing relevant data to not block audio thread during all the xml handling
        const ScopedLock sl(m_pluginProcessingLock);
        pluginName = m_pluginInstance->getName();
        pluginParameters = m_pluginInstance->getParameters();
    }
    auto pluginParameterInfos = Mema::PluginParameterInfo::parametersToInfos(pluginParameters);
    for (auto& pluginCommander : m_pluginCommanders)
        pluginCommander->setPluginParameterInfos(pluginParameterInfos, pluginName.toStdString(), m_pluginEnabled, m_pluginPost);
}
 
void MemaProcessor::initializeCtrlValuesToUnity(int inputCount, int outputCount)
{
    {
        const ScopedLock sl(m_audioDeviceIOCallbackLock);
        m_inputMuteStates.clear();
        m_outputMuteStates.clear();
        m_matrixCrosspointStates.clear();
        m_matrixCrosspointValues.clear();
    }
 
    auto inputChannelCount = (inputCount > s_minInputsCount) ? inputCount : s_minInputsCount;
    for (std::uint16_t channel = 1; channel <= inputChannelCount; channel++)
        setInputMuteState(channel, false);
    
    auto outputChannelCount = (outputCount > s_minOutputsCount) ? outputCount : s_minOutputsCount;
    for (std::uint16_t channel = 1; channel <= outputChannelCount; channel++)
        setOutputMuteState(channel, false);
 
    for (std::uint16_t in = 1; in <= inputChannelCount; in++)
    {
        for (std::uint16_t out = 1; out <= outputChannelCount; out++)
        {
            setMatrixCrosspointEnabledValue(in, out, in == out);
            setMatrixCrosspointFactorValue(in, out, 1.0f);
        }
    }
}
 
void MemaProcessor::initializeCtrlValuesToUnity()
{
    initializeCtrlValuesToUnity(m_inputChannelCount, m_outputChannelCount);
}
 
void MemaProcessor::setTrafficTypesForConnectionId(const std::vector<SerializableMessage::SerializableMessageType>& trafficTypes, int connectionId)
{
    DBG(juce::String(__FUNCTION__) << " " << connectionId << " chose " << trafficTypes.size() << " types");
    for (auto const& tt : trafficTypes)
    {
        if (m_trafficTypesPerConnection[connectionId].end() == std::find(m_trafficTypesPerConnection[connectionId].begin(), m_trafficTypesPerConnection[connectionId].end(), tt))
            m_trafficTypesPerConnection[connectionId].push_back(tt);
    }
}
 
 
} // namespace Mema