Vv-yichenxiMerge commit
9d0c825c创建于 4月27日历史提交
/****************************************************************************
 *  Copyright (C) 2022 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 <getopt.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#include "bluetooth.h"
#include "bt_adapter.h"
#include "bt_hfp_ag.h"
#include "bt_tools.h"

static int connect_cmd(void* handle, int argc, char* argv[]);
static int disconnect_cmd(void* handle, int argc, char* argv[]);
static int connect_audio_cmd(void* handle, int argc, char* argv[]);
static int disconnect_audio_cmd(void* handle, int argc, char* argv[]);
static int start_virtual_call_cmd(void* handle, int argc, char* argv[]);
static int stop_virtual_call_cmd(void* handle, int argc, char* argv[]);
static int start_voice_recognition_cmd(void* handle, int argc, char* argv[]);
static int stop_voice_recognition_cmd(void* handle, int argc, char* argv[]);
static int send_at_cmd_cmd(void* handle, int argc, char* argv[]);

static bt_command_t g_hfp_ag_tables[] = {
    { "connect", connect_cmd, 0, "\"establish hfp SLC connection     , params: <address>\"" },
    { "disconnect", disconnect_cmd, 0, "\"disconnect hfp SLC connection    , params: <address>\"" },
    { "connectaudio", connect_audio_cmd, 0, "\"establish hfp SCO connection     , params: <address>\"" },
    { "disconnectaudio", disconnect_audio_cmd, 0, "\"disconnect hfp SCO connection    , params: <address>\"" },
    { "startvc", start_virtual_call_cmd, 0, "\"establish SCO using virtual call , params: <address>\"" },
    { "stopvc", stop_virtual_call_cmd, 0, "\"disconnect SCO using virtual call, params: <address>\"" },
    { "startvr", start_voice_recognition_cmd, 0, "\"start voice recognition          , params: <address>\"" },
    { "stopvr", stop_voice_recognition_cmd, 0, "\"stop voice recognition           , params: <address>\"" },
    { "sendat", send_at_cmd_cmd, 0, "\"Send customize AT command to peer, params: <address> <atcmd>\"" },
};

static void* ag_callbacks = NULL;

static void usage(void)
{
    printf("Usage:\n");
    printf("\taddress: peer device address like 00:01:02:03:04:05\n");
    printf("Commands:\n");
    for (int i = 0; i < ARRAY_SIZE(g_hfp_ag_tables); i++) {
        printf("\t%-8s\t%s\n", g_hfp_ag_tables[i].cmd, g_hfp_ag_tables[i].help);
    }
}

static int connect_cmd(void* handle, int argc, char* argv[])
{
    if (argc < 1)
        return CMD_PARAM_NOT_ENOUGH;

    bt_address_t addr;
    if (bt_addr_str2ba(argv[0], &addr) < 0)
        return CMD_INVALID_ADDR;

    if (bt_hfp_ag_connect(handle, &addr) != BT_STATUS_SUCCESS)
        return CMD_ERROR;

    return CMD_OK;
}

static int disconnect_cmd(void* handle, int argc, char* argv[])
{
    bt_address_t addr;
    if (argc < 1)
        return CMD_PARAM_NOT_ENOUGH;

    if (bt_addr_str2ba(argv[0], &addr) < 0)
        return CMD_INVALID_ADDR;

    if (bt_hfp_ag_disconnect(handle, &addr) != BT_STATUS_SUCCESS)
        return CMD_ERROR;

    return CMD_OK;
}

static int connect_audio_cmd(void* handle, int argc, char* argv[])
{
    if (argc < 1)
        return CMD_PARAM_NOT_ENOUGH;

    bt_address_t addr;
    if (bt_addr_str2ba(argv[0], &addr) < 0)
        return CMD_INVALID_ADDR;

    if (bt_hfp_ag_connect_audio(handle, &addr) != BT_STATUS_SUCCESS)
        return CMD_ERROR;

    return CMD_OK;
}

static int disconnect_audio_cmd(void* handle, int argc, char* argv[])
{
    if (argc < 1)
        return CMD_PARAM_NOT_ENOUGH;

    bt_address_t addr;
    if (bt_addr_str2ba(argv[0], &addr) < 0)
        return CMD_INVALID_ADDR;

    if (bt_hfp_ag_disconnect_audio(handle, &addr) != BT_STATUS_SUCCESS)
        return CMD_ERROR;

    return CMD_OK;
}

static int start_virtual_call_cmd(void* handle, int argc, char* argv[])
{
    if (argc < 1)
        return CMD_PARAM_NOT_ENOUGH;

    bt_address_t addr;
    if (bt_addr_str2ba(argv[0], &addr) < 0)
        return CMD_INVALID_ADDR;

    if (bt_hfp_ag_start_virtual_call(handle, &addr) != BT_STATUS_SUCCESS)
        return CMD_ERROR;

    return CMD_OK;
}

static int stop_virtual_call_cmd(void* handle, int argc, char* argv[])
{
    if (argc < 1)
        return CMD_PARAM_NOT_ENOUGH;

    bt_address_t addr;
    if (bt_addr_str2ba(argv[0], &addr) < 0)
        return CMD_INVALID_ADDR;

    if (bt_hfp_ag_stop_virtual_call(handle, &addr) != BT_STATUS_SUCCESS)
        return CMD_ERROR;

    return CMD_OK;
}

static int start_voice_recognition_cmd(void* handle, int argc, char* argv[])
{
    if (argc < 1)
        return CMD_PARAM_NOT_ENOUGH;

    bt_address_t addr;
    if (bt_addr_str2ba(argv[0], &addr) < 0)
        return CMD_INVALID_ADDR;

    if (bt_hfp_ag_start_voice_recognition(handle, &addr) != BT_STATUS_SUCCESS)
        return CMD_ERROR;

    return CMD_OK;
}

static int stop_voice_recognition_cmd(void* handle, int argc, char* argv[])
{
    if (argc < 1)
        return CMD_PARAM_NOT_ENOUGH;

    bt_address_t addr;
    if (bt_addr_str2ba(argv[0], &addr) < 0)
        return CMD_INVALID_ADDR;

    if (bt_hfp_ag_stop_voice_recognition(handle, &addr) != BT_STATUS_SUCCESS)
        return CMD_ERROR;

    return CMD_OK;
}

static int send_at_cmd_cmd(void* handle, int argc, char* argv[])
{
    bt_address_t addr;
    int len = 0;
    char at_buf[64];

    if (argc < 2)
        return CMD_PARAM_NOT_ENOUGH;

    if (bt_addr_str2ba(argv[0], &addr) < 0)
        return CMD_INVALID_ADDR;

    len = strlen(argv[1]);
    if (len + 3 > 64)
        return CMD_INVALID_PARAM;

    memcpy(at_buf, argv[1], len);
    at_buf[len] = '\r';
    at_buf[len + 1] = '\n';
    at_buf[len + 2] = '\0';

    if (bt_hfp_ag_send_at_command(handle, &addr, argv[1]) != BT_STATUS_SUCCESS)
        return CMD_ERROR;

    return CMD_OK;
}

static void ag_connection_state_callback(void* context, bt_address_t* addr, profile_connection_state_t state)
{
    PRINT_ADDR("ag_connection_state_callback, addr:%s, state:%d", addr, state);
}

static void ag_audio_state_callback(void* context, bt_address_t* addr, hfp_audio_state_t state)
{
    PRINT_ADDR("ag_audio_state_callback, addr:%s, state:%d", addr, state);
}

static void ag_vr_cmd_callback(void* context, bt_address_t* addr, bool started)
{
    PRINT_ADDR("ag_vr_cmd_callback, addr:%s, started:%d", addr, started);
}

static void ag_battery_update_callback(void* context, bt_address_t* addr, uint8_t value)
{
    PRINT_ADDR("ag_battery_update_callback, addr:%s, battery:%d", addr, value);
}

static void ag_volume_control_callback(void* context, bt_address_t* addr, hfp_volume_type_t type, uint8_t volume)
{
    PRINT_ADDR("ag_volume_control_callback, addr:%s, type:%d, volume:%d", addr, type, volume);
}

static void ag_answer_call_callback(void* context, bt_address_t* addr)
{
    PRINT_ADDR("ag_answer_call_callback, addr:%s", addr);
}

static void ag_reject_call_callback(void* context, bt_address_t* addr)
{
    PRINT_ADDR("ag_reject_call_callback, addr:%s", addr);
}

static void ag_hangup_call_callback(void* context, bt_address_t* addr)
{
    PRINT_ADDR("ag_hangup_call_callback, addr:%s", addr);
}

static void ag_dial_call_callback(void* context, bt_address_t* addr, const char* number)
{
    PRINT_ADDR("ag_dial_call_callback, addr:%s, number:%s", addr, number ? number : "redial");
}

static void ag_at_cmd_callback(void* context, bt_address_t* addr, const char* at_command)
{
    PRINT_ADDR("ag_at_cmd_callback, addr:%s, at_command:%s", addr, at_command);
}

static const hfp_ag_callbacks_t hfp_ag_cbs = {
    sizeof(hfp_ag_cbs),
    ag_connection_state_callback,
    ag_audio_state_callback,
    ag_vr_cmd_callback,
    ag_battery_update_callback,
    ag_volume_control_callback,
    ag_answer_call_callback,
    ag_reject_call_callback,
    ag_hangup_call_callback,
    ag_dial_call_callback,
    ag_at_cmd_callback,
};

int hfp_ag_commond_init(void* handle)
{
    ag_callbacks = bt_hfp_ag_register_callbacks(handle, &hfp_ag_cbs);

    return 0;
}

int hfp_ag_commond_uninit(void* handle)
{
    bt_hfp_ag_unregister_callbacks(handle, ag_callbacks);

    return 0;
}

int hfp_ag_command_exec(void* handle, int argc, char* argv[])
{
    int ret = CMD_USAGE_FAULT;

    if (argc > 0)
        ret = execute_command_in_table(handle, g_hfp_ag_tables, ARRAY_SIZE(g_hfp_ag_tables), argc, argv);

    if (ret < 0)
        usage();

    return ret;
}