409 lines
15 KiB
C++
409 lines
15 KiB
C++
/*
|
|
* Cantata
|
|
*
|
|
* Copyright (c) 2011-2013 Craig Drummond <craig.p.drummond@gmail.com>
|
|
*
|
|
* ----
|
|
*
|
|
* This program 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 2 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* This program 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 this program; see the file COPYING. If not, write to
|
|
* the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
|
|
* Boston, MA 02110-1301, USA.
|
|
*/
|
|
|
|
#include "config.h"
|
|
#include "httpsocket.h"
|
|
#include "httpserver.h"
|
|
#include "settings.h"
|
|
#if defined CDDB_FOUND || defined MUSICBRAINZ5_FOUND
|
|
#include "cdparanoia.h"
|
|
#include "extractjob.h"
|
|
#ifdef LAME_FOUND
|
|
#include "lame/lame.h"
|
|
#endif
|
|
#endif
|
|
#include <QTcpSocket>
|
|
#include <QNetworkInterface>
|
|
#include <QStringList>
|
|
#include <QTextStream>
|
|
#include <QFile>
|
|
#include <QUrl>
|
|
#include <QNetworkProxy>
|
|
#if QT_VERSION >= 0x050000
|
|
#include <QUrlQuery>
|
|
#endif
|
|
#ifdef ENABLE_KDE_SUPPORT
|
|
#include <KDE/KMimeType>
|
|
#endif
|
|
#include <QFileInfo>
|
|
#ifdef TAGLIB_FOUND
|
|
#include <taglib/oggflacfile.h>
|
|
#include <taglib/trueaudiofile.h>
|
|
#include <taglib/vorbisfile.h>
|
|
#include <taglib/audioproperties.h>
|
|
#endif
|
|
|
|
static QString detectMimeType(const QString &file)
|
|
{
|
|
#ifdef ENABLE_KDE_SUPPORT
|
|
QString km=KMimeType::findByPath(file)->name();
|
|
if (!km.isEmpty() && (km.startsWith("audio/") || km.startsWith("application/"))) {
|
|
return QLatin1String("audio/x-ape")==km ? QLatin1String("audio/x-monkeys-audio") : km;
|
|
}
|
|
#endif
|
|
QString suffix = QFileInfo(file).suffix().toLower();
|
|
if (suffix == QLatin1String("mp3")) {
|
|
return QLatin1String("audio/mpeg");
|
|
}
|
|
#ifdef TAGLIB_FOUND
|
|
if (suffix == QLatin1String("ogg")) {
|
|
#ifdef Q_OS_WIN32
|
|
const wchar_t *encodedName = reinterpret_cast< const wchar_t * >(file.utf16());
|
|
#elif defined COMPLEX_TAGLIB_FILENAME
|
|
const wchar_t *encodedName = reinterpret_cast< const wchar_t * >(file.utf16());
|
|
#else
|
|
QByteArray fileName = QFile::encodeName(file);
|
|
const char *encodedName = fileName.constData(); // valid as long as fileName exists
|
|
#endif
|
|
|
|
QString mime;
|
|
TagLib::File *result = new TagLib::Ogg::Vorbis::File(encodedName, false, TagLib::AudioProperties::Fast);
|
|
if (result->isValid()) {
|
|
mime=QLatin1String("audio/x-vorbis+ogg");
|
|
}
|
|
delete result;
|
|
if (mime.isEmpty()) {
|
|
result = new TagLib::Ogg::FLAC::File(encodedName, false, TagLib::AudioProperties::Fast);
|
|
if (result->isValid()) {
|
|
mime=QLatin1String("audio/x-flac+ogg");
|
|
}
|
|
delete result;
|
|
}
|
|
if (mime.isEmpty()) {
|
|
result = new TagLib::TrueAudio::File(encodedName, false, TagLib::AudioProperties::Fast);
|
|
if (result->isValid()) {
|
|
mime=QLatin1String("audio/x-speex+ogg");
|
|
}
|
|
delete result;
|
|
}
|
|
return QLatin1String("audio/ogg");
|
|
}
|
|
#endif
|
|
else if (suffix == QLatin1String("flac")) {
|
|
return QLatin1String("audio/x-flac");
|
|
} else if (suffix == QLatin1String("wma")) {
|
|
return QLatin1String("audio/x-ms-wma");
|
|
} else if (suffix == QLatin1String("m4a") || suffix == QLatin1String("m4b") || suffix == QLatin1String("m4p") || suffix == QLatin1String("mp4")) {
|
|
return QLatin1String("audio/mp4");
|
|
} else if (suffix == QLatin1String("wav")) {
|
|
return QLatin1String("audio/x-wav");
|
|
} else if (suffix == QLatin1String("wv") || suffix == QLatin1String("wvp")) {
|
|
return QLatin1String("audio/x-wavpack");
|
|
} else if (suffix == QLatin1String("ape")) {
|
|
return QLatin1String("audio/x-monkeys-audio"); // "audio/x-ape";
|
|
} else if (suffix == QLatin1String("spx")) {
|
|
return QLatin1String("audio/x-speex");
|
|
} else if (suffix == QLatin1String("tta")) {
|
|
return QLatin1String("audio/x-tta");
|
|
} else if (suffix == QLatin1String("aiff") || suffix == QLatin1String("aif") || suffix == QLatin1String("aifc")) {
|
|
return QLatin1String("audio/x-aiff");
|
|
} else if (suffix == QLatin1String("mpc") || suffix == QLatin1String("mpp") || suffix == QLatin1String("mp+")) {
|
|
return QLatin1String("audio/x-musepack");
|
|
} else if (suffix == QLatin1String("dff")) {
|
|
return QLatin1String("application/x-dff");
|
|
} else if (suffix == QLatin1String("dsf")) {
|
|
return QLatin1String("application/x-dsf");
|
|
}
|
|
|
|
return QString();
|
|
}
|
|
|
|
static void writeMimeType(const QString &mimeType, QTcpSocket *socket)
|
|
{
|
|
if (!mimeType.isEmpty()) {
|
|
QTextStream os(socket);
|
|
os.setAutoDetectUnicode(true);
|
|
os << "HTTP/1.0 200 OK\r\nContent-Type: " << mimeType << "\r\n\r\n";
|
|
}
|
|
}
|
|
|
|
static QHostAddress getAddress(const QNetworkInterface &iface)
|
|
{
|
|
QList<QNetworkAddressEntry> addresses=iface.addressEntries();
|
|
foreach (const QNetworkAddressEntry &addr, addresses) {
|
|
QHostAddress hostAddress=addr.ip();
|
|
if (QAbstractSocket::IPv4Protocol==hostAddress.protocol()) {
|
|
return hostAddress;
|
|
break;
|
|
}
|
|
}
|
|
return QHostAddress();
|
|
}
|
|
|
|
HttpSocket::HttpSocket(const QString &addr, quint16 p)
|
|
: QTcpServer(0)
|
|
, cfgAddress(addr)
|
|
, terminated(false)
|
|
{
|
|
QHostAddress a;
|
|
if (!addr.isEmpty()) {
|
|
a=QHostAddress(addr);
|
|
|
|
if (a.isNull()) {
|
|
QNetworkInterface iface=QNetworkInterface::interfaceFromName(addr);
|
|
if (iface.isValid()) {
|
|
a=getAddress(iface);
|
|
}
|
|
}
|
|
}
|
|
|
|
if (a.isNull()) {
|
|
QList<QNetworkInterface> ifaces=QNetworkInterface::allInterfaces();
|
|
foreach (const QNetworkInterface &iface, ifaces) {
|
|
if (QLatin1String("lo")==iface.name()) {
|
|
continue;
|
|
}
|
|
a=getAddress(iface);
|
|
if (!a.isNull()) {
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
if (listen(QHostAddress::Any, p)) {
|
|
ifaceAddress=a.isNull() ? serverAddress().toString() : a.toString();
|
|
} else {
|
|
// Failed to liston on 'Any' address
|
|
if (addr.isEmpty()) {
|
|
// No specific address was set, so fallback to loopback address...
|
|
listen(QHostAddress::LocalHost, p);
|
|
ifaceAddress=QLatin1String("127.0.0.1");
|
|
} else {
|
|
// Listen probably failed due to proxy, so unset and try again!
|
|
setProxy(QNetworkProxy::NoProxy);
|
|
listen(QHostAddress::Any, p);
|
|
ifaceAddress=a.isNull() ? serverAddress().toString() : a.toString();
|
|
}
|
|
}
|
|
|
|
if (isListening() && ifaceAddress.isEmpty()) {
|
|
ifaceAddress=QLatin1String("127.0.0.1");
|
|
}
|
|
}
|
|
|
|
void HttpSocket::terminate()
|
|
{
|
|
terminated=true;
|
|
deleteLater();
|
|
}
|
|
|
|
void HttpSocket::incomingConnection(int socket)
|
|
{
|
|
QTcpSocket *s = new QTcpSocket(this);
|
|
connect(s, SIGNAL(readyRead()), this, SLOT(readClient()));
|
|
connect(s, SIGNAL(disconnected()), this, SLOT(discardClient()));
|
|
s->setSocketDescriptor(socket);
|
|
}
|
|
|
|
int getSep(const QByteArray &a, int pos)
|
|
{
|
|
for (int i=pos+1; i<a.length(); ++i) {
|
|
if ('\n'==a[i] || '\r'==a[i] || ' '==a[i]) {
|
|
return i;
|
|
}
|
|
}
|
|
return -1;
|
|
}
|
|
|
|
QList<QByteArray> split(const QByteArray &a)
|
|
{
|
|
QList<QByteArray> rv;
|
|
int lastPos=-1;
|
|
for (;;) {
|
|
int pos=getSep(a, lastPos);
|
|
|
|
if (pos==(lastPos+1)) {
|
|
lastPos++;
|
|
} else if (pos>-1) {
|
|
lastPos++;
|
|
rv.append(a.mid(lastPos, pos-lastPos));
|
|
lastPos=pos;
|
|
} else {
|
|
lastPos++;
|
|
rv.append(a.mid(lastPos));
|
|
break;
|
|
}
|
|
}
|
|
return rv;
|
|
}
|
|
|
|
void HttpSocket::readClient()
|
|
{
|
|
if (terminated) {
|
|
return;
|
|
}
|
|
|
|
QTcpSocket *socket = (QTcpSocket*)sender();
|
|
if (socket->canReadLine()) {
|
|
QList<QByteArray> tokens = split(socket->readLine()); // QRegExp("[ \r\n][ \r\n]*"));
|
|
if (tokens.length()>=2 && "GET"==tokens[0]) {
|
|
#if QT_VERSION < 0x050000
|
|
QUrl url(QUrl::fromEncoded(tokens[1]));
|
|
QUrl &q=url;
|
|
#else
|
|
QUrl url(QUrl::fromEncoded(tokens[1]));
|
|
QUrlQuery q(url);
|
|
#endif
|
|
bool ok=false;
|
|
|
|
if (q.hasQueryItem("cantata")) {
|
|
Song song=HttpServer::self()->decodeUrl(url);
|
|
if (song.isCdda()) {
|
|
#if defined CDDB_FOUND || defined MUSICBRAINZ5_FOUND
|
|
QStringList parts=song.file.split("/", QString::SkipEmptyParts);
|
|
if (parts.length()>=3) {
|
|
QString dev=QLatin1Char('/')+parts.at(1)+QLatin1Char('/')+parts.at(2);
|
|
CdParanoia cdparanoia(dev, false, false, true);
|
|
|
|
if (cdparanoia) {
|
|
int firstSector = cdparanoia.firstSectorOfTrack(song.id);
|
|
int lastSector = cdparanoia.lastSectorOfTrack(song.id);
|
|
int count = 0;
|
|
cdparanoia.seek(firstSector, SEEK_SET);
|
|
ok=true;
|
|
#ifdef LAME_FOUND
|
|
lame_global_flags *lame=0;
|
|
static const int constMp3BufferSize=CD_FRAMESIZE_RAW*2*sizeof(short int);
|
|
static const int constPcmSize=CD_FRAMESIZE_RAW/(2*sizeof(short int));
|
|
unsigned char mp3Buffer[constMp3BufferSize];
|
|
if (Settings::self()->cdMp3()) {
|
|
lame = lame_init();
|
|
lame_set_num_channels(lame, 2);
|
|
lame_set_in_samplerate(lame, 44100);
|
|
lame_set_brate(lame, 128);
|
|
lame_set_quality(lame, 5);
|
|
lame_set_VBR(lame, vbr_off);
|
|
if (-1!=lame_init_params(lame)) {
|
|
writeMimeType(QLatin1String("audio/mpeg"), socket);
|
|
} else {
|
|
lame_close(lame);
|
|
lame=0;
|
|
}
|
|
}
|
|
if (!lame) {
|
|
#endif
|
|
writeMimeType(QLatin1String("audio/x-wav"), socket);
|
|
ExtractJob::writeWavHeader(*socket);
|
|
#ifdef LAME_FOUND
|
|
}
|
|
#endif
|
|
bool stop=false;
|
|
while (!terminated && (firstSector+count) <= lastSector && !stop) {
|
|
qint16 *buf = cdparanoia.read();
|
|
if (!buf) {
|
|
break;
|
|
}
|
|
char *buffer=(char *)buf;
|
|
qint64 writePos=0;
|
|
qint64 toWrite=CD_FRAMESIZE_RAW;
|
|
|
|
#ifdef LAME_FOUND
|
|
if (lame) {
|
|
toWrite=lame_encode_buffer_interleaved(lame, (short *)buffer, constPcmSize, mp3Buffer, constMp3BufferSize);
|
|
buffer=(char *)mp3Buffer;
|
|
}
|
|
#endif
|
|
|
|
do {
|
|
qint64 bytesWritten=socket->write(&buffer[writePos], toWrite - writePos);
|
|
if (terminated || -1==bytesWritten) {
|
|
stop=true;
|
|
break;
|
|
}
|
|
socket->flush();
|
|
writePos+=bytesWritten;
|
|
} while (!terminated && writePos<toWrite);
|
|
count++;
|
|
}
|
|
#ifdef LAME_FOUND
|
|
if (lame) {
|
|
lame_close(lame);
|
|
lame=0;
|
|
}
|
|
#endif
|
|
}
|
|
}
|
|
#endif
|
|
} else {
|
|
QFile f(url.path());
|
|
|
|
if (f.open(QIODevice::ReadOnly)) {
|
|
writeMimeType(detectMimeType(url.path()), socket);
|
|
ok=true;
|
|
static const int constChunkSize=8192;
|
|
char buffer[constChunkSize];
|
|
qint64 totalBytes = f.size();
|
|
qint64 readPos = 0;
|
|
qint64 bytesRead = 0;
|
|
bool stop=false;
|
|
|
|
do {
|
|
bytesRead = f.read(buffer, constChunkSize);
|
|
readPos+=bytesRead;
|
|
if (bytesRead<0 || terminated) {
|
|
break;
|
|
}
|
|
|
|
qint64 writePos=0;
|
|
do {
|
|
qint64 bytesWritten = socket->write(&buffer[writePos], bytesRead - writePos);
|
|
if (terminated || -1==bytesWritten) {
|
|
stop=true;
|
|
break;
|
|
}
|
|
socket->flush();
|
|
writePos+=bytesWritten;
|
|
} while (writePos<bytesRead);
|
|
|
|
if (f.atEnd()) {
|
|
break;
|
|
}
|
|
} while ((readPos+bytesRead)<totalBytes && !stop && !terminated);
|
|
}
|
|
}
|
|
}
|
|
|
|
if (!ok) {
|
|
QTextStream os(socket);
|
|
os.setAutoDetectUnicode(true);
|
|
os << "HTTP/1.0 404 Ok\r\n"
|
|
"Content-Type: text/html; charset=\"utf-8\"\r\n"
|
|
"\r\n"
|
|
"<h1>Nothing to see here</h1>\n";
|
|
}
|
|
|
|
socket->close();
|
|
|
|
if (QTcpSocket::UnconnectedState==socket->state()) {
|
|
delete socket;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
void HttpSocket::discardClient()
|
|
{
|
|
QTcpSocket *socket = (QTcpSocket*)sender();
|
|
socket->deleteLater();
|
|
}
|