rtc_plugins/util/RTCContext.cpp

#include "RTCContext.h"

void RTCContext::onRoom(uint32_t typeId, RTCENGINE_NAMESPACE::MRTCRoomInfo& roomInfo) {
    //std::cout << "RTCContext::onRoom():" << roomInfo.roomId << "," << roomInfo.displayName << "," << roomInfo.userId << "," << roomInfo.message;
    std::cout << "RTCContext::onRoom()" << std::endl;
    std::lock_guard<std::mutex> lock(mutex_);
    isOnRoom_ = true;
}
void RTCContext::onConsumer(uint32_t msgId, const char* roomId, const char* peerId, RTCENGINE_NAMESPACE::MRTCConsumerInfo& consumerInfo) {
    std::cout << "RTCContext::onConsumer():" << consumerInfo.roomId << "," << consumerInfo.displayName << "," << consumerInfo.channelIndex;
    std::lock_guard<std::mutex> lock(mutex_);
    isOnConsumer_ = true;
    //std::cout << "RTCContext::onConsumer()" << std::endl;
}
void RTCContext::onRender(const char* roomId, const char* peerId,
                          RTCENGINE_NAMESPACE::MRTCVideoSourceType sourceType, const RTCENGINE_NAMESPACE::MRTCVideoFrame& videoFrame) {
    std::cout << "RTCContext::onRender()" << std::endl;
}
void RTCContext::onCallBackMessage(uint32_t msgId, const char* msg) {

    std::lock_guard<std::mutex> lock(mutex_);
    if (msgId == (uint32_t)mrtc::JOIN_MULTI_ROOM_SUCCESS) {
        std::cout << "receive join multi room callback" << msgId;
        isJoinMultiRoom_ = true;
    }

    std::cout << "RTCContext::onCallBackMessage(), msgId:" << msgId << ", msg:" << msg;
    //std::cout << "RTCContext::onCallBackMessage()" << std::endl;
}
void RTCContext::onCallBackCustomData(RTCENGINE_NAMESPACE::MRTCCustomDataObject object) {
    //std::cout << "RTCContext::onCallBackCustomData(), obj:" << object.peerId << "," << object.data << "," << object.data_length;
    std::cout << "RTCContext::onCallBackCustomData()" << std::endl;
}
void RTCContext::onSoundLevelUpdate(const char* roomId, const char* peerId, uint16_t audioSourceType,
                                    uint8_t channelIndex, uint16_t volume, int32_t vad)
{
    std::cout << "RTCContext::onSoundLevelUpdate()" << std::endl;
}
/*
void RTCContext::onAudioProcess(const char* roomId, const char* peerId,
                                mrtc::MRTCAudioFrame& audioFrame, mrtc::MRTCAudioSourceType audioSourceType)
{
    namespace py = boost::python;
    std::cout << "-----------------------------------" << std::endl;
    std::cout << "dataCount:" << audioFrame.dataCount << audioSourceType << std::endl;
    if (audioFrame.data == nullptr) {
        std::cout << "sudioFrame data is null" << std::endl;
    } else if (!py_callback_.is_none()) {
        std::cout << "python callback" << std::endl;
        npy_intp dims[1] = {audioFrame.dataCount};
        std::cout << "step1" << std::endl;
        PyObject* pyArray = PyArray_SimpleNewFromData(1, dims, NPY_INT16, audioFrame.data);
        std::cout << "step2" << std::endl;
        py_callback_(py::handle<>(pyArray), audioFrame.dataCount, audioFrame.sampleRate, audioFrame.numChannels,
                    audioFrame.channelIndex);
        std::cout << "step3" << std::endl;
    }
}
*/
void RTCContext::onAudioProcess(const char* roomId, const char* peerId,
                                mrtc::MRTCAudioFrame& audioFrame,
                                mrtc::MRTCAudioSourceType audioSourceType)
{
    namespace py = boost::python;

    // 1. 获取 GIL（绝对必要）
    py::gil_scoped_acquire gil;

    try {
        std::cout << "-----------------------------------" << std::endl;
        std::cout << "dataCount:" << audioFrame.dataCount << std::endl;

        // 2. 严格校验输入数据
        if (!audioFrame.data || audioFrame.dataCount <= 0) {
            std::cerr << "Invalid audio frame data" << std::endl;
            return;
        }

        std::cout << "step1" << std::endl;
        // 3. 检查 NumPy API 状态（关键！）
        if (PyArray_API == nullptr) {
            std::cerr << "NumPy API not initialized" << std::endl;
            return;
        }

        std::cout << "step2" << std::endl;
        // 4. 安全创建 NumPy 数组（深拷贝方案）
        npy_intp dims[1] = {audioFrame.dataCount};
        PyObject* pyArray = PyArray_SimpleNew(1, dims, NPY_INT16);  // 创建新数组
        if (!pyArray) {
            std::cerr << "Failed to create NumPy array" << std::endl;
            return;
        }
        std::cout << "step3" << std::endl;

        // 5. 拷贝数据（避免外部内存问题）
        void* array_data = PyArray_DATA((PyArrayObject*)pyArray);
        std::cout << "step4" << std::endl;
        std::memcpy(array_data, audioFrame.data, audioFrame.dataCount * sizeof(int16_t));
        std::cout << "step5" << std::endl;

        // 6. 执行回调
        if (!py_callback_.is_none()) {
            py_callback_(
                    py::handle<>(pyArray),  // 自动管理引用
                    audioFrame.dataCount,
                    audioFrame.sampleRate,
                    audioFrame.numChannels,
                    audioFrame.channelIndex
            );
        }
        std::cout << "step6" << std::endl;

        // 7. 释放数组（py::handle 会管理引用，此处可省略）
        Py_DECREF(pyArray);
        std::cout << "step7" << std::endl;

    } catch (const std::exception& e) {
        std::cerr << "Audio process error: " << e.what() << std::endl;
        PyErr_Print();
    }
}
void RTCContext::onProducer(uint32_t msgId, mrtc::MRTCProducerInfo& info)
{
    std::cout << "-----------------------------------" << std::endl;
    std::cout << "RTCContext::onProducer()" << std::endl;
}
bool RTCContext::init(const char* selfUserId, const char* selfDisplayName, const char* selfRoomId)
{
    mrtc::IMRTCEngineFactory * rtcFactory = mrtc::getMRTCEngineFactory();
    if (!rtcFactory)
    {
        return false;
    }
    rtcEngine_ = rtcFactory->produceMRTCEngine();
    if (!rtcEngine_)
    {
        return false;
    }
    mrtc::MRTCEngineConfig engineConfig;
    strcpy(engineConfig.domain, domain);
    strcpy(engineConfig.applicationId, appid);
    strcpy(engineConfig.appSecrectKey, appSecrectKey);
    engineConfig.port = port;
    if (0 != rtcEngine_->init(engineConfig, this))
    {
        std::cout << "RTCContext::instance().init() failed" << std::endl;
        return false;
    }

    if (0 != rtcEngine_->setUserInfo(selfUserId, selfDisplayName, selfRoomId))
    {
        std::cout << "RTCContext::instance().setUserInfo() failed" << std::endl;
        return false;
    }
    mrtc::MRTCJoinAuthority authority;
    strcpy(authority.applicationId, appid);
    strcpy(authority.appSecretKey, appSecrectKey);
    mrtc::MRTCJoinConfig loginConfig;
    if (0!= rtcEngine_->joinRoom(authority, loginConfig))
    {
        std::cout << "RTCContext::instance().joinRoom() failed" << std::endl;
        return false;
    }
    if (0 != rtcEngine_->registerListener(mrtc::MRTCListenerType::TYPE_LISTENER_ROOM, this))
    {
        std::cout << "RTCContext::instance().registerListener() failed" << std::endl;
        return false;
    }
    if (0 != rtcEngine_->registerListener(mrtc::MRTCListenerType::TYPE_LISTENER_CONSUMER, this))
    {
        std::cout << "RTCContext::instance().registerListener() failed" << std::endl;
        return false;
    }

    return true;
}
bool RTCContext::initRecv(const char* destRoomId, const char* srcUserId, const int16_t destChannelIndex)
{
    while (!isOnConsumer_)
    {
        std::cout << "wait for OnConsumer" << std::endl;
        sleep(3);
    }
    std::cout << "registerSoundLevelListener" << std::endl;
    int16_t ret1 = rtcEngine_->registerSoundLevelListener(mrtc::TYPE_AUDIO_SOURCE_CUSTOM, destRoomId,
                                                          srcUserId, destChannelIndex, this);
    if (0 != ret1)
    {
        std::cout << "RTCContext::instance().registerSoundLevelListener() inUser failed, ret:" << ret1;
        return false;
    }
    std::cout << "muteAudio" << std::endl;
    int16_t ret2 = rtcEngine_->muteAudio(destRoomId, srcUserId, mrtc::TYPE_AUDIO_SOURCE_CUSTOM, false, destChannelIndex);
    if (0 != ret2)
    {
        std::cout << "RTCContext::instance().muteAudio() failed, ret:" << ret2;
        return false;
    }
    std::cout << "init recv succ" << std::endl;
    return true;

}
bool RTCContext::initSend(const char* destRoomId, const int16_t destChannelIndex)
{
    while (!isOnRoom_)
    {
        std::cout << "wait for OnRoom" << std::endl;
        sleep(3);
    }
    std::cout << "join multi room" << std::endl;
    int16_t ret1 = rtcEngine_->joinMultiRoom(destRoomId);
    if (ret1 != 0)
    {
        std::cout << "joinMultiRoom fail, ret:" << ret1;
        return false;
    }

    mrtc::MRTCAudioOption option;
    strcpy(option.dstRoomId, destRoomId);
    option.channelIndex = destChannelIndex;
    std::cout << "startCustomAudio" << std::endl;
    int16_t ret2 = rtcEngine_->startCustomAudio(option);
    if (ret2 != 0)
    {
        std::cout << "startCustomAudio fail, ret:" << ret2;
        return false;
    }
    std::cout << "init send succ" << std::endl;
    return true;
}

void RTCContext::destorySend(const int16_t selfChannelIndex)
{
    rtcEngine_->stopCustomAudio(selfChannelIndex);
}
int16_t RTCContext::sendAudioData(uint8_t channelIndex, const void* pData, int32_t nSampleRate, uint64_t nNumberOfChannels, uint64_t dataLength)
{
    std::lock_guard<std::mutex> lock(mutex_);
    if (pData_)
    {
        return rtcEngine_->sendCustomAudioData(channelIndex, pData, nSampleRate, nNumberOfChannels, dataLength);
    }
    return 0;
}
int16_t RTCContext::sendCustomAudioData(const int16_t channelIndex, void* customData, int32_t sampleRate,
                                        uint64_t channelNum, uint64_t dataLen)
{
    while(!isOnRoom_ || !isJoinMultiRoom_) {
        std::cout << "wait for room and multi room before send" << std::endl;
        sleep(3);
    }
    std::lock_guard<std::mutex> lock(mutex_);
    if (customData == nullptr) {
        std::cout << "customData is null" << std::endl;
        return -1;
    }
    std::cout << "customData addr is:" << customData << std::endl;
    return rtcEngine_->sendCustomAudioData(channelIndex, customData, sampleRate, channelNum, dataLen);
}
mrtc::IMRTCEngine* RTCContext::getRtcEngine() const
{
    std::lock_guard<std::mutex> lock(mutex_);
    return rtcEngine_;
}
void* RTCContext::getpData() const
{
    std::lock_guard<std::mutex> lock(mutex_);
    return pData_;
}
void RTCContext::setpData(void* pData)
{
    std::lock_guard<std::mutex> lock(mutex_);
    pData_ = pData;
}
void RTCContext::setPyCallback(boost::python::object callback) {
    std::lock_guard<std::mutex> lock(mutex_);
    py_callback_ = callback;
}