mirror/yacreader
1
0
Fork 0
mirror of https://github.com/YACReader/yacreader synced 2026-03-01 18:33:09 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Drop server v1

Browse Source
This commit is contained in:
luisangelsm
2026-02-20 19:01:49 +01:00
parent e3aeb867f4
commit d898a56f3f
31 changed files with 6 additions and 1386 deletions
Download Patch File Download Diff File Expand all files Collapse all files

150
YACReaderLibrary/server/requestmapper.cpp
View File

@ -4,17 +4,6 @@
#include "controllers/versioncontroller.h"
#include "controllers/v1/librariescontroller.h"
#include "controllers/v1/foldercontroller.h"
#include "controllers/v1/covercontroller.h"
#include "controllers/v1/comiccontroller.h"
#include "controllers/v1/folderinfocontroller.h"
#include "controllers/v1/pagecontroller.h"
#include "controllers/v1/updatecomiccontroller.h"
#include "controllers/v1/errorcontroller.h"
#include "controllers/v1/comicdownloadinfocontroller.h"
#include "controllers/v1/synccontroller.h"
#include "controllers/v2/librariescontroller_v2.h"
#include "controllers/v2/covercontroller_v2.h"
#include "controllers/v2/comiccontroller_v2.h"
@ -51,83 +40,12 @@
using stefanfrings::HttpRequest;
using stefanfrings::HttpRequestHandler;
using stefanfrings::HttpResponse;
using stefanfrings::HttpSession;
QMutex RequestMapper::mutex;
RequestMapper::RequestMapper(QObject *parent)
: HttpRequestHandler(parent) { }
void RequestMapper::loadSessionV1(HttpRequest &request, HttpResponse &response)
{
QMutexLocker locker(&mutex);
HttpSession session = Static::sessionStore->getSession(request, response);
if (session.contains("ySession")) // session is already alive check if it is needed to update comics
{
auto ySession = Static::yacreaderSessionStore->getYACReaderSessionHttpSession(session.getId());
QString postData = QString::fromUtf8(request.getBody());
if (postData.contains("currentPage"))
return;
if (postData.length() > 0) {
QList<QString> data = postData.split("\n");
if (data.length() > 2) {
ySession->setDeviceType(data.at(0).split(":").at(1));
ySession->setDisplayType(data.at(1).split(":").at(1));
QList<QString> comics = data.at(2).split(":").at(1).split("\t");
ySession->clearComics();
foreach (QString hash, comics) {
ySession->setComicOnDevice(hash);
}
} else {
if (data.length() > 1) {
ySession->setDeviceType(data.at(0).split(":").at(1));
ySession->setDisplayType(data.at(1).split(":").at(1));
}
}
}
} else {
auto ySession = new YACReaderHttpSession(this);
Static::yacreaderSessionStore->addYACReaderHttpSession(session.getId(), ySession);
session.set("ySession", "ok");
QString postData = QString::fromUtf8(request.getBody());
// response.writeText(postData);
QList<QString> data = postData.split("\n");
if (data.length() > 2) {
auto deviceTypeData = data.at(0).split(":");
if (deviceTypeData.length() == 2) {
ySession->setDeviceType(deviceTypeData.at(1));
}
auto displayTypeData = data.at(1).split(":");
if (displayTypeData.length() == 2) {
ySession->setDisplayType(displayTypeData.at(1));
}
auto comicsData = data.at(2).split(":");
if (comicsData.length() == 2) {
QList<QString> comics = comicsData.at(1).split("\t");
foreach (QString hash, comics) {
ySession->setComicOnDevice(hash);
}
}
} else // values by default, only for debug purposes.
{
ySession->setDeviceType("ipad");
ySession->setDisplayType("@2x");
}
}
}
void RequestMapper::loadSessionV2(HttpRequest &request, HttpResponse & /* response */)
{
QMutexLocker locker(&mutex);
@ -160,7 +78,8 @@ void RequestMapper::service(HttpRequest &request, HttpResponse &response)
} else if (path.startsWith("/webui")) {
serviceWebUI(request, response);
} else {
serviceV1(request, response);
response.setStatus(404, "not found");
response.write("404 not found", true);
}
}
@ -169,71 +88,6 @@ void RequestMapper::serviceWebUI(HttpRequest &request, HttpResponse &response)
StatusPageController().service(request, response);
}
void RequestMapper::serviceV1(HttpRequest &request, HttpResponse &response)
{
QByteArray path = request.getPath();
QRegExp folder("/library/.+/folder/[0-9]+/?"); // get comic content
QRegExp folderInfo("/library/.+/folder/[0-9]+/info/?"); // get folder info
QRegExp comicDownloadInfo("/library/.+/comic/[0-9]+/?"); // get comic info (basic/download info)
QRegExp comicFullInfo("/library/.+/comic/[0-9]+/info/?"); // get comic info (full info)
QRegExp comicOpen("/library/.+/comic/[0-9]+/remote/?"); // the server will open for reading the comic
QRegExp comicUpdate("/library/.+/comic/[0-9]+/update/?"); // get comic info
QRegExp comicClose("/library/.+/comic/[0-9]+/close/?"); // the server will close the comic and free memory
QRegExp cover("/library/.+/cover/[0-9a-f]+.jpg"); // get comic cover (navigation)
QRegExp comicPage("/library/.+/comic/[0-9]+/page/[0-9]+/?"); // get comic page
QRegExp comicPageRemote("/library/.+/comic/[0-9]+/page/[0-9]+/remote?"); // get comic page (remote reading)
QRegExp sync("/sync");
QRegExp library("/library/([0-9]+)/.+"); // permite verificar que la biblioteca solicitada existe
path = QUrl::fromPercentEncoding(path).toUtf8();
if (!sync.exactMatch(path)) // no session is needed for syncback info, until security will be added
loadSessionV1(request, response);
// primera petición, se ha hecho un post, se sirven las bibliotecas si la seguridad mediante login no está habilitada
if (path == "/") // Don't send data to the server using '/' !!!!
{
LibrariesController().service(request, response);
} else {
if (sync.exactMatch(path))
SyncController().service(request, response);
else {
// se comprueba que la sesión sea la correcta con el fin de evitar accesos no autorizados
HttpSession session = Static::sessionStore->getSession(request, response, false);
if (!session.isNull() && session.contains("ySession")) {
if (library.indexIn(path) != -1 && DBHelper::getLibraries().contains(library.cap(1).toInt())) {
// listar el contenido del folder
if (folder.exactMatch(path)) {
FolderController().service(request, response);
} else if (folderInfo.exactMatch(path)) {
FolderInfoController().service(request, response);
} else if (cover.exactMatch(path)) {
CoverController().service(request, response);
} else if (comicDownloadInfo.exactMatch(path)) {
ComicDownloadInfoController().service(request, response);
} else if (comicFullInfo.exactMatch(path) || comicOpen.exactMatch(path)) // start download or start remote reading
{
ComicController().service(request, response);
} else if (comicPage.exactMatch(path) || comicPageRemote.exactMatch(path)) {
PageController().service(request, response);
} else if (comicUpdate.exactMatch(path)) {
UpdateComicController().service(request, response);
}
} else {
// response.writeText(library.cap(1));
Static::staticFileController->service(request, response);
}
} else // acceso no autorizado, redirección
{
ErrorController(300).service(request, response);
}
}
}
}
void RequestMapper::serviceV2(HttpRequest &request, HttpResponse &response)
{
QByteArray path = request.getPath();