File indexing completed on 2024-05-12 16:25:42

 /*
    SPDX-FileCopyrightText: 2023-2024 Laurent Montel <montel.org>
 
    SPDX-License-Identifier: LGPL-2.0-or-later
 */
 
 #include "localroomsdatabase.h"
 #include "localdatabaseutils.h"
 #include "room.h"
 #include "ruqola_database_debug.h"
 
 #include <QSqlDatabase>
 #include <QSqlError>
 #include <QSqlQuery>
 #include <QSqlRecord>
 
 static const char s_schemaRoomDataBase[] = "CREATE TABLE ROOMS (roomId TEXT PRIMARY KEY NOT NULL, timestamp INTEGER, json TEXT)";
 enum class RoomFields {
     RoomId,
     TimeStamp,
     Json,
 }; // in the same order as the table
 
 LocalRoomsDatabase::LocalRoomsDatabase()
     : LocalDatabaseBase(LocalDatabaseUtils::localRoomsDatabasePath(), LocalDatabaseBase::DatabaseType::Rooms)
 {
 }
 
 LocalRoomsDatabase::~LocalRoomsDatabase() = default;
 
 QString LocalRoomsDatabase::schemaDataBase() const
 {
     return QString::fromLatin1(s_schemaRoomDataBase);
 }
 
 void LocalRoomsDatabase::addRoom(const QString &accountName, Room *room)
 {
     QSqlDatabase db;
     if (initializeDataBase(accountName, db)) {
         QSqlQuery query(LocalDatabaseUtils::insertReplaceRoom(), db);
         query.addBindValue(room->roomId());
         query.addBindValue(room->updatedAt()); // TODO ?
         query.addBindValue(Room::serialize(room, false)); // TODO use binary ?
         if (!query.exec()) {
             qCWarning(RUQOLA_DATABASE_LOG) << "Couldn't insert-or-replace in ROOMS table" << db.databaseName() << query.lastError();
         }
     }
 }
 
 void LocalRoomsDatabase::deleteRoom(const QString &accountName, const QString &roomId)
 {
     QSqlDatabase db;
     if (!checkDataBase(accountName, db)) {
         return;
     }
     QSqlQuery query(LocalDatabaseUtils::deleteRooms(), db);
     query.addBindValue(roomId);
     if (!query.exec()) {
         qCWarning(RUQOLA_DATABASE_LOG) << "Couldn't insert-or-replace in ROOMS table" << db.databaseName() << query.lastError();
     }
 }
 
 QByteArray LocalRoomsDatabase::jsonRoom(const QString &accountName, const QString &roomId)
 {
     QSqlDatabase db;
     if (!initializeDataBase(accountName, db)) {
         qCWarning(RUQOLA_DATABASE_LOG) << "Could not initialize database from " << accountName << " roomId " << roomId;
         return {};
     }
     QSqlQuery query(QStringLiteral("SELECT json FROM ROOMS WHERE roomId = \"%1\"").arg(roomId), db);
     QByteArray value;
     // We have one element
     if (query.first()) {
         value = query.value(0).toByteArray();
     }
     return value;
 }