RoomRepository.cpp

#include "RoomRepository.h"

namespace DBService {

	//RoomRepository::RoomRepository(DBConnection* connection_) : a_dbConnection(connection_) {}
	RoomRepository::RoomRepository(const QString& connection_string_) : a_dbConnection(connection_string_) {}
	RoomRepository::~RoomRepository() {}

	QFuture<QList<DBEntity::DBRoom>> RoomRepository::getAllRooms() {
		return QtConcurrent::run([this, query_string_ = "SELECT * from room;"]() {
			QList<DBEntity::DBRoom> roomList;
			try
			{
				a_dbConnection.databaseConnectionOpen();

				if (a_dbConnection.getDatabase().isOpen()) {
					QSqlQueryModel queryModel;
					queryModel.setQuery(query_string_);

					if (queryModel.lastError().isValid()) {
						PLOG_ERROR << "Query error: " << queryModel.lastError().text();
						return roomList;
					}

					const int rowCount = queryModel.rowCount();
					for (int i = 0; i < rowCount; ++i) {
						qint32 id = queryModel.record(i).value("id").toInt();
						QString name = queryModel.record(i).value("name").toString();
						QString description = queryModel.record(i).value("description").toString();
						qint32 topic_id = queryModel.record(i).value("topic_id").toInt();
						bool is_private = queryModel.record(i).value("is_private").toBool();
						QString password = queryModel.record(i).value("password").toString();
						bool is_deleted = queryModel.record(i).value("is_deleted").toBool();

						DBEntity::DBRoom room(id, name, description, topic_id, is_private, password, is_deleted);
						roomList.append(room);
					}

					a_dbConnection.databaseConnectionClose();

					if (!roomList.isEmpty()) {
						return roomList;
					}
					else {
						PLOG_INFO << "No data found.";
					}
				}
				else {
					PLOG_ERROR << "Cannot connect to the data base.";
					a_dbConnection.databaseConnectionClose();
				}
			}
			catch (const std::exception& exception)
			{
				PLOG_ERROR << "Exception in getAllRooms method: " << exception.what();
			}
			return roomList;
			});
	}

	QFuture<QList<DBEntity::DBRoom>> RoomRepository::getAllActiveRooms() {
		return QtConcurrent::run([this, query_string_ = "SELECT * from room WHERE is_deleted=0;"]() {
			QList<DBEntity::DBRoom> roomList;
			try
			{
				a_dbConnection.databaseConnectionOpen();
				if (a_dbConnection.getDatabase().isOpen()) {
					QSqlQueryModel queryModel;
					queryModel.setQuery(query_string_);

					if (queryModel.lastError().isValid()) {
						PLOG_ERROR << "Query error: " << queryModel.lastError().text();
						return roomList;
					}

					const int rowCount = queryModel.rowCount();
					for (int i = 0; i < rowCount; ++i) {
						qint32 id = queryModel.record(i).value("id").toInt();
						QString name = queryModel.record(i).value("name").toString();
						QString description = queryModel.record(i).value("description").toString();
						qint32 topic_id = queryModel.record(i).value("topic_id").toInt();
						bool is_private = queryModel.record(i).value("is_private").toBool();
						QString password = queryModel.record(i).value("password").toString();
						bool is_deleted = queryModel.record(i).value("is_deleted").toBool();

						DBEntity::DBRoom room(id, name, description, topic_id, is_private, password, is_deleted);
						roomList.append(room);
					}

					a_dbConnection.databaseConnectionClose();

					if (!roomList.isEmpty()) {
						return roomList;
					}
					else {
						PLOG_INFO << "No data found.";
					}
				}
				else {
					PLOG_ERROR << "Cannot connect to the data base.";
				}
			}
			catch (const std::exception& exception)
			{
				PLOG_ERROR << "Exception in getAllActiveRooms method: " << exception.what();
			}
			return roomList;
			});
	}

	QFuture<qint32> RoomRepository::createRoom( const DBEntity::DBRoom& room_) {
		return QtConcurrent::run([this, query_string_ = "INSERT INTO room (name, description, topic_id, is_private, password, is_deleted) VALUES (:name, :description, :topic_id, :is_private, :password, :is_deleted)", room_]() {
			try
			{
				a_dbConnection.databaseConnectionOpen();
				if (a_dbConnection.getDatabase().isOpen()) {

					QSqlQuery query;
					query.prepare(query_string_);

					query.bindValue(":name", room_.getName());
					query.bindValue(":description", room_.getDescription());
					query.bindValue(":topic_id", room_.getTopicId());
					query.bindValue(":is_private", room_.isPrivate());
					query.bindValue(":password", room_.getPassword());
					query.bindValue(":is_deleted", false);

					if (query.exec()) {
						qint32 id = query.lastInsertId().toInt();
						PLOG_INFO << "ID of a new Room db entity: " << id;
						a_dbConnection.databaseConnectionClose();
						return id;
					}
					else {
						PLOG_ERROR << "Error adding a new Room db entity.";
						a_dbConnection.databaseConnectionClose();
						return -1;
					}
				}
				else {
					PLOG_ERROR << "Cannot connect to the data base.";
					a_dbConnection.databaseConnectionClose();
					return -1;
				}
			}
			catch (const std::exception& exception)
			{
				PLOG_ERROR << "Exception in createRoom method: " << exception.what();
				return -1;
			}
			});
	}

	QFuture<bool> RoomRepository::deleteRoom(const qint32& id_) {
		return QtConcurrent::run([this, query_string_ = "UPDATE room SET is_deleted=:is_deleted WHERE id=:id", id_]() {
			try
			{
				a_dbConnection.databaseConnectionOpen();
				if (a_dbConnection.getDatabase().isOpen()) {

					QSqlQuery query;
					query.prepare(query_string_);

					query.bindValue(":id", id_);
					query.bindValue(":is_deleted", true);

					if (query.exec()) {
						PLOG_INFO << "Room with ID: " << id_ << " was deleted successfully.";
						a_dbConnection.databaseConnectionClose();
						return true;
					}
					else {
						PLOG_ERROR << "Room with ID: " << id_ << " was not deleted.";
						a_dbConnection.databaseConnectionClose();
						return false;
					}
				}
				else {
					PLOG_ERROR << "Cannot connect to the data base.";
					a_dbConnection.databaseConnectionClose();
					return false;
				}
			}
			catch (const std::exception& exception)
			{
				PLOG_ERROR << "Exception in deleteRoom method: " << exception.what();
				return false;
			}
			});
	}
}