4 Commits

Author SHA1 Message Date
8d0b0fb4c5 Fix next song in status bar 2021-10-24 16:01:23 -05:00
f9122c2942 Fix typo n Next Song button 2021-10-24 16:01:23 -05:00
b0eeb81592 Add next song to status line 2021-10-24 16:01:23 -05:00
7999cc486f Fix OBS general GET reply handling 2021-10-24 16:01:23 -05:00
8 changed files with 50 additions and 16 deletions

View File

@ -3,6 +3,7 @@ from urllib.parse import urlparse, parse_qs
import threading import threading
import obspython as obs import obspython as obs
def set_current_scene(scene_name): def set_current_scene(scene_name):
scenes = obs.obs_frontend_get_scenes() scenes = obs.obs_frontend_get_scenes()
for scene in scenes: for scene in scenes:
@ -12,6 +13,7 @@ def set_current_scene(scene_name):
return 0 return 0
return 1 return 1
class RqstHandler(BaseHTTPRequestHandler): class RqstHandler(BaseHTTPRequestHandler):
def do_GET(self): def do_GET(self):
@ -25,12 +27,15 @@ class RqstHandler(BaseHTTPRequestHandler):
self.send_response(200) self.send_response(200)
self.end_headers() self.end_headers()
def log_message(self, format, *args): def log_message(self, format, *args):
pass pass
def run(name): def run(name):
httpd = HTTPServer(('127.0.0.1', 9302), RqstHandler) httpd = HTTPServer(('127.0.0.1', 9302), RqstHandler)
httpd.serve_forever() httpd.serve_forever()
t = threading.Thread(target=run, args=(1,), daemon=True) t = threading.Thread(target=run, args=(1,), daemon=True)
t.start() t.start()

View File

@ -6,9 +6,7 @@
* file, You can obtain one at http://mozilla.org/MPL/2.0/. * file, You can obtain one at http://mozilla.org/MPL/2.0/.
*/ */
#include <QFormLayout>
#include <QHBoxLayout> #include <QHBoxLayout>
#include <QLineEdit>
#include <QPushButton> #include <QPushButton>
#include <QStatusBar> #include <QStatusBar>
@ -22,16 +20,16 @@ MainWindow::MainWindow(QWidget *parent): QMainWindow(parent) {
const auto mainWidget = new QWidget(this); const auto mainWidget = new QWidget(this);
const auto rootLyt = new QVBoxLayout; const auto rootLyt = new QVBoxLayout;
const auto controlsLayout = new QGridLayout; const auto controlsLayout = new QGridLayout;
const auto slideView = new SlideView(this); m_slideView = new SlideView(this);
setCentralWidget(mainWidget); setCentralWidget(mainWidget);
mainWidget->setLayout(rootLyt); mainWidget->setLayout(rootLyt);
rootLyt->addWidget(slideView); rootLyt->addWidget(m_slideView);
rootLyt->addLayout(controlsLayout); rootLyt->addLayout(controlsLayout);
// setup slide controls // setup slide controls
const auto btnPrevSong = new QPushButton(tr("Previous Song (Left)"), this); const auto btnPrevSong = new QPushButton(tr("Previous Song (Left)"), this);
const auto btnPrevSlide = new QPushButton(tr("Previous Slide (Up)"), this); const auto btnPrevSlide = new QPushButton(tr("Previous Slide (Up)"), this);
const auto btnNextSlide = new QPushButton(tr("Next Slide (Down)"), this); const auto btnNextSlide = new QPushButton(tr("Next Slide (Down)"), this);
const auto btnNextSong = new QPushButton(tr("Next Song (Right))"), this); const auto btnNextSong = new QPushButton(tr("Next Song (Right)"), this);
const auto btnBlankSlides = new QPushButton(tr("Blank Slides (,)"), this); const auto btnBlankSlides = new QPushButton(tr("Blank Slides (,)"), this);
const auto btnShowSlides = new QPushButton(tr("Show Slides (.)"), this); const auto btnShowSlides = new QPushButton(tr("Show Slides (.)"), this);
controlsLayout->addWidget(btnPrevSlide, 0, 0); controlsLayout->addWidget(btnPrevSlide, 0, 0);
@ -54,12 +52,12 @@ MainWindow::MainWindow(QWidget *parent): QMainWindow(parent) {
connect(btnBlankSlides, &QPushButton::clicked, &m_openlpClient, &OpenLPClient::blankScreen); connect(btnBlankSlides, &QPushButton::clicked, &m_openlpClient, &OpenLPClient::blankScreen);
connect(btnBlankSlides, &QPushButton::clicked, &m_obsClient, &OBSClient::hideSlides); connect(btnBlankSlides, &QPushButton::clicked, &m_obsClient, &OBSClient::hideSlides);
connect(btnShowSlides, &QPushButton::clicked, &m_openlpClient, &OpenLPClient::showSlides); connect(btnShowSlides, &QPushButton::clicked, &m_openlpClient, &OpenLPClient::showSlides);
connect(&m_openlpClient, &OpenLPClient::pollUpdate, slideView, &SlideView::pollUpdate); connect(&m_openlpClient, &OpenLPClient::pollUpdate, m_slideView, &SlideView::pollUpdate);
connect(&m_openlpClient, &OpenLPClient::songListUpdate, slideView, &SlideView::songListUpdate); connect(&m_openlpClient, &OpenLPClient::songListUpdate, m_slideView, &SlideView::songListUpdate);
connect(&m_openlpClient, &OpenLPClient::slideListUpdate, slideView, &SlideView::slideListUpdate); connect(&m_openlpClient, &OpenLPClient::slideListUpdate, m_slideView, &SlideView::slideListUpdate);
connect(&m_openlpClient, &OpenLPClient::pollFailed, slideView, &SlideView::reset); connect(&m_openlpClient, &OpenLPClient::pollFailed, m_slideView, &SlideView::reset);
connect(slideView, &SlideView::songChanged, &m_openlpClient, &OpenLPClient::changeSong); connect(m_slideView, &SlideView::songChanged, &m_openlpClient, &OpenLPClient::changeSong);
connect(slideView, &SlideView::slideChanged, &m_openlpClient, &OpenLPClient::changeSlide); connect(m_slideView, &SlideView::slideChanged, &m_openlpClient, &OpenLPClient::changeSlide);
// setup scene selector // setup scene selector
const auto btnObsHideSlides = new QPushButton(tr("Hide Slides in OBS (;)"), mainWidget); const auto btnObsHideSlides = new QPushButton(tr("Hide Slides in OBS (;)"), mainWidget);
const auto btnObsShowSlides = new QPushButton(tr("Show Slides in OBS (')"), mainWidget); const auto btnObsShowSlides = new QPushButton(tr("Show Slides in OBS (')"), mainWidget);
@ -73,6 +71,7 @@ MainWindow::MainWindow(QWidget *parent): QMainWindow(parent) {
connect(btnObsShowSlides, &QPushButton::clicked, &m_openlpClient, &OpenLPClient::showSlides); connect(btnObsShowSlides, &QPushButton::clicked, &m_openlpClient, &OpenLPClient::showSlides);
// setup status bar // setup status bar
setStatusBar(new QStatusBar(this)); setStatusBar(new QStatusBar(this));
connect(&m_openlpClient, &OpenLPClient::songChanged, this, &MainWindow::refreshStatusBar);
connect(&m_openlpClient, &OpenLPClient::pollUpdate, this, &MainWindow::openLpConnectionInit); connect(&m_openlpClient, &OpenLPClient::pollUpdate, this, &MainWindow::openLpConnectionInit);
connect(&m_obsClient, &OBSClient::pollUpdate, this, &MainWindow::obsConnectionInit); connect(&m_obsClient, &OBSClient::pollUpdate, this, &MainWindow::obsConnectionInit);
refreshStatusBar(); refreshStatusBar();
@ -109,5 +108,7 @@ void MainWindow::obsConnectionLost() {
void MainWindow::refreshStatusBar() { void MainWindow::refreshStatusBar() {
const auto openLpStatus = m_openLpConnected ? tr("OpenLP: Connected") : tr("OpenLP: Not Connected"); const auto openLpStatus = m_openLpConnected ? tr("OpenLP: Connected") : tr("OpenLP: Not Connected");
const auto obsStatus = m_obsConnected ? tr("OBS: Connected") : tr("OBS: Not Connected"); const auto obsStatus = m_obsConnected ? tr("OBS: Connected") : tr("OBS: Not Connected");
statusBar()->showMessage(openLpStatus + " | " + obsStatus); const auto nextSong = m_openlpClient.getNextSong();
const auto nextSongTxt = m_openLpConnected ? " | Next Song: " + nextSong : "";
statusBar()->showMessage(openLpStatus + " | " + obsStatus + nextSongTxt);
} }

View File

@ -21,6 +21,7 @@ class MainWindow: public QMainWindow {
private: private:
OBSClient m_obsClient; OBSClient m_obsClient;
OpenLPClient m_openlpClient; OpenLPClient m_openlpClient;
class SlideView *m_slideView = nullptr;
bool m_openLpConnected = false; bool m_openLpConnected = false;
bool m_obsConnected = false; bool m_obsConnected = false;

View File

@ -5,6 +5,7 @@
* License, v. 2.0. If a copy of the MPL was not distributed with this * License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. * file, You can obtain one at http://mozilla.org/MPL/2.0/.
*/ */
#include <QNetworkReply> #include <QNetworkReply>
#include <QNetworkRequest> #include <QNetworkRequest>
#include <QUrl> #include <QUrl>

View File

@ -24,6 +24,15 @@ OpenLPClient::OpenLPClient(QObject *parent): QObject(parent) {
connect(m_pollingNam, &QNetworkAccessManager::finished, this, &OpenLPClient::handlePollResponse); connect(m_pollingNam, &QNetworkAccessManager::finished, this, &OpenLPClient::handlePollResponse);
} }
QString OpenLPClient::getNextSong() {
const auto currentSong = m_songNameMap[m_currentSongId];
const auto songIdx = m_songList.indexOf(currentSong) + 1;
if (songIdx < m_songList.size()) {
return m_songList[songIdx];
}
return "";
}
void OpenLPClient::nextSlide() { void OpenLPClient::nextSlide() {
get("/api/controller/live/next"); get("/api/controller/live/next");
} }
@ -117,6 +126,7 @@ void OpenLPClient::handlePollResponse(QNetworkReply *reply) {
if (m_currentSongId != songId) { if (m_currentSongId != songId) {
requestSlideList(); requestSlideList();
m_currentSongId = songId; m_currentSongId = songId;
emit songChanged(songId);
} }
emit pollUpdate(m_songNameMap[songId], slide); emit pollUpdate(m_songNameMap[songId], slide);
} }
@ -130,18 +140,18 @@ void OpenLPClient::handleSongListResponse(QNetworkReply *reply) {
if (data.isEmpty()) { if (data.isEmpty()) {
return; return;
} }
QStringList songList;
auto doc = QJsonDocument::fromJson(data); auto doc = QJsonDocument::fromJson(data);
auto items = doc.object()["results"].toObject()["items"].toArray(); auto items = doc.object()["results"].toObject()["items"].toArray();
m_songNameMap.clear(); m_songNameMap.clear();
m_songList.clear();
for (const auto &item : items) { for (const auto &item : items) {
auto song = item.toObject(); auto song = item.toObject();
auto name = song["title"].toString(); auto name = song["title"].toString();
auto id = song["id"].toString(); auto id = song["id"].toString();
m_songNameMap[id] = name; m_songNameMap[id] = name;
songList.push_back(name); m_songList.push_back(name);
} }
emit songListUpdate(songList); emit songListUpdate(m_songList);
} }
void OpenLPClient::handleSlideListResponse(QNetworkReply *reply) { void OpenLPClient::handleSlideListResponse(QNetworkReply *reply) {

View File

@ -30,13 +30,17 @@ class OpenLPClient: public QObject {
QNetworkAccessManager *m_slideListNam = new QNetworkAccessManager(this); QNetworkAccessManager *m_slideListNam = new QNetworkAccessManager(this);
QTimer m_pollTimer; QTimer m_pollTimer;
QHash<QString, QString> m_songNameMap; QHash<QString, QString> m_songNameMap;
QStringList m_songList;
int m_currentServiceId = -1; int m_currentServiceId = -1;
QString m_currentSongId; QString m_currentSongId;
public: public:
explicit OpenLPClient(QObject *parent = nullptr); explicit OpenLPClient(QObject *parent = nullptr);
public slots: [[nodiscard]]
QString getNextSong();
public slots:
void nextSlide(); void nextSlide();
void prevSlide(); void prevSlide();
@ -80,5 +84,6 @@ class OpenLPClient: public QObject {
void slideListUpdate(QStringList, QStringList); void slideListUpdate(QStringList, QStringList);
void songChanged(QString);
}; };

View File

@ -33,6 +33,15 @@ SlideView::SlideView(QWidget *parent): QWidget(parent) {
connect(m_slideTable, &QTableWidget::currentCellChanged, this, &SlideView::slideChanged); connect(m_slideTable, &QTableWidget::currentCellChanged, this, &SlideView::slideChanged);
} }
QString SlideView::getNextSong() const {
const auto cnt = m_songSelector->count();
const auto idx = m_songSelector->currentIndex() + 1;
if (idx < cnt) {
return m_songSelector->itemText(idx);
}
return "";
}
void SlideView::pollUpdate(QString songName, int slide) { void SlideView::pollUpdate(QString songName, int slide) {
if (songName != m_currentSong) { if (songName != m_currentSong) {
m_currentSong = songName; m_currentSong = songName;

View File

@ -19,6 +19,8 @@ class SlideView: public QWidget {
public: public:
explicit SlideView(QWidget *parent = nullptr); explicit SlideView(QWidget *parent = nullptr);
QString getNextSong() const;
public slots: public slots:
void pollUpdate(QString songId, int slideNum); void pollUpdate(QString songId, int slideNum);