/*
 * Cantata
 *
 * Copyright (c) 2011-2022 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 "httpsocket.h"
#include "config.h"
#include "gui/settings.h"
#include "httpserver.h"
#if defined CDDB_FOUND || defined MusicBrainz5_FOUND
#include "devices/cdparanoia.h"
#include "devices/extractjob.h"
#endif
#include <QDebug>
#include <QFile>
#include <QFileInfo>
#include <QNetworkProxy>
#include <QRegularExpression>
#include <QStringList>
#include <QTcpSocket>
#include <QTextStream>
#include <QUrl>
#include <QUrlQuery>
#define DBUG \
	if (HttpServer::debugEnabled()) qWarning() << "HttpSocket" << __FUNCTION__

static const quint64 constMaxBuffer = 32768;

static QString detectMimeType(const QString& file)
{
	QString suffix = QFileInfo(file).suffix().toLower();
	if (suffix == QLatin1String("mp3")) {
		return QLatin1String("audio/mpeg");
	}
	if (suffix == QLatin1String("ogg")) {
		return QLatin1String("audio/ogg");
	}
	if (suffix == QLatin1String("flac")) {
		return QLatin1String("audio/x-flac");
	}
	if (suffix == QLatin1String("wma")) {
		return QLatin1String("audio/x-ms-wma");
	}
	if (suffix == QLatin1String("m4a") || suffix == QLatin1String("m4b") || suffix == QLatin1String("m4p") || suffix == QLatin1String("mp4")) {
		return QLatin1String("audio/mp4");
	}
	if (suffix == QLatin1String("wav")) {
		return QLatin1String("audio/x-wav");
	}
	if (suffix == QLatin1String("wv") || suffix == QLatin1String("wvp")) {
		return QLatin1String("audio/x-wavpack");
	}
	if (suffix == QLatin1String("ape")) {
		return QLatin1String("audio/x-monkeys-audio");// "audio/x-ape";
	}
	if (suffix == QLatin1String("spx")) {
		return QLatin1String("audio/x-speex");
	}
	if (suffix == QLatin1String("tta")) {
		return QLatin1String("audio/x-tta");
	}
	if (suffix == QLatin1String("aiff") || suffix == QLatin1String("aif") || suffix == QLatin1String("aifc")) {
		return QLatin1String("audio/x-aiff");
	}
	if (suffix == QLatin1String("mpc") || suffix == QLatin1String("mpp") || suffix == QLatin1String("mp+")) {
		return QLatin1String("audio/x-musepack");
	}
	if (suffix == QLatin1String("dff")) {
		return QLatin1String("application/x-dff");
	}
	if (suffix == QLatin1String("dsf")) {
		return QLatin1String("application/x-dsf");
	}
	if (suffix == QLatin1String("opus")) {
		return QLatin1String("audio/opus");
	}

	return QString();
}

static void writeMimeType(const QString& mimeType, QTcpSocket* socket, qint32 from, qint32 size, bool allowSeek)
{
	if (!mimeType.isEmpty()) {
		QTextStream os(socket);
		os.setAutoDetectUnicode(true);
		if (allowSeek) {
			if (0 == from) {
				os << "HTTP/1.0 200 OK"
				   << "\r\nAccept-Ranges: bytes"
				   << "\r\nContent-Length: " << QString::number(size)
				   << "\r\nContent-Type: " << mimeType << "\r\n\r\n";
			}
			else {
				os << "HTTP/1.0 200 OK"
				   << "\r\nAccept-Ranges: bytes"
				   << "\r\nContent-Range: bytes " << QString::number(from) << "-" << QString::number(size - 1) << "/" << QString::number(size)
				   << "\r\nContent-Length: " << QString::number(size - from)
				   << "\r\nContent-Type: " << mimeType << "\r\n\r\n";
			}
			DBUG << mimeType << QString::number(size) << "Can seek";
		}
		else {
			os << "HTTP/1.0 200 OK"
			   << "\r\nContent-Length: " << QString::number(size)
			   << "\r\nContent-Type: " << mimeType << "\r\n\r\n";
			DBUG << mimeType << QString::number(size);
		}
	}
}

static 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;
}

static 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;
}

static void getRange(const QStringList& params, qint32& from, qint32& to)
{
	for (const QString& str : params) {
		if (str.startsWith("Range:")) {
			int start = str.indexOf("bytes=");
			if (start > 0) {
				QStringList range = str.mid(start + 6).split("-", CANTATA_SKIP_EMPTY);
				if (1 == range.length()) {
					from = range.at(0).toLong();
				}
				else if (2 == range.length()) {
					from = range.at(0).toLong();
					to = range.at(1).toLong();
				}
			}
			break;
		}
	}
}

HttpSocket::HttpSocket(const QString& iface, quint16 port)
	: QTcpServer(nullptr), cfgInterface(iface), terminated(false)
{
	if (!openPort(port)) {
		openPort(0);
	}

	DBUG << isListening() << serverPort();

	connect(MPDConnection::self(), SIGNAL(socketAddress(QString)), this, SLOT(mpdAddress(QString)));
	connect(MPDConnection::self(), SIGNAL(cantataStreams(QList<Song>, bool)), this, SLOT(cantataStreams(QList<Song>, bool)));
	connect(MPDConnection::self(), SIGNAL(cantataStreams(QStringList)), this, SLOT(cantataStreams(QStringList)));
	connect(MPDConnection::self(), SIGNAL(removedIds(QSet<qint32>)), this, SLOT(removedIds(QSet<qint32>)));
	connect(this, SIGNAL(newConnection()), SLOT(handleNewConnection()));
}

bool HttpSocket::openPort(quint16 p)
{
	setProxy(QNetworkProxy::NoProxy);
	if (listen(QHostAddress::Any, p)) {
		return true;
	}
	if (listen(QHostAddress::LocalHost, p)) {
		return true;
	}

	return false;
}

void HttpSocket::terminate()
{
	if (terminated) {
		return;
	}
	DBUG;
	terminated = true;
	close();
	deleteLater();
}

void HttpSocket::handleNewConnection()
{
	DBUG;
	while (hasPendingConnections()) {
		QTcpSocket* socket = nextPendingConnection();

		// prevent clients from sending too much data
		socket->setReadBufferSize(constMaxBuffer);

		static const QLatin1String constIpV6Prefix("::ffff:");

		QString peer = socket->peerAddress().toString();
		QString ifaceAddress = serverAddress().toString();
		const bool hostOk = peer == ifaceAddress || peer == mpdAddr || peer == (constIpV6Prefix + mpdAddr) || peer == QLatin1String("127.0.0.1") || peer == (constIpV6Prefix + QLatin1String("127.0.0.1"));

		DBUG << "peer:" << peer << "mpd:" << mpdAddr << "iface:" << ifaceAddress << "ok:" << hostOk;
		if (!hostOk) {
			sendErrorResponse(socket, 400);
			socket->close();
			DBUG << "Not from valid host";
			return;
		}

		connect(socket, SIGNAL(readyRead()), this, SLOT(readClient()));
		connect(socket, SIGNAL(disconnected()), this, SLOT(discardClient()));
	}
}

void HttpSocket::readClient()
{
	if (terminated) {
		return;
	}

	QTcpSocket* socket = static_cast<QTcpSocket*>(sender());
	if (!socket) {
		return;
	}

	if (static_cast<size_t>(socket->bytesAvailable()) >= constMaxBuffer) {
		// Request too large, reject
		sendErrorResponse(socket, 400);
		socket->close();
		DBUG << "Request too large";
		return;
	}

	if (socket->canReadLine()) {
		QList<QByteArray> tokens = split(socket->readLine());// QRegularExpression("[ \r\n][ \r\n]*"));
		if (tokens.length() >= 2 && "GET" == tokens[0]) {
			static const QRegularExpression paramRegex("[\r\n][\r\n]*");
			QStringList params = QString(socket->readAll()).split(paramRegex);

			DBUG << "params" << params << "tokens" << tokens;
			QUrl url(QUrl::fromEncoded(tokens[1]));
			QUrlQuery q(url);
			bool ok = false;
			qint32 readBytesFrom = 0;
			qint32 readBytesTo = 0;
			getRange(params, readBytesFrom, readBytesTo);

			DBUG << "readBytesFrom" << readBytesFrom << "readBytesTo" << readBytesTo;
			if (q.hasQueryItem("cantata")) {
				Song song = HttpServer::self()->decodeUrl(url);

				if (!isCantataStream(song.file)) {
					sendErrorResponse(socket, 400);
					socket->close();
					DBUG << "Not cantata stream file";
					return;
				}

				if (song.isCdda()) {
#if defined CDDB_FOUND || defined MusicBrainz5_FOUND
					QStringList parts = song.file.split("/", CANTATA_SKIP_EMPTY);
					if (parts.length() >= 3) {
						QString dev = QLatin1Char('/') + parts.at(1) + QLatin1Char('/') + parts.at(2);
						CdParanoia cdparanoia(dev, false, false, true, Settings::self()->paranoiaOffset());

						if (cdparanoia) {
							int firstSector = cdparanoia.firstSectorOfTrack(song.id);
							int lastSector = cdparanoia.lastSectorOfTrack(song.id);
							qint32 totalSize = ((lastSector - firstSector) + 1) * CD_FRAMESIZE_RAW;
							int count = 0;
							bool writeHeader = 0 == readBytesFrom;// Only write header if we are not seeking...
																  //                            int bytesToDiscard = 0; // Number of bytes to discard in first read sector due to range request in HTTP header
																  //                            if (readBytesFrom>=ExtractJob::constWavHeaderSize) {
																  //                                readBytesFrom-=ExtractJob::constWavHeaderSize;
																  //                            }

							//                            if (readBytesFrom>0) {
							//                                int sectorsToSeek=readBytesFrom/CD_FRAMESIZE_RAW;
							//                                firstSector+=sectorsToSeek;
							//                                bytesToDiscard=readBytesFrom-(sectorsToSeek*CD_FRAMESIZE_RAW);
							//                            }
							cdparanoia.seek(firstSector, SEEK_SET);
							ok = true;
							writeMimeType(QLatin1String("audio/x-wav"), socket, readBytesFrom, totalSize + ExtractJob::constWavHeaderSize, false);
							if (writeHeader) {
								ExtractJob::writeWavHeader(*socket, totalSize);
							}
							bool stop = false;
							while (!terminated && (firstSector + count) <= lastSector && !stop) {
								qint16* buf = cdparanoia.read();
								if (!buf) {
									break;
								}
								char* buffer = (char*)buf;
								qint32 writePos = 0;
								qint32 toWrite = CD_FRAMESIZE_RAW;

								//                                if (bytesToDiscard>0) {
								//                                    int toSkip=qMin(toWrite, bytesToDiscard);
								//                                    writePos=toSkip;
								//                                    toWrite-=toSkip;
								//                                    bytesToDiscard-=toSkip;
								//                                }

								if (toWrite > 0 && !write(socket, &buffer[writePos], toWrite, stop)) {
									break;
								}
								count++;
							}
						}
					}
#endif
				}
				else if (!song.file.isEmpty()) {
#ifdef Q_OS_WIN
					if (tokens[1].startsWith("//") && !song.file.startsWith(QLatin1String("//")) && !QFile::exists(song.file)) {
						QString share = QLatin1String("//") + url.host() + song.file;
						if (QFile::exists(share)) {
							song.file = share;
							DBUG << "fixed share-path" << song.file;
						}
					}
#endif

					QFile f(song.file);

					if (f.open(QIODevice::ReadOnly)) {
						qint32 totalBytes = f.size();

						writeMimeType(detectMimeType(song.file), socket, readBytesFrom, totalBytes, true);
						ok = true;
						qint32 readPos = 0;
						qint32 bytesRead = 0;

						if (0 != readBytesFrom) {
							if (!f.seek(readBytesFrom)) {
								ok = false;
							}
							bytesRead += readBytesFrom;
						}

						if (0 != readBytesTo && readBytesTo > readBytesFrom && readBytesTo != totalBytes) {
							totalBytes -= (totalBytes - readBytesTo);
						}

						if (ok) {
							static const int constChunkSize = 32768;
							char buffer[constChunkSize];
							bool stop = false;
							do {
								bytesRead = f.read(buffer, constChunkSize);
								readPos += bytesRead;
								if (!write(socket, buffer, bytesRead, stop) || f.atEnd()) {
									break;
								}
							} while (readPos < totalBytes && !stop && !terminated);
						}
					}
					else {
						DBUG << "Failed to open" << song.file;
					}
				}
			}

			if (!ok) {
				sendErrorResponse(socket, 404);
			}

			socket->close();

			if (QTcpSocket::UnconnectedState == socket->state()) {
				socket->deleteLater();
			}
		}
		else {
			// Bad Request
			sendErrorResponse(socket, 400);
			socket->close();
			DBUG << "Bad Request";
			return;
		}
	}
}

void HttpSocket::discardClient()
{
	static_cast<QTcpSocket*>(sender())->deleteLater();
}

void HttpSocket::mpdAddress(const QString& a)
{
	mpdAddr = a;
}

bool HttpSocket::isCantataStream(const QString& file) const
{
	DBUG << file << newlyAddedFiles.contains(file) << streamIds.values().contains(file);
	return newlyAddedFiles.contains(file) || streamIds.values().contains(file);
}

void HttpSocket::sendErrorResponse(QTcpSocket* socket, int code)
{
	QTextStream os(socket);
	os.setAutoDetectUnicode(true);
	os << "HTTP/1.0 " << code << " OK\r\n"
								 "Content-Type: text/html; charset=\"utf-8\"\r\n"
								 "\r\n";
}

void HttpSocket::cantataStreams(const QStringList& files)
{
	DBUG << files;
	for (const QString& f : files) {
		Song s = HttpServer::self()->decodeUrl(f);
		if (s.isCantataStream() || s.isCdda()) {
			DBUG << s.file;
			newlyAddedFiles += s.file;
		}
	}
}

void HttpSocket::cantataStreams(const QList<Song>& songs, bool isUpdate)
{
	DBUG << isUpdate << songs.count();
	if (!isUpdate) {
		streamIds.clear();
	}

	for (const Song& s : songs) {
		DBUG << s.file;
		if (s.isCantataStream()) {
			streamIds.insert(s.id, HttpServer::self()->decodeUrl(s.file).file);
		}
		else {
			streamIds.insert(s.id, s.file);
		}
		newlyAddedFiles.remove(s.file);
	}
	DBUG << streamIds;
}

void HttpSocket::removedIds(const QSet<qint32>& ids)
{
	for (qint32 id : ids) {
		streamIds.remove(id);
	}
}

bool HttpSocket::write(QTcpSocket* socket, char* buffer, qint32 bytesRead, bool& stop)
{
	if (bytesRead < 0 || terminated) {
		return false;
	}

	qint32 writePos = 0;
	do {
		qint32 bytesWritten = socket->write(&buffer[writePos], bytesRead - writePos);
		if (terminated || -1 == bytesWritten) {
			stop = true;
			break;
		}
		socket->flush();
		writePos += bytesWritten;
	} while (writePos < bytesRead);

	if (QAbstractSocket::ConnectedState == socket->state()) {
		socket->waitForBytesWritten();
	}
	if (QAbstractSocket::ConnectedState != socket->state()) {
		return false;
	}
	return true;
}

#include "moc_httpsocket.cpp"