/////////////////////////////////////////////////////////////////////////////////// // Copyright (C) 2017 Edouard Griffiths, F4EXB. // // // // Swagger server adapter interface // // // // This program 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 as version 3 of the License, or // // (at your option) any later version. // // // // This program 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 V3 for more details. // // // // You should have received a copy of the GNU General Public License // // along with this program. If not, see . // /////////////////////////////////////////////////////////////////////////////////// #include #include #include #include #include "SWGInstanceSummaryResponse.h" #include "SWGInstanceConfigResponse.h" #include "SWGInstanceDevicesResponse.h" #include "SWGInstanceChannelsResponse.h" #include "SWGLoggingInfo.h" #include "SWGAudioDevices.h" #include "SWGLocationInformation.h" #include "SWGDVSerialDevices.h" #include "SWGAMBEDevices.h" #include "SWGPresetImport.h" #include "SWGPresetExport.h" #include "SWGPresets.h" #include "SWGPresetTransfer.h" #include "SWGDeviceSettings.h" #include "SWGChannelsDetail.h" #include "SWGChannelSettings.h" #include "SWGChannelReport.h" #include "SWGSuccessResponse.h" #include "SWGErrorResponse.h" #include "SWGDeviceState.h" #include "SWGDeviceReport.h" #include "maincore.h" #include "loggerwithfile.h" #include "device/deviceset.h" #include "device/deviceapi.h" #include "device/deviceenumerator.h" #include "dsp/devicesamplesink.h" #include "dsp/devicesamplesource.h" #include "dsp/devicesamplemimo.h" #include "dsp/dspdevicesourceengine.h" #include "dsp/dspdevicesinkengine.h" #include "dsp/dspdevicemimoengine.h" #include "dsp/dspengine.h" #include "channel/channelapi.h" #include "plugin/pluginapi.h" #include "plugin/pluginmanager.h" #include "webapi/webapiadapterbase.h" #include "webapiadaptersrv.h" WebAPIAdapterSrv::WebAPIAdapterSrv(MainCore& mainCore) : m_mainCore(mainCore) { } WebAPIAdapterSrv::~WebAPIAdapterSrv() { } int WebAPIAdapterSrv::instanceSummary( SWGSDRangel::SWGInstanceSummaryResponse& response, SWGSDRangel::SWGErrorResponse& error) { response.init(); *response.getAppname() = QCoreApplication::applicationName(); *response.getVersion() = QCoreApplication::applicationVersion(); *response.getQtVersion() = QString(QT_VERSION_STR); response.setDspRxBits(SDR_RX_SAMP_SZ); response.setDspTxBits(SDR_TX_SAMP_SZ); response.setPid(QCoreApplication::applicationPid()); #if QT_VERSION >= 0x050400 *response.getArchitecture() = QString(QSysInfo::currentCpuArchitecture()); *response.getOs() = QString(QSysInfo::prettyProductName()); #endif SWGSDRangel::SWGLoggingInfo *logging = response.getLogging(); logging->init(); logging->setDumpToFile(m_mainCore.m_logger->getUseFileLogger() ? 1 : 0); if (logging->getDumpToFile()) { m_mainCore.m_logger->getLogFileName(*logging->getFileName()); m_mainCore.m_logger->getFileMinMessageLevelStr(*logging->getFileLevel()); } m_mainCore.m_logger->getConsoleMinMessageLevelStr(*logging->getConsoleLevel()); SWGSDRangel::SWGDeviceSetList *deviceSetList = response.getDevicesetlist(); getDeviceSetList(deviceSetList); return 200; } int WebAPIAdapterSrv::instanceDelete( SWGSDRangel::SWGSuccessResponse& response, SWGSDRangel::SWGErrorResponse& error) { MainCore::MsgDeleteInstance *msg = MainCore::MsgDeleteInstance::create(); m_mainCore.getInputMessageQueue()->push(msg); response.init(); *response.getMessage() = QString("Message to stop the SDRangel instance (MsgDeleteInstance) was submitted successfully"); return 202; } int WebAPIAdapterSrv::instanceConfigGet( SWGSDRangel::SWGInstanceConfigResponse& response, SWGSDRangel::SWGErrorResponse& error) { response.init(); WebAPIAdapterBase webAPIAdapterBase; webAPIAdapterBase.setPluginManager(m_mainCore.getPluginManager()); SWGSDRangel::SWGPreferences *preferences = response.getPreferences(); WebAPIAdapterBase::webapiFormatPreferences(preferences, m_mainCore.getMainSettings().getPreferences()); SWGSDRangel::SWGPreset *workingPreset = response.getWorkingPreset(); webAPIAdapterBase.webapiFormatPreset(workingPreset, m_mainCore.getMainSettings().getWorkingPresetConst()); int nbPresets = m_mainCore.m_settings.getPresetCount(); QList *swgPresets = response.getPresets(); for (int i = 0; i < nbPresets; i++) { const Preset *preset = m_mainCore.m_settings.getPreset(i); swgPresets->append(new SWGSDRangel::SWGPreset); webAPIAdapterBase.webapiFormatPreset(swgPresets->back(), *preset); } int nbCommands = m_mainCore.m_settings.getCommandCount(); QList *swgCommands = response.getCommands(); for (int i = 0; i < nbCommands; i++) { const Command *command = m_mainCore.m_settings.getCommand(i); swgCommands->append(new SWGSDRangel::SWGCommand); WebAPIAdapterBase::webapiFormatCommand(swgCommands->back(), *command); } return 200; } int WebAPIAdapterSrv::instanceConfigPutPatch( bool force, // PUT else PATCH SWGSDRangel::SWGInstanceConfigResponse& query, const ConfigKeys& configKeys, SWGSDRangel::SWGSuccessResponse& response, SWGSDRangel::SWGErrorResponse& error) { WebAPIAdapterBase webAPIAdapterBase; webAPIAdapterBase.setPluginManager(m_mainCore.getPluginManager()); if (force) { webAPIAdapterBase.webapiInitConfig(m_mainCore.m_settings); } Preferences newPreferences = m_mainCore.m_settings.getPreferences(); webAPIAdapterBase.webapiUpdatePreferences(query.getPreferences(), configKeys.m_preferencesKeys, newPreferences); m_mainCore.m_settings.setPreferences(newPreferences); Preset *workingPreset = m_mainCore.m_settings.getWorkingPreset(); webAPIAdapterBase.webapiUpdatePreset(force, query.getWorkingPreset(), configKeys.m_workingPresetKeys, workingPreset); QList::const_iterator presetKeysIt = configKeys.m_presetKeys.begin(); int i = 0; for (; presetKeysIt != configKeys.m_presetKeys.end(); ++presetKeysIt, i++) { Preset *newPreset = new Preset(); // created with default values SWGSDRangel::SWGPreset *swgPreset = query.getPresets()->at(i); webAPIAdapterBase.webapiUpdatePreset(force, swgPreset, *presetKeysIt, newPreset); m_mainCore.m_settings.addPreset(newPreset); } QList::const_iterator commandKeysIt = configKeys.m_commandKeys.begin(); i = 0; for (; commandKeysIt != configKeys.m_commandKeys.end(); ++commandKeysIt, i++) { Command *newCommand = new Command(); // created with default values SWGSDRangel::SWGCommand *swgCommand = query.getCommands()->at(i); webAPIAdapterBase.webapiUpdateCommand(swgCommand, *commandKeysIt, *newCommand); m_mainCore.m_settings.addCommand(newCommand); } MainCore::MsgApplySettings *msg = MainCore::MsgApplySettings::create(); m_mainCore.m_inputMessageQueue.push(msg); return 200; } int WebAPIAdapterSrv::instanceDevices( int direction, SWGSDRangel::SWGInstanceDevicesResponse& response, SWGSDRangel::SWGErrorResponse& error) { response.init(); int nbSamplingDevices; if (direction == 0) { // Single Rx stream device nbSamplingDevices = DeviceEnumerator::instance()->getNbRxSamplingDevices(); } else if (direction == 1) { // Single Tx stream device nbSamplingDevices = DeviceEnumerator::instance()->getNbTxSamplingDevices(); } else if (direction == 2) { // MIMO device nbSamplingDevices = DeviceEnumerator::instance()->getNbMIMOSamplingDevices(); } else { // not supported nbSamplingDevices = 0; } response.setDevicecount(nbSamplingDevices); QList *devices = response.getDevices(); for (int i = 0; i < nbSamplingDevices; i++) { const PluginInterface::SamplingDevice *samplingDevice = nullptr; if (direction == 0) { samplingDevice = DeviceEnumerator::instance()->getRxSamplingDevice(i); } else if (direction == 1) { samplingDevice = DeviceEnumerator::instance()->getTxSamplingDevice(i); } else if (direction == 2) { samplingDevice = DeviceEnumerator::instance()->getMIMOSamplingDevice(i); } else { continue; } devices->append(new SWGSDRangel::SWGDeviceListItem); devices->back()->init(); *devices->back()->getDisplayedName() = samplingDevice->displayedName; *devices->back()->getHwType() = samplingDevice->hardwareId; *devices->back()->getSerial() = samplingDevice->serial; devices->back()->setSequence(samplingDevice->sequence); devices->back()->setDirection((int) samplingDevice->streamType); devices->back()->setDeviceNbStreams(samplingDevice->deviceNbItems); devices->back()->setDeviceSetIndex(samplingDevice->claimed); devices->back()->setIndex(i); } return 200; } int WebAPIAdapterSrv::instanceChannels( int direction, SWGSDRangel::SWGInstanceChannelsResponse& response, SWGSDRangel::SWGErrorResponse& error) { response.init(); PluginAPI::ChannelRegistrations *channelRegistrations; int nbChannelDevices; if (direction == 0) // Single sink (Rx) channel { channelRegistrations = m_mainCore.m_pluginManager->getRxChannelRegistrations(); nbChannelDevices = channelRegistrations->size(); } else if (direction == 1) // Single source (Tx) channel { channelRegistrations = m_mainCore.m_pluginManager->getTxChannelRegistrations(); nbChannelDevices = channelRegistrations->size(); } else if (direction == 2) // MIMO channel { channelRegistrations = m_mainCore.m_pluginManager->getMIMOChannelRegistrations(); nbChannelDevices = channelRegistrations->size(); } else // not supported { channelRegistrations = nullptr; nbChannelDevices = 0; } response.setChannelcount(nbChannelDevices); QList *channels = response.getChannels(); for (int i = 0; i < nbChannelDevices; i++) { channels->append(new SWGSDRangel::SWGChannelListItem); channels->back()->init(); PluginInterface *channelInterface = channelRegistrations->at(i).m_plugin; const PluginDescriptor& pluginDescriptor = channelInterface->getPluginDescriptor(); *channels->back()->getVersion() = pluginDescriptor.version; *channels->back()->getName() = pluginDescriptor.displayedName; channels->back()->setDirection(direction); *channels->back()->getIdUri() = channelRegistrations->at(i).m_channelIdURI; *channels->back()->getId() = channelRegistrations->at(i).m_channelId; channels->back()->setIndex(i); } return 200; } int WebAPIAdapterSrv::instanceLoggingGet( SWGSDRangel::SWGLoggingInfo& response, SWGSDRangel::SWGErrorResponse& error) { response.init(); response.setDumpToFile(m_mainCore.m_logger->getUseFileLogger() ? 1 : 0); if (response.getDumpToFile()) { m_mainCore.m_logger->getLogFileName(*response.getFileName()); m_mainCore.m_logger->getFileMinMessageLevelStr(*response.getFileLevel()); } m_mainCore.m_logger->getConsoleMinMessageLevelStr(*response.getConsoleLevel()); return 200; } int WebAPIAdapterSrv::instanceLoggingPut( SWGSDRangel::SWGLoggingInfo& query, SWGSDRangel::SWGLoggingInfo& response, SWGSDRangel::SWGErrorResponse& error) { // response input is the query actually bool dumpToFile = (query.getDumpToFile() != 0); QString* consoleLevel = query.getConsoleLevel(); QString* fileLevel = query.getFileLevel(); QString* fileName = query.getFileName(); // perform actions if (consoleLevel) { m_mainCore.m_settings.setConsoleMinLogLevel(getMsgTypeFromString(*consoleLevel)); } if (fileLevel) { m_mainCore.m_settings.setFileMinLogLevel(getMsgTypeFromString(*fileLevel)); } m_mainCore.m_settings.setUseLogFile(dumpToFile); if (fileName) { m_mainCore.m_settings.setLogFileName(*fileName); } m_mainCore.setLoggingOptions(); // build response response.init(); getMsgTypeString(m_mainCore.m_settings.getConsoleMinLogLevel(), *response.getConsoleLevel()); response.setDumpToFile(m_mainCore.m_settings.getUseLogFile() ? 1 : 0); getMsgTypeString(m_mainCore.m_settings.getFileMinLogLevel(), *response.getFileLevel()); *response.getFileName() = m_mainCore.m_settings.getLogFileName(); return 200; } int WebAPIAdapterSrv::instanceAudioGet( SWGSDRangel::SWGAudioDevices& response, SWGSDRangel::SWGErrorResponse& error) { const QList& audioInputDevices = m_mainCore.m_dspEngine->getAudioDeviceManager()->getInputDevices(); const QList& audioOutputDevices = m_mainCore.m_dspEngine->getAudioDeviceManager()->getOutputDevices(); int nbInputDevices = audioInputDevices.size(); int nbOutputDevices = audioOutputDevices.size(); response.init(); response.setNbInputDevices(nbInputDevices); response.setNbOutputDevices(nbOutputDevices); QList *inputDevices = response.getInputDevices(); QList *outputDevices = response.getOutputDevices(); AudioDeviceManager::InputDeviceInfo inputDeviceInfo; AudioDeviceManager::OutputDeviceInfo outputDeviceInfo; // system default input device inputDevices->append(new SWGSDRangel::SWGAudioInputDevice); inputDevices->back()->init(); bool found = m_mainCore.m_dspEngine->getAudioDeviceManager()->getInputDeviceInfo(AudioDeviceManager::m_defaultDeviceName, inputDeviceInfo); *inputDevices->back()->getName() = AudioDeviceManager::m_defaultDeviceName; inputDevices->back()->setIndex(-1); inputDevices->back()->setSampleRate(inputDeviceInfo.sampleRate); inputDevices->back()->setIsSystemDefault(0); inputDevices->back()->setDefaultUnregistered(found ? 0 : 1); inputDevices->back()->setVolume(inputDeviceInfo.volume); // real input devices for (int i = 0; i < nbInputDevices; i++) { inputDevices->append(new SWGSDRangel::SWGAudioInputDevice); inputDevices->back()->init(); inputDeviceInfo.resetToDefaults(); found = m_mainCore.m_dspEngine->getAudioDeviceManager()->getInputDeviceInfo(audioInputDevices.at(i).deviceName(), inputDeviceInfo); *inputDevices->back()->getName() = audioInputDevices.at(i).deviceName(); inputDevices->back()->setIndex(i); inputDevices->back()->setSampleRate(inputDeviceInfo.sampleRate); inputDevices->back()->setIsSystemDefault(audioInputDevices.at(i).deviceName() == QAudioDeviceInfo::defaultInputDevice().deviceName() ? 1 : 0); inputDevices->back()->setDefaultUnregistered(found ? 0 : 1); inputDevices->back()->setVolume(inputDeviceInfo.volume); } // system default output device outputDevices->append(new SWGSDRangel::SWGAudioOutputDevice); outputDevices->back()->init(); found = m_mainCore.m_dspEngine->getAudioDeviceManager()->getOutputDeviceInfo(AudioDeviceManager::m_defaultDeviceName, outputDeviceInfo); *outputDevices->back()->getName() = AudioDeviceManager::m_defaultDeviceName; outputDevices->back()->setIndex(-1); outputDevices->back()->setSampleRate(outputDeviceInfo.sampleRate); inputDevices->back()->setIsSystemDefault(0); outputDevices->back()->setDefaultUnregistered(found ? 0 : 1); outputDevices->back()->setCopyToUdp(outputDeviceInfo.copyToUDP ? 1 : 0); outputDevices->back()->setUdpUsesRtp(outputDeviceInfo.udpUseRTP ? 1 : 0); outputDevices->back()->setUdpChannelMode((int) outputDeviceInfo.udpChannelMode); outputDevices->back()->setUdpChannelCodec((int) outputDeviceInfo.udpChannelCodec); outputDevices->back()->setUdpDecimationFactor(outputDeviceInfo.udpDecimationFactor); *outputDevices->back()->getUdpAddress() = outputDeviceInfo.udpAddress; outputDevices->back()->setUdpPort(outputDeviceInfo.udpPort); // real output devices for (int i = 0; i < nbOutputDevices; i++) { outputDevices->append(new SWGSDRangel::SWGAudioOutputDevice); outputDevices->back()->init(); outputDeviceInfo.resetToDefaults(); found = m_mainCore.m_dspEngine->getAudioDeviceManager()->getOutputDeviceInfo(audioOutputDevices.at(i).deviceName(), outputDeviceInfo); *outputDevices->back()->getName() = audioOutputDevices.at(i).deviceName(); outputDevices->back()->setIndex(i); outputDevices->back()->setSampleRate(outputDeviceInfo.sampleRate); outputDevices->back()->setIsSystemDefault(audioOutputDevices.at(i).deviceName() == QAudioDeviceInfo::defaultOutputDevice().deviceName() ? 1 : 0); outputDevices->back()->setDefaultUnregistered(found ? 0 : 1); outputDevices->back()->setCopyToUdp(outputDeviceInfo.copyToUDP ? 1 : 0); outputDevices->back()->setUdpUsesRtp(outputDeviceInfo.udpUseRTP ? 1 : 0); outputDevices->back()->setUdpChannelMode((int) outputDeviceInfo.udpChannelMode); outputDevices->back()->setUdpChannelCodec((int) outputDeviceInfo.udpChannelCodec); outputDevices->back()->setUdpDecimationFactor(outputDeviceInfo.udpDecimationFactor); *outputDevices->back()->getUdpAddress() = outputDeviceInfo.udpAddress; outputDevices->back()->setUdpPort(outputDeviceInfo.udpPort); } return 200; } int WebAPIAdapterSrv::instanceAudioInputPatch( SWGSDRangel::SWGAudioInputDevice& response, const QStringList& audioInputKeys, SWGSDRangel::SWGErrorResponse& error) { // TODO AudioDeviceManager::InputDeviceInfo inputDeviceInfo; QString deviceName; int deviceIndex = response.getIndex(); if (!m_mainCore.m_dspEngine->getAudioDeviceManager()->getInputDeviceName(deviceIndex, deviceName)) { error.init(); *error.getMessage() = QString("There is no input audio device at index %1").arg(deviceIndex); return 404; } m_mainCore.m_dspEngine->getAudioDeviceManager()->getInputDeviceInfo(deviceName, inputDeviceInfo); if (audioInputKeys.contains("sampleRate")) { inputDeviceInfo.sampleRate = response.getSampleRate(); } if (audioInputKeys.contains("volume")) { inputDeviceInfo.volume = response.getVolume(); } m_mainCore.m_dspEngine->getAudioDeviceManager()->setInputDeviceInfo(deviceIndex, inputDeviceInfo); m_mainCore.m_dspEngine->getAudioDeviceManager()->getInputDeviceInfo(deviceName, inputDeviceInfo); response.setSampleRate(inputDeviceInfo.sampleRate); response.setVolume(inputDeviceInfo.volume); return 200; } int WebAPIAdapterSrv::instanceAudioOutputPatch( SWGSDRangel::SWGAudioOutputDevice& response, const QStringList& audioOutputKeys, SWGSDRangel::SWGErrorResponse& error) { AudioDeviceManager::OutputDeviceInfo outputDeviceInfo; QString deviceName; int deviceIndex = response.getIndex(); if (!m_mainCore.m_dspEngine->getAudioDeviceManager()->getOutputDeviceName(deviceIndex, deviceName)) { error.init(); *error.getMessage() = QString("There is no output audio device at index %1").arg(deviceIndex); return 404; } m_mainCore.m_dspEngine->getAudioDeviceManager()->getOutputDeviceInfo(deviceName, outputDeviceInfo); if (audioOutputKeys.contains("sampleRate")) { outputDeviceInfo.sampleRate = response.getSampleRate(); } if (audioOutputKeys.contains("copyToUDP")) { outputDeviceInfo.copyToUDP = response.getCopyToUdp() == 0 ? 0 : 1; } if (audioOutputKeys.contains("udpUsesRTP")) { outputDeviceInfo.udpUseRTP = response.getUdpUsesRtp() == 0 ? 0 : 1; } if (audioOutputKeys.contains("udpChannelMode")) { outputDeviceInfo.udpChannelMode = static_cast(response.getUdpChannelMode() % 4); } if (audioOutputKeys.contains("udpAddress")) { outputDeviceInfo.udpAddress = *response.getUdpAddress(); } if (audioOutputKeys.contains("udpPort")) { outputDeviceInfo.udpPort = response.getUdpPort() % (1<<16); } m_mainCore.m_dspEngine->getAudioDeviceManager()->setOutputDeviceInfo(deviceIndex, outputDeviceInfo); m_mainCore.m_dspEngine->getAudioDeviceManager()->getOutputDeviceInfo(deviceName, outputDeviceInfo); response.setSampleRate(outputDeviceInfo.sampleRate); response.setCopyToUdp(outputDeviceInfo.copyToUDP == 0 ? 0 : 1); response.setUdpUsesRtp(outputDeviceInfo.udpUseRTP == 0 ? 0 : 1); response.setUdpChannelMode(outputDeviceInfo.udpChannelMode); response.setUdpChannelCodec(outputDeviceInfo.udpChannelCodec); response.setUdpDecimationFactor(outputDeviceInfo.udpDecimationFactor); if (response.getUdpAddress()) { *response.getUdpAddress() = outputDeviceInfo.udpAddress; } else { response.setUdpAddress(new QString(outputDeviceInfo.udpAddress)); } response.setUdpPort(outputDeviceInfo.udpPort % (1<<16)); return 200; } int WebAPIAdapterSrv::instanceAudioInputDelete( SWGSDRangel::SWGAudioInputDevice& response, SWGSDRangel::SWGErrorResponse& error) { AudioDeviceManager::InputDeviceInfo inputDeviceInfo; QString deviceName; int deviceIndex = response.getIndex(); if (!m_mainCore.m_dspEngine->getAudioDeviceManager()->getInputDeviceName(deviceIndex, deviceName)) { error.init(); *error.getMessage() = QString("There is no audio input device at index %1").arg(deviceIndex); return 404; } m_mainCore.m_dspEngine->getAudioDeviceManager()->unsetInputDeviceInfo(deviceIndex); m_mainCore.m_dspEngine->getAudioDeviceManager()->getInputDeviceInfo(deviceName, inputDeviceInfo); response.setSampleRate(inputDeviceInfo.sampleRate); response.setVolume(inputDeviceInfo.volume); return 200; } int WebAPIAdapterSrv::instanceAudioOutputDelete( SWGSDRangel::SWGAudioOutputDevice& response, SWGSDRangel::SWGErrorResponse& error) { AudioDeviceManager::OutputDeviceInfo outputDeviceInfo; QString deviceName; int deviceIndex = response.getIndex(); if (!m_mainCore.m_dspEngine->getAudioDeviceManager()->getOutputDeviceName(deviceIndex, deviceName)) { error.init(); *error.getMessage() = QString("There is no audio output device at index %1").arg(deviceIndex); return 404; } m_mainCore.m_dspEngine->getAudioDeviceManager()->unsetInputDeviceInfo(deviceIndex); m_mainCore.m_dspEngine->getAudioDeviceManager()->getOutputDeviceInfo(deviceName, outputDeviceInfo); response.setSampleRate(outputDeviceInfo.sampleRate); response.setCopyToUdp(outputDeviceInfo.copyToUDP == 0 ? 0 : 1); response.setUdpUsesRtp(outputDeviceInfo.udpUseRTP == 0 ? 0 : 1); response.setUdpChannelMode(outputDeviceInfo.udpChannelMode); response.setUdpChannelCodec(outputDeviceInfo.udpChannelCodec); response.setUdpDecimationFactor(outputDeviceInfo.udpDecimationFactor); if (response.getUdpAddress()) { *response.getUdpAddress() = outputDeviceInfo.udpAddress; } else { response.setUdpAddress(new QString(outputDeviceInfo.udpAddress)); } response.setUdpPort(outputDeviceInfo.udpPort % (1<<16)); return 200; } int WebAPIAdapterSrv::instanceAudioInputCleanupPatch( SWGSDRangel::SWGSuccessResponse& response, SWGSDRangel::SWGErrorResponse& error) { m_mainCore.m_dspEngine->getAudioDeviceManager()->inputInfosCleanup(); response.init(); *response.getMessage() = QString("Unregistered parameters for devices not in list of available input devices for this instance"); return 200; } int WebAPIAdapterSrv::instanceAudioOutputCleanupPatch( SWGSDRangel::SWGSuccessResponse& response, SWGSDRangel::SWGErrorResponse& error) { m_mainCore.m_dspEngine->getAudioDeviceManager()->outputInfosCleanup(); response.init(); *response.getMessage() = QString("Unregistered parameters for devices not in list of available output devices for this instance"); return 200; } int WebAPIAdapterSrv::instanceLocationGet( SWGSDRangel::SWGLocationInformation& response, SWGSDRangel::SWGErrorResponse& error) { response.init(); response.setLatitude(m_mainCore.m_settings.getLatitude()); response.setLongitude(m_mainCore.m_settings.getLongitude()); return 200; } int WebAPIAdapterSrv::instanceLocationPut( SWGSDRangel::SWGLocationInformation& response, SWGSDRangel::SWGErrorResponse& error) { float latitude = response.getLatitude(); float longitude = response.getLongitude(); latitude = latitude < -90.0 ? -90.0 : latitude > 90.0 ? 90.0 : latitude; longitude = longitude < -180.0 ? -180.0 : longitude > 180.0 ? 180.0 : longitude; m_mainCore.m_settings.setLatitude(latitude); m_mainCore.m_settings.setLongitude(longitude); response.setLatitude(m_mainCore.m_settings.getLatitude()); response.setLongitude(m_mainCore.m_settings.getLongitude()); return 200; } int WebAPIAdapterSrv::instanceDVSerialGet( SWGSDRangel::SWGDVSerialDevices& response, SWGSDRangel::SWGErrorResponse& error) { response.init(); std::vector deviceNames; m_mainCore.m_dspEngine->getDVSerialNames(deviceNames); response.setNbDevices((int) deviceNames.size()); QList *deviceNamesList = response.getDvSerialDevices(); std::vector::iterator it = deviceNames.begin(); while (it != deviceNames.end()) { deviceNamesList->append(new SWGSDRangel::SWGDVSerialDevice); deviceNamesList->back()->init(); *deviceNamesList->back()->getDeviceName() = QString::fromStdString(*it); ++it; } return 200; } int WebAPIAdapterSrv::instanceDVSerialPatch( bool dvserial, SWGSDRangel::SWGDVSerialDevices& response, SWGSDRangel::SWGErrorResponse& error) { m_mainCore.m_dspEngine->setDVSerialSupport(dvserial); response.init(); if (dvserial) { std::vector deviceNames; m_mainCore.m_dspEngine->getDVSerialNames(deviceNames); response.setNbDevices((int) deviceNames.size()); QList *deviceNamesList = response.getDvSerialDevices(); std::vector::iterator it = deviceNames.begin(); std::string deviceNamesStr = "DV Serial devices found: "; while (it != deviceNames.end()) { deviceNamesList->append(new SWGSDRangel::SWGDVSerialDevice); deviceNamesList->back()->init(); *deviceNamesList->back()->getDeviceName() = QString::fromStdString(*it); ++it; } } else { response.setNbDevices(0); } return 200; } int WebAPIAdapterSrv::instanceAMBESerialGet( SWGSDRangel::SWGDVSerialDevices& response, SWGSDRangel::SWGErrorResponse& error) { (void) error; response.init(); std::vector deviceNames; std::vector qDeviceNames; m_mainCore.m_dspEngine->getAMBEEngine()->scan(qDeviceNames); for (std::vector::const_iterator it = qDeviceNames.begin(); it != qDeviceNames.end(); ++it) { deviceNames.push_back(it->toStdString()); } response.setNbDevices((int) deviceNames.size()); QList *deviceNamesList = response.getDvSerialDevices(); std::vector::iterator it = deviceNames.begin(); while (it != deviceNames.end()) { deviceNamesList->append(new SWGSDRangel::SWGDVSerialDevice); deviceNamesList->back()->init(); *deviceNamesList->back()->getDeviceName() = QString::fromStdString(*it); ++it; } return 200; } int WebAPIAdapterSrv::instanceAMBEDevicesGet( SWGSDRangel::SWGAMBEDevices& response, SWGSDRangel::SWGErrorResponse& error) { (void) error; response.init(); std::vector deviceNames; m_mainCore.m_dspEngine->getDVSerialNames(deviceNames); response.setNbDevices((int) deviceNames.size()); QList *deviceNamesList = response.getAmbeDevices(); std::vector::iterator it = deviceNames.begin(); while (it != deviceNames.end()) { deviceNamesList->append(new SWGSDRangel::SWGAMBEDevice); deviceNamesList->back()->init(); *deviceNamesList->back()->getDeviceRef() = QString::fromStdString(*it); deviceNamesList->back()->setDelete(0); ++it; } return 200; } int WebAPIAdapterSrv::instanceAMBEDevicesDelete( SWGSDRangel::SWGSuccessResponse& response, SWGSDRangel::SWGErrorResponse& error) { (void) error; m_mainCore.m_dspEngine->getAMBEEngine()->releaseAll(); response.init(); *response.getMessage() = QString("All AMBE devices released"); return 200; } int WebAPIAdapterSrv::instanceAMBEDevicesPut( SWGSDRangel::SWGAMBEDevices& query, SWGSDRangel::SWGAMBEDevices& response, SWGSDRangel::SWGErrorResponse& error) { m_mainCore.m_dspEngine->getAMBEEngine()->releaseAll(); QList *ambeList = query.getAmbeDevices(); for (QList::const_iterator it = ambeList->begin(); it != ambeList->end(); ++it) { m_mainCore.m_dspEngine->getAMBEEngine()->registerController((*it)->getDeviceRef()->toStdString()); } instanceAMBEDevicesGet(response, error); return 200; } int WebAPIAdapterSrv::instanceAMBEDevicesPatch( SWGSDRangel::SWGAMBEDevices& query, SWGSDRangel::SWGAMBEDevices& response, SWGSDRangel::SWGErrorResponse& error) { QList *ambeList = query.getAmbeDevices(); for (QList::const_iterator it = ambeList->begin(); it != ambeList->end(); ++it) { if ((*it)->getDelete()) { m_mainCore.m_dspEngine->getAMBEEngine()->releaseController((*it)->getDeviceRef()->toStdString()); } else { m_mainCore.m_dspEngine->getAMBEEngine()->registerController((*it)->getDeviceRef()->toStdString()); } } instanceAMBEDevicesGet(response, error); return 200; } int WebAPIAdapterSrv::instancePresetFilePut( SWGSDRangel::SWGPresetImport& query, SWGSDRangel::SWGPresetIdentifier& response, SWGSDRangel::SWGErrorResponse& error) { const QString& fileName = *query.getFilePath(); if (fileName != "") { QFile exportFile(fileName); if (exportFile.open(QIODevice::ReadOnly | QIODevice::Text)) { QByteArray base64Str; QTextStream instream(&exportFile); instream >> base64Str; exportFile.close(); Preset* preset = m_mainCore.m_settings.newPreset("", ""); preset->deserialize(QByteArray::fromBase64(base64Str)); if (query.getGroupName() && (query.getGroupName()->size() > 0)) { preset->setGroup(*query.getGroupName()); } if (query.getDescription() && (query.getDescription()->size() > 0)) { preset->setDescription(*query.getDescription()); } response.init(); response.setCenterFrequency(preset->getCenterFrequency()); *response.getGroupName() = preset->getGroup(); *response.getType() = preset->isSourcePreset() ? "R" : preset->isSinkPreset() ? "T" : preset->isMIMOPreset() ? "M" : "X"; *response.getName() = preset->getDescription(); return 200; } else { error.init(); *error.getMessage() = QString("File %1 not found or not readable").arg(fileName); return 404; } } else { error.init(); *error.getMessage() = QString("Empty file path"); return 404; } } int WebAPIAdapterSrv::instancePresetFilePost( SWGSDRangel::SWGPresetExport& query, SWGSDRangel::SWGPresetIdentifier& response, SWGSDRangel::SWGErrorResponse& error) { QString filePath = *query.getFilePath(); SWGSDRangel::SWGPresetIdentifier *presetIdentifier = query.getPreset(); const Preset *selectedPreset = m_mainCore.m_settings.getPreset(*presetIdentifier->getGroupName(), presetIdentifier->getCenterFrequency(), *presetIdentifier->getName(), *presetIdentifier->getType()); if (selectedPreset == 0) { error.init(); *error.getMessage() = QString("There is no preset [%1, %2, %3, %4]") .arg(*presetIdentifier->getGroupName()) .arg(presetIdentifier->getCenterFrequency()) .arg(*presetIdentifier->getName()) .arg(*presetIdentifier->getType()); return 404; } QString base64Str = selectedPreset->serialize().toBase64(); if (filePath != "") { QFileInfo fileInfo(filePath); if (fileInfo.suffix() != "prex") { filePath += ".prex"; } QFile exportFile(filePath); if (exportFile.open(QIODevice::WriteOnly | QIODevice::Text)) { QTextStream outstream(&exportFile); outstream << base64Str; exportFile.close(); response.init(); response.setCenterFrequency(selectedPreset->getCenterFrequency()); *response.getGroupName() = selectedPreset->getGroup(); *response.getType() = selectedPreset->isSourcePreset() ? "R" : selectedPreset->isSinkPreset() ? "T" : selectedPreset->isMIMOPreset() ? "M" : "X"; *response.getName() = selectedPreset->getDescription(); return 200; } else { error.init(); *error.getMessage() = QString("File %1 cannot be written").arg(filePath); return 404; } } else { error.init(); *error.getMessage() = QString("Empty file path"); return 404; } } int WebAPIAdapterSrv::instancePresetsGet( SWGSDRangel::SWGPresets& response, SWGSDRangel::SWGErrorResponse& error) { int nbPresets = m_mainCore.m_settings.getPresetCount(); int nbGroups = 0; int nbPresetsThisGroup = 0; QString groupName; response.init(); QList *groups = response.getGroups(); QList *swgPresets = 0; int i = 0; // Presets are sorted by group first for (; i < nbPresets; i++) { const Preset *preset = m_mainCore.m_settings.getPreset(i); if ((i == 0) || (groupName != preset->getGroup())) // new group { if (i > 0) { groups->back()->setNbPresets(nbPresetsThisGroup); } groups->append(new SWGSDRangel::SWGPresetGroup); groups->back()->init(); groupName = preset->getGroup(); *groups->back()->getGroupName() = groupName; swgPresets = groups->back()->getPresets(); nbGroups++; nbPresetsThisGroup = 0; } swgPresets->append(new SWGSDRangel::SWGPresetItem); swgPresets->back()->init(); swgPresets->back()->setCenterFrequency(preset->getCenterFrequency()); *swgPresets->back()->getType() = preset->isSourcePreset() ? "R" : preset->isSinkPreset() ? "T" : preset->isMIMOPreset() ? "M" : "X"; *swgPresets->back()->getName() = preset->getDescription(); nbPresetsThisGroup++; } if (i > 0) { groups->back()->setNbPresets(nbPresetsThisGroup); } response.setNbGroups(nbGroups); return 200; } int WebAPIAdapterSrv::instancePresetPatch( SWGSDRangel::SWGPresetTransfer& query, SWGSDRangel::SWGPresetIdentifier& response, SWGSDRangel::SWGErrorResponse& error) { int deviceSetIndex = query.getDeviceSetIndex(); SWGSDRangel::SWGPresetIdentifier *presetIdentifier = query.getPreset(); int nbDeviceSets = m_mainCore.m_deviceSets.size(); if (deviceSetIndex >= nbDeviceSets) { error.init(); *error.getMessage() = QString("There is no device set at index %1. Number of device sets is %2").arg(deviceSetIndex).arg(nbDeviceSets); return 404; } const Preset *selectedPreset = m_mainCore.m_settings.getPreset(*presetIdentifier->getGroupName(), presetIdentifier->getCenterFrequency(), *presetIdentifier->getName(), *presetIdentifier->getType()); if (selectedPreset == 0) { error.init(); *error.getMessage() = QString("There is no preset [%1, %2, %3 %4]") .arg(*presetIdentifier->getGroupName()) .arg(presetIdentifier->getCenterFrequency()) .arg(*presetIdentifier->getName()) .arg(*presetIdentifier->getType()); return 404; } DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine && !selectedPreset->isSourcePreset()) { error.init(); *error.getMessage() = QString("Preset type and device set type (Rx) mismatch"); return 404; } if (deviceSet->m_deviceSinkEngine && !selectedPreset->isSinkPreset()) { error.init(); *error.getMessage() = QString("Preset type and device set type (Tx) mismatch"); return 404; } if (deviceSet->m_deviceMIMOEngine && !selectedPreset->isMIMOPreset()) { error.init(); *error.getMessage() = QString("Preset type and device set type (MIMO) mismatch"); return 404; } MainCore::MsgLoadPreset *msg = MainCore::MsgLoadPreset::create(selectedPreset, deviceSetIndex); m_mainCore.m_inputMessageQueue.push(msg); response.init(); response.setCenterFrequency(selectedPreset->getCenterFrequency()); *response.getGroupName() = selectedPreset->getGroup(); *response.getType() = selectedPreset->isSourcePreset() ? "R" : selectedPreset->isSinkPreset() ? "T" : selectedPreset->isMIMOPreset() ? "M" : "X"; *response.getName() = selectedPreset->getDescription(); return 202; } int WebAPIAdapterSrv::instancePresetPut( SWGSDRangel::SWGPresetTransfer& query, SWGSDRangel::SWGPresetIdentifier& response, SWGSDRangel::SWGErrorResponse& error) { int deviceSetIndex = query.getDeviceSetIndex(); SWGSDRangel::SWGPresetIdentifier *presetIdentifier = query.getPreset(); int nbDeviceSets = m_mainCore.m_deviceSets.size(); if (deviceSetIndex >= nbDeviceSets) { error.init(); *error.getMessage() = QString("There is no device set at index %1. Number of device sets is %2").arg(deviceSetIndex).arg(nbDeviceSets); return 404; } const Preset *selectedPreset = m_mainCore.m_settings.getPreset(*presetIdentifier->getGroupName(), presetIdentifier->getCenterFrequency(), *presetIdentifier->getName(), *presetIdentifier->getType()); if (selectedPreset == 0) { error.init(); *error.getMessage() = QString("There is no preset [%1, %2, %3 %4]") .arg(*presetIdentifier->getGroupName()) .arg(presetIdentifier->getCenterFrequency()) .arg(*presetIdentifier->getName()) .arg(*presetIdentifier->getType()); return 404; } else // update existing preset { DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine && !selectedPreset->isSourcePreset()) { error.init(); *error.getMessage() = QString("Preset type and device set type (Rx) mismatch"); return 404; } if (deviceSet->m_deviceSinkEngine && !selectedPreset->isSinkPreset()) { error.init(); *error.getMessage() = QString("Preset type and device set type (Tx) mismatch"); return 404; } if (deviceSet->m_deviceSinkEngine && !selectedPreset->isMIMOPreset()) { error.init(); *error.getMessage() = QString("Preset type and device set type (MIMO) mismatch"); return 404; } } MainCore::MsgSavePreset *msg = MainCore::MsgSavePreset::create(const_cast(selectedPreset), deviceSetIndex, false); m_mainCore.m_inputMessageQueue.push(msg); response.init(); response.setCenterFrequency(selectedPreset->getCenterFrequency()); *response.getGroupName() = selectedPreset->getGroup(); *response.getType() = selectedPreset->isSourcePreset() ? "R" : selectedPreset->isSinkPreset() ? "T": selectedPreset->isMIMOPreset() ? "M" : "X"; *response.getName() = selectedPreset->getDescription(); return 202; } int WebAPIAdapterSrv::instancePresetPost( SWGSDRangel::SWGPresetTransfer& query, SWGSDRangel::SWGPresetIdentifier& response, SWGSDRangel::SWGErrorResponse& error) { int deviceSetIndex = query.getDeviceSetIndex(); SWGSDRangel::SWGPresetIdentifier *presetIdentifier = query.getPreset(); int nbDeviceSets = m_mainCore.m_deviceSets.size(); if (deviceSetIndex >= nbDeviceSets) { error.init(); *error.getMessage() = QString("There is no device set at index %1. Number of device sets is %2").arg(deviceSetIndex).arg(nbDeviceSets); return 404; } DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; int deviceCenterFrequency = 0; int presetTypeCode; if (deviceSet->m_deviceSourceEngine) { // Rx deviceCenterFrequency = deviceSet->m_deviceSourceEngine->getSource()->getCenterFrequency(); presetTypeCode = 0; } else if (deviceSet->m_deviceSinkEngine) { // Tx deviceCenterFrequency = deviceSet->m_deviceSinkEngine->getSink()->getCenterFrequency(); presetTypeCode = 1; } else if (deviceSet->m_deviceMIMOEngine) { // MIMO deviceCenterFrequency = deviceSet->m_deviceMIMOEngine->getMIMO()->getMIMOCenterFrequency(); presetTypeCode = 2; } else { error.init(); *error.getMessage() = QString("Device set error"); return 500; } const Preset *selectedPreset = m_mainCore.m_settings.getPreset(*presetIdentifier->getGroupName(), deviceCenterFrequency, *presetIdentifier->getName(), *presetIdentifier->getType()); if (selectedPreset == 0) // save on a new preset { selectedPreset = m_mainCore.m_settings.newPreset(*presetIdentifier->getGroupName(), *presetIdentifier->getName()); } else { error.init(); *error.getMessage() = QString("Preset already exists [%1, %2, %3 %4]") .arg(*presetIdentifier->getGroupName()) .arg(deviceCenterFrequency) .arg(*presetIdentifier->getName()) .arg(*presetIdentifier->getType()); return 409; } MainCore::MsgSavePreset *msg = MainCore::MsgSavePreset::create(const_cast(selectedPreset), deviceSetIndex, true); m_mainCore.m_inputMessageQueue.push(msg); response.init(); response.setCenterFrequency(deviceCenterFrequency); *response.getGroupName() = selectedPreset->getGroup(); *response.getType() = presetTypeCode == 0 ? "R" : presetTypeCode == 1 ? "T" : presetTypeCode == 2 ? "M" : "X"; *response.getName() = selectedPreset->getDescription(); return 202; } int WebAPIAdapterSrv::instancePresetDelete( SWGSDRangel::SWGPresetIdentifier& response, SWGSDRangel::SWGErrorResponse& error) { const Preset *selectedPreset = m_mainCore.m_settings.getPreset(*response.getGroupName(), response.getCenterFrequency(), *response.getName(), *response.getType()); if (selectedPreset == 0) { error.init(); *error.getMessage() = QString("There is no preset [%1, %2, %3 %4]") .arg(*response.getGroupName()) .arg(response.getCenterFrequency()) .arg(*response.getName()) .arg(*response.getType()); return 404; } response.setCenterFrequency(selectedPreset->getCenterFrequency()); *response.getGroupName() = selectedPreset->getGroup(); *response.getType() = selectedPreset->isSourcePreset() ? "R" : selectedPreset->isSinkPreset() ? "T" : selectedPreset->isMIMOPreset() ? "M" : "X"; *response.getName() = selectedPreset->getDescription(); MainCore::MsgDeletePreset *msg = MainCore::MsgDeletePreset::create(const_cast(selectedPreset)); m_mainCore.m_inputMessageQueue.push(msg); return 202; } int WebAPIAdapterSrv::instanceDeviceSetsGet( SWGSDRangel::SWGDeviceSetList& response, SWGSDRangel::SWGErrorResponse& error) { getDeviceSetList(&response); return 200; } int WebAPIAdapterSrv::instanceDeviceSetPost( int direction, SWGSDRangel::SWGSuccessResponse& response, SWGSDRangel::SWGErrorResponse& error) { MainCore::MsgAddDeviceSet *msg = MainCore::MsgAddDeviceSet::create(direction); m_mainCore.m_inputMessageQueue.push(msg); response.init(); *response.getMessage() = QString("Message to add a new device set (MsgAddDeviceSet) was submitted successfully"); return 202; } int WebAPIAdapterSrv::instanceDeviceSetDelete( SWGSDRangel::SWGSuccessResponse& response, SWGSDRangel::SWGErrorResponse& error) { if (m_mainCore.m_deviceSets.size() > 0) { MainCore::MsgRemoveLastDeviceSet *msg = MainCore::MsgRemoveLastDeviceSet::create(); m_mainCore.m_inputMessageQueue.push(msg); response.init(); *response.getMessage() = QString("Message to remove last device set (MsgRemoveLastDeviceSet) was submitted successfully"); return 202; } else { error.init(); *error.getMessage() = "No more device sets to be removed"; return 404; } } int WebAPIAdapterSrv::devicesetGet( int deviceSetIndex, SWGSDRangel::SWGDeviceSet& response, SWGSDRangel::SWGErrorResponse& error) { if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainCore.m_deviceSets.size())) { const DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; getDeviceSet(&response, deviceSet, deviceSetIndex); return 200; } else { error.init(); *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterSrv::devicesetFocusPatch( int deviceSetIndex, SWGSDRangel::SWGSuccessResponse& response, SWGSDRangel::SWGErrorResponse& error) { *error.getMessage() = QString("Not supported in server instance"); return 400; } int WebAPIAdapterSrv::devicesetDevicePut( int deviceSetIndex, SWGSDRangel::SWGDeviceListItem& query, SWGSDRangel::SWGDeviceListItem& response, SWGSDRangel::SWGErrorResponse& error) { if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainCore.m_deviceSets.size())) { DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; if ((query.getDirection() != 1) && (deviceSet->m_deviceSinkEngine)) { error.init(); *error.getMessage() = QString("Device type and device set type (Tx) mismatch"); return 404; } if ((query.getDirection() != 0) && (deviceSet->m_deviceSourceEngine)) { error.init(); *error.getMessage() = QString("Device type and device set type (Rx) mismatch"); return 404; } if ((query.getDirection() != 2) && (deviceSet->m_deviceMIMOEngine)) { error.init(); *error.getMessage() = QString("Device type and device set type (MIMO) mismatch"); return 404; } int nbSamplingDevices; if (query.getDirection() == 0) { nbSamplingDevices = DeviceEnumerator::instance()->getNbRxSamplingDevices(); } else if (query.getDirection() == 1) { nbSamplingDevices = DeviceEnumerator::instance()->getNbTxSamplingDevices(); } else if (query.getDirection() == 2) { nbSamplingDevices = DeviceEnumerator::instance()->getNbMIMOSamplingDevices(); } else { nbSamplingDevices = 0; // TODO: not implemented yet } for (int i = 0; i < nbSamplingDevices; i++) { int direction; const PluginInterface::SamplingDevice *samplingDevice; if (query.getDirection() == 0) { direction = 0; samplingDevice = DeviceEnumerator::instance()->getRxSamplingDevice(i); } else if (query.getDirection() == 1) { direction = 1; samplingDevice = DeviceEnumerator::instance()->getTxSamplingDevice(i); } else if (query.getDirection() == 2) { direction = 2; samplingDevice = DeviceEnumerator::instance()->getMIMOSamplingDevice(i); } else { continue; // device not supported } if (query.getDisplayedName() && (*query.getDisplayedName() != samplingDevice->displayedName)) { continue; } if (query.getHwType() && (*query.getHwType() != samplingDevice->hardwareId)) { continue; } if ((query.getSequence() >= 0) && (query.getSequence() != samplingDevice->sequence)) { continue; } if (query.getSerial() && (*query.getSerial() != samplingDevice->serial)) { continue; } if ((query.getDeviceStreamIndex() >= 0) && (query.getDeviceStreamIndex() != samplingDevice->deviceItemIndex)) { continue; } MainCore::MsgSetDevice *msg = MainCore::MsgSetDevice::create(deviceSetIndex, i, query.getDirection()); m_mainCore.m_inputMessageQueue.push(msg); response.init(); *response.getDisplayedName() = samplingDevice->displayedName; *response.getHwType() = samplingDevice->hardwareId; *response.getSerial() = samplingDevice->serial; response.setSequence(samplingDevice->sequence); response.setDirection(direction); response.setDeviceNbStreams(samplingDevice->deviceNbItems); response.setDeviceStreamIndex(samplingDevice->deviceItemIndex); response.setDeviceSetIndex(deviceSetIndex); response.setIndex(i); return 202; } error.init(); *error.getMessage() = QString("Device not found"); return 404; } else { error.init(); *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterSrv::devicesetDeviceSettingsGet( int deviceSetIndex, SWGSDRangel::SWGDeviceSettings& response, SWGSDRangel::SWGErrorResponse& error) { error.init(); if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainCore.m_deviceSets.size())) { DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine) // Single Rx { response.setDeviceHwType(new QString(deviceSet->m_deviceAPI->getHardwareId())); response.setDirection(0); DeviceSampleSource *source = deviceSet->m_deviceAPI->getSampleSource(); return source->webapiSettingsGet(response, *error.getMessage()); } else if (deviceSet->m_deviceSinkEngine) // Single Tx { response.setDeviceHwType(new QString(deviceSet->m_deviceAPI->getHardwareId())); response.setDirection(1); DeviceSampleSink *sink = deviceSet->m_deviceAPI->getSampleSink(); return sink->webapiSettingsGet(response, *error.getMessage()); } else if (deviceSet->m_deviceMIMOEngine) // MIMO { response.setDeviceHwType(new QString(deviceSet->m_deviceAPI->getHardwareId())); response.setDirection(2); DeviceSampleMIMO *mimo = deviceSet->m_deviceAPI->getSampleMIMO(); return mimo->webapiSettingsGet(response, *error.getMessage()); } else { *error.getMessage() = QString("DeviceSet error"); return 500; } } else { *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterSrv::devicesetDeviceSettingsPutPatch( int deviceSetIndex, bool force, const QStringList& deviceSettingsKeys, SWGSDRangel::SWGDeviceSettings& response, SWGSDRangel::SWGErrorResponse& error) { error.init(); if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainCore.m_deviceSets.size())) { DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine) // Single Rx { if (response.getDirection() != 0) { *error.getMessage() = QString("Single Rx device found but other type of device requested"); return 400; } if (deviceSet->m_deviceAPI->getHardwareId() != *response.getDeviceHwType()) { *error.getMessage() = QString("Device mismatch. Found %1 input").arg(deviceSet->m_deviceAPI->getHardwareId()); return 400; } else { DeviceSampleSource *source = deviceSet->m_deviceAPI->getSampleSource(); return source->webapiSettingsPutPatch(force, deviceSettingsKeys, response, *error.getMessage()); } } else if (deviceSet->m_deviceSinkEngine) // Single Tx { if (response.getDirection() != 1) { *error.getMessage() = QString("Single Tx device found but other type of device requested"); return 400; } else if (deviceSet->m_deviceAPI->getHardwareId() != *response.getDeviceHwType()) { *error.getMessage() = QString("Device mismatch. Found %1 output").arg(deviceSet->m_deviceAPI->getHardwareId()); return 400; } else { DeviceSampleSink *sink = deviceSet->m_deviceAPI->getSampleSink(); return sink->webapiSettingsPutPatch(force, deviceSettingsKeys, response, *error.getMessage()); } } else if (deviceSet->m_deviceMIMOEngine) // MIMO { if (response.getDirection() != 2) { *error.getMessage() = QString("MIMO device found but other type of device requested"); return 400; } else if (deviceSet->m_deviceAPI->getHardwareId() != *response.getDeviceHwType()) { *error.getMessage() = QString("Device mismatch. Found %1 output").arg(deviceSet->m_deviceAPI->getHardwareId()); return 400; } else { DeviceSampleMIMO *mimo = deviceSet->m_deviceAPI->getSampleMIMO(); return mimo->webapiSettingsPutPatch(force, deviceSettingsKeys, response, *error.getMessage()); } } else { *error.getMessage() = QString("DeviceSet error"); return 500; } } else { *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterSrv::devicesetDeviceRunGet( int deviceSetIndex, SWGSDRangel::SWGDeviceState& response, SWGSDRangel::SWGErrorResponse& error) { error.init(); if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainCore.m_deviceSets.size())) { DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine) // Rx { DeviceSampleSource *source = deviceSet->m_deviceAPI->getSampleSource(); response.init(); return source->webapiRunGet(response, *error.getMessage()); } else if (deviceSet->m_deviceSinkEngine) // Tx { DeviceSampleSink *sink = deviceSet->m_deviceAPI->getSampleSink(); response.init(); return sink->webapiRunGet(response, *error.getMessage()); } else { *error.getMessage() = QString("DeviceSet error"); return 500; } } else { *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterSrv::devicesetDeviceSubsystemRunGet( int deviceSetIndex, int subsystemIndex, SWGSDRangel::SWGDeviceState& response, SWGSDRangel::SWGErrorResponse& error) { error.init(); if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainCore.m_deviceSets.size())) { DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; if (deviceSet->m_deviceMIMOEngine) // MIMO { DeviceSampleMIMO *mimo = deviceSet->m_deviceAPI->getSampleMIMO(); response.init(); return mimo->webapiRunGet(subsystemIndex, response, *error.getMessage()); } else { *error.getMessage() = QString("DeviceSet error"); return 500; } } else { *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterSrv::devicesetDeviceRunPost( int deviceSetIndex, SWGSDRangel::SWGDeviceState& response, SWGSDRangel::SWGErrorResponse& error) { error.init(); if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainCore.m_deviceSets.size())) { DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine) // Rx { DeviceSampleSource *source = deviceSet->m_deviceAPI->getSampleSource(); response.init(); return source->webapiRun(true, response, *error.getMessage()); } else if (deviceSet->m_deviceSinkEngine) // Tx { DeviceSampleSink *sink = deviceSet->m_deviceAPI->getSampleSink(); response.init(); return sink->webapiRun(true, response, *error.getMessage()); } else { *error.getMessage() = QString("DeviceSet error"); return 500; } } else { *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterSrv::devicesetDeviceSubsystemRunPost( int deviceSetIndex, int subsystemIndex, SWGSDRangel::SWGDeviceState& response, SWGSDRangel::SWGErrorResponse& error) { error.init(); if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainCore.m_deviceSets.size())) { DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; if (deviceSet->m_deviceMIMOEngine) // MIMO { DeviceSampleMIMO *mimo = deviceSet->m_deviceAPI->getSampleMIMO(); response.init(); return mimo->webapiRun(true, subsystemIndex, response, *error.getMessage()); } else { *error.getMessage() = QString("DeviceSet error"); return 500; } } else { *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterSrv::devicesetDeviceRunDelete( int deviceSetIndex, SWGSDRangel::SWGDeviceState& response, SWGSDRangel::SWGErrorResponse& error) { error.init(); if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainCore.m_deviceSets.size())) { DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine) // Rx { DeviceSampleSource *source = deviceSet->m_deviceAPI->getSampleSource(); response.init(); return source->webapiRun(false, response, *error.getMessage()); } else if (deviceSet->m_deviceSinkEngine) // Tx { DeviceSampleSink *sink = deviceSet->m_deviceAPI->getSampleSink(); response.init(); return sink->webapiRun(false, response, *error.getMessage()); } else { *error.getMessage() = QString("DeviceSet error"); return 500; } } else { *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterSrv::devicesetDeviceSubsystemRunDelete( int deviceSetIndex, int subsystemIndex, SWGSDRangel::SWGDeviceState& response, SWGSDRangel::SWGErrorResponse& error) { error.init(); if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainCore.m_deviceSets.size())) { DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; if (deviceSet->m_deviceMIMOEngine) // MIMO { DeviceSampleMIMO *mimo = deviceSet->m_deviceAPI->getSampleMIMO(); response.init(); return mimo->webapiRun(false, subsystemIndex, response, *error.getMessage()); } else { *error.getMessage() = QString("DeviceSet error"); return 500; } } else { *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterSrv::devicesetDeviceReportGet( int deviceSetIndex, SWGSDRangel::SWGDeviceReport& response, SWGSDRangel::SWGErrorResponse& error) { error.init(); if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainCore.m_deviceSets.size())) { DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine) // Single Rx { response.setDeviceHwType(new QString(deviceSet->m_deviceAPI->getHardwareId())); response.setDirection(0); DeviceSampleSource *source = deviceSet->m_deviceAPI->getSampleSource(); return source->webapiReportGet(response, *error.getMessage()); } else if (deviceSet->m_deviceSinkEngine) // Single Tx { response.setDeviceHwType(new QString(deviceSet->m_deviceAPI->getHardwareId())); response.setDirection(1); DeviceSampleSink *sink = deviceSet->m_deviceAPI->getSampleSink(); return sink->webapiReportGet(response, *error.getMessage()); } else if (deviceSet->m_deviceMIMOEngine) // MIMO { response.setDeviceHwType(new QString(deviceSet->m_deviceAPI->getHardwareId())); response.setDirection(2); DeviceSampleMIMO *mimo = deviceSet->m_deviceAPI->getSampleMIMO(); return mimo->webapiReportGet(response, *error.getMessage()); } else { *error.getMessage() = QString("DeviceSet error"); return 500; } } else { *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterSrv::devicesetChannelsReportGet( int deviceSetIndex, SWGSDRangel::SWGChannelsDetail& response, SWGSDRangel::SWGErrorResponse& error) { if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainCore.m_deviceSets.size())) { const DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; getChannelsDetail(&response, deviceSet); return 200; } else { error.init(); *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterSrv::devicesetChannelPost( int deviceSetIndex, SWGSDRangel::SWGChannelSettings& query, SWGSDRangel::SWGSuccessResponse& response, SWGSDRangel::SWGErrorResponse& error) { if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainCore.m_deviceSets.size())) { DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; if (query.getDirection() == 0) // Single Rx { if (!deviceSet->m_deviceSourceEngine && !deviceSet->m_deviceMIMOEngine) { error.init(); *error.getMessage() = QString("Device set at %1 is not a receive capable device set").arg(deviceSetIndex); return 400; } PluginAPI::ChannelRegistrations *channelRegistrations = m_mainCore.m_pluginManager->getRxChannelRegistrations(); int nbRegistrations = channelRegistrations->size(); int index = 0; for (; index < nbRegistrations; index++) { if (channelRegistrations->at(index).m_channelId == *query.getChannelType()) { break; } } if (index < nbRegistrations) { MainCore::MsgAddChannel *msg = MainCore::MsgAddChannel::create(deviceSetIndex, index, false); m_mainCore.m_inputMessageQueue.push(msg); response.init(); *response.getMessage() = QString("Message to add a channel (MsgAddChannel) was submitted successfully"); return 202; } else { error.init(); *error.getMessage() = QString("There is no receive channel with id %1").arg(*query.getChannelType()); return 404; } } else if (query.getDirection() == 1) // single Tx { if (!deviceSet->m_deviceSinkEngine && !deviceSet->m_deviceMIMOEngine) { error.init(); *error.getMessage() = QString("Device set at %1 is not a transmit capable device set").arg(deviceSetIndex); return 400; } PluginAPI::ChannelRegistrations *channelRegistrations = m_mainCore.m_pluginManager->getTxChannelRegistrations(); int nbRegistrations = channelRegistrations->size(); int index = 0; for (; index < nbRegistrations; index++) { if (channelRegistrations->at(index).m_channelId == *query.getChannelType()) { break; } } if (index < nbRegistrations) { MainCore::MsgAddChannel *msg = MainCore::MsgAddChannel::create(deviceSetIndex, index, true); m_mainCore.m_inputMessageQueue.push(msg); response.init(); *response.getMessage() = QString("Message to add a channel (MsgAddChannel) was submitted successfully"); return 202; } else { error.init(); *error.getMessage() = QString("There is no transmit channel with id %1").arg(*query.getChannelType()); return 404; } } else if (query.getDirection() == 2) // MIMO { if (!deviceSet->m_deviceMIMOEngine) { error.init(); *error.getMessage() = QString("Device set at %1 is not a MIMO capable device set").arg(deviceSetIndex); return 400; } PluginAPI::ChannelRegistrations *channelRegistrations = m_mainCore.m_pluginManager->getMIMOChannelRegistrations(); int nbRegistrations = channelRegistrations->size(); int index = 0; for (; index < nbRegistrations; index++) { if (channelRegistrations->at(index).m_channelId == *query.getChannelType()) { break; } } if (index < nbRegistrations) { MainCore::MsgAddChannel *msg = MainCore::MsgAddChannel::create(deviceSetIndex, index, true); m_mainCore.m_inputMessageQueue.push(msg); response.init(); *response.getMessage() = QString("Message to add a channel (MsgAddChannel) was submitted successfully"); return 202; } else { error.init(); *error.getMessage() = QString("There is no MIMO channel with id %1").arg(*query.getChannelType()); return 404; } } else { error.init(); *error.getMessage() = QString("This type of device is not implemented yet"); return 400; } } else { error.init(); *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterSrv::devicesetChannelDelete( int deviceSetIndex, int channelIndex, SWGSDRangel::SWGSuccessResponse& response, SWGSDRangel::SWGErrorResponse& error) { if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainCore.m_deviceSets.size())) { DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; if (channelIndex < deviceSet->getNumberOfChannels()) { MainCore::MsgDeleteChannel *msg = MainCore::MsgDeleteChannel::create(deviceSetIndex, channelIndex); m_mainCore.m_inputMessageQueue.push(msg); response.init(); *response.getMessage() = QString("Message to delete a channel (MsgDeleteChannel) was submitted successfully"); return 202; } else { error.init(); *error.getMessage() = QString("There is no channel at index %1. There are %2 channels") .arg(channelIndex) .arg(channelIndex < deviceSet->getNumberOfChannels()); return 400; } } else { error.init(); *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterSrv::devicesetChannelSettingsGet( int deviceSetIndex, int channelIndex, SWGSDRangel::SWGChannelSettings& response, SWGSDRangel::SWGErrorResponse& error) { error.init(); if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainCore.m_deviceSets.size())) { DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine) // Single Rx { ChannelAPI *channelAPI = deviceSet->m_deviceAPI->getChanelSinkAPIAt(channelIndex); if (channelAPI == 0) { *error.getMessage() = QString("There is no channel with index %1").arg(channelIndex); return 404; } else { response.setChannelType(new QString()); channelAPI->getIdentifier(*response.getChannelType()); response.setDirection(0); return channelAPI->webapiSettingsGet(response, *error.getMessage()); } } else if (deviceSet->m_deviceSinkEngine) // Single Tx { ChannelAPI *channelAPI = deviceSet->m_deviceAPI->getChanelSourceAPIAt(channelIndex); if (channelAPI == 0) { *error.getMessage() = QString("There is no channel with index %1").arg(channelIndex); return 404; } else { response.setChannelType(new QString()); channelAPI->getIdentifier(*response.getChannelType()); response.setDirection(1); return channelAPI->webapiSettingsGet(response, *error.getMessage()); } } else if (deviceSet->m_deviceMIMOEngine) // MIMO { int nbSinkChannels = deviceSet->m_deviceAPI->getNbSinkChannels(); int nbSourceChannels = deviceSet->m_deviceAPI->getNbSourceChannels(); int nbMIMOChannels = deviceSet->m_deviceAPI->getNbMIMOChannels(); ChannelAPI *channelAPI = nullptr; if (channelIndex < nbSinkChannels) { channelAPI = deviceSet->m_deviceAPI->getChanelSinkAPIAt(channelIndex); response.setDirection(0); } else if (channelIndex < nbSinkChannels + nbSourceChannels) { channelAPI = deviceSet->m_deviceAPI->getChanelSourceAPIAt(channelIndex - nbSinkChannels); response.setDirection(1); } else if (channelIndex < nbSinkChannels + nbSourceChannels + nbMIMOChannels) { channelAPI = deviceSet->m_deviceAPI->getMIMOChannelAPIAt(channelIndex - nbSinkChannels - nbSourceChannels); response.setDirection(2); } else { *error.getMessage() = QString("Ther is no channel with index %1").arg(channelIndex); return 404; } if (channelAPI) { response.setChannelType(new QString()); channelAPI->getIdentifier(*response.getChannelType()); return channelAPI->webapiSettingsGet(response, *error.getMessage()); } else { *error.getMessage() = QString("Ther is no channel with index %1").arg(channelIndex); return 404; } } else { *error.getMessage() = QString("DeviceSet error"); return 500; } } else { *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterSrv::devicesetChannelReportGet( int deviceSetIndex, int channelIndex, SWGSDRangel::SWGChannelReport& response, SWGSDRangel::SWGErrorResponse& error) { error.init(); if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainCore.m_deviceSets.size())) { DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine) // Single Rx { ChannelAPI *channelAPI = deviceSet->m_deviceAPI->getChanelSinkAPIAt(channelIndex); if (channelAPI == 0) { *error.getMessage() = QString("There is no channel with index %1").arg(channelIndex); return 404; } else { response.setChannelType(new QString()); channelAPI->getIdentifier(*response.getChannelType()); response.setDirection(0); return channelAPI->webapiReportGet(response, *error.getMessage()); } } else if (deviceSet->m_deviceSinkEngine) // Single Tx { ChannelAPI *channelAPI = deviceSet->m_deviceAPI->getChanelSourceAPIAt(channelIndex); if (channelAPI == 0) { *error.getMessage() = QString("There is no channel with index %1").arg(channelIndex); return 404; } else { response.setChannelType(new QString()); channelAPI->getIdentifier(*response.getChannelType()); response.setDirection(1); return channelAPI->webapiReportGet(response, *error.getMessage()); } } else if (deviceSet->m_deviceMIMOEngine) // MIMO { int nbSinkChannels = deviceSet->m_deviceAPI->getNbSinkChannels(); int nbSourceChannels = deviceSet->m_deviceAPI->getNbSourceChannels(); int nbMIMOChannels = deviceSet->m_deviceAPI->getNbMIMOChannels(); ChannelAPI *channelAPI = nullptr; if (channelIndex < nbSinkChannels) { channelAPI = deviceSet->m_deviceAPI->getChanelSinkAPIAt(channelIndex); response.setDirection(0); } else if (channelIndex < nbSinkChannels + nbSourceChannels) { channelAPI = deviceSet->m_deviceAPI->getChanelSourceAPIAt(channelIndex - nbSinkChannels); response.setDirection(1); } else if (channelIndex < nbSinkChannels + nbSourceChannels + nbMIMOChannels) { channelAPI = deviceSet->m_deviceAPI->getMIMOChannelAPIAt(channelIndex - nbSinkChannels - nbSourceChannels); response.setDirection(2); } else { *error.getMessage() = QString("Ther is no channel with index %1").arg(channelIndex); return 404; } if (channelAPI) { response.setChannelType(new QString()); channelAPI->getIdentifier(*response.getChannelType()); return channelAPI->webapiReportGet(response, *error.getMessage()); } else { *error.getMessage() = QString("Ther is no channel with index %1").arg(channelIndex); return 404; } } else { *error.getMessage() = QString("DeviceSet error"); return 500; } } else { *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterSrv::devicesetChannelSettingsPutPatch( int deviceSetIndex, int channelIndex, bool force, const QStringList& channelSettingsKeys, SWGSDRangel::SWGChannelSettings& response, SWGSDRangel::SWGErrorResponse& error) { error.init(); if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainCore.m_deviceSets.size())) { DeviceSet *deviceSet = m_mainCore.m_deviceSets[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine) // Rx { ChannelAPI *channelAPI = deviceSet->m_deviceAPI->getChanelSinkAPIAt(channelIndex); if (channelAPI == 0) { *error.getMessage() = QString("There is no channel with index %1").arg(channelIndex); return 404; } else { QString channelType; channelAPI->getIdentifier(channelType); if (channelType == *response.getChannelType()) { return channelAPI->webapiSettingsPutPatch(force, channelSettingsKeys, response, *error.getMessage()); } else { *error.getMessage() = QString("There is no channel type %1 at index %2. Found %3.") .arg(*response.getChannelType()) .arg(channelIndex) .arg(channelType); return 404; } } } else if (deviceSet->m_deviceSinkEngine) // Tx { ChannelAPI *channelAPI = deviceSet->m_deviceAPI->getChanelSourceAPIAt(channelIndex); if (channelAPI == 0) { *error.getMessage() = QString("There is no channel with index %1").arg(channelIndex); return 404; } else { QString channelType; channelAPI->getIdentifier(channelType); if (channelType == *response.getChannelType()) { return channelAPI->webapiSettingsPutPatch(force, channelSettingsKeys, response, *error.getMessage()); } else { *error.getMessage() = QString("There is no channel type %1 at index %2. Found %3.") .arg(*response.getChannelType()) .arg(channelIndex) .arg(channelType); return 404; } } } else if (deviceSet->m_deviceMIMOEngine) // MIMO { int nbSinkChannels = deviceSet->m_deviceAPI->getNbSinkChannels(); int nbSourceChannels = deviceSet->m_deviceAPI->getNbSourceChannels(); int nbMIMOChannels = deviceSet->m_deviceAPI->getNbMIMOChannels(); ChannelAPI *channelAPI = nullptr; if (channelIndex < nbSinkChannels) { channelAPI = deviceSet->m_deviceAPI->getChanelSinkAPIAt(channelIndex); response.setDirection(0); } else if (channelIndex < nbSinkChannels + nbSourceChannels) { channelAPI = deviceSet->m_deviceAPI->getChanelSourceAPIAt(channelIndex - nbSinkChannels); response.setDirection(1); } else if (channelIndex < nbSinkChannels + nbSourceChannels + nbMIMOChannels) { channelAPI = deviceSet->m_deviceAPI->getMIMOChannelAPIAt(channelIndex - nbSinkChannels - nbSourceChannels); response.setDirection(2); } else { *error.getMessage() = QString("here is no channel with index %1").arg(channelIndex); return 404; } if (channelAPI) { QString channelType; channelAPI->getIdentifier(channelType); if (channelType == *response.getChannelType()) { return channelAPI->webapiSettingsPutPatch(force, channelSettingsKeys, response, *error.getMessage()); } else { *error.getMessage() = QString("There is no channel type %1 at index %2. Found %3.") .arg(*response.getChannelType()) .arg(channelIndex) .arg(channelType); return 404; } } else { *error.getMessage() = QString("There is no channel with index %1").arg(channelIndex); return 404; } } else { *error.getMessage() = QString("DeviceSet error"); return 500; } } else { *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } void WebAPIAdapterSrv::getDeviceSetList(SWGSDRangel::SWGDeviceSetList* deviceSetList) { deviceSetList->init(); deviceSetList->setDevicesetcount((int) m_mainCore.m_deviceSets.size()); std::vector::const_iterator it = m_mainCore.m_deviceSets.begin(); for (int i = 0; it != m_mainCore.m_deviceSets.end(); ++it, i++) { QList *deviceSets = deviceSetList->getDeviceSets(); deviceSets->append(new SWGSDRangel::SWGDeviceSet()); getDeviceSet(deviceSets->back(), *it, i); } } void WebAPIAdapterSrv::getDeviceSet(SWGSDRangel::SWGDeviceSet *swgDeviceSet, const DeviceSet* deviceSet, int deviceUISetIndex) { swgDeviceSet->init(); SWGSDRangel::SWGSamplingDevice *samplingDevice = swgDeviceSet->getSamplingDevice(); samplingDevice->init(); samplingDevice->setIndex(deviceUISetIndex); if (deviceSet->m_deviceSinkEngine) // Single Tx data { samplingDevice->setDirection(1); *samplingDevice->getHwType() = deviceSet->m_deviceAPI->getHardwareId(); *samplingDevice->getSerial() = deviceSet->m_deviceAPI->getSamplingDeviceSerial(); samplingDevice->setSequence(deviceSet->m_deviceAPI->getSamplingDeviceSequence()); samplingDevice->setDeviceNbStreams(deviceSet->m_deviceAPI->getDeviceNbItems()); samplingDevice->setDeviceStreamIndex(deviceSet->m_deviceAPI->getDeviceItemIndex()); deviceSet->m_deviceAPI->getDeviceEngineStateStr(*samplingDevice->getState()); DeviceSampleSink *sampleSink = deviceSet->m_deviceSinkEngine->getSink(); if (sampleSink) { samplingDevice->setCenterFrequency(sampleSink->getCenterFrequency()); samplingDevice->setBandwidth(sampleSink->getSampleRate()); } swgDeviceSet->setChannelcount(deviceSet->m_deviceAPI->getNbSourceChannels()); QList *channels = swgDeviceSet->getChannels(); for (int i = 0; i < swgDeviceSet->getChannelcount(); i++) { channels->append(new SWGSDRangel::SWGChannel); channels->back()->init(); ChannelAPI *channel = deviceSet->m_deviceAPI->getChanelSourceAPIAt(i); channels->back()->setDeltaFrequency(channel->getCenterFrequency()); channels->back()->setDirection(1); channels->back()->setIndex(channel->getIndexInDeviceSet()); channels->back()->setUid(channel->getUID()); channel->getIdentifier(*channels->back()->getId()); channel->getTitle(*channels->back()->getTitle()); } } if (deviceSet->m_deviceSourceEngine) // Single Rx data { samplingDevice->setDirection(0); *samplingDevice->getHwType() = deviceSet->m_deviceAPI->getHardwareId(); *samplingDevice->getSerial() = deviceSet->m_deviceAPI->getSamplingDeviceSerial(); samplingDevice->setSequence(deviceSet->m_deviceAPI->getSamplingDeviceSequence()); samplingDevice->setDeviceNbStreams(deviceSet->m_deviceAPI->getDeviceNbItems()); samplingDevice->setDeviceStreamIndex(deviceSet->m_deviceAPI->getDeviceItemIndex()); deviceSet->m_deviceAPI->getDeviceEngineStateStr(*samplingDevice->getState()); DeviceSampleSource *sampleSource = deviceSet->m_deviceSourceEngine->getSource(); if (sampleSource) { samplingDevice->setCenterFrequency(sampleSource->getCenterFrequency()); samplingDevice->setBandwidth(sampleSource->getSampleRate()); } swgDeviceSet->setChannelcount(deviceSet->m_deviceAPI->getNbSinkChannels()); QList *channels = swgDeviceSet->getChannels(); for (int i = 0; i < swgDeviceSet->getChannelcount(); i++) { channels->append(new SWGSDRangel::SWGChannel); channels->back()->init(); ChannelAPI *channel = deviceSet->m_deviceAPI->getChanelSinkAPIAt(i); channels->back()->setDeltaFrequency(channel->getCenterFrequency()); channels->back()->setDirection(0); channels->back()->setIndex(channel->getIndexInDeviceSet()); channels->back()->setUid(channel->getUID()); channel->getIdentifier(*channels->back()->getId()); channel->getTitle(*channels->back()->getTitle()); } } if (deviceSet->m_deviceMIMOEngine) // MIMO data { samplingDevice->setDirection(2); *samplingDevice->getHwType() = deviceSet->m_deviceAPI->getHardwareId(); *samplingDevice->getSerial() = deviceSet->m_deviceAPI->getSamplingDeviceSerial(); samplingDevice->setSequence(deviceSet->m_deviceAPI->getSamplingDeviceSequence()); samplingDevice->setDeviceNbStreams(deviceSet->m_deviceAPI->getDeviceNbItems()); samplingDevice->setDeviceStreamIndex(deviceSet->m_deviceAPI->getDeviceItemIndex()); samplingDevice->setState(new QString("notStarted")); deviceSet->m_deviceAPI->getDeviceEngineStateStr(*samplingDevice->getStateRx(), 0); deviceSet->m_deviceAPI->getDeviceEngineStateStr(*samplingDevice->getStateTx(), 1); DeviceSampleMIMO *sampleMIMO = deviceSet->m_deviceMIMOEngine->getMIMO(); if (sampleMIMO) { samplingDevice->setCenterFrequency(sampleMIMO->getMIMOCenterFrequency()); samplingDevice->setBandwidth(sampleMIMO->getMIMOSampleRate()); } int nbSinkChannels = deviceSet->m_deviceAPI->getNbSinkChannels(); int nbSourceChannels = deviceSet->m_deviceAPI->getNbSourceChannels(); int nbMIMOChannels = deviceSet->m_deviceAPI->getNbMIMOChannels(); swgDeviceSet->setChannelcount(nbSinkChannels + nbSourceChannels + nbMIMOChannels); QList *channels = swgDeviceSet->getChannels(); for (int i = 0; i < nbSinkChannels; i++) { channels->append(new SWGSDRangel::SWGChannel); channels->back()->init(); ChannelAPI *channel = deviceSet->m_deviceAPI->getChanelSinkAPIAt(i); channels->back()->setDeltaFrequency(channel->getCenterFrequency()); channels->back()->setDirection(0); channels->back()->setIndex(channel->getIndexInDeviceSet()); channels->back()->setUid(channel->getUID()); channel->getIdentifier(*channels->back()->getId()); channel->getTitle(*channels->back()->getTitle()); } for (int i = 0; i < nbSourceChannels; i++) { channels->append(new SWGSDRangel::SWGChannel); channels->back()->init(); ChannelAPI *channel = deviceSet->m_deviceAPI->getChanelSourceAPIAt(i); channels->back()->setDeltaFrequency(channel->getCenterFrequency()); channels->back()->setDirection(1); channels->back()->setIndex(channel->getIndexInDeviceSet()); channels->back()->setUid(channel->getUID()); channel->getIdentifier(*channels->back()->getId()); channel->getTitle(*channels->back()->getTitle()); } for (int i = 0; i < nbMIMOChannels; i++) { channels->append(new SWGSDRangel::SWGChannel); channels->back()->init(); ChannelAPI *channel = deviceSet->m_deviceAPI->getMIMOChannelAPIAt(i); channels->back()->setDeltaFrequency(channel->getCenterFrequency()); channels->back()->setDirection(2); channels->back()->setIndex(channel->getIndexInDeviceSet()); channels->back()->setUid(channel->getUID()); channel->getIdentifier(*channels->back()->getId()); channel->getTitle(*channels->back()->getTitle()); } } } void WebAPIAdapterSrv::getChannelsDetail(SWGSDRangel::SWGChannelsDetail *channelsDetail, const DeviceSet* deviceSet) { channelsDetail->init(); SWGSDRangel::SWGChannelReport *channelReport; QString channelReportError; if (deviceSet->m_deviceSinkEngine) // Tx data { channelsDetail->setChannelcount(deviceSet->m_deviceAPI->getNbSourceChannels()); QList *channels = channelsDetail->getChannels(); for (int i = 0; i < channelsDetail->getChannelcount(); i++) { channels->append(new SWGSDRangel::SWGChannel); channels->back()->init(); ChannelAPI *channel = deviceSet->m_deviceAPI->getChanelSourceAPIAt(i); channels->back()->setDeltaFrequency(channel->getCenterFrequency()); channels->back()->setDirection(1); channels->back()->setIndex(channel->getIndexInDeviceSet()); channels->back()->setUid(channel->getUID()); channel->getIdentifier(*channels->back()->getId()); channel->getTitle(*channels->back()->getTitle()); channelReport = new SWGSDRangel::SWGChannelReport(); if (channel->webapiReportGet(*channelReport, channelReportError) != 501) { channels->back()->setReport(channelReport); } else { delete channelReport; } } } if (deviceSet->m_deviceSourceEngine) // Rx data { channelsDetail->setChannelcount(deviceSet->m_deviceAPI->getNbSinkChannels()); QList *channels = channelsDetail->getChannels(); for (int i = 0; i < channelsDetail->getChannelcount(); i++) { channels->append(new SWGSDRangel::SWGChannel); channels->back()->init(); ChannelAPI *channel = deviceSet->m_deviceAPI->getChanelSinkAPIAt(i); channels->back()->setDeltaFrequency(channel->getCenterFrequency()); channels->back()->setDirection(0); channels->back()->setIndex(channel->getIndexInDeviceSet()); channels->back()->setUid(channel->getUID()); channel->getIdentifier(*channels->back()->getId()); channel->getTitle(*channels->back()->getTitle()); channelReport = new SWGSDRangel::SWGChannelReport(); if (channel->webapiReportGet(*channelReport, channelReportError) != 501) { channels->back()->setReport(channelReport); } else { delete channelReport; } } } if (deviceSet->m_deviceMIMOEngine) // MIMO data { int nbSinkChannels = deviceSet->m_deviceAPI->getNbSinkChannels(); int nbSourceChannels = deviceSet->m_deviceAPI->getNbSourceChannels(); int nbMIMOChannels = deviceSet->m_deviceAPI->getNbMIMOChannels(); QList *channels = channelsDetail->getChannels(); channelsDetail->setChannelcount(nbSinkChannels + nbSourceChannels + nbMIMOChannels); for (int i = 0; i < nbSinkChannels; i++) { channels->append(new SWGSDRangel::SWGChannel); channels->back()->init(); ChannelAPI *channel = deviceSet->m_deviceAPI->getChanelSinkAPIAt(i); channels->back()->setDeltaFrequency(channel->getCenterFrequency()); channels->back()->setDirection(0); channels->back()->setIndex(channel->getIndexInDeviceSet()); channels->back()->setUid(channel->getUID()); channel->getIdentifier(*channels->back()->getId()); channel->getTitle(*channels->back()->getTitle()); channelReport = new SWGSDRangel::SWGChannelReport(); if (channel->webapiReportGet(*channelReport, channelReportError) != 501) { channels->back()->setReport(channelReport); } else { delete channelReport; } } for (int i = 0; i < nbSourceChannels; i++) { channels->append(new SWGSDRangel::SWGChannel); channels->back()->init(); ChannelAPI *channel = deviceSet->m_deviceAPI->getChanelSourceAPIAt(i); channels->back()->setDeltaFrequency(channel->getCenterFrequency()); channels->back()->setDirection(1); channels->back()->setIndex(channel->getIndexInDeviceSet()); channels->back()->setUid(channel->getUID()); channel->getIdentifier(*channels->back()->getId()); channel->getTitle(*channels->back()->getTitle()); channelReport = new SWGSDRangel::SWGChannelReport(); if (channel->webapiReportGet(*channelReport, channelReportError) != 501) { channels->back()->setReport(channelReport); } else { delete channelReport; } } for (int i = 0; i < nbMIMOChannels; i++) { channels->append(new SWGSDRangel::SWGChannel); channels->back()->init(); ChannelAPI *channel = deviceSet->m_deviceAPI->getMIMOChannelAPIAt(i); channels->back()->setDeltaFrequency(channel->getCenterFrequency()); channels->back()->setDirection(2); channels->back()->setIndex(channel->getIndexInDeviceSet()); channels->back()->setUid(channel->getUID()); channel->getIdentifier(*channels->back()->getId()); channel->getTitle(*channels->back()->getTitle()); channelReport = new SWGSDRangel::SWGChannelReport(); if (channel->webapiReportGet(*channelReport, channelReportError) != 501) { channels->back()->setReport(channelReport); } else { delete channelReport; } } } } QtMsgType WebAPIAdapterSrv::getMsgTypeFromString(const QString& msgTypeString) { if (msgTypeString == "debug") { return QtDebugMsg; } else if (msgTypeString == "info") { return QtInfoMsg; } else if (msgTypeString == "warning") { return QtWarningMsg; } else if (msgTypeString == "error") { return QtCriticalMsg; } else { return QtDebugMsg; } } void WebAPIAdapterSrv::getMsgTypeString(const QtMsgType& msgType, QString& levelStr) { switch (msgType) { case QtDebugMsg: levelStr = "debug"; break; case QtInfoMsg: levelStr = "info"; break; case QtWarningMsg: levelStr = "warning"; break; case QtCriticalMsg: case QtFatalMsg: levelStr = "error"; break; default: levelStr = "debug"; break; } }