diff --git a/.gitignore b/.gitignore
index a4ce7f0..9eec94c 100644
--- a/.gitignore
+++ b/.gitignore
@@ -2,7 +2,6 @@ build
*.rdbg
*.pdb
*.ps1
-*.exe
Makefile
Makefile.Debug
Makefile.Release
\ No newline at end of file
diff --git a/assets.qrc b/assets.qrc
index 2206a8a..a9cbd38 100644
--- a/assets.qrc
+++ b/assets.qrc
@@ -1,10 +1,7 @@
- assets/selawk.ttf
assets/notificationAreaIcon.png
assets/style.qss
assets/logo.ico
- assets/mute.svg
- assets/unmute.svg
diff --git a/assets/SoundVolumeView.exe b/assets/SoundVolumeView.exe
new file mode 100644
index 0000000..4c7a7d2
Binary files /dev/null and b/assets/SoundVolumeView.exe differ
diff --git a/assets/installer.ico b/assets/installer.ico
deleted file mode 100644
index b4e6f82..0000000
Binary files a/assets/installer.ico and /dev/null differ
diff --git a/assets/installer.xcf b/assets/installer.xcf
deleted file mode 100644
index 96669f1..0000000
Binary files a/assets/installer.xcf and /dev/null differ
diff --git a/assets/selawk.ttf b/assets/selawk.ttf
deleted file mode 100644
index 736bac3..0000000
Binary files a/assets/selawk.ttf and /dev/null differ
diff --git a/assets/uninstaller.ico b/assets/uninstaller.ico
deleted file mode 100644
index 24278c2..0000000
Binary files a/assets/uninstaller.ico and /dev/null differ
diff --git a/bueno.bat b/bueno.bat
index 540be60..edb534d 100644
--- a/bueno.bat
+++ b/bueno.bat
@@ -1,7 +1,5 @@
-taskkill /F /IM "MixerQ.exe"
-taskkill /F /IM "MixerQd.exe"
-qmake -o build\Makefile .\qtest.pro
-REM mingw32-make.exe -C .\build -f Makefile.Release
-mingw32-make.exe -C .\build -f Makefile.Debug
-REM makensis /DBUILDTYPE=release install\installer.nsi
-REM makensis /DBUILDTYPE=debug install\installer.nsi
+taskkill /F /IM "qtest.exe"
+qmake -o build\Makefile .\qtest.pro
+copy /Y /B .\assets\SoundVolumeView.exe .\build\debug
+copy /Y /B .\assets\SoundVolumeView.exe .\build\release
+mingw32-make.exe -C .\build -f Makefile
diff --git a/install/installer.nsi b/install/installer.nsi
deleted file mode 100644
index 7e62045..0000000
--- a/install/installer.nsi
+++ /dev/null
@@ -1,265 +0,0 @@
-;Auto versioning-------------------------------
-
- !makensis "/DBUILDTYPE=${BUILDTYPE} version.nsi"
- !system "GetVersion.exe"
- !include "Version.txt"
- ;optional cleanup
- !delfile "GetVersion.exe"
- !delfile "Version.txt"
-
-;Includes--------------------------------
-
- !include "MUI2.nsh"
- !include "nsDialogs.nsh"
- !include "LogicLib.nsh"
- !include "${NSISDIR}\Contrib\Language files\English.nsh"
- !include "${NSISDIR}\Contrib\Language files\Spanish.nsh"
- ;!include "${NSISDIR}\Contrib\Language files\English.nsh"
-
-
-;Defines----------------------------------
- !define MUI_LANGDLL_ALLLANGUAGES
- !define MUI_UNICON "..\assets\uninstaller.ico"
- !define MUI_ICON "..\assets\installer.ico"
-
-
-;--------------------------------
-;General
-
- ;Name and file
- !if ${BUILDTYPE} == "release"
- Name "MixerQ"
- !else
- Name "MixerQd"
- !endif
- OutFile "..\build\bin\MixerQ-installer-${version}.exe"
-
- ;Get installation folder from registry if available
- ;InstallDirRegKey HKCU "Software\Modern UI Test" ""
-
- Unicode True
- Var Is_Admin
- Var Install_Type
-
- ;Request application privileges for UAC. If admin is not available, only user-level install will be available
- RequestExecutionLevel highest
-;--------------------------------
-;Interface Settings
-
- !define MUI_ABORTWARNING
-
-;--------------------------------
-;Pages
- !insertmacro MUI_PAGE_WELCOME
- !insertmacro MUI_PAGE_LICENSE "..\LICENSE.txt"
- ;!insertmacro MULTIUSER_PAGE_INSTALLMODE
- Page Custom InstallTargetPage
- ;!insertmacro MUI_PAGE_COMPONENTS
- !define MUI_PAGE_CUSTOMFUNCTION_PRE Skip_Directory_Func
- !insertmacro MUI_PAGE_DIRECTORY
- !insertmacro MUI_PAGE_INSTFILES
- !insertmacro MUI_PAGE_FINISH
-
- !insertmacro MUI_UNPAGE_WELCOME
- !insertmacro MUI_UNPAGE_CONFIRM
- !insertmacro MUI_UNPAGE_INSTFILES
- !insertmacro MUI_UNPAGE_FINISH
-
-;--------------------------------
-;Languages
-
- !insertmacro MUI_LANGUAGE "English"
- !insertmacro MUI_LANGUAGE "Spanish"
- !insertmacro MUI_LANGUAGE "SpanishInternational"
-
- ;English----------------------------
- LangString Header_Title ${LANG_ENGLISH} "Configure Install"
- LangString Header_Subtitle ${LANG_ENGLISH} "Customize install settings"
- LangString Option_Scope ${LANG_ENGLISH} "Select for whom will $(^Name) be installed: "
- LangString Scope_Machine ${LANG_ENGLISH} "All users"
- LangString Scope_User ${LANG_ENGLISH} "Current user"
-
- ;Spanish/SpanishInternational----------------------------
- LangString Header_Title ${LANG_SPANISH} "Configurar instalación"
- LangString Header_Subtitle ${LANG_SPANISH} "Elija los ajustes de la instalación"
- LangString Option_Scope ${LANG_SPANISH} "$(^Name) será instalado para: "
- LangString Scope_Machine ${LANG_SPANISH} "Todos los usuarios"
- LangString Scope_User ${LANG_SPANISH} "Usuario actual"
-
- LangString Header_Title ${LANG_SPANISHINTERNATIONAL} "Configurar instalación"
- LangString Header_Subtitle ${LANG_SPANISHINTERNATIONAL} "Elija los ajustes de la instalación"
- LangString Option_Scope ${LANG_SPANISHINTERNATIONAL} "$(^Name) será instalado para: "
- LangString Scope_Machine ${LANG_SPANISHINTERNATIONAL} "Todos los usuarios"
- LangString Scope_User ${LANG_SPANISHINTERNATIONAL} "Usuario actual"
-
-;Functions------------------------------
- Function Skip_Directory_Func
- ;StrCmp $Install_Type "user" dontSkip
- Abort # skip the page
- ;dontSkip:
- FunctionEnd
-
- !macro ONINIT un
- Function ${un}.onInit
- ; The value of SetShellVarContext detetmines whether SHCTX is HKLM or HKCU
- ; and whether SMPROGRAMS refers to all users or just the current
- !insertmacro MUI_LANGDLL_DISPLAY
- UserInfo::GetAccountType
- Pop $0
- ${If} $0 == "Admin"
- ; If we're an admin, default to installing to C:\Program Files
- SetShellVarContext all
- ; StrCpy $INSTDIR "$PROGRAMFILES64\$(^Name)"
- StrCpy $Is_Admin "true"
- ${Else}
- ; If we're just a user, default to installing to ~\AppData\Local
- SetShellVarContext current
- ; StrCpy $INSTDIR "$LOCALAPPDATA\$(^Name)"
- StrCpy $Is_Admin "false"
- ${EndIf}
-
- ; ${If} $INSTDIR == ""
- ; ; This only happens in the installer, because the uninstaller already knows INSTDIR
- ; ReadRegStr $0 SHCTX "Software\${PRODUCT_NAME}" ""
-
- ; ${If} $0 != ""
- ; ; If we're already installed, use the existing directory
- ; StrCpy $INSTDIR "$0"
- ; ${Else}
- ; StrCpy $INSTDIR "$INSTDIR_BASE\${PRODUCT_NAME}"
- ; ${Endif}
- ; ${Endif}
- FunctionEnd
- !macroend
-
-!insertmacro ONINIT ""
-!insertmacro ONINIT "un"
-
-;NSDialog InstallTarget Page definition---------------------------------
-
-Function InstallTargetPage
- !insertmacro MUI_HEADER_TEXT $(Header_Title) $(Header_Subtitle)
- ;MessageBox MB_OK "Install type $Install_Type"
- ;MessageBox MB_OK "Build type ${BUILDTYPE}"
- nsDialogs::Create 1018
- Pop $0
-
- FindWindow $0 "#32770"
- GetDlgItem $1 $0 1 ;next/install button
- SendMessage $1 ${WM_SETTEXT} 1 "STR:$(^InstallBtn)"
- Pop $0
-
- ${NSD_CreateLabel} 0 0 100% 10% $(Option_Scope)
- Pop $3
-
- ${NSD_CreateFirstRadioButton} 0 12% 40% 6% $(Scope_Machine)
- Pop $1
- ${If} $Is_Admin == "false"
- EnableWindow $1 0
- StrCpy $INSTDIR "$LOCALAPPDATA\$(^Name)"
- ${Else}
- SendMessage $1 ${BM_CLICK} "" "" ;Set default
- StrCpy $INSTDIR "$PROGRAMFILES64\$(^Name)"
- ${EndIf}
- ${NSD_OnClick} $1 All_Users_Click
-
- ${NSD_CreateAdditionalRadioButton} 0 24% 40% 6% $(Scope_User)
- Pop $2
- ${IfThen} $Is_Admin == "false" ${|} SendMessage $2 ${BM_CLICK} "" "" ${|}
- ${NSD_OnClick} $2 Current_User_Click
-
- nsDialogs::Show
-FunctionEnd
-
-Function All_Users_Click
- Pop $0
- SetShellVarContext all
- StrCpy $INSTDIR "$PROGRAMFILES64\$(^Name)"
- StrCpy $Install_Type "machine"
- ;${NSD_SetText} $0 "machine"
- ;FindWindow $0 "#32770"
- ;GetDlgItem $1 $0 1 ;next/install button
- ;SendMessage $1 ${WM_SETTEXT} 1 "STR:$(^InstallBtn)"
-FunctionEnd
-
-Function Current_User_Click
- Pop $0
- SetShellVarContext current
- StrCpy $INSTDIR "$LOCALAPPDATA\$(^Name)"
- StrCpy $Install_Type "user"
- ;${NSD_SetText} $0 "user"
- ;FindWindow $0 "#32770"
- ;GetDlgItem $1 $0 1 ;next/install button
- ;SendMessage $1 ${WM_SETTEXT} 1 "STR:$(^NextBtn)"
-FunctionEnd
-
-;Default section----------------------
-Section
- SetRegView 64
- SetOutPath $INSTDIR
-
- !if ${BUILDTYPE} == "release"
- File "..\build\bin\MixerQ.exe"
- !else
- File "..\build\bin\MixerQd.exe"
- !endif
- File "..\LICENSE.txt"
-
- ;Start menu shortcut
- createDirectory "$SMPROGRAMS\$(^Name)"
- createShortCut "$SMPROGRAMS\$(^Name)\$(^Name).lnk" "$INSTDIR\$(^Name).exe"
- createShortCut "$SMPROGRAMS\$(^Name)\Uninstall$(^Name).lnk" "$INSTDIR\Uninstall$(^Name).exe"
-
- ;Store installation folder
- WriteRegStr SHCTX "SOFTWARE\Microsoft\Windows\CurrentVersion\Uninstall\$(^Name)" "DisplayName" "$(^Name)"
- WriteRegStr SHCTX "SOFTWARE\Microsoft\Windows\CurrentVersion\Uninstall\$(^Name)" "UninstallString" '"$INSTDIR\Uninstall$(^Name).exe"'
- WriteRegDWORD SHCTX "SOFTWARE\Microsoft\Windows\CurrentVersion\Uninstall\$(^Name)" "NoModify" 1
- WriteRegDWORD SHCTX "SOFTWARE\Microsoft\Windows\CurrentVersion\Uninstall\$(^Name)" "NoRepair" 1
- WriteRegStr SHCTX "SOFTWARE\Microsoft\Windows\CurrentVersion\Run" "$(^Name)" "$INSTDIR\$(^Name)"
-
- ;Create uninstaller
- WriteUninstaller "$INSTDIR\Uninstall$(^Name).exe"
-
-SectionEnd
-
-
-;--------------------------------
-;Descriptions
-
- ; ;Language strings
- ; LangString DESC_SecDummy ${LANG_ENGLISH} "A test section."
-
- ; ;Assign language strings to sections
- ; !insertmacro MUI_FUNCTION_DESCRIPTION_BEGIN
- ; !insertmacro MUI_DESCRIPTION_TEXT ${SecDummy} $(DESC_SecDummy)
- ; !insertmacro MUI_FUNCTION_DESCRIPTION_END
-
-;--------------------------------
-;Uninstaller Section
-
-Section "Uninstall"
- SetRegView 64
-
- SetShellVarContext current
- DeleteRegValue HKCU "SOFTWARE\Microsoft\Windows\CurrentVersion\Run" "$(^Name)"
- DeleteRegKey HKCU "SOFTWARE\Microsoft\Windows\CurrentVersion\Uninstall\$(^Name)"
- Delete "$SMPROGRAMS\$(^Name)\$(^Name).lnk"
- Delete "$SMPROGRAMS\$(^Name)\Uninstall$(^Name).lnk"
- RMDir "$SMPROGRAMS\$(^Name)"
-
- ${If} $Is_Admin == "true"
- SetShellVarContext all
- DeleteRegValue HKLM "SOFTWARE\Microsoft\Windows\CurrentVersion\Run" "$(^Name)"
- DeleteRegKey HKLM "SOFTWARE\Microsoft\Windows\CurrentVersion\Uninstall\$(^Name)"
- Delete "$SMPROGRAMS\$(^Name)\$(^Name).lnk"
- Delete "$SMPROGRAMS\$(^Name)\Uninstall$(^Name).lnk"
- RMDir "$SMPROGRAMS\$(^Name)"
- ${EndIf}
-
- Delete "$INSTDIR\$(^Name).exe"
- Delete "$INSTDIR\LICENSE.txt"
- Delete "$INSTDIR\Uninstall$(^Name).exe"
- ;!define PRODUCT_UNINST_ROOT_KEY "HKLM"
- RMDir "$INSTDIR"
-
-SectionEnd
diff --git a/install/version.nsi b/install/version.nsi
deleted file mode 100644
index 5e85c8c..0000000
--- a/install/version.nsi
+++ /dev/null
@@ -1,26 +0,0 @@
-!if ${BUILDTYPE} == "release"
- !define File "..\build\bin\MixerQ.exe"
-!else
- !define File "..\build\bin\MixerQd.exe"
-!endif
-
-OutFile "GetVersion.exe"
-SilentInstall silent
-RequestExecutionLevel user ; don't write $EXEDIR\Version.txt with admin permissions and prevent invoking UAC
-
-Section
-
- ## Get file version
- GetDllVersion "${File}" $R0 $R1
- IntOp $R2 $R0 / 0x00010000
- IntOp $R3 $R0 & 0x0000FFFF
- IntOp $R4 $R1 / 0x00010000
- IntOp $R5 $R1 & 0x0000FFFF
- StrCpy $R1 "$R2.$R3.$R4.$R5"
-
- ## Write it to a !define for use in main script
- FileOpen $R0 "$EXEDIR\Version.txt" w
- FileWrite $R0 '!define version "$R1"'
- FileClose $R0
-
-SectionEnd
\ No newline at end of file
diff --git a/qtest.pro b/qtest.pro
index 42a1165..4677fd8 100644
--- a/qtest.pro
+++ b/qtest.pro
@@ -1,28 +1,18 @@
-TEMPLATE = app
-QMAKE_CXXFLAGS += --target=x86_64-w64-mingw32 -Werror=return-type
-QMAKE_LFLAGS += --target=x86_64-w64-mingw32 -v
-CONFIG(release, debug|release) {
- TARGET = MixerQ
- DESTDIR = bin
- VERSION = 0.9.0.0
- #QMAKE_CXXFLAGS += -O2 < Default. Modifying requires removing.
-} else {
- TARGET = MixerQd
- DESTDIR = bin
- VERSION = 0.9.0.1
- QMAKE_CXXFLAGS += -g -gcodeview -O0
- QMAKE_LFLAGS += -g -Wl,-pdb=
-}
+QMAKE_CXXFLAGS += --target=x86_64-w64-mingw32 -g -gcodeview
+QMAKE_LFLAGS += --target=x86_64-w64-mingw32 -g -Wl,-pdb= -v
+LIBS += -LC:/capybara/libclang/x86_64-w64-mingw32/lib -lWinmm -lodbc32 -lodbccp32 -luuid -loleaut32 -lole32 -lshell32 -ladvapi32 -lcomdlg32 -lwinspool -lgdi32 -luser32 -lkernel32 -lpropsys
+#"kernel32.lib" "user32.lib" "gdi32.lib" "winspool.lib" "comdlg32.lib" "advapi32.lib" "shell32.lib" "ole32.lib" "oleaut32.lib" "uuid.lib" "odbc32.lib" "odbccp32.lib" -luuid -loleaut32 -lole32 -lshell32 -ladvapi32 -lcomdlg32 -lwinspool -lgdi32 -luser32 -lkernel32
+DEFINES += DEBUG QT_LOGGING_TO_CONSOLE=1 WIN32_LEAN_AND_MEAN
+CONFIG += debug
-LIBS += -lWinmm -lodbc32 -lodbccp32 -luuid -loleaut32 -lole32 -lshell32 -ladvapi32 -lcomdlg32 -lwinspool -lgdi32 -luser32 -lkernel32 -lpropsys -static -stdlib=libc++ -lunwind
-DEFINES += QT_LOGGING_TO_CONSOLE=1 WIN32_LEAN_AND_MEAN _WIN32_WINNT=0x0602
-DEFINES_DEBUG += DEBUG
-
-QT += widgets network svg
+QT += widgets network
INCLUDEPATH += "$$PWD\src" "$$PWD\src\qt" "$$PWD\src\back" "$$PWD\src\back\reimpl" "$$PWD\src\cont"
-VPATH += "$$PWD\src" "$$PWD\src\qt" "$$PWD\src\back" "$$PWD\src\back\reimpl" "$$PWD\src\cont"
+DESTPATH += "$$PWD\src" "$$PWD\src\qt" "$$PWD\src\back" "$$PWD\src\back\reimpl" "$$PWD\src\cont"
+VPATH += "$$PWD\src" "$$PWD\src\qt" "$$PWD\src\back" "$$PWD\src\back\reimpl" "$$PWD\src\cont"
-SOURCES += qtestmain.cpp qtclasses.cpp backlasses.cpp backsessionclasses.cpp contclasses.cpp contsessionclasses.cpp settings.cpp
-HEADERS += qtclasses.h backlasses.h backsessionclasses.h contclasses.h contsessionclasses.h global.h debug.h backfuncs.h ipolicyconfig.h msinclude.h meterslider.h qtvisuals.h settings.h
-RESOURCES = assets.qrc
+SOURCES += qtestmain.cpp qtclasses.cpp backlasses.cpp backsessionclasses.cpp contclasses.cpp contsessionclasses.cpp
+HEADERS += qtclasses.h backlasses.h backsessionclasses.h contclasses.h contsessionclasses.h global.h debug.h backfuncs.h ipolicyconfig.h msinclude.h
+RESOURCES = assets.qrc
RC_ICONS += assets/logo.ico
+
+#DESTDIR += "build"
diff --git a/src/back/backlasses.cpp b/src/back/backlasses.cpp
index 74af6a0..e398b21 100644
--- a/src/back/backlasses.cpp
+++ b/src/back/backlasses.cpp
@@ -1,7 +1,5 @@
-#include "backlasses.h"
-#include "backfuncs.h"
-
-using namespace Environment;
+#include
+#include
EndpointNewSessionCallback::EndpointNewSessionCallback(EndpointHandler* eph){
this->eph = eph;
@@ -41,27 +39,23 @@ HRESULT EndpointNewSessionCallback::QueryInterface(REFIID riid, VOID **ppvInterf
HRESULT EndpointNewSessionCallback::OnSessionCreated(IAudioSessionControl *NewSession) {
if (eph->getFlow() == Flows::FLOW_CAPTURE) return S_OK;
+ HRESULT result = CoInitializeEx(NULL, COINIT_APARTMENTTHREADED | COINIT_DISABLE_OLE1DDE);
IAudioSessionControl2* sessionControl;
//ISimmpleAudioVolume* sessionVolume;
if (FAILED(NewSession->QueryInterface(__uuidof(IAudioSessionControl2), (void**)&sessionControl))) { log_wdebugcpp(L"no nueva sesion......"); };
if (sessionControl) {
+ sessionControl->AddRef();
+ //sessionControl->QueryInterface(__uuidof(ISimpleAudioVolume), (void**)&sessionVolume);
Session* newSession = new Session(this->eph->getEndpoint(), sessionControl);
-
- SessionThreadParams tp = { .eph = this->eph, .session = newSession, .isDelete = false };
- wait = true;
- std::thread newSessionThread(&EndpointNewSessionCallback::createSessionThread, this, tp);
- newSessionThread.detach();
- while(wait);
+ eph->addSessionSendFront(newSession);
}
+ if (result == S_OK)
+ CoUninitialize();
+
return S_OK;
}
-void EndpointNewSessionCallback::createSessionThread(SessionThreadParams params) {
- params.eph->addSessionSendFront(params.session);
- this->wait = false;
-}
-
EndpointVolumeCallback::EndpointVolumeCallback(Endpoint* ep){
this->ep = ep;
}
@@ -100,69 +94,46 @@ HRESULT EndpointVolumeCallback::QueryInterface(REFIID riid, VOID **ppvInterface)
HRESULT EndpointVolumeCallback::OnNotify(PAUDIO_VOLUME_NOTIFICATION_DATA pNotify) {
if (pNotify == NULL) return E_INVALIDARG;
- AUDIO_VOLUME_NOTIFICATION_DATA paramCopy;
- memcpy(¶mCopy, pNotify, sizeof(AUDIO_VOLUME_NOTIFICATION_DATA));
- float* channelVolumes = (float*)malloc(pNotify->nChannels * sizeof(float));
- for (int i = 0; i < pNotify->nChannels; i++) {
- channelVolumes[i] = pNotify->afChannelVolumes[i];
- }
- wait = true;
- std::thread updateVolumeThread(&EndpointVolumeCallback::updateVolumeInfo, this, paramCopy, channelVolumes);
- updateVolumeThread.detach();
- while(wait);
- return S_OK;
-}
-
-void EndpointVolumeCallback::updateVolumeInfo(AUDIO_VOLUME_NOTIFICATION_DATA newVolume, float* channelVolumes) {
//delete osh->getPlaybackEndpointHandlers().at(this->ep->getIndex())->getCallbackInfo()->caller;
//osh->getPlaybackEndpointHandlers().at(this->ep->getIndex())->getCallbackInfo()->caller.freeData4();
//Could've made a function or = override to hide this within Nguid, but back in cont = bad.
- osh->handlersPlaybackMutex.lock();
- osh->handlersCaptureMutex.lock();
- osh->lockEndpoints();
osh->getPlaybackEndpointHandlers().at(this->ep->getIndex())->getCallbackInfo()->caller.data1 \
- = newVolume.guidEventContext.Data1;
+ = pNotify->guidEventContext.Data1;
osh->getPlaybackEndpointHandlers().at(this->ep->getIndex())->getCallbackInfo()->caller.data2 \
- = newVolume.guidEventContext.Data2;
+ = pNotify->guidEventContext.Data2;
osh->getPlaybackEndpointHandlers().at(this->ep->getIndex())->getCallbackInfo()->caller.data3 \
- = newVolume.guidEventContext.Data3;
+ = pNotify->guidEventContext.Data3;
for(int i = 0; i < 8 /* Data4 size */; i++){
- osh->getPlaybackEndpointHandlers().at(this->ep->getIndex())->getCallbackInfo()->caller.data4[i] = newVolume.guidEventContext.Data4[i];
+ osh->getPlaybackEndpointHandlers().at(this->ep->getIndex())->getCallbackInfo()->caller.data4[i] = pNotify->guidEventContext.Data4[i];
}
- //memcpy(&osh->getPlaybackEndpointHandlers().at(this->ep->getIndex())->getCallbackInfo()->caller, &newVolume.guidEventContext,sizeof(NGuid) );
- Flows flow = this->ep->getFlow();
- EndpointHandler* eph = nullptr;
- if (flow & Flows::FLOW_PLAYBACK) {
- eph = osh->getPlaybackEndpointHandlers().at(this->ep->getIndex());
- } else {
- eph = osh->getCaptureEndpointHandlers().at(this->ep->getIndex());
- }
+ //memcpy(&osh->getPlaybackEndpointHandlers().at(this->ep->getIndex())->getCallbackInfo()->caller, &pNotify->guidEventContext,sizeof(NGuid) );
+ Flows flow = this->ep->getFlow();
+ EndpointHandler* eph = nullptr;
+ if (flow & Flows::FLOW_PLAYBACK) {
+ eph = osh->getPlaybackEndpointHandlers().at(this->ep->getIndex());
+ } else {
+ eph = osh->getCaptureEndpointHandlers().at(this->ep->getIndex());
+ }
- eph->getCallbackInfo()->muted = newVolume.bMuted;
- eph->getCallbackInfo()->mainVolume = newVolume.fMasterVolume;
- eph->getCallbackInfo()->channels = newVolume.nChannels;
+ eph->getCallbackInfo()->muted = pNotify->bMuted;
+ eph->getCallbackInfo()->mainVolume = pNotify->fMasterVolume;
+ eph->getCallbackInfo()->channels = pNotify->nChannels;
- UINT j = 0;
- //todo: do while here caused stack corruption; sus
- while(j < newVolume.nChannels) {
- if (flow & Flows::FLOW_PLAYBACK)
- eph->getCallbackInfo()->channelVolumes[j] = channelVolumes[j];
- else
- eph->getCallbackInfo()->channelVolumes[j] = channelVolumes[j];
- j++;
- }
- free(channelVolumes);
- osh->unlockEndpoints();
- osh->handlersPlaybackMutex.unlock();
- osh->handlersCaptureMutex.unlock();
- wait = false;
+ UINT j = 0;
+ //todo: do while here caused stack corruption; sus
+ while(j < pNotify->nChannels) {
+ if (flow & Flows::FLOW_PLAYBACK)
+ eph->getCallbackInfo()->channelVolumes[j] = pNotify->afChannelVolumes[j];
+ else
+ eph->getCallbackInfo()->channelVolumes[j] = pNotify->afChannelVolumes[j];
+ j++;
+ }
+ return S_OK;
}
-void EndpointVolumeCallback::reportFinished() {
- this->wait = false;
-}
+
EndpointSituationCallback::EndpointSituationCallback(Overseer* os){
this->os = os;
@@ -202,7 +173,6 @@ HRESULT EndpointSituationCallback::QueryInterface(REFIID riid, VOID **ppvInterfa
HRESULT EndpointSituationCallback::OnDefaultDeviceChanged(EDataFlow flow, ERole role,LPCWSTR pwstrDeviceId) {
if (flow == EDataFlow::eCapture) return E_INVALIDARG;
- if (!pwstrDeviceId) return E_INVALIDARG;
Roles nRole;
switch (role) {
@@ -218,7 +188,8 @@ HRESULT EndpointSituationCallback::OnDefaultDeviceChanged(EDataFlow flow, ERole
}
std::wstring wstringEndpointId = pwstrDeviceId;
log_wdebugcpp(L"we got za defol 4 " + wstringEndpointId);
- osh->roleBucketEntryCallback(nRole, wstringEndpointId);
+ osh->changeFrontDefaultsCallback(nRole, wstringEndpointId);
+
return S_OK;
}
@@ -234,54 +205,39 @@ HRESULT EndpointSituationCallback::OnDeviceRemoved(LPCWSTR pwstrDeviceId) {
HRESULT EndpointSituationCallback::OnDeviceStateChanged(LPCWSTR pwstrDeviceId, DWORD dwNewState) {
std::wstring endpointId = std::wstring(pwstrDeviceId);
- log_wdebugcpp(L"Endpoint state change for " + endpointId);
- EndpointState newState;
- switch (dwNewState) {
+ switch (dwNewState){
case DEVICE_STATE_ACTIVE:
- newState = EndpointState::ENDPOINT_ACTIVE;
+ osh->reviseEndpointShowing(endpointId, EndpointState::ENDPOINT_ACTIVE);
break;
case DEVICE_STATE_DISABLED:
- newState = EndpointState::ENDPOINT_DISABLED;
+ osh->reviseEndpointShowing(endpointId, EndpointState::ENDPOINT_DISABLED);
break;
case DEVICE_STATE_NOTPRESENT:
- newState = EndpointState::ENDPOINT_NOTPRESENT;
+ osh->reviseEndpointShowing(endpointId, EndpointState::ENDPOINT_NOTPRESENT);
break;
case DEVICE_STATE_UNPLUGGED:
- newState = EndpointState::ENDPOINT_UNPLUGGED;
+ osh->reviseEndpointShowing(endpointId, EndpointState::ENDPOINT_UNPLUGGED);
break;
}
- isEpStateChanging.exchange(true);
- std::thread newEndpointThread(&OverseerHandler::reviseEndpointShowing, osh,
- endpointId, newState);
- newEndpointThread.detach();
- while(isEpStateChanging);
+
return S_OK;
}
HRESULT EndpointSituationCallback::OnPropertyValueChanged(LPCWSTR pwstrDeviceId, const PROPERTYKEY key) {
- isEpStateChanging.exchange(true);
- std::thread propertyThread(&Overseer::updateEndpointInfo, os, std::wstring(pwstrDeviceId));
- propertyThread.detach();
- while(isEpStateChanging);
+ os->updateEndpointInfo(std::wstring(pwstrDeviceId));
return S_OK;
}
-void EndpointSituationCallback::reportFinishedStateChange() {
- this->isEpStateChanging.exchange(false);
- return;
-}
-
-Endpoint::Endpoint(IMMDevice* ep, IPolicyConfig7* policyConfig, uint64_t idx) {
+Endpoint::Endpoint(IMMDevice* ep, uint64_t idx){
this->endpoint = ep;
this->idx = idx;
- this->policyConfig = policyConfig;
+
/*
* It can't multiflag, it's that stupid. MS momento.
* Only shows most relevant flag according to MS, i.e. 0110 sends 0010
*/
- DWORD state;
- if(FAILED(endpoint->GetState(&state))) {exit(-2);};
- this->endpointState = (EndpointState)state;
+ //todo: preguntitas owindows dword no es uint32_t even tho mingw mingas
+ if(FAILED(endpoint->GetState(&this->endpointState))) {exit(-2);};
if(this->endpointState == EndpointState::ENDPOINT_ACTIVE) {
activateEndpointVolume();
@@ -292,9 +248,11 @@ Endpoint::Endpoint(IMMDevice* ep, IPolicyConfig7* policyConfig, uint64_t idx) {
}
+ reloadEndpointChannels();
+
//todo: atexit into exit Gather ID
LPWSTR tempString = nullptr;
- if (FAILED(endpoint->GetId(&tempString))) { exit(-1); };
+ if (FAILED(endpoint->GetId(&tempString))) {exit(-1);};
endpointId = std::wstring(tempString);
log_wdebugcpp(endpointId);
CoTaskMemFree(tempString);
@@ -302,14 +260,16 @@ Endpoint::Endpoint(IMMDevice* ep, IPolicyConfig7* policyConfig, uint64_t idx) {
endpoint->OpenPropertyStore(STGM_READ, &properties);
this->updateName();
this->setFlow();
-
- reloadEndpointChannels();
+ if (this->flow == Flows::FLOW_PLAYBACK) {
+ activateEndpointSessions();
+ log_debugcpp("plays back");
+ }
}
void Endpoint::updateName() {
PROPVARIANT pv;
#define store_name(key, propvariant, wstr) do { \
- properties->GetValue(key, &propvariant); \
+ properties->GetValue(key , &propvariant); \
if (pv.pwszVal == nullptr) wstr = L"Unnamed Not Present Endpoint"; \
else wstr = std::wstring(pv.pwszVal); \
} while (0)
@@ -322,34 +282,27 @@ void Endpoint::updateName() {
}
void Endpoint::activateEndpointSessions() {
- if (this->flow != Flows::FLOW_PLAYBACK) {
- log_debugcpp("recording. No seshes for u :(");
- return;
- }
-
- if (!sessionManager) {
- if (FAILED(endpoint->Activate(__uuidof(IAudioSessionManager2),
- CLSCTX_ALL, NULL, (void**) &sessionManager))) {
- log_debugcpp("Couldn't open session manager2, huh");
- return;
- }
- }
-
+ //sessionManager;
+ if (FAILED(endpoint->Activate(__uuidof(IAudioSessionManager2), CLSCTX_ALL, NULL, (void**) &sessionManager))) { log_wdebugcpp(L"sesionbros..."); return; }
+
IAudioSessionEnumerator* sessionEnumerator = nullptr;
- if (FAILED(sessionManager->GetSessionEnumerator(&sessionEnumerator))) { log_wdebugcpp(L"sesEnumeratorBros..."); exit(-5); return; }
+ if (FAILED(sessionManager->GetSessionEnumerator(&sessionEnumerator))) { log_wdebugcpp(L"sesEnumeratorBros..."); return; }
endpointSessions.resize(1, nullptr);
int sessionCount;
sessionEnumerator->GetCount(&sessionCount);
- for (int i = 0; i < sessionCount; i++) {
+ for (int i = 0; i < sessionCount; i++) {
IAudioSessionControl* sessionControlTmp;
- if (FAILED(sessionEnumerator->GetSession(i, (IAudioSessionControl**)&sessionControlTmp))) {
- exit(-6);
- }
+ sessionEnumerator->GetSession(i, (IAudioSessionControl**)&sessionControlTmp);
+ /*todo: borrar when donezo
+ * float test2;
+ * IAudioMeterInformation* ttmp = (IAudioMeterInformation*)sessionControlTmp;
+ * ttmp->GetPeakValue(&test2);
+ */
+ //todo:: asegurar lo del dynamic_cast
IAudioSessionControl2* sessionControl;
- if(FAILED(sessionControlTmp->QueryInterface(__uuidof(IAudioSessionControl2), (void**)&sessionControl))){
- exit(-7);
- }
+ sessionControlTmp->QueryInterface(__uuidof(IAudioSessionControl2), (void**)&sessionControl);
+ sessionControl->AddRef();
sessionControlTmp->Release();
Session* session = new Session(this, sessionControl, (size_t)i);
if (sessionControl->IsSystemSoundsSession() == S_OK) endpointSessions[0] = session;
@@ -358,38 +311,34 @@ void Endpoint::activateEndpointSessions() {
sessionEnumerator->Release();
}
-/*
- * void Endpoint::deleteSessionManager() {
- * sessionManager->Release();
- * sessionManager = nullptr;
- * }
- */
-
void Endpoint::addSession(Session* session) {
session->setIndex(this->getSessionCount());
endpointSessions.push_back(session);
}
void Endpoint::activateEndpointVolume() {
- //If this EP is created after init, COM won't be initialized on the executing thread.
- HRESULT result = CoInitializeEx(NULL, COINIT_MULTITHREADED | COINIT_DISABLE_OLE1DDE);
- if (this->endpointVolume == nullptr) {
- if(FAILED(endpoint->Activate(
- IID_IAudioEndpointVolume,
- CLSCTX_ALL,
- NULL,
- (void**)&this->endpointVolume))) {
- log_debugcpp("No volume, huh");
- }
+ //bool extraThread = false;
+ /*
+ * Forgive me, for MS has sinned, and now I must too.
+ */
+ if (this->endpointVolume == nullptr){
+ HRESULT result = CoInitializeEx(NULL, COINIT_APARTMENTTHREADED | COINIT_DISABLE_OLE1DDE);
+ endpoint->Activate(IID_IAudioEndpointVolume, CLSCTX_ALL, NULL, (void**)&this->endpointVolume);
//todo: check header
if(FAILED(endpoint->Activate(__uuidof(IAudioMeterInformation),
- CLSCTX_ALL, NULL, (void**)&endpointPeakMeter))) {
- log_debugcpp("peakbros...");
- }
+ CLSCTX_ALL, NULL, (void**)&endpointPeakMeter))) { log_debugcpp("peakbros..."); }
+ //
+
+ //if (endpointVolume == nullptr) { //why they returning 0 after dealing with the error jfc CO_E_NOTINITIALIZED) {
+ //CoInitializeEx(NULL, COINIT_MULTITHREADED | COINIT_DISABLE_OLE1DDE);
+ //extraThread = true;
+ //goto initialized;
+ //}
+ //log_debugcpp(std::string("no endpointVolume (IAudioEndpointVolume)"));
+ if (result == S_OK)
+ CoUninitialize();
}
- if (result == S_OK)
- CoUninitialize();
}
void Endpoint::reloadEndpointChannels() {
@@ -442,7 +391,7 @@ bool Endpoint::getMute(){
return mute;
}
-void Endpoint::setState(EndpointState state){
+void Endpoint::setState(uint8_t state){
this->endpointState = state;
if(state == EndpointState::ENDPOINT_ACTIVE) {
this->activateEndpointVolume();
@@ -450,7 +399,7 @@ void Endpoint::setState(EndpointState state){
}
}
-EndpointState Endpoint::getState(){
+size_t Endpoint::getState(){
return this->endpointState;
}
@@ -458,13 +407,9 @@ void Endpoint::setVolume(NGuid guid, int channel, float volume) {
//TIP: There used to be log messages here. Now, it's a ghost town.
GUID tempMsGuid = NGuidToGUID(guid);
if (channel == AudioChannel::CHANNEL_MAIN) {
- if(FAILED(endpointVolume->SetMasterVolumeLevelScalar(volume, &tempMsGuid))) {
- log_wdebugcpp(L"Master volume failed for endpoint: " + friendlyName);
- };
+ if(FAILED(endpointVolume->SetMasterVolumeLevelScalar(volume, &tempMsGuid))) {};
} else {
- if(FAILED(endpointVolume->SetChannelVolumeLevelScalar(channel, volume, &tempMsGuid))) {
- log_wdebugcpp(L"Channel " + std::to_wstring(channel) + L" volume failed for endpoint: " + friendlyName);
- };
+ if(FAILED(endpointVolume->SetChannelVolumeLevelScalar(channel, volume, &tempMsGuid))) {};
}
}
@@ -489,29 +434,70 @@ Roles Endpoint::getRoles(){
}
void Endpoint::setRoles(Roles role){
- if (!policyConfig) return;
+ //todo: otro exe momento
+ STARTUPINFOEXW startupConfig;
+ PROCESS_INFORMATION processInfo;
+ SecureZeroMemory(&startupConfig, sizeof(STARTUPINFOEXW));
+ SecureZeroMemory(&startupConfig.StartupInfo, sizeof(STARTUPINFOW));
+ startupConfig.StartupInfo.cb = sizeof(STARTUPINFOEXW);
+ SecureZeroMemory(&processInfo, sizeof(PROCESS_INFORMATION));
- bool allRoles = false;
- ERole val;
- switch(role) {
+ std::wstring command = L"SoundVolumeView.exe /SetDefault " + endpointId + L" ";
+ std::wstring troublePair = L"1";
+ switch (role) {
+ case Roles::ROLE_ALL:
+ /*
+ * console or multimedia, one sends both, at least for now;
+ * either cos of ms or dis guy;
+ * no choice but to treat them as one for now.
+ * command += L"all"; and nothing else would've been nice...
+ */
+ troublePair = command + troublePair;
+ if(CreateProcessW(
+ NULL,
+ (wchar_t*)troublePair.c_str(),
+ NULL,
+ NULL,
+ false,
+ CREATE_UNICODE_ENVIRONMENT,
+ NULL,
+ NULL,
+ (LPSTARTUPINFOW)&startupConfig,
+ &processInfo
+ ) == true) {
+ WaitForSingleObject(processInfo.hProcess, INFINITE );
+ CloseHandle(processInfo.hProcess);
+ CloseHandle(processInfo.hThread);
+ }
+ command += L"2";
+ break;
case Roles::ROLE_CONSOLE:
- val = eConsole;
+ command += std::to_wstring(0);
break;
case Roles::ROLE_MULTIMEDIA:
- val = eMultimedia;
+ command += std::to_wstring(1);
break;
case Roles::ROLE_COMMUNICATIONS:
- val = eCommunications;
- break;
- default:
- allRoles = true;
+ command += std::to_wstring(2);
break;
}
- if (allRoles) {
- policyConfig->SetDefaultEndpoint(endpointId.c_str(), eMultimedia);
- //policyConfig->SetDefaultEndpoint(endpointId.c_str(), eConsole);
- policyConfig->SetDefaultEndpoint(endpointId.c_str(), eCommunications);
- } else policyConfig->SetDefaultEndpoint(endpointId.c_str(), val);
+
+ if(CreateProcessW(
+ NULL,
+ (wchar_t*)command.c_str(),
+ NULL,
+ NULL,
+ false,
+ CREATE_UNICODE_ENVIRONMENT,
+ NULL,
+ NULL,
+ (LPSTARTUPINFOW)&startupConfig,
+ &processInfo
+ ) == true) {
+ WaitForSingleObject(processInfo.hProcess, INFINITE );
+ CloseHandle(processInfo.hProcess);
+ CloseHandle(processInfo.hThread);
+ }
}
void Endpoint::assignRoles(Roles role){
@@ -526,10 +512,11 @@ void Endpoint::removeRoles(Roles role){
void Endpoint::setFlow() {
IMMEndpoint* flowGetter;
+ //this should be as simple as writing IID_IMMEndpoint, but it just won't find the macro, so I reimpl it. Sad.
if(FAILED(this->endpoint->QueryInterface(__uuidof(IMMEndpoint), (void**)&flowGetter)))
{ log_debugcpp("no flow..."); }
EDataFlow MSflow;
- flowGetter->GetDataFlow(&MSflow);
+ HRESULT vafllar = flowGetter->GetDataFlow(&MSflow);
this->flow = (MSflow == EDataFlow::eRender ? Flows::FLOW_PLAYBACK : Flows::FLOW_CAPTURE);
log_debugcpp("Endpoint flow: " + std::to_string(flow));
flowGetter->Release();
@@ -545,9 +532,7 @@ std::vector Endpoint::getSessions() {
}
size_t Endpoint::getSessionCount() {
- size_t sessionCount;
- sessionCount = endpointSessions.size();
- return sessionCount;
+ return endpointSessions.size();
}
void Endpoint::registerNewSessionNotification(EndpointNewSessionCallback* ensc){
@@ -558,28 +543,18 @@ void Endpoint::unregisterNewSessionNotification(EndpointNewSessionCallback* ensc
sessionManager->UnregisterSessionNotification(ensc);
}
-void Endpoint::deleteSessions() {
- for (auto session : endpointSessions) {
- delete session;
- }
- endpointSessions.resize(0);
-}
-
Endpoint::~Endpoint(){
- //EPs are never deleted.
log_wdebugcpp(L"murio endpoint-san uwu");
properties->Release();
endpointVolume->Release();
endpoint->Release();
sessionManager->Release();
- for (auto session : endpointSessions) {
- delete session;
- }
}
void Overseer::initCOMLibrary() {
+ OutputDebugStringW(L"EPWidget creation\n");
if(FAILED(CoInitializeEx(NULL, COINIT_APARTMENTTHREADED | COINIT_DISABLE_OLE1DDE))) {
- log_debugcpp("Not even COM?"); };
+ log_debugcpp("si"); };
//Retrieving endpoint enumerator
@@ -587,7 +562,7 @@ void Overseer::initCOMLibrary() {
if(FAILED(CoCreateInstance( __uuidof(MMDeviceEnumerator), NULL,
CLSCTX_ALL, __uuidof(IMMDeviceEnumerator),
(void**)&deviceEnumerator)) )
- { log_debugcpp("No MMDeviceEnum. Weird."); };
+ { log_debugcpp("si"); };
GUID tempGuid;
if(FAILED(CoCreateGuid(&tempGuid))) { log_debugcpp("Failed to obtain GUID: " ); };
@@ -603,7 +578,7 @@ void Overseer::initCOMLibrary() {
//TODO: Uninitialize COM
}
-void Overseer::createEndpoints(Flows flow) {
+void Overseer::reloadEndpoints(Flows flow) {
IMMDeviceCollection *deviceCollection;
unsigned int numEndpoints;
EDataFlow MSflow = (flow == Flows::FLOW_PLAYBACK ? EDataFlow::eRender : EDataFlow::eCapture);
@@ -615,8 +590,8 @@ void Overseer::createEndpoints(Flows flow) {
/*
* Counting them
*/
- if(FAILED(deviceCollection->GetCount(&numEndpoints))) { log_debugcpp("si");};
- if(numEndpoints == 0) { log_debugcpp("si"); };
+ if(FAILED(deviceCollection->GetCount(&numEndpoints))) { log_debugcpp("si");};
+ if(numEndpoints == 0) { log_debugcpp("si"); };
/*
* Retrieving actual endpoints and storing them on their own collection
@@ -624,7 +599,7 @@ void Overseer::createEndpoints(Flows flow) {
IMMDevice *temp;
for (unsigned int i = 0; i < numEndpoints; i++){
if(deviceCollection->Item(i, &temp) != 0) { log_debugcpp("si"); };
- Endpoint *endpoint = new Endpoint(temp, policyConfig, i);
+ Endpoint *endpoint = new Endpoint(temp, i);
if (flow == Flows::FLOW_PLAYBACK)
this->playbackDevices.push_back(endpoint);
else
@@ -633,6 +608,16 @@ void Overseer::createEndpoints(Flows flow) {
}
deviceCollection->Release();
+ //IPolicyConfig7 test
+ /*
+ * deviceEnumerator->GetDefaultAudioEndpoint(MSflow, ERole::eCommunications, &temp);
+ * LPWSTR tempString = nullptr;
+ * temp->GetId(&tempString);
+ * HRESULT hre = policyConfig->SetDefaultEndpoint(
+ * tempString,
+ * ERole::eMultimedia
+ * );
+ */
/*
* Discerning default endpoints per role
@@ -652,8 +637,6 @@ void Overseer::createEndpoints(Flows flow) {
break;
}
deviceEnumerator->GetDefaultAudioEndpoint(MSflow, val, &temp);
- if (!temp) continue;
-
LPWSTR id = nullptr;
if (flow == Flows::FLOW_PLAYBACK) {
@@ -683,17 +666,11 @@ void Overseer::createEndpoints(Flows flow) {
}
Endpoint* Overseer::addEndpoint(std::wstring endpointId, /* out */Flows* flow = nullptr) {
- //This method is only called from the new endpoint callback and its subsequent thread,
- //so another STA can be safely instantiated
- if(FAILED(CoInitializeEx(NULL, COINIT_APARTMENTTHREADED | COINIT_DISABLE_OLE1DDE))) {
- log_debugcpp("EP Callback Thread failed. Sad!");
- return nullptr;
- }
IMMDevice* newep;
if(FAILED(deviceEnumerator->GetDevice((LPCWSTR)endpointId.c_str(), &newep)))
- log_debugcpp("ay caramba con la hot metida. Sad!");
+ log_debugcpp("ay caramba con la hot metida.");
- Endpoint *endpoint = new Endpoint(newep, policyConfig);
+ Endpoint *endpoint = new Endpoint(newep);
Flows getFlow = endpoint->getFlow();
if (getFlow == Flows::FLOW_PLAYBACK) {
@@ -704,179 +681,25 @@ Endpoint* Overseer::addEndpoint(std::wstring endpointId, /* out */Flows* flow =
this->captureDevices.push_back(endpoint);
}
if (flow != nullptr) *flow = getFlow;
- CoUninitialize();
return endpoint;
}
-void Overseer::reportFinishedStateChange() {
- epsc.reportFinishedStateChange();
-}
-
-Overseer::Overseer() : epsc(this) {
- log_debugcpp("Initializing Overseer");
-
- //Storing exe path for later use (mainly "Run on startup")
- log_debugcpp("-Caching exe path");
- uint32_t cPathLen = 0;
- wchar_t* cPath = getExeAbsPath(&cPathLen);
- exeAbsPath = cPath;
-
- //Detecting install scope
- wchar_t *machine = wcsstr(cPath, L"Program Files");
- if (!machine)
- Environment::scope = HKEY_CURRENT_USER;
- else Environment::scope = HKEY_LOCAL_MACHINE;
- free(cPath);
-
+Overseer::Overseer() : epsc(this){
//Initializing COM library
- log_debugcpp("-Initializing COM");
+ log_debugcpp("Initializing Overseer");
initCOMLibrary();
- //Obtaining playback endpoint collection
- createEndpoints(Flows::FLOW_PLAYBACK);
+ //Obtaining playback endpoint collection on this point in time
+ reloadEndpoints(Flows::FLOW_PLAYBACK);
//reloadEndpoints(Flows::FLOW_CAPTURE);
-}
-NGuid Overseer::getGuid() {
- return guid;
-}
-
-void Overseer::registerEndpointSituationCallback() {
+ //Registering for endpoint information callback
+ //this->epsc.fill(deviceEnumerator, playbackDevices, captureDevices);
+ //this->epsc.fill(deviceEnumerator);
if(FAILED(deviceEnumerator->RegisterEndpointNotificationCallback(((IMMNotificationClient*)&epsc)))) { log_debugcpp("when no enchufas......"); }
}
-std::vector Overseer::getPlaybackEndpoints() {
- return playbackDevices;
-}
-
-std::vector Overseer::getCaptureEndpoints() {
- return captureDevices;
-}
-
-void Overseer::updateEndpointInfo(std::wstring endpointId) {
- //todo: reintroduce capture devices
- playbackMutex.lock();
- log_wdebugcpp(L"new name Endpoint id: " + endpointId);
- for(auto ep : playbackDevices) {
- if (ep->getId() == endpointId && ep->getState() == EndpointState::ENDPOINT_ACTIVE) {
- ep->updateName();
- osh->updateFrontEndpointName(ep);
- break;
- }
- }
- playbackMutex.unlock();
- epsc.reportFinishedStateChange();
-}
-
-Overseer::~Overseer(){
- //Overseer is never deleted. This is to annotate what would need to be taken care of.
- log_debugcpp("jej");
- deviceEnumerator->Release();
- for(unsigned long long i = 0; i < playbackDevices.size(); i++){
- delete(playbackDevices.at(i));
- }
-}
-
-wchar_t* Environment::getExeAbsPath(uint32_t *exeAbsPathLength) {
- wchar_t *exeAbsPath = (wchar_t*)calloc(UNICODE_STRING_MAX_CHARS, sizeof(wchar_t));
- *exeAbsPathLength = GetModuleFileNameW(
- NULL,
- exeAbsPath,
- UNICODE_STRING_MAX_CHARS
- );
- return exeAbsPath;
-}
-
-std::string Environment::createSettingsPath(SettingsTargetDirectory target) {
- wchar_t* settingsPath = nullptr;
- wchar_t settingsFile[] = L"\\settings.ini";
- uint32_t settingsFileLen = (sizeof(settingsFile) / sizeof(wchar_t)) - 1;
- wchar_t maxPathBypass[] = L"\\\\?\\";
- uint32_t exePathLength = 0;
- wchar_t folderPath[] = L"\\" LAPP_NAME;
- uint32_t maxPathBypassLen = (sizeof(maxPathBypass)/ sizeof(wchar_t)) - 1;
- uint32_t folderPathLen = (sizeof(folderPath) / sizeof(wchar_t)) - 1;
- wchar_t* roamingPath = nullptr;
-
- log_wdebugcpp(L"Bypass size: " + std::to_wstring((sizeof(maxPathBypass)/sizeof(maxPathBypass[0]))));
-
- switch(target) {
- case HOME_DIR:
- {
- if(SHGetKnownFolderPath(
- FOLDERID_RoamingAppData,
- 0,
- NULL,
- &roamingPath)
- == S_OK) {
- //Retrieve path len
- uint32_t pathLen = 0;
- wchar_t currentChar = roamingPath[pathLen];
- while(currentChar != '\0') {
- pathLen++;
- currentChar = roamingPath[pathLen];
- }
-
- settingsPath = (wchar_t*)calloc(pathLen +
- maxPathBypassLen +
- folderPathLen +
- settingsFileLen,
- sizeof(wchar_t));
- memcpy(settingsPath, maxPathBypass, sizeof(wchar_t) * maxPathBypassLen);
- memcpy(settingsPath + (maxPathBypassLen), roamingPath, sizeof(wchar_t) * pathLen);
- CoTaskMemFree(roamingPath);
- memcpy(settingsPath + (maxPathBypassLen + pathLen),
- folderPath, sizeof(wchar_t) * folderPathLen);
- log_wdebugcpp(L"Settings folder path: " + std::wstring(settingsPath));
-
- if(CreateDirectoryW(settingsPath, NULL) || GetLastError() == ERROR_ALREADY_EXISTS) {
- memcpy(settingsPath + (maxPathBypassLen + pathLen + folderPathLen),
- settingsFile, sizeof(wchar_t) * settingsFileLen);
- std::string utf8path = utf16ToUtf8(settingsPath);
- free(settingsPath);
- return utf8path;
- }
- }
- }
- return nullptr;
- break;
- case APP_PATH:
- {
- //Executable dir
- settingsPath = getExeAbsPath(&exePathLength);
-
- //reverse wcsstr
- while(exePathLength >= 0) {
- if(settingsPath[exePathLength] == '\\') {
- memset(settingsPath + exePathLength,
- 0,
- (UNICODE_STRING_MAX_CHARS - exePathLength) * sizeof(wchar_t));
- break;
- } else exePathLength--;
- }
- log_wdebugcpp(L"Exe folder: " + std::wstring(settingsPath));
- if((UNICODE_STRING_MAX_CHARS - exePathLength) > (settingsFileLen + 1)) {
- memcpy(settingsPath + exePathLength, settingsFile, sizeof(wchar_t) * settingsFileLen);
- std::string utf8path = utf16ToUtf8(settingsPath);
- free(settingsPath);
- return utf8path;
- }
- }
- return nullptr;
- break;
- default:
- return nullptr;
- break;
- }
- return nullptr;
-}
-
-void Environment::populateSystemValues() {
- updateColors();
- Environment::startup = checkStartup(scope);
-}
-
-void Environment::openControlPanel() {
+void Overseer::openControlPanel() {
STARTUPINFOEXW startupConfig;
PROCESS_INFORMATION processInfo;
SecureZeroMemory(&startupConfig, sizeof(STARTUPINFOEXW));
@@ -902,146 +725,36 @@ void Environment::openControlPanel() {
}
}
-ProcessedNativeEvent Environment::processTopLevelWindowMessage(void* msg) {
-#ifdef WIN32
- MSG *message = static_cast(msg);
- switch(message->message) {
- case WM_SETTINGCHANGE:
- //TODO: This looks like a future pain point. Ex handler would come in clutch
- if(message->lParam && !wcscmp(((wchar_t*)message->lParam), L"ImmersiveColorSet"))
- return updateColors();
- break;
- default:
- return ProcessedNativeEvent::NONE;
- break;
+NGuid Overseer::getGuid() {
+ return guid;
+}
+
+std::vector Overseer::getPlaybackEndpoints() {
+ return playbackDevices;
+}
+
+std::vector Overseer::getCaptureEndpoints() {
+ return captureDevices;
+}
+
+void Overseer::updateEndpointInfo(std::wstring endpointId) {
+ log_wdebugcpp(L"new name Endpoint id: " + endpointId);
+ //todo: reintroduce capture devices
+ for(auto ep : playbackDevices) {
+ if (ep->getId() == endpointId) {
+ ep->updateName();
+ osh->updateFrontEndpointName(ep);
+ break;
+ }
}
- return ProcessedNativeEvent::NONE;
- //if (message->message != WM_SETTINGCHANGE) {return false;}
-#endif
}
-ProcessedNativeEvent Environment::updateColors() {
- // DwmGetColorizationColor( WM_DWMCOLORIZATIONCOLORCHANGED
- DWORD value = 0;
- DWORD size = sizeof(DWORD);
-
- LSTATUS result;
-
- //Theme bg color
- result = RegGetValueW(HKEY_CURRENT_USER, L"Software\\Microsoft\\Windows\\CurrentVersion\\Themes\\Personalize", L"AppsUseLightTheme", RRF_RT_REG_DWORD, nullptr, &value, &size);
- lightMode = (bool)value;
-
- //Accent color
- result = RegGetValueW(HKEY_CURRENT_USER, L"Software\\Microsoft\\Windows\\DWM", L"ColorizationColor", RRF_RT_REG_DWORD, nullptr, &value, &size);
- if (result == ERROR_SUCCESS) {
- accentColor = value;
- } else accentColor = 0xffffffff;
-
- return ProcessedNativeEvent::COLORS;
-}
-
-bool Environment::checkStartup(HKEY rootKeyFlags) {
- //LSTATUS result;
- DWORD typeReturned;
-
- //Checking if app entry exists
- if(RegGetValueW(rootKeyFlags, L"Software\\Microsoft\\Windows\\CurrentVersion\\Run", LAPP_NAME, RRF_RT_REG_SZ, &typeReturned, nullptr, nullptr) != ERROR_SUCCESS && typeReturned != REG_SZ)
- return false;
- else return true;
-}
-
-void Environment::updateStartupConfig(bool onStartup) {
- wchar_t regSubKey[] = L"Software\\Microsoft\\Windows\\CurrentVersion\\Run\\";
-
- if(!onStartup) {
- HKEY runKey;
- if (RegOpenKeyExW(
- scope,
- regSubKey,
- 0,
- KEY_SET_VALUE,
- &runKey
- )
- == ERROR_SUCCESS) {
- RegDeleteValueW(runKey, LAPP_NAME);
- RegCloseKey(runKey);
- }
- } else {
- LSTATUS result;
- uint32_t cPathLen = 0;
- wchar_t* cPath = getExeAbsPath(&cPathLen);
- wchar_t* regPath = (wchar_t*)calloc(UNICODE_STRING_MAX_CHARS + 2, sizeof(wchar_t));
- //char* v = 0xFF'00'00'00'00'00'00'21;
- regPath[0] = L'"';
- memcpy(regPath + 1, cPath, sizeof(wchar_t) * cPathLen);
- memcpy(regPath + cPathLen + 1, L"\"", sizeof(wchar_t) * 2);
-
- result = RegSetKeyValueW(
- scope,
- regSubKey,
- LAPP_NAME,
- REG_SZ,
- (void*)regPath,
- (cPathLen + 3) * sizeof(wchar_t));
- /*
- * if (result != ERROR_SUCCESS) {
- * wchar_t* error;
- * FormatMessageW(
- * FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM,
- * nullptr,
- * (DWORD)result,
- * LANG_USER_DEFAULT,
- * error,
- * 1,
- * nullptr);
- * LocalFree(error);
- * }
- */
- free(cPath);
+Overseer::~Overseer(){
+ log_debugcpp("cum");
+ deviceEnumerator->Release();
+ for(unsigned long long i = 0; i < playbackDevices.size(); i++){
+ delete(playbackDevices.at(i));
}
- return;
-}
-
-void Environment::setStartupConfig(bool onStartup) {
- //TODO: Use the cache!!!! lol
- uint32_t cPathLen = 0;
- wchar_t* cPath = getExeAbsPath(&cPathLen);
- wchar_t startupParam[] = L"--change-startup";
- uint32_t startupParamLen = (sizeof(startupParam) / sizeof(wchar_t)) - 1;
- wchar_t* completeParam = (wchar_t*)calloc(startupParamLen + 3, sizeof(wchar_t));
- memcpy(completeParam, startupParam, sizeof(wchar_t) * startupParamLen);
- if (onStartup)
- memcpy(completeParam + startupParamLen, L" 1", sizeof(wchar_t) * 3);
- else
- memcpy(completeParam + startupParamLen, L" 0", sizeof(wchar_t) * 3);
-
- if(scope == HKEY_LOCAL_MACHINE) {
- ShellExecuteW(
- NULL,
- L"runas",
- cPath,
- completeParam,
- NULL, // default dir
- SW_SHOWNORMAL
- );
- } else {
- Environment::updateStartupConfig(onStartup);
- }
- free(cPath);
- free(completeParam);
- return;
-}
-
-bool Environment::isLightMode() {
- return lightMode;
-}
-
-bool Environment::isToRunAtStartup() {
- return startup;
-}
-
-uint32_t Environment::getAccentColor() {
- return accentColor;
}
//int Overseer::getCaptureEndpoints(std::vector *captureEndpoints);
diff --git a/src/back/backlasses.h b/src/back/backlasses.h
index 5acedba..0cee06e 100644
--- a/src/back/backlasses.h
+++ b/src/back/backlasses.h
@@ -4,50 +4,14 @@
#include "backsessionclasses.h"
#include "global.h"
#include "contclasses.h"
-//#include "environment.h"
class EndpointVolumeCallback;
class Session;
-// Convert a wide UTF16LE string to an UTF8 string
-static inline std::string utf16ToUtf8(const wchar_t* wstr) {
- if(!wstr || wstr[0] == '\0') return std::string();
- int size_needed = WideCharToMultiByte(CP_UTF8,
- 0,
- wstr,
- -1,
- NULL,
- 0,
- NULL,
- NULL);
- std::string str(size_needed, 0);
- WideCharToMultiByte(CP_UTF8,
- 0,
- wstr,
- -1,
- &str[0],
- size_needed,
- NULL,
- NULL);
- return str;
-}
-
-// Convert an UTF8 string to a wide UTF16LE String
-/*
- * std::wstring utf8_decode(const std::string &str)
- * {
- * if( str.empty() ) return std::wstring();
- * int size_needed = MultiByteToWideChar(CP_UTF8, 0, &str[0], (int)str.size(), NULL, 0);
- * std::wstring wstrTo( size_needed, 0 );
- * MultiByteToWideChar (CP_UTF8, 0, &str[0], (int)str.size(), &wstrTo[0], size_needed);
- * return wstrTo;
- * }
- */
-
class Endpoint {
public:
- Endpoint(IMMDevice* endpoint, IPolicyConfig7* policyConfig, uint64_t idx = 0);
+ Endpoint(IMMDevice* endpoint, uint64_t idx = 0);
//todo: how to forward declare delegate constructors?
//Endpoint(IMMDevice* endpoint) : Endpoint(endpoint, 0) {};
void reloadEndpointChannels();
@@ -58,8 +22,8 @@ class Endpoint {
float getVolume(int channel);
void setMute(NGuid guid, bool muted);
bool getMute();
- void setState(EndpointState state);
- EndpointState getState();
+ void setState(uint8_t state);
+ size_t getState();
Roles getRoles();
void setRoles(Roles role);
void assignRoles(Roles role);
@@ -80,34 +44,32 @@ class Endpoint {
void addSession(Session* session);
void registerNewSessionNotification(EndpointNewSessionCallback* ensc);
void unregisterNewSessionNotification(EndpointNewSessionCallback* ensc);
- void deleteSessions();
- void activateEndpointSessions();
- //void deleteSessionManager();
- std::mutex endpointSessionsMutex;
+
~Endpoint();
private:
void inline activateEndpointVolume();
+ void inline activateEndpointSessions();
std::vector endpointSessions;
uint32_t channelCount = 0;
IMMDevice *endpoint;
- IAudioEndpointVolume *endpointVolume = nullptr;
- IPropertyStore *properties;
- IAudioMeterInformation *endpointPeakMeter = nullptr;
- //IAudioClient *audioClient;
+ IAudioClient *audioClient;
int64_t defTime, minTime;
- IAudioSessionManager2 *sessionManager = nullptr;
+ IAudioSessionManager2 *sessionManager;
Flows flow;
+ IAudioEndpointVolume *endpointVolume = nullptr;
+ IPropertyStore *properties;
std::wstring friendlyName;
std::wstring descriptionName;
std::wstring deviceName;
std::wstring endpointId;
- EndpointState endpointState;
+ unsigned long endpointState;
Roles endpointRoles = (Roles)0;
uint64_t idx;
//Not implemented in llvm-mingw. Sad! todo: mingw patch
- IPolicyConfig7* policyConfig;
+ IAudioMeterInformation *endpointPeakMeter = nullptr;
+
};
class EndpointVolumeCallback : public IAudioEndpointVolumeCallback {
@@ -119,14 +81,11 @@ class EndpointVolumeCallback : public IAudioEndpointVolumeCallback {
ULONG Release();
HRESULT QueryInterface(REFIID riid, VOID **ppvInterface);
HRESULT OnNotify(PAUDIO_VOLUME_NOTIFICATION_DATA update);
- void updateVolumeInfo(AUDIO_VOLUME_NOTIFICATION_DATA newVolume, float* channelVolumes);
- void reportFinished();
//~EndpointVolumeCallback();
private:
ULONG ref = 1;
Endpoint* ep;
- std::atomic wait = false;
};
class EndpointSituationCallback : public IMMNotificationClient {
@@ -140,31 +99,24 @@ class EndpointSituationCallback : public IMMNotificationClient {
HRESULT OnDeviceRemoved(LPCWSTR pwstrDeviceId);
HRESULT OnDeviceStateChanged(LPCWSTR pwstrDeviceId, DWORD dwNewState);
HRESULT OnPropertyValueChanged(LPCWSTR pwstrDeviceId, const PROPERTYKEY key);
- void reportFinishedStateChange();
+
private:
ULONG ref = 1;
Overseer* os;
- std::atomic isEpStateChanging = false;
};
class Overseer {
public:
Overseer();
- void registerEndpointSituationCallback();
- NGuid getGuid();
-
+ void openControlPanel();
std::vector getPlaybackEndpoints();
std::vector getCaptureEndpoints();
void updateEndpointInfo(std::wstring endpointId);
- void createEndpoints(Flows flow);
+ void reloadEndpoints(Flows flow);
Endpoint* addEndpoint(std::wstring endpointId, /* out */ Flows* flow);
-
- void reportFinishedStateChange();
-
- std::mutex playbackMutex;
- std::mutex captureMutex;
+ NGuid getGuid();
//void setEndpointStatusCallback();
//void setEndpointStatusCallback();
@@ -176,65 +128,29 @@ class Overseer {
~Overseer();
private:
- void initCOMLibrary();
-
NGuid guid;
IMMDeviceEnumerator *deviceEnumerator;
EndpointSituationCallback epsc;
-
+ //IPolicyConfig *policyConfig;
std::vector playbackDevices;
std::vector captureDevices;
+ void initCOMLibrary();
IPolicyConfig7* policyConfig;
- friend class Endpoint;
//IMMDeviceCollection *deviceCollection;
//int numCaptureEndpoints;
//std::vector *captureDevices;
};
class EndpointNewSessionCallback : public IAudioSessionNotification {
- private:
- struct SessionThreadParams;
-
public:
EndpointNewSessionCallback(EndpointHandler *eph);
ULONG AddRef();
ULONG Release();
HRESULT QueryInterface(REFIID riid, VOID **ppvInterface);
HRESULT OnSessionCreated(IAudioSessionControl *NewSession);
- void createSessionThread(SessionThreadParams params);
private:
- std::atomic wait = false;
ULONG ref = 1;
EndpointHandler *eph;
-
- struct SessionThreadParams {
- EndpointHandler *eph;
- Session *session;
- bool isDelete;
- };
-};
-
-namespace Environment {
- wchar_t* getExeAbsPath(uint32_t *exeAbsPathLength);
- std::string createSettingsPath(SettingsTargetDirectory target);
- void populateSystemValues();
- void openControlPanel();
- ProcessedNativeEvent processTopLevelWindowMessage(void* msg);
- ProcessedNativeEvent updateColors();
- bool checkStartup(HKEY rootKeyFlags);
- void updateStartupConfig(bool onStartup);
- void setStartupConfig(bool onStartup);
- bool isLightMode();
- bool isToRunAtStartup();
- uint32_t getAccentColor();
-
- //todo: binary path cache unused
- static std::wstring exeAbsPath;
- static uint32_t exeAbsPathLen;
- static bool lightMode;
- static bool startup = false;
- static HKEY scope;
- static uint32_t accentColor;
};
diff --git a/src/back/backsessionclasses.cpp b/src/back/backsessionclasses.cpp
index c9aaa85..80eeac8 100644
--- a/src/back/backsessionclasses.cpp
+++ b/src/back/backsessionclasses.cpp
@@ -37,9 +37,6 @@ HRESULT SessionStateCallback::QueryInterface(REFIID riid, VOID **ppvInterface) {
}
HRESULT SessionStateCallback::OnDisplayNameChanged(LPCWSTR NewDisplayName, LPCGUID EventContext) {
- //TODO: Preguntar
- while(sh->getVolumeInfo()->isNameChanged == true);
-
sh->setName(std::wstring(NewDisplayName));
sh->getVolumeInfo()->isNameChanged = true;
return S_OK;
@@ -94,10 +91,8 @@ HRESULT SessionStateCallback::OnStateChanged(AudioSessionState NewState) {
}
HRESULT SessionStateCallback::OnSessionDisconnected(AudioSessionDisconnectReason DisconnectReason) {
- if (DisconnectReason != DisconnectReasonDeviceRemoval) {
- sh->setState(SessionState::DISCONNECTED);
- sh->reviseSessionShowing(SessionState::DISCONNECTED);
- }
+ sh->setState(SessionState::DISCONNECTED);
+ sh->reviseSessionShowing(SessionState::DISCONNECTED);
return S_OK;
}
@@ -131,19 +126,10 @@ Session::Session(Endpoint* ep, IAudioSessionControl2* sessionControl, size_t idx
else {
LPWSTR sessionDisplayName;
this->sessionControl->GetDisplayName(&sessionDisplayName);
- if (!wcscmp(sessionDisplayName, L"")) {
- std::wstring exePath;
- if (getExePath(pid, &exePath)) {
- this->sessionName = exePath;
- if (fetchName(exePath, pid)) goto nameFound;
- }
- if (fetchNameViaWindowName(pid, &this->sessionName)) goto nameFound;
- } else {
+ if (!wcscmp(sessionDisplayName, L""))
+ this->sessionName = this->fetchProcessName(pid);
+ else
this->sessionName = std::wstring(sessionDisplayName);
- goto nameFound;
- }
-
- nameFound:
CoTaskMemFree(sessionDisplayName);
}
}
@@ -206,196 +192,87 @@ void Session::setMute(NGuid guid, bool muted) {
if(FAILED(sessionVolume->SetMute(muted, &tempMsGuid))) { log_wdebugcpp(std::wstring(L"SessionVolume null?")); };
}
-bool Session::getExePath(DWORD pid, std::wstring *exePath) {
- //std::wstring msixName;
- HANDLE processHandle;
- wchar_t fileName[UNICODE_STRING_MAX_CHARS];
- processHandle = OpenProcess(PROCESS_QUERY_INFORMATION | PROCESS_VM_READ, FALSE, pid);
- if (processHandle != NULL) {
- if (GetModuleFileNameEx(processHandle, NULL, fileName, UNICODE_STRING_MAX_CHARS) == 0) {
- CloseHandle(processHandle);
- return false;
- }
- } else {
- log_wdebugcpp(L"aye no procname. -> " + std::to_wstring(GetLastError()));
- return false;
+std::wstring Session::fetchProcessName(DWORD pid) {
+ /*
+ * https://learn.microsoft.com/en-us/windows/win32/api/tlhelp32/nf-tlhelp32-createtoolhelp32snapshot
+ * https://stackoverflow.com/questions/11843368/how-to-get-process-description
+ */
+
+ /* Executable path retrieval */
+ std::wstring exePath = L"";
+
+ HANDLE processList = CreateToolhelp32Snapshot(TH32CS_SNAPMODULE | TH32CS_SNAPMODULE32, pid);
+ if (processList == INVALID_HANDLE_VALUE) {
+ log_wdebugcpp(L"aye no procname.");
+ return exePath;
}
- *exePath = std::wstring(fileName);
- return true;
-}
+ MODULEENTRY32W me32w;
+ me32w.dwSize = sizeof(MODULEENTRY32W);
+ if(Module32FirstW(processList, &me32w)) {
+ do {
+ if (me32w.th32ProcessID == pid) {
+ exePath = std::wstring(me32w.szExePath);
+ break;
+ /*
+ * However, if the calling process is a 32-bit process, you must call the
+ * QueryFullProcessImageName function to retrieve the full path of the
+ * executable file for a 64-bit process.
+ */
+ }
+ } while(Module32NextW(processList, &me32w));
+ }
+ CloseHandle(processList);
-bool Session::fetchNameViaFD(std::wstring exePath, DWORD pid, std::wstring *sessionName) {
- /* File description retrieval: size and available lang-codepages */
+ /* File description retrieval */
struct LANGANDCODEPAGE {
WORD wLanguage;
WORD wCodePage;
} *translationArray;
DWORD filler;
- DWORD fileVersionInfoSize = GetFileVersionInfoSizeExW
- (FILE_VER_GET_LOCALISED | FILE_VER_GET_NEUTRAL, exePath.c_str(), &filler);
- if (!fileVersionInfoSize) return false;
+ DWORD fileVersionInfoSize = GetFileVersionInfoSizeW(exePath.c_str(), &filler);
+ if (!fileVersionInfoSize) return exePath;
void* fileVersionInfo = malloc(fileVersionInfoSize);
- if(!GetFileVersionInfoExW(FILE_VER_GET_LOCALISED | FILE_VER_GET_NEUTRAL,
- exePath.c_str(),0,fileVersionInfoSize, fileVersionInfo)) {
- return false;
- }
+ if(!GetFileVersionInfoW(exePath.c_str(),0,fileVersionInfoSize, fileVersionInfo))
+ return exePath;
UINT translationArrayLen = 0;
- if (!VerQueryValueW(fileVersionInfo, L"\\VarFileInfo\\Translation", (LPVOID*)&translationArray, &translationArrayLen)) {
- free(fileVersionInfo);
- return false;
- }
- //File descriptor parsing
- //TODO: https://learn.microsoft.com/en-us/windows/win32/api/winnls/nf-winnls-getuserpreferreduilanguages
- /* It is possible to retrieve user languages and try to use one of those before falling back to whatever
- * is available. Also possible to hardcode en-US or any other lang-codepage combo. When an actual translation
- * sysem is put in place, I'll come finish this up.
- */
- uint64_t availableLangs = (translationArrayLen / sizeof(LANGANDCODEPAGE));
- if (!availableLangs) { free(fileVersionInfo); return false; }
+ if (!VerQueryValueW(fileVersionInfo, L"\\VarFileInfo\\Translation", (LPVOID*)&translationArray, &translationArrayLen))
+ return exePath;
- int8_t syslangIdx = -1;
- wchar_t metadataStringKey[256];
- wchar_t* metadataString = NULL;
- for (UINT i = 0; i < availableLangs; i++) {
+ bool match = false;
+ for (UINT i = 0; i < (translationArrayLen / sizeof(LANGANDCODEPAGE)); i++) {
+ wchar_t fileDescriptionKey[256];
LANGID defaultUILanguage = GetUserDefaultUILanguage();
if (defaultUILanguage != translationArray[i].wLanguage)
continue;
- syslangIdx = i;
- break;
+ match = true;
+ wchar_t* fileDescription = NULL;
+ UINT fileDescriptionSize = 0;
+ swprintf(fileDescriptionKey, L"\\StringFileInfo\\%04x%04x\\FileDescription",
+ translationArray[i].wLanguage, translationArray[i].wCodePage);
+ if (VerQueryValueW(fileVersionInfo, fileDescriptionKey, (LPVOID*)&fileDescription, &fileDescriptionSize)) {
+ exePath = std::wstring(fileDescription);
+ }
}
- UINT metadataStringSize = 0;
- swprintf(metadataStringKey, L"\\StringFileInfo\\%04x%04x\\FileDescription",
- translationArray[(syslangIdx < 0 ? 0 : syslangIdx)].wLanguage,
- translationArray[(syslangIdx < 0 ? 0 : syslangIdx)].wCodePage);
- if (VerQueryValueW(fileVersionInfo, metadataStringKey, (LPVOID*)&metadataString, &metadataStringSize)
- && metadataString[0] != '\0') {
- free(fileVersionInfo);
- *sessionName = std::wstring(metadataString);
- return true;
- }
- swprintf(metadataStringKey, L"\\StringFileInfo\\%04x%04x\\ProductName",
- translationArray[(syslangIdx < 0 ? 0 : syslangIdx)].wLanguage,
- translationArray[(syslangIdx < 0 ? 0 : syslangIdx)].wCodePage);
- if (VerQueryValueW(fileVersionInfo, metadataStringKey, (LPVOID*)&metadataString, &metadataStringSize)
- && metadataString[0] != '\0') {
- free(fileVersionInfo);
- *sessionName = std::wstring(metadataString);
- return true;
- }
+ if (!match && 1 <= (translationArrayLen / sizeof(LANGANDCODEPAGE))) {
+ wchar_t fileDescriptionKey[256];
- if(fileVersionInfo)
- free(fileVersionInfo);
-
- return false;
-}
-
-
-bool Session::fetchNameViaMSIX(std::wstring exePath, DWORD pid, std::wstring *sessionName) {
- HANDLE process = OpenProcess(PROCESS_QUERY_LIMITED_INFORMATION, FALSE, pid);
- if(!process) return false;
-
- //constant missing in mingw64. TB removed when I upgrade to a mingw64 ver that has it
- #define APPLICATION_USER_MODEL_ID_MAX_LENGTH 130
- uint32_t length = APPLICATION_USER_MODEL_ID_MAX_LENGTH;
- PWSTR userModelId = (PWSTR)malloc(length * sizeof(wchar_t));
- if(GetApplicationUserModelId(process, &length, userModelId) != ERROR_SUCCESS) {
- CloseHandle(process);
- return false;
- }
- CloseHandle(process);
-
- static constexpr wchar_t* prefix = L"shell:appsfolder\\";
- uint32_t prefixLen = wcslen(prefix);
- uint32_t userModelIdLen = wcslen(userModelId);
- wchar_t* fullName;
- fullName = (prefixLen + userModelIdLen < length)
- ? (wchar_t*)malloc(length * sizeof(wchar_t))
- : (wchar_t*)malloc((length * 2) * sizeof(wchar_t));
- for (int32_t i = prefixLen - 1; i >= 0; i--) {
- fullName[i] = prefix[i];
- }
- for (uint32_t i = 0; i < userModelIdLen + 1; i++) {
- fullName[prefixLen + i] = userModelId[i];
- }
-
- IShellItem* si;
- HRESULT hr = SHCreateItemFromParsingName(fullName,
- nullptr,
- IID_IShellItem,
- (void**)&si
- );
- free(fullName);
- LPWSTR humanName = nullptr;
- si->GetDisplayName(SIGDN_NORMALDISPLAY, &humanName);
- if(humanName && humanName[0] != '\0') {
- *sessionName = std::wstring(humanName);
- CoTaskMemFree(humanName);
- }
- if(si) si->Release();
-
- if (sessionName->length() > 0)
- return true;
- else return false;
-}
-
-
-bool Session::fetchNameViaWindowName(DWORD pid, std::wstring *sessionName) {
- //lParam is documented as in, so... Beware of future explosions, ig?
- std::pair params = { 0, pid };
-
- BOOL result = EnumWindows([](HWND hwnd, LPARAM lParam) -> BOOL {
- auto pParams = (std::pair*)(lParam);
-
- DWORD processId;
- //IsWindowVisible(hwnd) &&&& GetWindow(hwnd, GW_OWNER) == 0
- if ( GetWindowThreadProcessId(hwnd, &processId) && processId == pParams->second) {
- int length = GetWindowTextLength(hwnd);
- if (!length) return TRUE;
-
- // Stop enumerating
- SetLastError(-1);
- pParams->first = hwnd;
- return FALSE;
- }
-
- // Continue enumerating
- return TRUE;
- } , (LPARAM)¶ms);
-
- if(!result && GetLastError() == -1 && params.first) {
- //todo: double-dipping length... Not a fan
- int length = GetWindowTextLength(params.first);
- wchar_t* buffer = new wchar_t[length + 1];
- GetWindowTextW(params.first, buffer, length + 1);
- *sessionName = buffer;
- delete[] buffer;
- return true;
- }
- return false;
-}
-
-bool Session::fetchName(std::wstring exePath, DWORD pid) {
- /*
- * if(fetchNameViaWindowName(exePath, pid, &this->sessionName))
- * return;
- * else if(fetchNameViaMSIX(exePath, pid, &this->sessionName))
- * return;
- * else if(!fetchNameViaFD(exePath, pid, &this->sessionName))
- * this->sessionName = exePath;
- */
-
- if(fetchNameViaFD(exePath, pid, &this->sessionName))
- return true;
- return fetchNameViaMSIX(exePath, pid, &this->sessionName);
- //else if(!fetchNameViaWindowName(exePath, pid, &this->sessionName))
- /// this->sessionName = exePath;
+wchar_t* fileDescription = NULL;
+ UINT fileDescriptionSize = 0;
+ swprintf(fileDescriptionKey, L"\\StringFileInfo\\%04x%04x\\FileDescription",
+ translationArray[0].wLanguage, translationArray[0].wCodePage);
+ if (VerQueryValueW(fileVersionInfo, fileDescriptionKey, (LPVOID*)&fileDescription, &fileDescriptionSize)) {
+ exePath = std::wstring(fileDescription);
+ }
+ }
+ free(fileVersionInfo);
+ return exePath;
}
//todo: conflicting names. change callback name
@@ -419,7 +296,4 @@ Session::~Session() {
meterInformation->Release();
sessionControl->Release();
sessionVolume->Release();
- meterInformation = nullptr;
- sessionControl = nullptr;
- sessionVolume = nullptr;
}
diff --git a/src/back/backsessionclasses.h b/src/back/backsessionclasses.h
index ae87f0a..2b5db99 100644
--- a/src/back/backsessionclasses.h
+++ b/src/back/backsessionclasses.h
@@ -47,18 +47,13 @@ class Session {
//uint32_t getChannelCount();
private:
- bool getExePath(DWORD pid, /*out*/ std::wstring *exePath);
- bool fetchName(std::wstring exePath, DWORD pid);
- bool fetchNameViaFD(std::wstring exePath, DWORD pid, /*out*/ std::wstring *sessionName);
- bool fetchNameViaMSIX(std::wstring exePath, DWORD pid, /*out*/ std::wstring *sessionName);
- bool fetchNameViaWindowName(DWORD pid, /*out*/ std::wstring *sessionName);
- /* std::wstring fetchProcessName(DWORD pid); */
+ std::wstring fetchProcessName(DWORD pid);
std::wstring sessionName;
SessionState sessionState;
Endpoint* ep;
IAudioSessionControl2* sessionControl = nullptr;
IAudioMeterInformation* meterInformation = nullptr;
ISimpleAudioVolume* sessionVolume = nullptr;
- size_t idx;
+ size_t idx;
};
diff --git a/src/back/msinclude.h b/src/back/msinclude.h
index 52fccbd..16216f6 100644
--- a/src/back/msinclude.h
+++ b/src/back/msinclude.h
@@ -1,15 +1,12 @@
#pragma once
+#define _WIN32_WINNT 0x0A00
#include
//done by qt by def #define UNICODE
#include
#include
-#include
-#include
-#include
-#include
#include
#include
#include
@@ -17,7 +14,6 @@
#include
#include
#include
-#include
//#include
#include
@@ -29,7 +25,6 @@
#include
#include
#include
-#include
#include "ipolicyconfig.h"
#include "audiometerinfo.h"
diff --git a/src/cont/contclasses.cpp b/src/cont/contclasses.cpp
index d2188f0..f46571c 100644
--- a/src/cont/contclasses.cpp
+++ b/src/cont/contclasses.cpp
@@ -1,37 +1,27 @@
#include "backlasses.h"
#include "contclasses.h"
-
-void setConfigDirToDefaults() {
- #define tryFileDir(dir, create) do { \
- OverseerHandler::settingsPath = Environment::createSettingsPath(dir); \
- set = ini::UserSettings::createSettings(OverseerHandler::settingsPath.c_str(), create); \
- if(set) { \
- return; \
- } else OverseerHandler::settingsPath.clear(); \
- } while(0)
- #define tryOpenFileDir(dir) tryFileDir(dir, false)
- #define tryCreateFileDir(dir) tryFileDir(dir, true)
-
- tryOpenFileDir(SettingsTargetDirectory::APP_PATH);
- tryOpenFileDir(SettingsTargetDirectory::HOME_DIR);
- tryCreateFileDir(SettingsTargetDirectory::HOME_DIR);
- tryCreateFileDir(SettingsTargetDirectory::APP_PATH);
-
- return;
- #undef tryOpenFileDir
- #undef tryCreateFileDir
- #undef tryFileDir
-}
+//TODO: pragma once
EndpointHandler::EndpointHandler(uint64_t idx, Flows flow) {
+ //std::vector endpoints = osh->getPlaybackEndpoints().at(idx);
this->idx = idx;
this->flow = flow;
this->ep = (flow == Flows::FLOW_PLAYBACK ? osh->getPlaybackEndpoints().at(idx) : osh->getCaptureEndpoints().at(idx));
+ epc = new EndpointVolumeCallback(ep);
+ ensc = new EndpointNewSessionCallback(this);
this->callbackInfo.caller = osh->getGuid();
+ ep->registerNewSessionNotification(ensc);
//epName = ep->getName();
this->setBackEndpointVolumeCallbackInfoContent(this->getState());
osh->pushBackEndpointHandler(this, flow);
+
+ if (this->flow == Flows::FLOW_PLAYBACK) {
+ for (int i = 0; i < this->getSessionCount(); i++) {
+ SessionHandler* sessionHandler = new SessionHandler(this, this->getSessions().at(i),i);
+ sessionHandlers.push_back(sessionHandler);
+ }
+ }
}
void OverseerHandler::pushBackEndpointHandler(EndpointHandler* eph, Flows flow) {
@@ -60,6 +50,16 @@ Flows EndpointHandler::getFlow(){
return ep->getFlow();
}
+/* these two, currently unused. If I use them, I should feel bad.
+ * Endpoint* EndpointHandler::getEndpoint() {
+ * return this->ep;
+ * }
+ *
+ * EndpointVolumeCallback* EndpointHandler::getEndpointVolumeCallback() {
+ * return this->epc;
+ * }
+ */
+
BackEndpointVolumeCallbackInfo* EndpointHandler::getCallbackInfo(){
return &this->callbackInfo;
}
@@ -114,10 +114,7 @@ void EndpointHandler::setBackEndpointVolumeCallbackInfoContent(uint8_t state) {
callbackInfo.muted = this->getMute();
callbackInfo.mainVolume = this->getVolume(AudioChannel::CHANNEL_MAIN);
callbackInfo.channels = this->getChannelCount();
- if (!epc) {
- epc = new EndpointVolumeCallback(ep);
- ep->setVolumeCallback(epc);
- }
+ ep->setVolumeCallback(epc);
callbackInfo.channelVolumes.resize(this->callbackInfo.channels);
for(uint32_t i = 0; i < this->getChannelCount(); i++){
callbackInfo.channelVolumes.at(i) = this->getVolume(i);
@@ -125,12 +122,12 @@ void EndpointHandler::setBackEndpointVolumeCallbackInfoContent(uint8_t state) {
}
}
-void EndpointHandler::setState(EndpointState state){
+void EndpointHandler::setState(uint8_t state){
ep->setState(state);
this->setBackEndpointVolumeCallbackInfoContent(state);
}
-void EndpointHandler::setState(EndpointState state, uint64_t index){
+void EndpointHandler::setState(uint8_t state, uint64_t index){
ep->setState(state);
this->setFrontVisibilityInfo((EndpointState)state, index);
this->setBackEndpointVolumeCallbackInfoContent(state);
@@ -182,15 +179,10 @@ Endpoint* EndpointHandler::getEndpoint() {
}
void EndpointHandler::addSessionSendFront(Session* session) {
- if(!ep->endpointSessionsMutex.try_lock()) return;
- sessionHandlersMutex.lock();
-
- this->ep->addSession(session);
+ ep->addSession(session);
+
SessionHandler* sessionHandler = new SessionHandler(this, session, (getSessionCount() - 1));
-
sessionHandlers.push_back(sessionHandler);
- ep->endpointSessionsMutex.unlock();
- sessionHandlersMutex.unlock();
this->addSessionWidget(sessionHandler);
}
@@ -202,49 +194,6 @@ void EndpointHandler::removeSessionFromFront(SessionHandler* sh) {
this->removeSessionWidget(sh);
}
-void EndpointHandler::deleteSessions() {
- ep->unregisterNewSessionNotification(ensc);
- ensc->Release();
- ensc = nullptr;
- for (auto sh : sessionHandlers) {
- delete sh;
- }
- sessionHandlers.resize(0);
- ep->deleteSessions();
- //ep->deleteSessionManager();
-}
-
-void EndpointHandler::createSessionHandlers() {
- ep->activateEndpointSessions();
- if (this->flow == Flows::FLOW_PLAYBACK) {
- for (int i = 0; i < this->getSessionCount(); i++) {
- SessionHandler* sessionHandler = new SessionHandler(this, this->getSessions().at(i),i);
- sessionHandlers.push_back(sessionHandler);
- }
- }
-}
-
-void EndpointHandler::createSessionHandlersCallback() {
- ensc = new EndpointNewSessionCallback(this);
- ep->registerNewSessionNotification(ensc);
-}
-
-void EndpointHandler::lockSessionCollections() {
- this->sessionHandlersMutex.lock();
- this->ep->endpointSessionsMutex.lock();
-}
-
-void EndpointHandler::unlockSessionCollections() {
- this->sessionHandlersMutex.unlock();
- this->ep->endpointSessionsMutex.unlock();
-}
-
-void EndpointHandler::removeVolumeCallback() {
- ep->removeVolumeCallback(epc);
- epc->Release();
- epc = nullptr;
-}
-
EndpointHandler::~EndpointHandler() {
ep->removeVolumeCallback(epc);
ep->unregisterNewSessionNotification(ensc);
@@ -256,44 +205,8 @@ OverseerHandler::OverseerHandler() {
this->os = new Overseer();
}
-void OverseerHandler::setSettingsPath(std::string path) {
- OverseerHandler::settingsPath = path;
-}
-
-std::string OverseerHandler::getSettingsPath(){
- return OverseerHandler::settingsPath;
-}
-
-void OverseerHandler::updateStartupConfig(bool onStartup) {
- Environment::updateStartupConfig(onStartup);
-}
-
-void OverseerHandler::setStartupConfig(bool onStartup) {
- Environment::setStartupConfig(onStartup);
-}
-
-void OverseerHandler::populateSystemValues() {
- Environment::populateSystemValues();
-}
-
void OverseerHandler::openControlPanel() {
- Environment::openControlPanel();
-}
-
-ProcessedNativeEvent OverseerHandler::processTopLevelWindowMessage(void* msg) {
- return Environment::processTopLevelWindowMessage(msg);
-}
-
-bool OverseerHandler::isLightMode() {
- return Environment::isLightMode();
-}
-
-bool OverseerHandler::isToRunAtStartup() {
- return Environment::isToRunAtStartup();
-}
-
-uint32_t OverseerHandler::getAccentColor() {
- return Environment::getAccentColor();
+ this->os->openControlPanel();
}
std::vector OverseerHandler::getPlaybackEndpoints() {
@@ -320,7 +233,7 @@ uint64_t OverseerHandler::getCaptureEndpointsCount(){
return this->os->getCaptureEndpoints().size();
}
-void OverseerHandler::createEndpointHandlers(){
+void OverseerHandler::reloadEndpointHandlers(){
//todo: add capture
//std::vector* ephs = new std::vector;
@@ -328,7 +241,9 @@ void OverseerHandler::createEndpointHandlers(){
for(uint64_t i = 0; i < this->getPlaybackEndpointsCount(); i++){
log_debugcpp("Creating Playback handler " + std::to_string(i));
- new EndpointHandler(i, Flows::FLOW_PLAYBACK);
+
+ EndpointHandler* ephexx = new EndpointHandler(i, Flows::FLOW_PLAYBACK);
+ //this->playbackEndpointHandlers.push_back(ephexx);
log_debugcpp("Created Playback handler " + std::to_string(i) + ", adding to vector. " + " VSize: " + std::to_string(this->playbackEndpointHandlers.size()));
}
@@ -336,55 +251,51 @@ void OverseerHandler::createEndpointHandlers(){
log_debugcpp("Capture VSize: " +
std::to_string(this->getCaptureEndpointsCount()));
- for(uint64_t i = 0; i < this->getCaptureEndpointsCount(); i++) {
+ for(uint64_t i = 0; i < this->getCaptureEndpointsCount(); i++){
log_debugcpp("Creating Capture handler " + std::to_string(i));
- new EndpointHandler(i, Flows::FLOW_CAPTURE);
+
+ /*
+ * if(i < (this->captureEndpointHandlers.size()) &&
+ * this->captureEndpointHandlers.at(i) != nullptr)
+ * delete captureEndpointHandlers.at(i);
+ */
+
+ EndpointHandler* ephoo = new EndpointHandler(i, Flows::FLOW_CAPTURE);
+ //this->captureEndpointHandlers.push_back(ephoo);
log_debugcpp("Created Capture handler " + std::to_string(i) + ", adding to vector. " + " VSize: " + std::to_string(this->captureEndpointHandlers.size()));
+
/*
* if (i >= this->captureEndpointHandlers.size())
* captureEndpointHandlers.push_back(eph);
* else captureEndpointHandlers.at(i) = eph;
*/
}
- os->registerEndpointSituationCallback();
+ //setEndpointHandlers(ephs);
}
-EndpointHandler* OverseerHandler::addEndpoint(std::wstring endpointId, /* out */ Flows *flow = nullptr) {
- //This method is only called from the new endpoint callback and its subsequent thread
+EndpointHandler* OverseerHandler::addEndpoint(std::wstring endpointId, /* out */ Flows *flow = nullptr){
Flows localFlow;
Endpoint* newEp = this->os->addEndpoint(endpointId, &localFlow);
uint64_t ephIdx = (localFlow == Flows::FLOW_PLAYBACK ? this->getPlaybackEndpointsCount() : this->getCaptureEndpointsCount()) - 1;
EndpointHandler* newEph = new EndpointHandler(ephIdx, localFlow);
+ // std::vector getPlaybackEndpointHandlers();
+ //std::vector getCaptureEndpointHandlers();
if (flow != nullptr) *flow = localFlow;
return newEph;
}
-void OverseerHandler::reportFinishedStateChange() {
- os->reportFinishedStateChange();
-}
-
NGuid OverseerHandler::getGuid() {
return this->os->getGuid();
}
-/*
- * void OverseerHandler::setChangeFrontDefaultsFunction(std::function changeFrontDefaults){
- * this->changeFrontDefaults = changeFrontDefaults;
- * }
- *
- * void OverseerHandler::changeFrontDefaultsCallback(Roles role, std::wstring endpointId) {
- * this->changeFrontDefaults(role, endpointId);
- * }
- */
-
-void OverseerHandler::roleBucketEntryCallback(Roles role, std::wstring endpointId){
- this->roleBucketEntry(role, endpointId);
+void OverseerHandler::setChangeFrontDefaultsFunction(std::function changeFrontDefaults){
+ this->changeFrontDefaults = changeFrontDefaults;
}
-void OverseerHandler::setRoleBucketEntryFunction(std::function roleBucketEntry) {
- this->roleBucketEntry = roleBucketEntry;
+void OverseerHandler::changeFrontDefaultsCallback(Roles role, std::wstring endpointId) {
+ this->changeFrontDefaults(role, endpointId);
}
void OverseerHandler::updateFrontEndpointName(Endpoint* ep) {
@@ -395,12 +306,7 @@ void OverseerHandler::updateFrontEndpointName(Endpoint* ep) {
}
void OverseerHandler::reviseEndpointShowing(std::wstring endpointId, EndpointState state) {
- //TODO: Race condition!!!!!
std::vector allHandlers;
- handlersPlaybackMutex.lock();
- handlersCaptureMutex.lock();
- os->playbackMutex.lock();
- os->captureMutex.lock();
allHandlers.insert(allHandlers.end(), this->captureEndpointHandlers.begin(), this->captureEndpointHandlers.end());
allHandlers.insert(allHandlers.end(), this->playbackEndpointHandlers.begin(), this->playbackEndpointHandlers.end());
EndpointHandler* eph = nullptr;
@@ -414,29 +320,20 @@ void OverseerHandler::reviseEndpointShowing(std::wstring endpointId, EndpointSta
//debug
Flows flow;
if (!eph) {
- if (state ^ EndpointState::ENDPOINT_ACTIVE) goto end;
+ if (state ^ EndpointState::ENDPOINT_ACTIVE) return;
//flow = Flows::FLOW_CAPTURE;
eph = osh->addEndpoint(endpointId, &flow);
} else
flow = eph->getFlow();
//todo: mic done but disabled. Tab-kun will come...
- if (flow == Flows::FLOW_CAPTURE) goto end;
+ if (flow == Flows::FLOW_CAPTURE) return;
- if (eph && EndpointState::ENDPOINT_ACTIVE & state) {
- eph->setState(EndpointState::ENDPOINT_ACTIVE);
+ if(eph && EndpointState::ENDPOINT_ACTIVE & state) {
this->addEndpointWidget(eph);
- } else if (eph && eph->getFrontVisibilityState() == EndpointState::ENDPOINT_ACTIVE) {
- eph->removeVolumeCallback();
+ } else if (eph && eph->getFrontVisibilityState() == EndpointState::ENDPOINT_ACTIVE){
this->removeEndpointWidget(eph->getFrontVisibilityIndex());
}
-
- end:
- handlersPlaybackMutex.unlock();
- handlersCaptureMutex.unlock();
- os->playbackMutex.unlock();
- os->captureMutex.unlock();
- os->reportFinishedStateChange();
return;
}
@@ -451,14 +348,3 @@ void OverseerHandler::setRemoveEndpointWidgetFunction(std::function ephs){
this->playbackEndpointHandlers = ephs;
}
-
-void OverseerHandler::lockEndpoints() {
- os->playbackMutex.lock();
- os->captureMutex.lock();
-}
-
-void OverseerHandler::unlockEndpoints() {
- os->playbackMutex.unlock();
- os->captureMutex.unlock();
-}
-
diff --git a/src/cont/contclasses.h b/src/cont/contclasses.h
index cd0e03e..b0cea92 100644
--- a/src/cont/contclasses.h
+++ b/src/cont/contclasses.h
@@ -1,7 +1,6 @@
#pragma once
#include "global.h"
-#include "settings.h"
#include "contsessionclasses.h"
//#define invoke_mem_fn(object,ptrToMember) ((object).*(ptrToMember))
//#define pinvoke_mem_fn(object,ptrToMember) ((object)->*(ptrToMember))
@@ -17,13 +16,11 @@ struct BackEndpointVolumeCallbackInfo {
NGuid caller;
bool muted;
float mainVolume;
- size_t channels;
+ size_t channels;
std::vector channelVolumes;
bool updateName = false;
};
-void setConfigDirToDefaults();
-
class EndpointHandler {
public:
@@ -58,8 +55,8 @@ public:
void setVolume(NGuid guid, int channel, int value);
void setMute(NGuid guid, bool muted);
- void setState(EndpointState state);
- void setState(EndpointState state, uint64_t idx);
+ void setState(uint8_t state);
+ void setState(uint8_t state, uint64_t idx);
float getPeakVolume();
/* sessions */
@@ -74,13 +71,6 @@ public:
void setRemoveSessionWidgetFunction(std::function removeSessionWidget);
void sendSessionToFront(SessionHandler* sh);
void removeSessionFromFront(SessionHandler* sh);
- void deleteSessions();
- void createSessionHandlers();
- void createSessionHandlersCallback();
- std::mutex sessionHandlersMutex;
- void lockSessionCollections();
- void unlockSessionCollections();
- void removeVolumeCallback();
~EndpointHandler();
private:
@@ -107,24 +97,11 @@ class OverseerHandler {
public:
OverseerHandler();
- static void setSettingsPath(std::string path);
- static std::string getSettingsPath();
- static inline std::string settingsPath;
- void updateStartupConfig(bool onStartup);
- void setStartupConfig(bool onStartup);
- void populateSystemValues();
void openControlPanel();
- ProcessedNativeEvent processTopLevelWindowMessage(void* msg);
- bool isLightMode();
- bool isToRunAtStartup();
- uint32_t getAccentColor();
- //void setChangeFrontDefaultsFunction(std::function changeFrontDefaults);
- //void changeFrontDefaultsCallback(Roles role, std::wstring endpointId);
+ void setChangeFrontDefaultsFunction(std::function changeFrontDefaults);
+ void changeFrontDefaultsCallback(Roles role, std::wstring endpointId);
- void roleBucketEntryCallback(Roles role, std::wstring endpointId);
- void setRoleBucketEntryFunction(std::function roleBucketEntry);
-
void updateFrontEndpointName(Endpoint* ep);
//void setReviseEndpointShowingFunction(std::function reviseEndpointShowing);
void reviseEndpointShowing(std::wstring endpointId, EndpointState state);
@@ -139,29 +116,25 @@ public:
void pushBackEndpointHandler(EndpointHandler* eph, Flows flow);
uint64_t getPlaybackEndpointsCount();
uint64_t getCaptureEndpointsCount();
- void createEndpointHandlers();
- EndpointHandler* addEndpoint(std::wstring endpointId, Flows *flow);
- void reportFinishedStateChange();
+ void reloadEndpointHandlers();
+ EndpointHandler* addEndpoint(std::wstring endpointId, Flows *flow);
NGuid getGuid();
- std::mutex handlersPlaybackMutex;
- std::mutex handlersCaptureMutex;
- void lockEndpoints();
- void unlockEndpoints();
+ /*
+ * void setSessionVolumeCallback(std::function changeSessionVolume);
+ * void setSessionVolume(float newValue, );
+ */
private:
Overseer *os;
std::vector playbackEndpointHandlers;
std::vector captureEndpointHandlers;
-
std::function changeFrontDefaults;
std::function removeEndpointWidget;
std::function addEndpointWidget;
- std::function roleBucketEntry;
-
+
/* Session's */
std::function changeSessionVolume;
-
//std::function updateFrontVolumeCallback;
//std::function updateFrontMuteCallback;
diff --git a/src/cont/contsessionclasses.cpp b/src/cont/contsessionclasses.cpp
index 0f6caaf..b63631e 100644
--- a/src/cont/contsessionclasses.cpp
+++ b/src/cont/contsessionclasses.cpp
@@ -5,7 +5,7 @@ SessionHandler::SessionHandler(EndpointHandler* eph, Session* session, size_t id
this->eph = eph;
this->idx = idx;
this->session = session;
-
+
this->svi.mainVolume = session->getVolume(AudioChannel::CHANNEL_MAIN);
this->svi.muted = session->getMute();
this->svi.caller = osh->getGuid();
@@ -85,7 +85,3 @@ void SessionHandler::reviseSessionShowing(SessionState state) {
}
}
-SessionHandler::~SessionHandler() {
- session->removeStateCallback(ssc);
- ssc->Release();
-}
diff --git a/src/cont/contsessionclasses.h b/src/cont/contsessionclasses.h
index 24c0ba7..488d3ea 100644
--- a/src/cont/contsessionclasses.h
+++ b/src/cont/contsessionclasses.h
@@ -9,10 +9,10 @@ class SessionStateCallback;
struct SessionVolumeInfo {
//SessionVolumeInfo(bool muted, float mainVolume);
- bool muted;
- float mainVolume;
- NGuid caller;
- std::atomic isNameChanged = false;
+ bool muted;
+ float mainVolume;
+ NGuid caller;
+ bool isNameChanged = false;
//size_t channels;
//std::vector channelVolumes;
};
@@ -33,7 +33,7 @@ class SessionHandler {
void setName(std::wstring newName);
void reviseSessionShowing(SessionState state);
SessionVolumeInfo* getVolumeInfo();
- ~SessionHandler();
+
private:
SessionVolumeInfo svi;
EndpointHandler* eph;
diff --git a/src/debug.h b/src/debug.h
index 61855c1..176825a 100644
--- a/src/debug.h
+++ b/src/debug.h
@@ -2,8 +2,6 @@
#if defined (QT_DEBUG) || defined (DEBUG) || defined (_DEBUG)
-#define PIPE_NAME "Mixerq-dev"
-
#ifdef INIT_FILELOG
std::wstring_convert, wchar_t> converter;
FILE* fileLog;
@@ -58,7 +56,7 @@ std::bitset varToBitset(T info) {
OutputDebugStringW(std::wstring(L"[DEBUG] (" + std::wstring(WFILE) + L":" + std::to_wstring(__LINE__) + L"): " + std::wstring(str) +L"\n").c_str()); \
} while (0)
-#endif //_WIN32
+#endif
#define log_to_file(fmt, cnt...) do { \
if(writable) fprintf_s(fileLog, fmt,##cnt); \
@@ -74,9 +72,8 @@ std::bitset varToBitset(T info) {
#define print_as_binary(info)
#define log_to_file(fmt, cnt...)
#define initialize_file_log() false
-#define close_file_log_buffer()
-#define PIPE_NAME "Mixerq"
-#endif //DEBUG
+#define close_file_log_buffer()
+#endif
/* Here as a quick reference, in case smthn similar is needed again */
/* typedef void (EndpointWidget::*epwMuteFunc)(bool muted); */
diff --git a/src/global.h b/src/global.h
index 8799892..b8b9bcb 100644
--- a/src/global.h
+++ b/src/global.h
@@ -10,17 +10,10 @@
#include
#include
#include
-#include