Skip to content

Commit

Permalink
[UI] brand new UI!
Browse files Browse the repository at this point in the history
  • Loading branch information
zhang-ray committed Nov 1, 2018
1 parent b30fb9d commit 08dddef
Show file tree
Hide file tree
Showing 17 changed files with 914 additions and 389 deletions.
24 changes: 11 additions & 13 deletions client_essential/Worker.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ decltype(WebRtcNsx_Create()) ns_ = nullptr;

using namespace webrtc;

const char *constPort ="1222";
//const char *constPort ="80";

Worker::Worker(bool needAec)
:needAec_(needAec)
Expand Down Expand Up @@ -82,29 +82,27 @@ bool Worker::initCodec(){
}

bool Worker::initDevice(std::function<void(const std::string &, const std::string &)> reportInfo,
std::function<void(const uint8_t)> reportMicVolume,
std::function<void(const uint8_t)> reportSpkVolume,
std::function<void(const AudioIoVolume)> reportVolume,
std::function<void(const bool)> vadReporter){
device_ = &(Factory::get().create());

std::string micInfo;
std::string spkInfo;
if (device_->init(micInfo, spkInfo)){
reportInfo(micInfo, spkInfo);
micVolumeReporter_ = reportMicVolume;
spkVolumeReporter_ = reportSpkVolume;
volumeReporter_ = reportVolume;
vadReporter_ = vadReporter;
return true;
}
return false;
}

void Worker::asyncStart(const std::string &host, std::function<void (const NetworkState &, const std::string &)> toggleState){
void Worker::asyncStart(const std::string &host,const std::string &port, std::function<void (const NetworkState &, const std::string &)> toggleState){
syncStop();
netThread_.reset(new std::thread(std::bind(&Worker::syncStart, this, host, toggleState)));
netThread_.reset(new std::thread(std::bind(&Worker::syncStart, this, host, port, toggleState)));
}

void Worker::syncStart(const std::string &host,
void Worker::syncStart(const std::string &host,const std::string &port,
std::function<void(const NetworkState &newState, const std::string &extraMessage)> toggleState
){

Expand All @@ -114,7 +112,7 @@ void Worker::syncStart(const std::string &host,
bool isLogin = false;
TcpClient client(
host.c_str(),
constPort,
port.c_str(),
[&](TcpClient *_TcpClient, const NetPacket& netPacket){
// on Received Data
switch (netPacket.payloadType()){
Expand Down Expand Up @@ -147,9 +145,9 @@ void Worker::syncStart(const std::string &host,
}
}
auto ret = device_->write(decodedPcm);
if (spkVolumeReporter_){
if (volumeReporter_){
static SuckAudioVolume sav;
spkVolumeReporter_(sav.calculate(decodedPcm));
volumeReporter_({AudioInOut::Out, sav.calculate(decodedPcm, AudioIoVolume::MAX_VOLUME_LEVEL)});
}
if (!ret) {
std::cout << ret.message() << std::endl;
Expand Down Expand Up @@ -251,9 +249,9 @@ void Worker::syncStart(const std::string &host,



if (micVolumeReporter_){
if (volumeReporter_){
static SuckAudioVolume sav;
micVolumeReporter_(sav.calculate(denoisedBuffer));
volumeReporter_({AudioInOut::In, sav.calculate(denoisedBuffer, AudioIoVolume::MAX_VOLUME_LEVEL)});
}

auto haveVoice = (1==WebRtcVad_Process(vad, sampleRate, denoisedBuffer.data(), sampleRate/100));
Expand Down
9 changes: 7 additions & 2 deletions client_qt5/CMakeLists.txt
Original file line number Diff line number Diff line change
Expand Up @@ -49,14 +49,19 @@ set(SRCS
mainwindow.ui
mainwindow.cpp
main.cpp

)

# QRC files
set(QRC_SOURCE_FILES resources/Resource.qrc)
qt5_add_resources(QRC_FILES ${QRC_SOURCE_FILES})



if(WIN32)
add_executable(${PROJECT_NAME} WIN32 ${SRCS} resources/Resource.rc)
add_executable(${PROJECT_NAME} WIN32 ${SRCS} ${QRC_FILES} resources/Resource.rc)
else(WIN32)
add_executable(${PROJECT_NAME} ${SRCS})
add_executable(${PROJECT_NAME} ${SRCS} ${QRC_FILES})
endif(WIN32)

target_link_libraries(
Expand Down
Loading

0 comments on commit 08dddef

Please sign in to comment.