1 files changed, 178 insertions, 0 deletions
diff --git a/src-qt5/desktop-utils/lumina-mediaplayer/PianoBarProcess.cpp b/src-qt5/desktop-utils/lumina-mediaplayer/PianoBarProcess.cpp
new file mode 100644
index 00000000..667ebefb
--- /dev/null
+++ b/src-qt5/desktop-utils/lumina-mediaplayer/PianoBarProcess.cpp
@@ -0,0 +1,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);
+    }
+  }
+}