deviceendpoint.cc

Go to the documentation of this file.

/*
 * This file is part of plptools.
 *
 *  Copyright (c) 2026 Jason Morley <hello@jbmorley.co.uk>
 *
 *  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; either version 2 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 for more details.
 *
 *  You should have received a copy of the GNU General Public License along
 *  along with this program; if not, see <https://www.gnu.org/licenses/>.
 *
 */
#include "config.h"
 
#include <memory>
#include <optional>
#include <string>
 
#include "deviceendpoint.h"
 
#include "device.h"
#include "deviceconfiguration.h"
#include "rclip.h"
#include "rfsv.h"
#include "rpcs.h"
#include "uuid.h"
 
std::unique_ptr<DeviceEndpoint> DeviceEndpoint::connect(const std::string host,
                                                        int port,
                                                        Enum<ConnectionError> *error) {
    Enum<ConnectionError> internalError = ConnectionError::FACERR_NONE;
    auto rfsv = std::unique_ptr<RFSV>(RFSV::connect(host, port, &internalError));
    if (!rfsv) {
        if (error) {
            *error = internalError;
        }
        return nullptr;
    }
 
    // Get the device configuration.
    Enum<RFSV::errs> result;
    auto deviceConfiguration = device::read_configuration(*rfsv, result);
    std::string id = deviceConfiguration ? deviceConfiguration->id() : uuid::uuid4();
    auto name = deviceConfiguration ? std::optional<std::string>(deviceConfiguration->name()) : std::nullopt;
    bool hasPersistentConfiguration = static_cast<bool>(deviceConfiguration);
 
    auto rpcs = std::unique_ptr<RPCS>(RPCS::connect(host, port, &internalError));
    if (!rpcs) {
        if (error) {
            *error = internalError;
        }
        return nullptr;
    }
 
    auto clip = std::unique_ptr<rclip>(rclip::connect(host, port, &internalError));
    if (!clip) {
        if (error) {
            *error = internalError;
        }
        return nullptr;
    }
 
    return std::unique_ptr<DeviceEndpoint>(
        new DeviceEndpoint(id,
                           name,
                           hasPersistentConfiguration,
                           std::move(rfsv),
                           std::move(rpcs),
                           std::move(clip)));
}
 
DeviceEndpoint::DeviceEndpoint(const std::string &id,
                               const std::optional<std::string> &name,
                               bool hasPersistentConfiguration,
                               std::unique_ptr<RFSV> rfsv,
                               std::unique_ptr<RPCS> rpcs,
                               std::unique_ptr<rclip> clip)
: rfsv_(std::move(rfsv))
, rpcs_(std::move(rpcs))
, clip_(std::move(clip))
, id_(id)
, name_(name)
, hasPersistentConfiguration_(hasPersistentConfiguration) {
}
 
std::string DeviceEndpoint::id() const {
    return id_;
}
 
bool DeviceEndpoint::hasPersistentId() const {
    return hasPersistentConfiguration_;
}
 
std::optional<std::string> DeviceEndpoint::name() const {
    return name_;
}
 
Enum<RFSV::errs> DeviceEndpoint::setName(const std::string &name) {
    auto deviceConfiguration = std::make_unique<DeviceConfiguration>(id_, name);
    auto result = device::write_configuration(*rfsv_, *deviceConfiguration);
    if (result == RFSV::E_PSI_GEN_NONE) {
        name_ = name;
        hasPersistentConfiguration_ = true;
    }
    return result;
}