From d303dbf71b8b8cedbaed2a7f20fe15381aef453d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=90=D0=BD=D1=82=D0=BE=D0=BD?= Date: Fri, 29 Aug 2025 19:59:08 +0300 Subject: [PATCH] =?UTF-8?q?=D0=9A=D0=BE=D1=80=D1=80=D0=B5=D0=BA=D1=82?= =?UTF-8?q?=D0=BD=D1=8B=D0=B9,=20=D1=85=D0=BE=D1=82=D1=8C=20=D0=B8=20?= =?UTF-8?q?=D0=B3=D1=80=D1=83=D0=B1=D1=8B=D0=B9=20=D0=B7=D0=B0=D1=85=D0=B2?= =?UTF-8?q?=D0=B0=D1=82=20JSON'=D0=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/DAO/MySQLUserDAO.cpp | 12 ++++++++++++ src/endpoints_handlers/AuthRegistrationExecutor.h | 6 ++++-- src/main.cpp | 15 --------------- 3 files changed, 16 insertions(+), 17 deletions(-) diff --git a/src/DAO/MySQLUserDAO.cpp b/src/DAO/MySQLUserDAO.cpp index 2b3d29e..a2c8875 100644 --- a/src/DAO/MySQLUserDAO.cpp +++ b/src/DAO/MySQLUserDAO.cpp @@ -23,6 +23,18 @@ optional MySQLUserDAO::GetByGUID(string guid) std::optional MySQLUserDAO::GetByLogin(std::string login) { + auto sql_result = session_.sql("SELECT * FROM `up_and_down`.`users` WHERE (login = '" + login + "') LIMIT 1;"s).execute(); + list rows = sql_result.fetchAll(); + + if (rows.size()) + { + auto row_data = *rows.begin(); + + string replicated_login = row_data[1].get(); + + cout << "SUCCESS!" << endl; + } + return nullopt; } diff --git a/src/endpoints_handlers/AuthRegistrationExecutor.h b/src/endpoints_handlers/AuthRegistrationExecutor.h index 6fe9c77..810f146 100644 --- a/src/endpoints_handlers/AuthRegistrationExecutor.h +++ b/src/endpoints_handlers/AuthRegistrationExecutor.h @@ -33,14 +33,16 @@ public: auto body = req.body(); object json_as_object = json::parse(body).as_object(); - std::string login = serialize(json_as_object.at("login").as_string()); - std::string password = serialize(json_as_object.at("password").as_string()); + std::string login = json_as_object.at("login").as_string().c_str(); + std::string password = json_as_object.at("password").as_string().c_str(); User user; user.SetLogin(login); user.SetPassword(password); + user_dao_->GetByLogin(login); + http::response res{ http::status::ok, req.version() }; diff --git a/src/main.cpp b/src/main.cpp index 4c840f0..ab0bdc4 100644 --- a/src/main.cpp +++ b/src/main.cpp @@ -45,21 +45,6 @@ int main(int argc, char* argv[]) string mysql_credentials = argv[5]; uad::SetMySqlSession(new mysqlx::Session(mysql_credentials)); - auto& session = uad::GetMySqlSession(); - - auto schema = session.getSchema("up_and_down"); - - auto collections_names = schema.getCollectionNames(); - auto users_collection = schema.getCollection("users"); - auto users_collection_2 = session.sql("SELECT * FROM up_and_down.users;").execute(); - - auto users_rows = users_collection_2.fetchAll(); - - auto rows = *users_rows.begin(); - - const auto& user_guid = static_cast(rows.get(0)); - const auto& user_login = static_cast(rows.get(1)); - const auto& user_hashed_password = static_cast(rows.get(2)); net::io_context ioc{threads};