summaryrefslogtreecommitdiffstats
path: root/src/musicbrainz/acoustidclient.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/musicbrainz/acoustidclient.cpp')
-rw-r--r--src/musicbrainz/acoustidclient.cpp205
1 files changed, 0 insertions, 205 deletions
diff --git a/src/musicbrainz/acoustidclient.cpp b/src/musicbrainz/acoustidclient.cpp
deleted file mode 100644
index 497e108f66..0000000000
--- a/src/musicbrainz/acoustidclient.cpp
+++ /dev/null
@@ -1,205 +0,0 @@
-/*****************************************************************************
- * Copyright © 2012 John Maguire <john.maguire@gmail.com> *
- * David Sansome <me@davidsansome.com> *
- * This work is free. You can redistribute it and/or modify it under the *
- * terms of the Do What The Fuck You Want To Public License, Version 2, *
- * as published by Sam Hocevar. *
- * See http://www.wtfpl.net/ for more details. *
- *****************************************************************************/
-
-#include <QNetworkReply>
-#include <QJsonDocument>
-#include <QUrl>
-#include <QUrlQuery>
-#include <QtDebug>
-
-#include "musicbrainz/acoustidclient.h"
-#include "musicbrainz/gzip.h"
-#include "musicbrainz/network.h"
-
-#include "util/logger.h"
-
-namespace {
-
-mixxx::Logger kLogger("AcoustidClient");
-
-// see API-KEY site here http://acoustid.org/application/496
-// I registered the KEY for version 1.12 -- kain88 (may 2013)
-// See also: https://acoustid.org/webservice
-const QString CLIENT_APIKEY = "czKxnkyO";
-const QString ACOUSTID_URL = "https://api.acoustid.org/v2/lookup";
-constexpr int kDefaultTimeout = 5000; // msec
-
-} // anonymous namespace
-
-AcoustidClient::AcoustidClient(QObject* parent)
- : QObject(parent),
- m_network(this),
- m_timeouts(kDefaultTimeout, this) {
-}
-
-void AcoustidClient::setTimeout(int msec) {
- VERIFY_OR_DEBUG_ASSERT(msec > 0) {
- kLogger.warning() << "Invalid timeout" << msec << "[ms]";
- return;
- }
- m_timeouts.setTimeout(msec);
-}
-
-void AcoustidClient::start(int id, const QString& fingerprint, int duration) {
- QUrlQuery urlQuery;
- // The default format is JSON
- //urlQuery.addQueryItem("format", "json");
- urlQuery.addQueryItem("client", CLIENT_APIKEY);
- urlQuery.addQueryItem("duration", QString::number(duration));
- urlQuery.addQueryItem("meta", "recordingids");
- urlQuery.addQueryItem("fingerprint", fingerprint);
- // application/x-www-form-urlencoded request bodies must be percent encoded.
- QByteArray body = urlQuery.query(QUrl::FullyEncoded).toLatin1();
-
- QUrl url(ACOUSTID_URL);
- QNetworkRequest req(url);
- req.setHeader(QNetworkRequest::ContentTypeHeader, "application/x-www-form-urlencoded");
- req.setRawHeader("Content-Encoding", "gzip");
-
- kLogger.debug()
- << "POST request:" << ACOUSTID_URL
- << "body:" << body;
-
- QNetworkReply* reply = m_network.post(req, gzipCompress(body));
- m_pendingReplies[reply] = id;
- connect(reply, &QNetworkReply::finished, this, &AcoustidClient::onReplyFinished);
- m_timeouts.addReply(reply);
-}
-
-void AcoustidClient::cancel(int id) {
- QNetworkReply* reply = m_pendingReplies.key(id);
- if (!reply) {
- return;
- }
- cancelPendingReply(reply);
-}
-
-void AcoustidClient::cancelPendingReply(QNetworkReply* reply) {
- DEBUG_ASSERT(reply);
- m_timeouts.removeReply(reply);
- m_pendingReplies.remove(reply);
- if (reply->isRunning()) {
- reply->abort();
- }
-}
-
-void AcoustidClient::cancelAll() {
- while (!m_pendingReplies.isEmpty()) {
- QNetworkReply* reply = m_pendingReplies.firstKey();
- cancelPendingReply(reply);
- DEBUG_ASSERT(!m_pendingReplies.contains(reply));
- }
-}
-
-void AcoustidClient::onReplyFinished() {
- QNetworkReply* reply = qobject_cast<QNetworkReply*>(sender());
- VERIFY_OR_DEBUG_ASSERT(reply) {
- return;
- }
- reply->deleteLater();
-
- if (!m_pendingReplies.contains(reply)) {
- // Already Cancelled
- return;
- }
-
- m_timeouts.removeReply(reply);
- int id = m_pendingReplies.take(reply);
-
- const int statusCode = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
- const QByteArray body = reply->readAll();
- if (kLogger.debugEnabled()) {
- kLogger.debug()
- << "POST reply status:" << statusCode
- << "body:" << body;
- }
-
- const auto jsonResponse = QJsonDocument::fromJson(body);
- QString statusText;
- if (jsonResponse.isObject()) {
- statusText = jsonResponse.object().value("status").toString();
- }
-
- if (statusCode != 200 || statusText != "ok") {
- QString errorMessage;
- int errorCode = 0;
- if (jsonResponse.isObject() && statusText == "error") {
- const auto error = jsonResponse.object().value("error").toObject();
- errorMessage = error.value("message").toString();
- errorCode = error.value("message").toInt(errorCode);
- }
- emit networkError(
- statusCode,
- "AcoustID",
- errorMessage,
- errorCode);
- return;
- }
-
- QStringList recordingIds;
- DEBUG_ASSERT(jsonResponse.isObject());
- DEBUG_ASSERT(jsonResponse.object().value(QStringLiteral("results")).isArray());
- const QJsonArray results = jsonResponse.object().value(QStringLiteral("results")).toArray();
- double maxScore = -1.0; // uninitialized (< 0)
- // Results are expected to be ordered by score (descending)
- for (const auto result : results) {
- DEBUG_ASSERT(result.isObject());
- const auto resultObject = result.toObject();
- const auto resultId =
- resultObject.value(QStringLiteral("id")).toString();
- DEBUG_ASSERT(!resultId.isEmpty());
- // The default score is 1.0 if missing
- const double score =
- resultObject.value(QStringLiteral("score")).toDouble(1.0);
- DEBUG_ASSERT(score >= 0.0);
- DEBUG_ASSERT(score <= 1.0);
- if (maxScore < 0.0) {
- // Initialize the maximum score
- maxScore = score;
- }
- DEBUG_ASSERT(score <= maxScore);
- if (score < maxScore && !recordingIds.isEmpty()) {
- // Ignore all remaining results with lower values
- // than the maximum score
- break;
- }
- const auto recordings = result.toObject().value(QStringLiteral("recordings"));
- if (recordings.isUndefined()) {
- if (kLogger.debugEnabled()) {
- kLogger.debug()
- << "No recording(s) available for result"
- << resultId
- << "with score"
- << score;
- }
- continue;
- } else {
- DEBUG_ASSERT(recordings.isArray());
- const QJsonArray recordingsArray = recordings.toArray();
- if (kLogger.debugEnabled()) {
- kLogger.debug()
- << "Found"
- << recordingsArray.size()
- << "recording(s) for result"
- << resultId
- << "with score"
- << score;
- }
- for (const auto recording : recordingsArray) {
- DEBUG_ASSERT(recording.isObject());
- const auto recordingObject = recording.toObject();
- const auto recordingId =
- recordingObject.value(QStringLiteral("id")).toString();
- DEBUG_ASSERT(!recordingId.isEmpty());
- recordingIds.append(recordingId);
- }
- }
- }
- emit finished(id, recordingIds);
-}
generated by cgit v1.2.3 (git 2.25.1) at 2024-09-09 19:27:50 +0000