1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
|
//===========================================
// Lumina-Desktop source code
// Copyright (c) 2017, Ken Moore
// Available under the 3-clause BSD license
// See the LICENSE file for full details
//===========================================
#include "PianoBarProcess.h"
#include <QTime>
#include <QDir>
#include <QFile>
#include <QTextStream>
#include <LUtils.h>
PianoBarProcess::PianoBarProcess(QWidget *parent) : QObject(parent){
setupProcess();
}
PianoBarProcess::~PianoBarProcess(){
}
// ===== PUBLIC ======
//Interaction functions
bool PianoBarProcess::isSetup(); //email/password already saved for use or not
void PianoBarProcess::setLogin(QString email, QString pass);
void PianoBarProcess::closePianoBar(); //"q"
QString PianoBarProcess::currentStation(); //Re-direct for the "autostartStation()" function;
QStringList PianoBarProcess::stations();
void PianoBarProcess::setCurrentStation(QString station);
void PianoBarProcess::deleteCurrentStation(); //"d"
void PianoBarProcess::createNewStation(); //"c"
void PianoBarProcess::createStationFromCurrentSong(); //"v"
void PianoBarProcess::changeStation(); //"s"
//Settings Manipulation
QString PianoBarProcess::audioQuality(){ // "audio_quality" = [low, medium, high]
}
void PianoBarProcess::setAudioQuality(QString); // [low, medium, high]
QString PianoBarProcess::autostartStation(); //"autostart_station" = ID
void PianoBarProcess::setAutostartStation(QString);
QString PianoBarProcess::proxy(); //"proxy" = URL (example: "http://USER:PASSWORD@HOST:PORT/" )
void PianoBarProcess::setProxy(QString);
QString PianoBarProcess::controlProxy(); //"control_proxy" = URL (example: "http://USER:PASSWORD@HOST:PORT/" )
void PianoBarProcess::setControlProxy(QString);
// ====== PUBLIC SLOTS ======
void PianoBarProcess::play(); // "P"
void PianoBarProcess::pause(); //"S"
void PianoBarProcess::volumeDown(); //"("
void PianoBarProcess::volumeUp(); //")"
void PianoBarProcess::skipSong(); //"n"
void PianoBarProcess::loveSong(); // "+"
void PianoBarProcess::tiredSong(); // "t"
void PianoBarProcess::banSong(); //"-"
void PianoBarProcess::bookmarkSong(); //"b"
void PianoBarProcess::explainSong(); //"e"
void PianoBarProcess::requestHistory(); // "h"
void PianoBarProcess::requestSongInfo(); //"i"
void PianoBarProcess::requestUpcoming(); //"u"
// ====== PRIVATE ======
void PianoBarProcess::GenerateSettings(){
currentSettings << "audio_quality = medium";
currentSettings << "autoselect = 1"; //automatically select the last item in a list (station selection only)
currentSettings << "format_list_song = %r::::%t::::%a"; //[rating, title, artist]
currentSettings << "format_nowplaying_song = %r::::%t::::%a::::%l::::%u::::%s"; // [rating, title, artist, album, details url, station (if not quickmix)]
currentSettings << "format_nowplaying_station = %n::::%i"; //[name, id]
}
void PianoBarProcess::loadSettings(){
currentSettings.clear();
QFile file(settingspath);
if(!file.exists()){ return; }
if(file.open(QIODevice::ReadOnly)){
QTextStream in(&file);
currentSettings = in.readAll().split("\n");
file.close();
}
}
QString PianoBarProcess::settingValue(QString var){
for(int i=0; i<currentSettings.length(); i++){
if(currentSettings[i].startsWith(var+" = ")){ return currentSettings[i].section(" = ", 1,-1); }
}
return "";
}
void PianoBarProcess::setSettingValue(QString var,QString val){
bool changed = false;
for(int i=0; i<currentSettings.length() && !changed; i++){
if(currentSettings[i].startsWith(var+" = ")){ currentSettings[i] = var+" = "+val; changed = true; }
}
if(!changed){ currentSettings << var+" = "+val; }
}
void PianoBarProcess::saveSettingsFile(){
//Ensure the parent directory exists first
QDir dir(settingspath.section("/",0,-2));
if(!dir.exists()){ dir.mkpath(dir.absolutePath()); }
//Now save the settings
QFile file(settingspath);
if(file.open(QIODevice::WriteOnly | QIODevice::Truncate)){
QTextStream out(&file);
out << currentSettings.join("\n");
file.close();
}
}
void PianoBarProcess::setupProcess(){
PROC = new QProcess(this);
//Ensure this process always points to the right configuration directory/files
QString configdir = getenv("XDG_CONFIG_HOME");
if(configdir.isEmpty()){ configdir = QDir::homePath()+"/.config/lumina-desktop"; }
else{ configdir.append("/lumina-desktop"); }
QProcessEnvironment penv;
penv.insert("XDG_CONFIG_HOME",configdir);
settingspath = configdir+"/pianobar/config";
PROC->setProcessEnvironment(penv);
//Now setup the rest of the process
PROC->setProcessChannelMode(QProcess::MergedChannels);
QString bin = "pianobar";
LUtils::isValidBinary(bin); //will change "bin" to the full path
PROC->setProgram(bin);
connect(PROC, SIGNAL(readyRead()), this, SLOT(ProcUpdate()) );
}
// ====== PRIVATE SLOTS ======
void PianoBarProcess::ProcUpdate(){
QStringList info = QString(PROC->readAllStandardOutput()).split("\n");
//NOTE: Need to have a cache of info lines which can carry over between updates as needed (for questions, etc)
qDebug() << "Got Update:" << info;
for(int i=0; i<info.length(); i++){
if(info[i].startsWith("|>")){
//Now playing line (station, or song)
QStringList data = info[i].section(">",1,-1).simplified().split("::::"); //Make sure to chop the line prefix off first
if(data.length()==2){ //station
cstation = data[0]; //save the name for later
emit NowPlayingStation(data[0], data[1]);
//Automatically save this station for autostart next time (make toggle-able later)
if(data[1]!=autostartStation()){ setAutostartStation(data[1]); }
}else if(data.length()==6){ //song
emit NowPlayingSong( data[0]=="<3", data[1], data[2], data[3], data[4], data[5] );
}
}else if(info[i].startsWith("(i) ")){ //informational line
emit NewInformation(info[i].section(" ",1,-1));
}else if(info[i].startsWith("[?] ")){ //waiting for reply to question
if(info[i].contains("Select Station:"){
//Find the number before this line which corresponds to the cstation variable/name
for(j=i-1; j>=0; j--){
if(info[j].contains(")" && info[j].contains(cstation) ){
PROC->write(info[j].section(")",0,0).simplified() + "\r\n");
break;
}
}
}
}else if(info[i].startsWith("#")){
//Time Stamp
QTime stamp = QTime::fromString(info[i].section("/",0,0).section("-",1,-1), "mm:ss");
int curS = 60*stamp.minutes() + stamp.seconds(); //time remaining
stamp = QTime::fromString(info[i].section("/",1,-1), "mm:ss");
int totS = 60*stamp.minutes() + stamp.sections(); //time total
emit TimeUpdate(totS-curS, totS);
}
}
}
|
