pulse_audio_output_observer.h

Go to the documentation of this file.

/*
 * Copyright © 2014 Canonical Ltd.
 * Copyright © 2022 UBports Foundation.
 *
 * Contact: Alberto Mardegan <mardy@users.sourceforge.net>
 *
 * This program is free software: you can redistribute it and/or modify it
 * under the terms of the GNU Lesser General Public License version 3,
 * as published by the Free Software Foundation.
 *
 * 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 Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 *
 * Authored by: Thomas Voß <thomas.voss@canonical.com>
 *              Ricardo Mendoza <ricardo.mendoza@canonical.com>
 */
#ifndef LOMIRI_MEDIAHUBSERVICE_AUDIO_PULSE_AUDIO_OUTPUT_OBSERVER_H
#define LOMIRI_MEDIAHUBSERVICE_AUDIO_PULSE_AUDIO_OUTPUT_OBSERVER_H
 
#include "audio/output_observer_p.h"
 
#include <iosfwd>
#include <memory>
#include <set>
#include <string>
 
class QStringList;
 
namespace lomiri
{
namespace MediaHubService
{
namespace audio
{
// Implements the audio::OutputObserver interface
// relying on pulse to query the connected ports
// of the primary card of the system.
class PulseAudioOutputObserver : public OutputObserverPrivate
{
public:
    // Reporter is responsible for surfacing events from the implementation
    // that help in resolving/tracking down issues. Default implementation is empty.
    struct Reporter
    {
        // To save us some typing.
        typedef std::shared_ptr<Reporter> Ptr;
 
        // Simple type to help in reporting.
        struct Port
        {
            // Returns true iff the name of both ports are equal.
            bool operator==(const Port& rhs) const;
            // Returns true iff the name of the ports differ.
            bool operator<(const Port& rhs) const;
 
            std::string name; // The name of the port.
            std::string description; // Human-readable description of the port.
            bool is_available; // True if the port is available.
            bool is_monitored; // True if the port is monitored by the observer.
        };
 
        virtual ~Reporter();
        // connected_to_pulse_audio is called when a connection with pulse has been established.
        virtual void connected_to_pulse_audio();
        // query_for_default_sink_failed is called when no default sink was returned.
        virtual void query_for_default_sink_failed();
        // query_for_default_sink_finished is called when the default sink query against pulse
        // has finished, reporting the name of the sink to observers.
        virtual void query_for_default_sink_finished(const std::string& sink_name);
        // query_for_sink_info_finished is called when a query for information about a specific sink
        // has finished, reporting the name, index of the sink as well as the set of ports known to the sink.
        virtual void query_for_sink_info_finished(const std::string& name, std::uint32_t index, const std::set<Port>& known_ports);
        // sink_event_with_index is called when something happened on a sink, reporing the index of the
        // sink.
        virtual void sink_event_with_index(std::uint32_t index);
    };
 
    // Constructs a new instance, throws:
    //   * std::runtime_error if connection to pulseaudio fails.
    //   * std::runtime_error if reporter instance is null.
    PulseAudioOutputObserver(const QString &sink,
                             const QStringList &outputPortPatterns,
                             Reporter::Ptr reporter,
                             OutputObserver *q);
 
    // We provide the name of the sink we are connecting to as a
    // getable property. This is specifically meant for
    // consumption by test code.
    QString sink() const;
    // The set of ports that have been identified on the configured sink.
    // Specifically meant for consumption by test code.
    std::set<Reporter::Port>& knownPorts() const;
 
private:
    struct Private;
    std::shared_ptr<Private> d;
};
}
}
}
 
#endif // LOMIRI_MEDIAHUBSERVICE_AUDIO_PULSE_AUDIO_OUTPUT_OBSERVER_H