mirror of
https://github.com/vicr123/theshell.git
synced 2025-01-23 12:12:06 -05:00
269 lines
11 KiB
C++
269 lines
11 KiB
C++
#include "audiomanager.h"
|
|
|
|
AudioManager::AudioManager(QObject *parent) : QObject(parent)
|
|
{
|
|
pulseLoopApi = pa_glib_mainloop_get_api(pa_glib_mainloop_new(NULL));
|
|
|
|
pa_proplist* propList = pa_proplist_new();
|
|
pa_proplist_sets(propList, PA_PROP_APPLICATION_NAME, "theShell");
|
|
pa_proplist_sets(propList, PA_PROP_APPLICATION_ID, "org.thesuite.theshell");
|
|
pa_proplist_sets(propList, PA_PROP_APPLICATION_ICON_NAME, "theshell");
|
|
|
|
pulseContext = pa_context_new_with_proplist(pulseLoopApi, NULL, propList);
|
|
pa_proplist_free(propList);
|
|
pa_context_set_state_callback(pulseContext, &AudioManager::pulseStateChanged, this);
|
|
|
|
int connected = pa_context_connect(pulseContext, NULL, PA_CONTEXT_NOFLAGS, NULL);
|
|
|
|
if (connected < 0) {
|
|
pulseAvailable = false;
|
|
} else {
|
|
pulseAvailable = true;
|
|
}
|
|
}
|
|
|
|
void AudioManager::changeVolume(int volume) {
|
|
pa_volume_t avgVol = pa_cvolume_avg(&defaultSinkVolume);
|
|
int onePercent = (PA_VOLUME_NORM - PA_VOLUME_MUTED) / 100;
|
|
pa_volume_t newVol = avgVol + (onePercent * volume);
|
|
if (newVol < PA_VOLUME_MUTED) newVol = PA_VOLUME_MUTED;
|
|
if (newVol > PA_VOLUME_MAX) newVol = PA_VOLUME_MAX;
|
|
|
|
if (volume < 0) {
|
|
if (newVol > avgVol) {
|
|
newVol = PA_VOLUME_MUTED;
|
|
}
|
|
}
|
|
if (avgVol < PA_VOLUME_NORM) {
|
|
if (newVol > PA_VOLUME_NORM) {
|
|
newVol = PA_VOLUME_NORM;
|
|
}
|
|
}
|
|
|
|
|
|
pa_cvolume newCVol = defaultSinkVolume;
|
|
for (int i = 0; i < newCVol.channels; i++) {
|
|
newCVol.values[i] = newVol;
|
|
}
|
|
pa_context_set_sink_mute_by_index(pulseContext, defaultSinkIndex, false, NULL, NULL);
|
|
pa_context_set_sink_volume_by_index(pulseContext, defaultSinkIndex, &newCVol, NULL, NULL);
|
|
}
|
|
|
|
void AudioManager::setMasterVolume(int volume) {
|
|
if (pulseAvailable) {
|
|
pa_volume_t setVol = PA_VOLUME_MUTED + (((float) volume / 100) * (float) PA_VOLUME_NORM);
|
|
pa_cvolume newVol = defaultSinkVolume;
|
|
for (int i = 0; i < newVol.channels; i++) {
|
|
newVol.values[i] = setVol;
|
|
}
|
|
pa_context_set_sink_volume_by_index(pulseContext, defaultSinkIndex, &newVol, NULL, NULL);
|
|
} else {
|
|
//Get Current Limits
|
|
QProcess* mixer = new QProcess(this);
|
|
mixer->start("amixer");
|
|
mixer->waitForFinished();
|
|
QString output(mixer->readAll());
|
|
|
|
bool readLine = false;
|
|
int limit;
|
|
for (QString line : output.split("\n")) {
|
|
if (line.startsWith(" ") && readLine) {
|
|
if (line.startsWith(" Limits:")) {
|
|
limit = line.split(" ").last().toInt();
|
|
}
|
|
} else {
|
|
if (line.contains("'Master'")) {
|
|
readLine = true;
|
|
} else {
|
|
readLine = false;
|
|
}
|
|
}
|
|
}
|
|
|
|
mixer->start("amixer set Master " + QString::number(limit * (volume / (float) 100)) + " on");
|
|
connect(mixer, SIGNAL(finished(int)), mixer, SLOT(deleteLater()));
|
|
}
|
|
}
|
|
|
|
int AudioManager::MasterVolume() {
|
|
if (pulseAvailable) {
|
|
pa_volume_t avgVol = pa_cvolume_avg(&defaultSinkVolume);
|
|
int currentVol = ((float) (avgVol - PA_VOLUME_MUTED) / (float) PA_VOLUME_NORM) * 100;
|
|
return currentVol;
|
|
} else {
|
|
//Get Current Volume
|
|
QProcess* mixer = new QProcess(this);
|
|
mixer->start("amixer");
|
|
mixer->waitForFinished();
|
|
QString output(mixer->readAll());
|
|
delete mixer;
|
|
|
|
bool readLine = false;
|
|
for (QString line : output.split("\n")) {
|
|
if (line.startsWith(" ") && readLine) {
|
|
if (line.startsWith(" Front Left:")) {
|
|
if (line.contains("[off]")) {
|
|
return 0;
|
|
} else {
|
|
QString percent = line.mid(line.indexOf("\[") + 1, 3).remove("\%").remove("]");
|
|
return percent.toInt();
|
|
}
|
|
}
|
|
} else {
|
|
if (line.contains("'Master'")) {
|
|
readLine = true;
|
|
} else {
|
|
readLine = false;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
void AudioManager::pulseStateChanged(pa_context *c, void *userdata) {
|
|
AudioManager* currentManager = (AudioManager*) userdata;
|
|
switch (pa_context_get_state(c)) {
|
|
case PA_CONTEXT_READY:
|
|
pa_context_set_subscribe_callback(c, &AudioManager::pulseSubscribe, currentManager);
|
|
pa_context_subscribe(c, (pa_subscription_mask_t) (PA_SUBSCRIPTION_MASK_SINK | PA_SUBSCRIPTION_MASK_SOURCE | PA_SUBSCRIPTION_MASK_SINK_INPUT | PA_SUBSCRIPTION_MASK_CLIENT), NULL, userdata);
|
|
pa_context_get_server_info(c, &AudioManager::pulseServerInfo, currentManager);
|
|
pa_context_get_sink_info_list(c, &AudioManager::pulseGetSinks, currentManager);
|
|
pa_context_get_source_info_list(c, &AudioManager::pulseGetSources, currentManager);
|
|
pa_context_get_sink_input_info_list(c, &AudioManager::pulseGetInputSinks, currentManager);
|
|
pa_context_get_client_info_list(c, &AudioManager::pulseGetClients, currentManager);
|
|
}
|
|
}
|
|
|
|
void AudioManager::pulseSubscribe(pa_context *c, pa_subscription_event_type_t t, uint32_t index, void *userdata) {
|
|
AudioManager* currentManager = (AudioManager*) userdata;
|
|
switch (t & PA_SUBSCRIPTION_EVENT_FACILITY_MASK) {
|
|
case PA_SUBSCRIPTION_EVENT_SINK:
|
|
pa_context_get_server_info(c, &AudioManager::pulseServerInfo, currentManager);
|
|
pa_context_get_sink_info_list(c, &AudioManager::pulseGetSinks, currentManager);
|
|
break;
|
|
case PA_SUBSCRIPTION_EVENT_SINK_INPUT:
|
|
pa_context_get_sink_input_info_list(c, &AudioManager::pulseGetInputSinks, currentManager);
|
|
break;
|
|
case PA_SUBSCRIPTION_EVENT_SOURCE:
|
|
pa_context_get_server_info(c, &AudioManager::pulseServerInfo, currentManager);
|
|
pa_context_get_source_info_list(c, &AudioManager::pulseGetSources, currentManager);
|
|
break;
|
|
case PA_SUBSCRIPTION_EVENT_CLIENT:
|
|
pa_context_get_client_info_list(c, &AudioManager::pulseGetClients, currentManager);
|
|
}
|
|
}
|
|
|
|
void AudioManager::pulseGetSinks(pa_context *c, const pa_sink_info *i, int eol, void *userdata) {
|
|
|
|
}
|
|
|
|
void AudioManager::pulseServerInfo(pa_context *c, const pa_server_info *i, void *userdata) {
|
|
pa_context_get_sink_info_by_name(c, i->default_sink_name, &AudioManager::pulseGetDefaultSink, userdata);
|
|
|
|
}
|
|
|
|
void AudioManager::pulseGetDefaultSink(pa_context *c, const pa_sink_info *i, int eol, void *userdata) {
|
|
if (eol == 0) {
|
|
AudioManager* currentManager = (AudioManager*) userdata;
|
|
currentManager->defaultSinkIndex = i->index;
|
|
currentManager->defaultSinkVolume = i->volume;
|
|
}
|
|
}
|
|
|
|
void AudioManager::pulseGetSources(pa_context *c, const pa_source_info *i, int eol, void *userdata) {
|
|
AudioManager* currentManager = (AudioManager*) userdata;
|
|
if (eol == 0) {
|
|
|
|
}
|
|
}
|
|
|
|
void AudioManager::quietStreams() {
|
|
if (pulseAvailable) {
|
|
for (int source : originalStreamVolumes.keys()) {
|
|
//Set volume to 50% of original
|
|
pa_cvolume originalVolume = originalStreamVolumes.value(source);
|
|
for (int i = 0; i < originalVolume.channels; i++) {
|
|
originalVolume.values[i] /= 2;
|
|
}
|
|
pa_context_set_sink_input_volume(pulseContext, source, &originalVolume, NULL, NULL);
|
|
}
|
|
quietMode = true;
|
|
}
|
|
}
|
|
|
|
void AudioManager::silenceStreams() {
|
|
if (pulseAvailable) {
|
|
for (int source : originalStreamVolumes.keys()) {
|
|
//Set volume to 10% of original
|
|
pa_cvolume originalVolume = originalStreamVolumes.value(source);
|
|
for (int i = 0; i < originalVolume.channels; i++) {
|
|
originalVolume.values[i] /= 10;
|
|
}
|
|
pa_context_set_sink_input_volume(pulseContext, source, &originalVolume, NULL, NULL);
|
|
}
|
|
quietMode = true;
|
|
}
|
|
}
|
|
|
|
void AudioManager::restoreStreams(bool immediate) {
|
|
if (pulseAvailable) {
|
|
//Sounds much better if we delay by a second
|
|
QTimer::singleShot(immediate ? 0 : 1000, [=]() {
|
|
for (int source : originalStreamVolumes.keys()) {
|
|
//Restore volume of each stream
|
|
pa_cvolume originalVolume = originalStreamVolumes.value(source);
|
|
if (originalVolume.channels > 0) {
|
|
tVariantAnimation* anim = new tVariantAnimation;
|
|
anim->setStartValue(originalVolume.values[0] / 2);
|
|
anim->setEndValue(originalVolume.values[0]);
|
|
anim->setDuration(500);
|
|
connect(anim, &tVariantAnimation::valueChanged, [=](QVariant value) {
|
|
pa_cvolume originalVolume = originalStreamVolumes.value(source);
|
|
for (int i = 0; i < originalVolume.channels; i++) {
|
|
originalVolume.values[i] = value.toUInt();
|
|
}
|
|
pa_context_set_sink_input_volume(pulseContext, source, &originalVolume, NULL, NULL);
|
|
});
|
|
connect(anim, SIGNAL(finished()), anim, SLOT(deleteLater()));
|
|
anim->start();
|
|
}
|
|
|
|
}
|
|
quietMode = false;
|
|
});
|
|
}
|
|
}
|
|
|
|
void AudioManager::pulseGetInputSinks(pa_context *c, const pa_sink_input_info *i, int eol, void *userdata) {
|
|
AudioManager* currentManager = (AudioManager*) userdata;
|
|
if (eol == 0) {
|
|
if (!currentManager->tsClientIndices.contains(i->client)) {
|
|
if (currentManager->quietMode) {
|
|
if (currentManager->originalStreamVolumes.contains(i->index)) {
|
|
pa_cvolume originalVolume = i->volume;
|
|
for (int i = 0; i < originalVolume.channels; i++) {
|
|
originalVolume.values[i] = originalVolume.values[i] * 2;
|
|
}
|
|
currentManager->originalStreamVolumes.insert(i->index, originalVolume);
|
|
} else {
|
|
currentManager->originalStreamVolumes.insert(i->index, i->volume);
|
|
}
|
|
} else {
|
|
currentManager->originalStreamVolumes.insert(i->index, i->volume);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
void AudioManager::pulseGetClients(pa_context *c, const pa_client_info *i, int eol, void *userdata) {
|
|
AudioManager* currentManager = (AudioManager*) userdata;
|
|
if (eol == 0) {
|
|
if (QString::fromUtf8(i->name).toLower().contains("theshell") || QString::fromUtf8(i->name).toLower().contains("qtpulseaudio")) {
|
|
currentManager->newTsClientIndices.append(i->index);
|
|
}
|
|
} else {
|
|
currentManager->tsClientIndices = currentManager->newTsClientIndices;
|
|
currentManager->newTsClientIndices.clear();
|
|
}
|
|
}
|