Add radios

src/radios/radiobackend.cpp

@@ -0,0 +1,135 @@
+/*
+ * Strawberry Music Player
+ * Copyright 2021, Jonas Kvinge <jonas@jkvinge.net>
+ *
+ * Strawberry is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * Strawberry is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Strawberry.  If not, see <http://www.gnu.org/licenses/>.
+ *
+ */
+
+#include <QObject>
+#include <QThread>
+#include <QMutexLocker>
+
+#include "core/logging.h"
+#include "core/application.h"
+#include "core/database.h"
+#include "core/song.h"
+#include "radiobackend.h"
+#include "radiochannel.h"
+
+RadioBackend::RadioBackend(Application *app, Database *db, QObject *parent)
+    : QObject(parent),
+      app_(app),
+      db_(db),
+      original_thread_(thread()) {}
+
+void RadioBackend::Close() {
+
+  if (db_) {
+    QMutexLocker l(db_->Mutex());
+    db_->Close();
+  }
+
+}
+
+void RadioBackend::ExitAsync() {
+  metaObject()->invokeMethod(this, "Exit", Qt::QueuedConnection);
+}
+
+void RadioBackend::Exit() {
+
+  assert(QThread::currentThread() == thread());
+
+  moveToThread(original_thread_);
+  emit ExitFinished();
+
+}
+
+void RadioBackend::AddChannelsAsync(const RadioChannelList &channels) {
+  metaObject()->invokeMethod(this, "AddChannels", Qt::QueuedConnection, Q_ARG(RadioChannelList, channels));
+}
+
+void RadioBackend::AddChannels(const RadioChannelList &channels) {
+
+  QMutexLocker l(db_->Mutex());
+  QSqlDatabase db(db_->Connect());
+
+  QSqlQuery q(db);
+  q.prepare(QString("INSERT INTO radio_channels (source, name, url, thumbnail_url) VALUES (:source, :name, :url, :thumbnail_url)"));
+
+  RadioChannelList streams;
+  for (const RadioChannel &channel : channels) {
+    q.bindValue(":source", channel.source);
+    q.bindValue(":name", channel.name);
+    q.bindValue(":url", channel.url);
+    q.bindValue(":thumbnail_url", channel.thumbnail_url);
+    if (!q.exec()) {
+      db_->CheckErrors(q);
+    }
+  }
+
+  emit NewChannels(channels);
+
+}
+
+void RadioBackend::GetChannelsAsync() {
+
+  metaObject()->invokeMethod(this, "GetChannels", Qt::QueuedConnection);
+
+}
+
+void RadioBackend::GetChannels() {
+
+  QMutexLocker l(db_->Mutex());
+  QSqlDatabase db(db_->Connect());
+
+  QSqlQuery q(db);
+  q.prepare("SELECT source, name, url, thumbnail_url FROM radio_channels");
+
+  if (!q.exec()) {
+    db_->CheckErrors(q);
+    return;
+  }
+
+  RadioChannelList channels;
+  while (q.next()) {
+    RadioChannel channel;
+    channel.source = Song::Source(q.value(0).toInt());
+    channel.name = q.value(1).toString();
+    channel.url.setUrl(q.value(2).toString());
+    channel.thumbnail_url.setUrl(q.value(3).toString());
+    channels << channel;
+  }
+
+  emit NewChannels(channels);
+
+}
+
+void RadioBackend::DeleteChannelsAsync() {
+  metaObject()->invokeMethod(this, "DeleteChannels", Qt::QueuedConnection);
+}
+
+void RadioBackend::DeleteChannels() {
+
+  QMutexLocker l(db_->Mutex());
+  QSqlDatabase db(db_->Connect());
+
+  QSqlQuery q(db);
+  q.prepare("DELETE FROM radio_channels");
+
+  if (!q.exec()) {
+    db_->CheckErrors(q);
+  }
+
+}