/////////////////////////////////////////////////////////////////////////////////// // 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 // // // // 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 "mainwindow.h" #include "ui_mainwindow.h" #include "loggerwithfile.h" #include "device/devicesourceapi.h" #include "device/devicesinkapi.h" #include "device/deviceuiset.h" #include "device/deviceenumerator.h" #include "dsp/devicesamplesource.h" #include "dsp/devicesamplesink.h" #include "dsp/dspengine.h" #include "plugin/pluginapi.h" #include "plugin/pluginmanager.h" #include "channel/channelsinkapi.h" #include "channel/channelsourceapi.h" #include "SWGInstanceSummaryResponse.h" #include "SWGInstanceDevicesResponse.h" #include "SWGInstanceChannelsResponse.h" #include "SWGDeviceListItem.h" #include "SWGAudioDevices.h" #include "SWGAudioDevicesSelect.h" #include "SWGLocationInformation.h" #include "SWGDVSeralDevices.h" #include "SWGDVSerialDevice.h" #include "SWGPresets.h" #include "SWGPresetGroup.h" #include "SWGPresetItem.h" #include "SWGPresetTransfer.h" #include "SWGPresetIdentifier.h" #include "SWGDeviceSettings.h" #include "SWGDeviceState.h" #include "SWGChannelSettings.h" #include "SWGSuccessResponse.h" #include "SWGErrorResponse.h" #include "SWGDeviceState.h" #include "webapiadaptergui.h" WebAPIAdapterGUI::WebAPIAdapterGUI(MainWindow& mainWindow) : m_mainWindow(mainWindow) { } WebAPIAdapterGUI::~WebAPIAdapterGUI() { } int WebAPIAdapterGUI::instanceSummary( SWGSDRangel::SWGInstanceSummaryResponse& response, SWGSDRangel::SWGErrorResponse& error __attribute__((unused))) { response.init(); *response.getAppname() = qApp->applicationName(); *response.getVersion() = qApp->applicationVersion(); *response.getQtVersion() = QString(QT_VERSION_STR); response.setDspRxBits(SDR_RX_SAMP_SZ); response.setDspTxBits(SDR_TX_SAMP_SZ); response.setPid(qApp->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_mainWindow.m_logger->getUseFileLogger() ? 1 : 0); if (logging->getDumpToFile()) { m_mainWindow.m_logger->getLogFileName(*logging->getFileName()); m_mainWindow.m_logger->getFileMinMessageLevelStr(*logging->getFileLevel()); } m_mainWindow.m_logger->getConsoleMinMessageLevelStr(*logging->getConsoleLevel()); SWGSDRangel::SWGDeviceSetList *deviceSetList = response.getDevicesetlist(); getDeviceSetList(deviceSetList); return 200; } int WebAPIAdapterGUI::instanceDelete( SWGSDRangel::SWGInstanceSummaryResponse& response __attribute__((unused)), SWGSDRangel::SWGErrorResponse& error) { *error.getMessage() = QString("Not supported in GUI instance"); return 400; } int WebAPIAdapterGUI::instanceDevices( bool tx, SWGSDRangel::SWGInstanceDevicesResponse& response, SWGSDRangel::SWGErrorResponse& error __attribute__((unused))) { response.init(); int nbSamplingDevices = tx ? DeviceEnumerator::instance()->getNbTxSamplingDevices() : DeviceEnumerator::instance()->getNbRxSamplingDevices(); response.setDevicecount(nbSamplingDevices); QList *devices = response.getDevices(); for (int i = 0; i < nbSamplingDevices; i++) { PluginInterface::SamplingDevice samplingDevice = tx ? DeviceEnumerator::instance()->getTxSamplingDevice(i) : DeviceEnumerator::instance()->getRxSamplingDevice(i); 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()->setTx(!samplingDevice.rxElseTx); devices->back()->setNbStreams(samplingDevice.deviceNbItems); devices->back()->setDeviceSetIndex(samplingDevice.claimed); devices->back()->setIndex(i); } return 200; } int WebAPIAdapterGUI::instanceChannels( bool tx, SWGSDRangel::SWGInstanceChannelsResponse& response, SWGSDRangel::SWGErrorResponse& error __attribute__((unused))) { response.init(); PluginAPI::ChannelRegistrations *channelRegistrations = tx ? m_mainWindow.m_pluginManager->getTxChannelRegistrations() : m_mainWindow.m_pluginManager->getRxChannelRegistrations(); int nbChannelDevices = channelRegistrations->size(); 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()->setTx(tx); *channels->back()->getIdUri() = channelRegistrations->at(i).m_channelIdURI; *channels->back()->getId() = channelRegistrations->at(i).m_channelId; channels->back()->setIndex(i); } return 200; } int WebAPIAdapterGUI::instanceLoggingGet( SWGSDRangel::SWGLoggingInfo& response, SWGSDRangel::SWGErrorResponse& error __attribute__((unused))) { response.init(); response.setDumpToFile(m_mainWindow.m_logger->getUseFileLogger() ? 1 : 0); if (response.getDumpToFile()) { m_mainWindow.m_logger->getLogFileName(*response.getFileName()); m_mainWindow.m_logger->getFileMinMessageLevelStr(*response.getFileLevel()); } m_mainWindow.m_logger->getConsoleMinMessageLevelStr(*response.getConsoleLevel()); return 200; } int WebAPIAdapterGUI::instanceLoggingPut( SWGSDRangel::SWGLoggingInfo& query, SWGSDRangel::SWGLoggingInfo& response, SWGSDRangel::SWGErrorResponse& error __attribute__((unused))) { // 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_mainWindow.m_settings.setConsoleMinLogLevel(getMsgTypeFromString(*consoleLevel)); } if (fileLevel) { m_mainWindow.m_settings.setFileMinLogLevel(getMsgTypeFromString(*fileLevel)); } m_mainWindow.m_settings.setUseLogFile(dumpToFile); if (fileName) { m_mainWindow.m_settings.setLogFileName(*fileName); } m_mainWindow.setLoggingOptions(); // build response response.init(); getMsgTypeString(m_mainWindow.m_settings.getConsoleMinLogLevel(), *response.getConsoleLevel()); response.setDumpToFile(m_mainWindow.m_settings.getUseLogFile() ? 1 : 0); getMsgTypeString(m_mainWindow.m_settings.getFileMinLogLevel(), *response.getFileLevel()); *response.getFileName() = m_mainWindow.m_settings.getLogFileName(); return 200; } int WebAPIAdapterGUI::instanceAudioGet( SWGSDRangel::SWGAudioDevices& response, SWGSDRangel::SWGErrorResponse& error __attribute__((unused))) { const QList& audioInputDevices = m_mainWindow.m_audioDeviceInfo.getInputDevices(); const QList& audioOutputDevices = m_mainWindow.m_audioDeviceInfo.getOutputDevices(); int nbInputDevices = audioInputDevices.size(); int nbOutputDevices = audioOutputDevices.size(); response.init(); response.setNbInputDevices(nbInputDevices); response.setInputDeviceSelectedIndex(m_mainWindow.m_audioDeviceInfo.getInputDeviceIndex()); response.setNbOutputDevices(nbOutputDevices); response.setOutputDeviceSelectedIndex(m_mainWindow.m_audioDeviceInfo.getOutputDeviceIndex()); response.setInputVolume(m_mainWindow.m_audioDeviceInfo.getInputVolume()); QList *inputDevices = response.getInputDevices(); QList *outputDevices = response.getOutputDevices(); for (int i = 0; i < nbInputDevices; i++) { inputDevices->append(new SWGSDRangel::SWGAudioDevice); inputDevices->back()->init(); *inputDevices->back()->getName() = audioInputDevices.at(i).deviceName(); } for (int i = 0; i < nbOutputDevices; i++) { outputDevices->append(new SWGSDRangel::SWGAudioDevice); outputDevices->back()->init(); *outputDevices->back()->getName() = audioOutputDevices.at(i).deviceName(); } return 200; } int WebAPIAdapterGUI::instanceAudioPatch( SWGSDRangel::SWGAudioDevicesSelect& response, SWGSDRangel::SWGErrorResponse& error __attribute__((unused))) { // response input is the query actually float inputVolume = response.getInputVolume(); int inputIndex = response.getInputIndex(); int outputIndex = response.getOutputIndex(); const QList& audioInputDevices = m_mainWindow.m_audioDeviceInfo.getInputDevices(); const QList& audioOutputDevices = m_mainWindow.m_audioDeviceInfo.getOutputDevices(); int nbInputDevices = audioInputDevices.size(); int nbOutputDevices = audioOutputDevices.size(); inputVolume = inputVolume < 0.0 ? 0.0 : inputVolume > 1.0 ? 1.0 : inputVolume; inputIndex = inputIndex < -1 ? -1 : inputIndex > nbInputDevices ? nbInputDevices-1 : inputIndex; outputIndex = outputIndex < -1 ? -1 : outputIndex > nbOutputDevices ? nbOutputDevices-1 : outputIndex; m_mainWindow.m_audioDeviceInfo.setInputVolume(inputVolume); m_mainWindow.m_audioDeviceInfo.setInputDeviceIndex(inputIndex); m_mainWindow.m_audioDeviceInfo.setOutputDeviceIndex(outputIndex); m_mainWindow.m_dspEngine->setAudioInputVolume(inputVolume); m_mainWindow.m_dspEngine->setAudioInputDeviceIndex(inputIndex); m_mainWindow.m_dspEngine->setAudioOutputDeviceIndex(outputIndex); response.setInputVolume(m_mainWindow.m_audioDeviceInfo.getInputVolume()); response.setInputIndex(m_mainWindow.m_audioDeviceInfo.getInputDeviceIndex()); response.setOutputIndex(m_mainWindow.m_audioDeviceInfo.getOutputDeviceIndex()); return 200; } int WebAPIAdapterGUI::instanceLocationGet( SWGSDRangel::SWGLocationInformation& response, SWGSDRangel::SWGErrorResponse& error __attribute__((unused))) { response.init(); response.setLatitude(m_mainWindow.m_settings.getLatitude()); response.setLongitude(m_mainWindow.m_settings.getLongitude()); return 200; } int WebAPIAdapterGUI::instanceLocationPut( SWGSDRangel::SWGLocationInformation& response, SWGSDRangel::SWGErrorResponse& error __attribute__((unused))) { 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_mainWindow.m_settings.setLatitude(latitude); m_mainWindow.m_settings.setLongitude(longitude); response.setLatitude(m_mainWindow.m_settings.getLatitude()); response.setLongitude(m_mainWindow.m_settings.getLongitude()); return 200; } int WebAPIAdapterGUI::instanceDVSerialPatch( bool dvserial, SWGSDRangel::SWGDVSeralDevices& response, SWGSDRangel::SWGErrorResponse& error __attribute__((unused))) { m_mainWindow.m_dspEngine->setDVSerialSupport(dvserial); m_mainWindow.ui->action_DV_Serial->setChecked(dvserial); response.init(); if (dvserial) { std::vector deviceNames; m_mainWindow.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 WebAPIAdapterGUI::instancePresetsGet( SWGSDRangel::SWGPresets& response, SWGSDRangel::SWGErrorResponse& error __attribute__((unused))) { int nbPresets = m_mainWindow.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_mainWindow.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" : "T"; *swgPresets->back()->getName() = preset->getDescription(); nbPresetsThisGroup++; } if (i > 0) { groups->back()->setNbPresets(nbPresetsThisGroup); } response.setNbGroups(nbGroups); return 200; } int WebAPIAdapterGUI::instancePresetPatch( SWGSDRangel::SWGPresetTransfer& query, SWGSDRangel::SWGPresetIdentifier& response, SWGSDRangel::SWGErrorResponse& error) { int deviceSetIndex = query.getDeviceSetIndex(); SWGSDRangel::SWGPresetIdentifier *presetIdentifier = query.getPreset(); int nbDeviceSets = m_mainWindow.m_deviceUIs.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_mainWindow.m_settings.getPreset(*presetIdentifier->getGroupName(), presetIdentifier->getCenterFrequency(), *presetIdentifier->getName()); if (selectedPreset == 0) { error.init(); *error.getMessage() = QString("There is no preset [%1, %2, %3]") .arg(*presetIdentifier->getGroupName()) .arg(presetIdentifier->getCenterFrequency()) .arg(*presetIdentifier->getName()); return 404; } DeviceUISet *deviceUI = m_mainWindow.m_deviceUIs[deviceSetIndex]; if (deviceUI->m_deviceSourceEngine && !selectedPreset->isSourcePreset()) { error.init(); *error.getMessage() = QString("Preset type (T) and device set type (Rx) mismatch"); return 404; } if (deviceUI->m_deviceSinkEngine && selectedPreset->isSourcePreset()) { error.init(); *error.getMessage() = QString("Preset type (R) and device set type (Tx) mismatch"); return 404; } MainWindow::MsgLoadPreset *msg = MainWindow::MsgLoadPreset::create(selectedPreset, deviceSetIndex); m_mainWindow.m_inputMessageQueue.push(msg); response.init(); response.setCenterFrequency(selectedPreset->getCenterFrequency()); *response.getGroupName() = selectedPreset->getGroup(); *response.getType() = selectedPreset->isSourcePreset() ? "R" : "T"; *response.getName() = selectedPreset->getDescription(); return 202; } int WebAPIAdapterGUI::instancePresetPut( SWGSDRangel::SWGPresetTransfer& query, SWGSDRangel::SWGPresetIdentifier& response, SWGSDRangel::SWGErrorResponse& error) { int deviceSetIndex = query.getDeviceSetIndex(); SWGSDRangel::SWGPresetIdentifier *presetIdentifier = query.getPreset(); int nbDeviceSets = m_mainWindow.m_deviceUIs.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_mainWindow.m_settings.getPreset(*presetIdentifier->getGroupName(), presetIdentifier->getCenterFrequency(), *presetIdentifier->getName()); if (selectedPreset == 0) { error.init(); *error.getMessage() = QString("There is no preset [%1, %2, %3]") .arg(*presetIdentifier->getGroupName()) .arg(presetIdentifier->getCenterFrequency()) .arg(*presetIdentifier->getName()); return 404; } else // update existing preset { DeviceUISet *deviceUI = m_mainWindow.m_deviceUIs[deviceSetIndex]; if (deviceUI->m_deviceSourceEngine && !selectedPreset->isSourcePreset()) { error.init(); *error.getMessage() = QString("Preset type (T) and device set type (Rx) mismatch"); return 404; } if (deviceUI->m_deviceSinkEngine && selectedPreset->isSourcePreset()) { error.init(); *error.getMessage() = QString("Preset type (R) and device set type (Tx) mismatch"); return 404; } } MainWindow::MsgSavePreset *msg = MainWindow::MsgSavePreset::create(const_cast(selectedPreset), deviceSetIndex, false); m_mainWindow.m_inputMessageQueue.push(msg); response.init(); response.setCenterFrequency(selectedPreset->getCenterFrequency()); *response.getGroupName() = selectedPreset->getGroup(); *response.getType() = selectedPreset->isSourcePreset() ? "R" : "T"; *response.getName() = selectedPreset->getDescription(); return 202; } int WebAPIAdapterGUI::instancePresetPost( SWGSDRangel::SWGPresetTransfer& query, SWGSDRangel::SWGPresetIdentifier& response, SWGSDRangel::SWGErrorResponse& error) { int deviceSetIndex = query.getDeviceSetIndex(); SWGSDRangel::SWGPresetIdentifier *presetIdentifier = query.getPreset(); int nbDeviceSets = m_mainWindow.m_deviceUIs.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; } DeviceUISet *deviceSet = m_mainWindow.m_deviceUIs[deviceSetIndex]; int deviceCenterFrequency = 0; if (deviceSet->m_deviceSourceEngine) { // Rx deviceCenterFrequency = deviceSet->m_deviceSourceEngine->getSource()->getCenterFrequency(); } else if (deviceSet->m_deviceSinkEngine) { // Tx deviceCenterFrequency = deviceSet->m_deviceSinkEngine->getSink()->getCenterFrequency(); } else { error.init(); *error.getMessage() = QString("Device set error"); return 500; } const Preset *selectedPreset = m_mainWindow.m_settings.getPreset(*presetIdentifier->getGroupName(), deviceCenterFrequency, *presetIdentifier->getName()); if (selectedPreset == 0) // save on a new preset { selectedPreset = m_mainWindow.m_settings.newPreset(*presetIdentifier->getGroupName(), *presetIdentifier->getName()); } else { error.init(); *error.getMessage() = QString("Preset already exists [%1, %2, %3]") .arg(*presetIdentifier->getGroupName()) .arg(deviceCenterFrequency) .arg(*presetIdentifier->getName()); return 409; } MainWindow::MsgSavePreset *msg = MainWindow::MsgSavePreset::create(const_cast(selectedPreset), deviceSetIndex, true); m_mainWindow.m_inputMessageQueue.push(msg); response.init(); response.setCenterFrequency(selectedPreset->getCenterFrequency()); *response.getGroupName() = selectedPreset->getGroup(); *response.getType() = selectedPreset->isSourcePreset() ? "R" : "T"; *response.getName() = selectedPreset->getDescription(); return 202; } int WebAPIAdapterGUI::instancePresetDelete( SWGSDRangel::SWGPresetIdentifier& response, SWGSDRangel::SWGErrorResponse& error) { const Preset *selectedPreset = m_mainWindow.m_settings.getPreset(*response.getGroupName(), response.getCenterFrequency(), *response.getName()); if (selectedPreset == 0) { *error.getMessage() = QString("There is no preset [%1, %2, %3]") .arg(*response.getGroupName()) .arg(response.getCenterFrequency()) .arg(*response.getName()); return 404; } response.setCenterFrequency(selectedPreset->getCenterFrequency()); *response.getGroupName() = selectedPreset->getGroup(); *response.getType() = selectedPreset->isSourcePreset() ? "R" : "T"; *response.getName() = selectedPreset->getDescription(); MainWindow::MsgDeletePreset *msg = MainWindow::MsgDeletePreset::create(const_cast(selectedPreset)); m_mainWindow.m_inputMessageQueue.push(msg); return 202; } int WebAPIAdapterGUI::instanceDeviceSetsGet( SWGSDRangel::SWGDeviceSetList& response, SWGSDRangel::SWGErrorResponse& error __attribute__((unused))) { getDeviceSetList(&response); return 200; } int WebAPIAdapterGUI::instanceDeviceSetPost( bool tx, SWGSDRangel::SWGSuccessResponse& response, SWGSDRangel::SWGErrorResponse& error __attribute__((unused))) { MainWindow::MsgAddDeviceSet *msg = MainWindow::MsgAddDeviceSet::create(tx); m_mainWindow.m_inputMessageQueue.push(msg); response.init(); *response.getMessage() = QString("Message to add a new device set (MsgAddDeviceSet) was submitted successfully"); return 202; } int WebAPIAdapterGUI::instanceDeviceSetDelete( SWGSDRangel::SWGSuccessResponse& response, SWGSDRangel::SWGErrorResponse& error) { if (m_mainWindow.m_deviceUIs.size() > 1) { MainWindow::MsgRemoveLastDeviceSet *msg = MainWindow::MsgRemoveLastDeviceSet::create(); m_mainWindow.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 WebAPIAdapterGUI::devicesetGet( int deviceSetIndex, SWGSDRangel::SWGDeviceSet& response, SWGSDRangel::SWGErrorResponse& error) { if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainWindow.m_deviceUIs.size())) { const DeviceUISet *deviceSet = m_mainWindow.m_deviceUIs[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 WebAPIAdapterGUI::devicesetFocusPatch( int deviceSetIndex, SWGSDRangel::SWGSuccessResponse& response, SWGSDRangel::SWGErrorResponse& error) { if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainWindow.m_deviceUIs.size())) { MainWindow::MsgDeviceSetFocus *msg = MainWindow::MsgDeviceSetFocus::create(deviceSetIndex); m_mainWindow.m_inputMessageQueue.push(msg); response.init(); *response.getMessage() = QString("Message to focus on device set (MsgDeviceSetFocus) was submitted successfully"); return 202; } else { error.init(); *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterGUI::devicesetDevicePut( int deviceSetIndex, SWGSDRangel::SWGDeviceListItem& query, SWGSDRangel::SWGDeviceListItem& response, SWGSDRangel::SWGErrorResponse& error) { if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainWindow.m_deviceUIs.size())) { DeviceUISet *deviceSet = m_mainWindow.m_deviceUIs[deviceSetIndex]; if ((query.getTx() == 0) && (deviceSet->m_deviceSinkEngine)) { error.init(); *error.getMessage() = QString("Device type (Rx) and device set type (Tx) mismatch"); return 404; } if ((query.getTx() != 0) && (deviceSet->m_deviceSourceEngine)) { error.init(); *error.getMessage() = QString("Device type (Tx) and device set type (Rx) mismatch"); return 404; } int nbSamplingDevices = query.getTx() != 0 ? DeviceEnumerator::instance()->getNbTxSamplingDevices() : DeviceEnumerator::instance()->getNbRxSamplingDevices(); int tx = query.getTx(); for (int i = 0; i < nbSamplingDevices; i++) { PluginInterface::SamplingDevice samplingDevice = query.getTx() ? DeviceEnumerator::instance()->getTxSamplingDevice(i) : DeviceEnumerator::instance()->getRxSamplingDevice(i); 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.getStreamIndex() >= 0) && (query.getStreamIndex() != samplingDevice.deviceItemIndex)) { continue; } MainWindow::MsgSetDevice *msg = MainWindow::MsgSetDevice::create(deviceSetIndex, i, query.getTx() != 0); m_mainWindow.m_inputMessageQueue.push(msg); response.init(); *response.getDisplayedName() = samplingDevice.displayedName; *response.getHwType() = samplingDevice.hardwareId; *response.getSerial() = samplingDevice.serial; response.setSequence(samplingDevice.sequence); response.setTx(tx); response.setNbStreams(samplingDevice.deviceNbItems); response.setStreamIndex(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 WebAPIAdapterGUI::devicesetDeviceSettingsGet( int deviceSetIndex, SWGSDRangel::SWGDeviceSettings& response, SWGSDRangel::SWGErrorResponse& error) { if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainWindow.m_deviceUIs.size())) { DeviceUISet *deviceSet = m_mainWindow.m_deviceUIs[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine) // Rx { response.setDeviceHwType(new QString(deviceSet->m_deviceSourceAPI->getHardwareId())); response.setTx(0); DeviceSampleSource *source = deviceSet->m_deviceSourceAPI->getSampleSource(); return source->webapiSettingsGet(response, *error.getMessage()); } else if (deviceSet->m_deviceSinkEngine) // Tx { response.setDeviceHwType(new QString(deviceSet->m_deviceSinkAPI->getHardwareId())); response.setTx(1); DeviceSampleSink *sink = deviceSet->m_deviceSinkAPI->getSampleSink(); return sink->webapiSettingsGet(response, *error.getMessage()); } else { error.init(); *error.getMessage() = QString("DeviceSet error"); return 500; } } else { error.init(); *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterGUI::devicesetDeviceSettingsPutPatch( int deviceSetIndex, bool force, const QStringList& deviceSettingsKeys, SWGSDRangel::SWGDeviceSettings& response, SWGSDRangel::SWGErrorResponse& error) { if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainWindow.m_deviceUIs.size())) { DeviceUISet *deviceSet = m_mainWindow.m_deviceUIs[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine) // Rx { if (response.getTx() != 0) { error.init(); *error.getMessage() = QString("Rx device found but Tx device requested"); return 400; } if (deviceSet->m_deviceSourceAPI->getHardwareId() != *response.getDeviceHwType()) { error.init(); *error.getMessage() = QString("Device mismatch. Found %1 input").arg(deviceSet->m_deviceSourceAPI->getHardwareId()); return 400; } else { DeviceSampleSource *source = deviceSet->m_deviceSourceAPI->getSampleSource(); return source->webapiSettingsPutPatch(force, deviceSettingsKeys, response, *error.getMessage()); } } else if (deviceSet->m_deviceSinkEngine) // Tx { if (response.getTx() == 0) { error.init(); *error.getMessage() = QString("Tx device found but Rx device requested"); return 400; } else if (deviceSet->m_deviceSinkAPI->getHardwareId() != *response.getDeviceHwType()) { error.init(); *error.getMessage() = QString("Device mismatch. Found %1 output").arg(deviceSet->m_deviceSinkAPI->getHardwareId()); return 400; } else { DeviceSampleSink *sink = deviceSet->m_deviceSinkAPI->getSampleSink(); return sink->webapiSettingsPutPatch(force, deviceSettingsKeys, response, *error.getMessage()); } } else { error.init(); *error.getMessage() = QString("DeviceSet error"); return 500; } } else { error.init(); *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterGUI::devicesetDeviceRunGet( int deviceSetIndex, SWGSDRangel::SWGDeviceState& response, SWGSDRangel::SWGErrorResponse& error) { error.init(); if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainWindow.m_deviceUIs.size())) { DeviceUISet *deviceSet = m_mainWindow.m_deviceUIs[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine) // Rx { DeviceSampleSource *source = deviceSet->m_deviceSourceAPI->getSampleSource(); response.init(); return source->webapiRunGet(response, *error.getMessage()); } else if (deviceSet->m_deviceSinkEngine) // Tx { DeviceSampleSink *sink = deviceSet->m_deviceSinkAPI->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 WebAPIAdapterGUI::devicesetDeviceRunPost( int deviceSetIndex, SWGSDRangel::SWGDeviceState& response, SWGSDRangel::SWGErrorResponse& error) { error.init(); if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainWindow.m_deviceUIs.size())) { DeviceUISet *deviceSet = m_mainWindow.m_deviceUIs[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine) // Rx { DeviceSampleSource *source = deviceSet->m_deviceSourceAPI->getSampleSource(); response.init(); return source->webapiRun(true, response, *error.getMessage()); } else if (deviceSet->m_deviceSinkEngine) // Tx { DeviceSampleSink *sink = deviceSet->m_deviceSinkAPI->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 WebAPIAdapterGUI::devicesetDeviceRunDelete( int deviceSetIndex, SWGSDRangel::SWGDeviceState& response, SWGSDRangel::SWGErrorResponse& error) { error.init(); if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainWindow.m_deviceUIs.size())) { DeviceUISet *deviceSet = m_mainWindow.m_deviceUIs[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine) // Rx { DeviceSampleSource *source = deviceSet->m_deviceSourceAPI->getSampleSource(); response.init(); return source->webapiRun(false, response, *error.getMessage()); } else if (deviceSet->m_deviceSinkEngine) // Tx { DeviceSampleSink *sink = deviceSet->m_deviceSinkAPI->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 WebAPIAdapterGUI::devicesetChannelPost( int deviceSetIndex, SWGSDRangel::SWGChannelSettings& query, SWGSDRangel::SWGSuccessResponse& response, SWGSDRangel::SWGErrorResponse& error) { if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainWindow.m_deviceUIs.size())) { DeviceUISet *deviceSet = m_mainWindow.m_deviceUIs[deviceSetIndex]; if (query.getTx() == 0) // Rx { if (deviceSet->m_deviceSourceEngine == 0) { error.init(); *error.getMessage() = QString("Device set at %1 is not a receive device set").arg(deviceSetIndex); return 400; } PluginAPI::ChannelRegistrations *channelRegistrations = m_mainWindow.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) { MainWindow::MsgAddChannel *msg = MainWindow::MsgAddChannel::create(deviceSetIndex, index, false); m_mainWindow.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 // Tx { if (deviceSet->m_deviceSinkEngine == 0) { error.init(); *error.getMessage() = QString("Device set at %1 is not a transmit device set").arg(deviceSetIndex); return 400; } PluginAPI::ChannelRegistrations *channelRegistrations = m_mainWindow.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) { MainWindow::MsgAddChannel *msg = MainWindow::MsgAddChannel::create(deviceSetIndex, index, true); m_mainWindow.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 { error.init(); *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterGUI::devicesetChannelDelete( int deviceSetIndex, int channelIndex, SWGSDRangel::SWGSuccessResponse& response, SWGSDRangel::SWGErrorResponse& error) { if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainWindow.m_deviceUIs.size())) { DeviceUISet *deviceSet = m_mainWindow.m_deviceUIs[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine) // Rx { if (channelIndex < deviceSet->getNumberOfRxChannels()) { MainWindow::MsgDeleteChannel *msg = MainWindow::MsgDeleteChannel::create(deviceSetIndex, channelIndex, false); m_mainWindow.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 Rx channels") .arg(channelIndex) .arg(channelIndex < deviceSet->getNumberOfRxChannels()); return 400; } } else if (deviceSet->m_deviceSinkEngine) // Tx { if (channelIndex < deviceSet->getNumberOfTxChannels()) { MainWindow::MsgDeleteChannel *msg = MainWindow::MsgDeleteChannel::create(deviceSetIndex, channelIndex, true); m_mainWindow.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 Tx channels") .arg(channelIndex) .arg(channelIndex < deviceSet->getNumberOfRxChannels()); return 400; } } else { error.init(); *error.getMessage() = QString("DeviceSet error"); return 500; } } else { error.init(); *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterGUI::devicesetChannelSettingsGet( int deviceSetIndex, int channelIndex, SWGSDRangel::SWGChannelSettings& response, SWGSDRangel::SWGErrorResponse& error) { if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainWindow.m_deviceUIs.size())) { DeviceUISet *deviceSet = m_mainWindow.m_deviceUIs[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine) // Rx { ChannelSinkAPI *channelAPI = deviceSet->m_deviceSourceAPI->getChanelAPIAt(channelIndex); if (channelAPI == 0) { error.init(); *error.getMessage() = QString("There is no channel with index %1").arg(channelIndex); return 404; } else { response.setChannelType(new QString()); channelAPI->getIdentifier(*response.getChannelType()); response.setTx(0); return channelAPI->webapiSettingsGet(response, *error.getMessage()); } } else if (deviceSet->m_deviceSinkEngine) // Tx { ChannelSourceAPI *channelAPI = deviceSet->m_deviceSinkAPI->getChanelAPIAt(channelIndex); if (channelAPI == 0) { error.init(); *error.getMessage() = QString("There is no channel with index %1").arg(channelIndex); return 404; } else { response.setChannelType(new QString()); channelAPI->getIdentifier(*response.getChannelType()); response.setTx(1); return channelAPI->webapiSettingsGet(response, *error.getMessage()); } } else { error.init(); *error.getMessage() = QString("DeviceSet error"); return 500; } } else { error.init(); *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } int WebAPIAdapterGUI::devicesetChannelSettingsPutPatch( int deviceSetIndex, int channelIndex, bool force, const QStringList& channelSettingsKeys, SWGSDRangel::SWGChannelSettings& response, SWGSDRangel::SWGErrorResponse& error) { if ((deviceSetIndex >= 0) && (deviceSetIndex < (int) m_mainWindow.m_deviceUIs.size())) { DeviceUISet *deviceSet = m_mainWindow.m_deviceUIs[deviceSetIndex]; if (deviceSet->m_deviceSourceEngine) // Rx { ChannelSinkAPI *channelAPI = deviceSet->m_deviceSourceAPI->getChanelAPIAt(channelIndex); if (channelAPI == 0) { error.init(); *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.init(); *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 { ChannelSourceAPI *channelAPI = deviceSet->m_deviceSinkAPI->getChanelAPIAt(channelIndex); if (channelAPI == 0) { error.init(); *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.init(); *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.init(); *error.getMessage() = QString("DeviceSet error"); return 500; } } else { error.init(); *error.getMessage() = QString("There is no device set with index %1").arg(deviceSetIndex); return 404; } } void WebAPIAdapterGUI::getDeviceSetList(SWGSDRangel::SWGDeviceSetList* deviceSetList) { deviceSetList->init(); deviceSetList->setDevicesetcount((int) m_mainWindow.m_deviceUIs.size()); if (m_mainWindow.m_deviceUIs.size() > 0) { deviceSetList->setDevicesetfocus(m_mainWindow.ui->tabInputsView->currentIndex()); } std::vector::const_iterator it = m_mainWindow.m_deviceUIs.begin(); for (int i = 0; it != m_mainWindow.m_deviceUIs.end(); ++it, i++) { QList *deviceSets = deviceSetList->getDeviceSets(); deviceSets->append(new SWGSDRangel::SWGDeviceSet()); getDeviceSet(deviceSets->back(), *it, i); } } void WebAPIAdapterGUI::getDeviceSet(SWGSDRangel::SWGDeviceSet *deviceSet, const DeviceUISet* deviceUISet, int deviceUISetIndex) { deviceSet->init(); SWGSDRangel::SWGSamplingDevice *samplingDevice = deviceSet->getSamplingDevice(); samplingDevice->init(); samplingDevice->setIndex(deviceUISetIndex); samplingDevice->setTx(deviceUISet->m_deviceSinkEngine != 0); if (deviceUISet->m_deviceSinkEngine) // Tx data { *samplingDevice->getHwType() = deviceUISet->m_deviceSinkAPI->getHardwareId(); *samplingDevice->getSerial() = deviceUISet->m_deviceSinkAPI->getSampleSinkSerial(); samplingDevice->setSequence(deviceUISet->m_deviceSinkAPI->getSampleSinkSequence()); samplingDevice->setNbStreams(deviceUISet->m_deviceSinkAPI->getNbItems()); samplingDevice->setStreamIndex(deviceUISet->m_deviceSinkAPI->getItemIndex()); deviceUISet->m_deviceSinkAPI->getDeviceEngineStateStr(*samplingDevice->getState()); DeviceSampleSink *sampleSink = deviceUISet->m_deviceSinkEngine->getSink(); if (sampleSink) { samplingDevice->setCenterFrequency(sampleSink->getCenterFrequency()); samplingDevice->setBandwidth(sampleSink->getSampleRate()); } deviceSet->setChannelcount(deviceUISet->m_deviceSinkAPI->getNbChannels()); QList *channels = deviceSet->getChannels(); for (int i = 0; i < deviceSet->getChannelcount(); i++) { channels->append(new SWGSDRangel::SWGChannel); channels->back()->init(); ChannelSourceAPI *channel = deviceUISet->m_deviceSinkAPI->getChanelAPIAt(i); channels->back()->setDeltaFrequency(channel->getCenterFrequency()); channels->back()->setIndex(channel->getIndexInDeviceSet()); channels->back()->setUid(channel->getUID()); channel->getIdentifier(*channels->back()->getId()); channel->getTitle(*channels->back()->getTitle()); } } if (deviceUISet->m_deviceSourceEngine) // Rx data { *samplingDevice->getHwType() = deviceUISet->m_deviceSourceAPI->getHardwareId(); *samplingDevice->getSerial() = deviceUISet->m_deviceSourceAPI->getSampleSourceSerial(); samplingDevice->setSequence(deviceUISet->m_deviceSourceAPI->getSampleSourceSequence()); samplingDevice->setNbStreams(deviceUISet->m_deviceSourceAPI->getNbItems()); samplingDevice->setStreamIndex(deviceUISet->m_deviceSourceAPI->getItemIndex()); deviceUISet->m_deviceSourceAPI->getDeviceEngineStateStr(*samplingDevice->getState()); DeviceSampleSource *sampleSource = deviceUISet->m_deviceSourceEngine->getSource(); if (sampleSource) { samplingDevice->setCenterFrequency(sampleSource->getCenterFrequency()); samplingDevice->setBandwidth(sampleSource->getSampleRate()); } deviceSet->setChannelcount(deviceUISet->m_deviceSourceAPI->getNbChannels()); QList *channels = deviceSet->getChannels(); for (int i = 0; i < deviceSet->getChannelcount(); i++) { channels->append(new SWGSDRangel::SWGChannel); channels->back()->init(); ChannelSinkAPI *channel = deviceUISet->m_deviceSourceAPI->getChanelAPIAt(i); channels->back()->setDeltaFrequency(channel->getCenterFrequency()); channels->back()->setIndex(channel->getIndexInDeviceSet()); channels->back()->setUid(channel->getUID()); channel->getIdentifier(*channels->back()->getId()); channel->getTitle(*channels->back()->getTitle()); } } } QtMsgType WebAPIAdapterGUI::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 WebAPIAdapterGUI::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; } }