main.cpp

#include <iostream>
#include <string>
#include <curl/curl.h>
#include "include/crow_all.h"
#include "include/config.h"

using namespace std;

// Construim comanda Cypher pentru crearea utilizatorului
string construiesteCypher(const string& nume,
                          const string& email,
                          const string& parola) {
    return "CREATE (u:User {nume: '" + nume +
           "', email: '" + email +
           "', parola: '" + parola + "'})";
}

// Construim JSON-ul necesar pentru API-ul Neo4j
string construiesteJSON(const string& cypher) {
    return "{\"statements\": [{\"statement\": \"" + cypher + "\"}]}";
}

// Trimitem datele către baza de date folosind libcurl
bool trimiteLaNeo4j(const string& json) {
    CURL* curl = curl_easy_init();
    if (!curl) return false;

    struct curl_slist* headers = NULL;
    headers = curl_slist_append(headers, "Content-Type: application/json");
    
    // Folosim token-ul din config.h pentru securitate
    string authHeader = "Authorization: Basic " + NEO4J_AUTH_TOKEN;
    headers = curl_slist_append(headers, authHeader.c_str());

    curl_easy_setopt(curl, CURLOPT_URL, NEO4J_URL.c_str());
    curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers);
    curl_easy_setopt(curl, CURLOPT_POSTFIELDS, json.c_str());

    CURLcode res = curl_easy_perform(curl);

    curl_slist_free_all(headers);
    curl_easy_cleanup(curl);

    return (res == CURLE_OK);
}

int main() {
    crow::App<crow::CORSHandler> app;

    // Configurare CORS pentru a permite cereri de la site-ul tău (Site_page)
    auto& cors = app.get_middleware<crow::CORSHandler>();
    cors.global()
        .origin("*")
        .methods("POST"_method, "GET"_method, "OPTIONS"_method)
        .headers("Content-Type");

    // Endpoint-ul POST care primește datele de la formularul web
    CROW_ROUTE(app, "/create_user").methods("POST"_method)
    ([](const crow::request& req){
        auto body = crow::json::load(req.body);

        if (!body) return crow::response(400, "JSON invalid");

        string nume = body["nume"].s();
        string email = body["email"].s();
        string parola = body["parola"].s();

        cout << "Log: Inregistrare utilizator nou: " << nume << " (" << email << ")" << endl;

        string cypher = construiesteCypher(nume, email, parola);
        string json   = construiesteJSON(cypher);

        if (trimiteLaNeo4j(json)) {
            return crow::response(200, "Utilizator salvat in Neo4j cu succes!");
        } else {
            return crow::response(500, "Eroare la comunicarea cu baza de date!");
        }
    });

    cout << "-------------------------------------------" << endl;
    cout << "Serverul C++ este activ pe http://localhost:18080" << endl;
    cout << "Astept date de la Site_page..." << endl;
    cout << "-------------------------------------------" << endl;

    app.port(18080).multithreaded().run();
}