PulseAudioBluetoothInitializer.h

Go to the documentation of this file.

/*
 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
 *
 * Licensed under the Apache License, Version 2.0 (the "License").
 * You may not use this file except in compliance with the License.
 * A copy of the License is located at
 *
 *     http://aws.amazon.com/apache2.0/
 *
 * or in the "license" file accompanying this file. This file is distributed
 * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
 * express or implied. See the License for the specific language governing
 * permissions and limitations under the License.
 */

#ifndef ALEXA_CLIENT_SDK_BLUETOOTHIMPLEMENTATIONS_BLUEZ_INCLUDE_BLUEZ_PULSEAUDIOBLUETOOTHINITIALIZER_H_
#define ALEXA_CLIENT_SDK_BLUETOOTHIMPLEMENTATIONS_BLUEZ_INCLUDE_BLUEZ_PULSEAUDIOBLUETOOTHINITIALIZER_H_

#include <condition_variable>
#include <memory>
#include <mutex>

#include <AVSCommon/Utils/Bluetooth/BluetoothEventBus.h>
#include <AVSCommon/Utils/Threading/Executor.h>

#include "pulse/pulseaudio.h"

namespace alexaClientSDK {
namespace bluetoothImplementations {
namespace blueZ {

class PulseAudioBluetoothInitializer
        : public avsCommon::utils::bluetooth::BluetoothEventListenerInterface
        , public std::enable_shared_from_this<PulseAudioBluetoothInitializer> {
public:
    enum class ModuleState {
        UNKNOWN,
        INITIALLY_LOADED,
        UNLOADED,
        LOADED_BY_SDK,
    };

    static std::shared_ptr<PulseAudioBluetoothInitializer> create(
        std::shared_ptr<avsCommon::utils::bluetooth::BluetoothEventBus> eventBus);

    ~PulseAudioBluetoothInitializer();

protected:
    void onEventFired(const avsCommon::utils::bluetooth::BluetoothEvent& event) override;

private:
    static void onStateChanged(pa_context* context, void* userdata);

    static void onModuleFound(pa_context* context, const pa_module_info* info, int eol, void* userData);

    static void onLoadPolicyResult(pa_context* context, uint32_t index, void* userdata);

    static void onLoadDiscoverResult(pa_context* context, uint32_t index, void* userdata);

    static void onUnloadPolicyResult(pa_context* context, int success, void* userdata);

    static void onUnloadDiscoverResult(pa_context* context, int success, void* userdata);

    void handleLoadModuleResult(pa_context* context, uint32_t index, const std::string& moduleName);

    void handleUnloadModuleResult(pa_context* context, int success, const std::string& moduleName);

    bool updateStateLocked(const ModuleState& state, const std::string& module);

    void setStateAndNotify(pa_context_state_t state);

    void init();

    void run();

    void cleanup();

    PulseAudioBluetoothInitializer(std::shared_ptr<avsCommon::utils::bluetooth::BluetoothEventBus> eventBus);

    std::condition_variable m_mainThreadCv;

    std::mutex m_mutex;

    std::shared_ptr<avsCommon::utils::bluetooth::BluetoothEventBus> m_eventBus;

    pa_threaded_mainloop* m_paLoop;

    bool m_paLoopStarted;

    pa_context* m_context;

    ModuleState m_policyState;

    ModuleState m_discoverState;

    bool m_connected;

    avsCommon::utils::threading::Executor m_executor;
};

inline std::string moduleStateToString(const PulseAudioBluetoothInitializer::ModuleState& state) {
    switch (state) {
        case PulseAudioBluetoothInitializer::ModuleState::UNKNOWN:
            return "UNKNOWN";
        case PulseAudioBluetoothInitializer::ModuleState::INITIALLY_LOADED:
            return "INITIALLY_LOADED";
        case PulseAudioBluetoothInitializer::ModuleState::UNLOADED:
            return "UNLOADED";
        case PulseAudioBluetoothInitializer::ModuleState::LOADED_BY_SDK:
            return "LOADED_BY_SDK";
    }

    return "INVALID";
}

inline std::ostream& operator<<(std::ostream& stream, const PulseAudioBluetoothInitializer::ModuleState& state) {
    return stream << moduleStateToString(state);
}

}  // namespace blueZ
}  // namespace bluetoothImplementations
}  // namespace alexaClientSDK

#endif  // ALEXA_CLIENT_SDK_BLUETOOTHIMPLEMENTATIONS_BLUEZ_INCLUDE_BLUEZ_PULSEAUDIOBLUETOOTHINITIALIZER_H_