Page MenuHomePhorge
Files F85804364

No OneTemporary
Actions

Size
8 KB
Referenced Files
None
Subscribers
None

View Options

diff --git a/src/tests/CMakeLists.txt b/src/tests/CMakeLists.txt
index 040f492..6457800 100644
--- a/src/tests/CMakeLists.txt
+++ b/src/tests/CMakeLists.txt
@@ -1,55 +1,60 @@
set(KAZV_TEST_TEMP_DIR ${CMAKE_CURRENT_BINARY_DIR}/test-temp)
configure_file(test-temp.hpp.in test-temp.hpp)
set(kazvtestlib_SRCS
test-model.cpp
)
add_library(kazvtestlib STATIC ${kazvtestlib_SRCS})
target_include_directories(kazvtestlib PUBLIC ${CMAKE_CURRENT_BINARY_DIR})
target_link_libraries(kazvtestlib PUBLIC kazvprivlib libkazv::kazvtestfixtures)
add_executable(matrix-sdk-session-loader matrix-sdk-session-loader.cpp matrix-sdk-sessions-test.cpp)
target_compile_definitions(matrix-sdk-session-loader PRIVATE MATRIX_SDK_SESSIONS_TEST_NO_MAIN)
target_link_libraries(matrix-sdk-session-loader Qt${QT_MAJOR_VERSION}::Test kazvtestlib)
ecm_add_tests(
qt-job-handler-test.cpp
qt-promise-handler-test.cpp
qt-json-test.cpp
device-mgmt-test.cpp
matrix-sdk-test.cpp
matrix-sdk-sessions-test.cpp
matrix-promise-test.cpp
matrix-room-timeline-test.cpp
matrix-room-member-list-model-test.cpp
matrix-room-list-test.cpp
kazv-markdown-test.cpp
matrix-sticker-pack-test.cpp
matrix-link-test.cpp
matrix-user-given-attrs-map-test.cpp
kazv-abstract-list-model-test.cpp
matrix-event-list-test.cpp
matrix-event-test.cpp
kazv-file-test.cpp
LINK_LIBRARIES Qt${QT_MAJOR_VERSION}::Test kazvtestlib
)
ecm_add_test(
kazv-io-job-test.cpp
LINK_LIBRARIES Qt${QT_MAJOR_VERSION}::Test Qt${QT_MAJOR_VERSION}::HttpServer kazvtestlib
)
+ecm_add_test(
+ kazv-io-manager-test.cpp
+ LINK_LIBRARIES Qt${QT_MAJOR_VERSION}::Test Qt${QT_MAJOR_VERSION}::HttpServer kazvtestlib
+)
+
ecm_add_test(
quick-test.cpp
TEST_NAME quicktest
LINK_LIBRARIES Qt${QT_MAJOR_VERSION}::QuickTest kazvtestlib
)
if(KAZV_BUILD_BENCHMARKS)
ecm_add_test(
matrix-room-timeline-benchmark-test.cpp
LINK_LIBRARIES Qt${QT_MAJOR_VERSION}::Test kazvtestlib
)
endif()
set_tests_properties(quicktest PROPERTIES WORKING_DIRECTORY ${CMAKE_SOURCE_DIR})
diff --git a/src/tests/kazv-io-manager-test.cpp b/src/tests/kazv-io-manager-test.cpp
new file mode 100644
index 0000000..af9087c
--- /dev/null
+++ b/src/tests/kazv-io-manager-test.cpp
@@ -0,0 +1,190 @@
+/*
+ * This file is part of kazv.
+ * SPDX-FileCopyrightText: 2025 nannanko <nannanko@kazv.moe>
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+
+#include <kazv-defs.hpp>
+
+#include "kazv-io-manager.hpp"
+#include "test-model.hpp"
+#include "test-utils.hpp"
+
+#include <QObject>
+#include <QtTest>
+#include <QHttpServer>
+#include <QTcpServer>
+#include <QThread>
+#include <QTemporaryFile>
+#include <QString>
+#include <QHttpServerResponder>
+
+using namespace Qt::Literals::StringLiterals;
+
+static const QString downloadEndpoint =
+ u"/_matrix/client/v1/media/download/serverName/download"_s;
+static const char *downloadFileContent = "download";
+
+class KazvIOManagerTest : public QObject
+{
+ Q_OBJECT
+
+private:
+ QHttpServer httpServer;
+ QTcpServer tcpServer; // Required by QHttpServer
+ QThread serverThread;
+ quint16 port;
+
+ QTemporaryFile downloadFile;
+
+ QString serverUrl;
+
+private Q_SLOTS:
+ void initTestCase();
+ void cleanupTestCase();
+ void testCache();
+ void testDownload();
+ void testUpload();
+ void testRoomlessUpload();
+ void testClearJobs();
+
+Q_SIGNALS:
+ void readyResume();
+ void readyPause();
+};
+
+void KazvIOManagerTest::initTestCase()
+{
+ downloadFile.open();
+ downloadFile.write(downloadFileContent);
+ downloadFile.close();
+
+ // QHttpServer::route() requires QHttpServerResponder must be passed by universal reference before Qt6.8
+ // https://doc.qt.io/qt-6.5/qhttpserver.html#route
+#if QT_VERSION < QT_VERSION_CHECK(6, 8, 0)
+ using QHttpServerResponderRef = QHttpServerResponder &&;
+#else
+ using QHttpServerResponderRef = QHttpServerResponder &;
+#endif
+ httpServer.route(downloadEndpoint, [this](QHttpServerResponderRef res) {
+ QSignalSpy qs{this, &KazvIOManagerTest::readyResume};
+ Q_EMIT readyPause();
+ QVERIFY(qs.wait());
+ downloadFile.open();
+ res.write(downloadFile.readAll(), "application/octet-stream"_ba);
+ downloadFile.close();
+ });
+ QVERIFY(tcpServer.listen());
+ httpServer.bind(&tcpServer);
+
+ port = tcpServer.serverPort();
+ serverUrl = u"http://localhost:"_s + QString::number(port);
+ httpServer.moveToThread(&serverThread);
+ serverThread.start();
+}
+
+void KazvIOManagerTest::cleanupTestCase()
+{
+ serverThread.quit();
+ serverThread.wait();
+}
+
+void KazvIOManagerTest::testCache()
+{
+ KazvIOManager manager;
+ auto url = QUrl{serverUrl + downloadEndpoint};
+ auto id = u"id"_s;
+ QSignalSpy qsPause{this, &KazvIOManagerTest::readyPause};
+ manager.cacheFile(url, id);
+ QVERIFY(qsPause.wait());
+ auto job = manager.getCacheJob(id);
+ QVERIFY(job != nullptr);
+ // Multiple calls do not repeat downloads
+ manager.cacheFile(QUrl{u"url"_s}, id);
+ QCOMPARE(manager.getCacheJob(id), job);
+ QSignalSpy qs{job, &KazvIOBaseJob::result};
+ Q_EMIT readyResume();
+ // Cache job is automatically destroyed
+ QVERIFY(qs.wait());
+ QCOMPARE(manager.getCacheJob(id), nullptr);
+}
+
+void KazvIOManagerTest::testDownload()
+{
+ KazvIOManager manager;
+ auto id = u"id"_s;
+ manager.startNewDownloadJob(
+ QUrl{u"serverUrl"_s}, QUrl{u"localFileUrl"_s}, id, u"hash"_s);
+ QVERIFY(manager.getDownloadJob(id) != nullptr);
+ manager.deleteDownloadJob(id);
+ QCOMPARE(manager.getDownloadJob(id), nullptr);
+}
+
+void KazvIOManagerTest::testUpload()
+{
+ auto model = makeTestModel();
+ Kazv::RoomModel room;
+ room.roomId = "!test:tusooa.xyz";
+ model.client.roomList.rooms =
+ model.client.roomList.rooms.set(room.roomId, room);
+
+ std::unique_ptr<MatrixSdk> sdk{makeTestSdk(model)};
+ auto roomList = toUniquePtr(sdk->roomList());
+
+ KazvIOManager manager;
+ auto job = manager.startNewUploadJob(QUrl{u"serverUrl"_s}, QUrl{u"localFileUrl"_s},
+ u"token"_s, QString::fromStdString(room.roomId), roomList.get(), false,
+ u"relType"_s, u"relatedTo"_s);
+ auto roomId = QString::fromStdString(room.roomId);
+ auto uploadModel = QPointer{manager.getUploadJobs(roomId)};
+ QCOMPARE(uploadModel->rowCount(), 1);
+ manager.deleteUploadJob(roomId, job);
+ QCOMPARE(uploadModel->rowCount(), 0);
+ manager.deleteModelIfEmpty(roomId);
+ QVERIFY(uploadModel.isNull());
+}
+
+void KazvIOManagerTest::testRoomlessUpload()
+{
+ const auto ROOMLESS = u"not-a-room"_s;
+ KazvIOManager manager;
+ auto job = manager.startNewRoomlessUploadJob(QUrl{u"serverUrl"_s},
+ QUrl{u"localFileUrl"_s}, u"token"_s);
+ auto uploadModel = QPointer{manager.getUploadJobs(ROOMLESS)};
+ QCOMPARE(uploadModel->rowCount(), 1);
+ manager.deleteRoomlessUploadJob(job);
+ QCOMPARE(uploadModel->rowCount(), 0);
+ manager.deleteModelIfEmpty(ROOMLESS);
+ QVERIFY(uploadModel.isNull());
+}
+
+void KazvIOManagerTest::testClearJobs()
+{
+ KazvIOManager manager;
+ auto id = u"id"_s;
+ manager.startNewDownloadJob(
+ QUrl{u"serverUrl"_s}, QUrl{u"localFileUrl"_s}, id, u"hash"_s);
+ QVERIFY(manager.getDownloadJob(id) != nullptr);
+
+ auto model = makeTestModel();
+ Kazv::RoomModel room;
+ room.roomId = "!test:tusooa.xyz";
+ model.client.roomList.rooms =
+ model.client.roomList.rooms.set(room.roomId, room);
+
+ std::unique_ptr<MatrixSdk> sdk{makeTestSdk(model)};
+ auto roomList = toUniquePtr(sdk->roomList());
+ manager.startNewUploadJob(QUrl{u"serverUrl"_s}, QUrl{u"localFileUrl"_s},
+ u"token"_s, QString::fromStdString(room.roomId), roomList.get(), false,
+ u"relType"_s, u"relatedTo"_s);
+ auto roomId = QString::fromStdString(room.roomId);
+ QCOMPARE(manager.getUploadJobs(roomId)->rowCount(), 1);
+
+ manager.clearJobs();
+ QCOMPARE(manager.getDownloadJob(id), nullptr);
+ QCOMPARE(manager.getUploadJobs(roomId)->rowCount(), 0);
+}
+
+QTEST_MAIN(KazvIOManagerTest)
+
+#include "kazv-io-manager-test.moc"

File Metadata

Mime Type
text/x-diff
Expires
Sat, Oct 10, 4:34 AM (1 d, 12 h)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
1785032
Default Alt Text
(8 KB)

Event Timeline