frameworks_bluetooth/framework/socket/bt_a2dp_source.c

/****************************************************************************
 *  Copyright (C) 2023 Xiaomi Corporation
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License 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.
 ***************************************************************************/

#include <stdint.h>
#include <stdlib.h>
#include <string.h>

#include "bt_a2dp_source.h"
#include "bt_socket.h"

void* bt_a2dp_source_register_callbacks(bt_instance_t* ins, const a2dp_source_callbacks_t* callbacks)
{
    bt_message_packet_t packet;
    bt_status_t status;
    void* handle;

    BT_SOCKET_INS_VALID(ins, NULL);
    if (ins->a2dp_source_callbacks != NULL) {
        handle = bt_remote_callbacks_register(ins->a2dp_source_callbacks, NULL, (void*)callbacks);
        return handle;
    }

    ins->a2dp_source_callbacks = bt_callbacks_list_new(CONFIG_BLUETOOTH_MAX_REGISTER_NUM);

    handle = bt_remote_callbacks_register(ins->a2dp_source_callbacks, NULL, (void*)callbacks);
    if (handle == NULL) {
        bt_callbacks_list_free(ins->a2dp_source_callbacks);
        ins->a2dp_source_callbacks = NULL;
        return handle;
    }

    status = bt_socket_client_sendrecv(ins, &packet, BT_A2DP_SOURCE_REGISTER_CALLBACKS);
    if (status != BT_STATUS_SUCCESS || packet.a2dp_source_r.status != BT_STATUS_SUCCESS) {
        bt_callbacks_list_free(ins->a2dp_source_callbacks);
        ins->a2dp_source_callbacks = NULL;
        return NULL;
    }

    return handle;
}

bool bt_a2dp_source_unregister_callbacks(bt_instance_t* ins, void* cookie)
{
    bt_message_packet_t packet;
    bt_status_t status;
    callbacks_list_t* cbsl;

    BT_SOCKET_INS_VALID(ins, false);
    if (!ins->a2dp_source_callbacks)
        return false;

    bt_remote_callbacks_unregister(ins->a2dp_source_callbacks, NULL, cookie);
    if (bt_callbacks_list_count(ins->a2dp_source_callbacks) > 0) {
        return true;
    }

    cbsl = ins->a2dp_source_callbacks;
    ins->a2dp_source_callbacks = NULL;
    bt_socket_client_free_callbacks(ins, cbsl);

    status = bt_socket_client_sendrecv(ins, &packet, BT_A2DP_SOURCE_UNREGISTER_CALLBACKS);
    if (status != BT_STATUS_SUCCESS || packet.a2dp_source_r.status != BT_STATUS_SUCCESS) {
        return false;
    }

    return true;
}

bool bt_a2dp_source_is_connected(bt_instance_t* ins, bt_address_t* addr)
{
    bt_message_packet_t packet;
    bt_status_t status;

    BT_SOCKET_INS_VALID(ins, false);
    memcpy(&packet.a2dp_source_pl._bt_a2dp_source_is_connected.addr, addr, sizeof(bt_address_t));

    status = bt_socket_client_sendrecv(ins, &packet, BT_A2DP_SOURCE_IS_CONNECTED);
    if (status != BT_STATUS_SUCCESS) {
        return false;
    }

    return packet.a2dp_source_r.bbool;
}

bool bt_a2dp_source_is_playing(bt_instance_t* ins, bt_address_t* addr)
{
    bt_message_packet_t packet;
    bt_status_t status;

    BT_SOCKET_INS_VALID(ins, false);
    memcpy(&packet.a2dp_source_pl._bt_a2dp_source_is_playing.addr, addr, sizeof(bt_address_t));

    status = bt_socket_client_sendrecv(ins, &packet, BT_A2DP_SOURCE_IS_PLAYING);
    if (status != BT_STATUS_SUCCESS) {
        return false;
    }

    return packet.a2dp_source_r.bbool;
}

profile_connection_state_t bt_a2dp_source_get_connection_state(bt_instance_t* ins, bt_address_t* addr)
{
    bt_message_packet_t packet;
    bt_status_t status;

    BT_SOCKET_INS_VALID(ins, PROFILE_STATE_DISCONNECTED);
    memcpy(&packet.a2dp_source_pl._bt_a2dp_source_get_connection_state.addr, addr, sizeof(bt_address_t));

    status = bt_socket_client_sendrecv(ins, &packet, BT_A2DP_SOURCE_GET_CONNECTION_STATE);
    if (status != BT_STATUS_SUCCESS) {
        return PROFILE_STATE_DISCONNECTED;
    }

    return packet.a2dp_source_r.state;
}

bt_status_t bt_a2dp_source_connect(bt_instance_t* ins, bt_address_t* addr)
{
    bt_message_packet_t packet;
    bt_status_t status;

    BT_SOCKET_INS_VALID(ins, BT_STATUS_PARM_INVALID);
    memcpy(&packet.a2dp_source_pl._bt_a2dp_source_connect.addr, addr, sizeof(bt_address_t));

    status = bt_socket_client_sendrecv(ins, &packet, BT_A2DP_SOURCE_CONNECT);
    if (status != BT_STATUS_SUCCESS) {
        return status;
    }

    return packet.a2dp_source_r.status;
}

bt_status_t bt_a2dp_source_disconnect(bt_instance_t* ins, bt_address_t* addr)
{
    bt_message_packet_t packet;
    bt_status_t status;

    BT_SOCKET_INS_VALID(ins, BT_STATUS_PARM_INVALID);
    memcpy(&packet.a2dp_source_pl._bt_a2dp_source_disconnect.addr, addr, sizeof(bt_address_t));

    status = bt_socket_client_sendrecv(ins, &packet, BT_A2DP_SOURCE_DISCONNECT);
    if (status != BT_STATUS_SUCCESS) {
        return status;
    }

    return packet.a2dp_source_r.status;
}

bt_status_t bt_a2dp_source_set_silence_device(bt_instance_t* ins, bt_address_t* addr, bool silence)
{
    bt_message_packet_t packet;
    bt_status_t status;

    BT_SOCKET_INS_VALID(ins, BT_STATUS_PARM_INVALID);
    memcpy(&packet.a2dp_source_pl._bt_a2dp_source_set_silence_device.addr, addr, sizeof(bt_address_t));

    // TODO: lack ins parameters
    status = bt_socket_client_sendrecv(ins, &packet, BT_A2DP_SOURCE_SET_SILENCE_DEVICE);
    if (status != BT_STATUS_SUCCESS) {
        return status;
    }

    return packet.a2dp_source_r.status;
}

bt_status_t bt_a2dp_source_set_active_device(bt_instance_t* ins, bt_address_t* addr)
{
    bt_message_packet_t packet;
    bt_status_t status;

    BT_SOCKET_INS_VALID(ins, BT_STATUS_PARM_INVALID);
    memcpy(&packet.a2dp_source_pl._bt_a2dp_source_set_active_device.addr, addr, sizeof(bt_address_t));

    // TODO: lack ins parameters
    status = bt_socket_client_sendrecv(ins, &packet, BT_A2DP_SOURCE_SET_ACTIVE_DEVICE);
    if (status != BT_STATUS_SUCCESS) {
        return status;
    }

    return packet.a2dp_source_r.status;
}