Index: .idea/.gitignore =================================================================== --- .idea/.gitignore (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) +++ .idea/.gitignore (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) @@ -0,0 +1,8 @@ +# Default ignored files +/shelf/ +/workspace.xml +# Editor-based HTTP Client requests +/httpRequests/ +# Datasource local storage ignored files +/dataSources/ +/dataSources.local.xml Index: .idea/GlobeGuru.iml =================================================================== --- .idea/GlobeGuru.iml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) +++ .idea/GlobeGuru.iml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) @@ -0,0 +1,6 @@ + + + + + + Index: .idea/compiler.xml =================================================================== --- .idea/compiler.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) +++ .idea/compiler.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) @@ -0,0 +1,13 @@ + + + + + + + + + + + + + Index: .idea/dataSources.xml =================================================================== --- .idea/dataSources.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) +++ .idea/dataSources.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) @@ -0,0 +1,20 @@ + + + + + sqlite.xerial + true + org.sqlite.JDBC + jdbc:sqlite:D:\Finki\Projects\GlobeGuru\globe_guru.db + $ProjectFileDir$ + + + file://$APPLICATION_CONFIG_DIR$/jdbc-drivers/Xerial SQLiteJDBC/3.45.1/org/xerial/sqlite-jdbc/3.45.1.0/sqlite-jdbc-3.45.1.0.jar + + + file://$APPLICATION_CONFIG_DIR$/jdbc-drivers/Xerial SQLiteJDBC/3.45.1/org/slf4j/slf4j-api/1.7.36/slf4j-api-1.7.36.jar + + + + + Index: .idea/encodings.xml =================================================================== --- .idea/encodings.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) +++ .idea/encodings.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) @@ -0,0 +1,7 @@ + + + + + + + Index: .idea/jarRepositories.xml =================================================================== --- .idea/jarRepositories.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) +++ .idea/jarRepositories.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) @@ -0,0 +1,20 @@ + + + + + + + + + + + Index: .idea/jsLibraryMappings.xml =================================================================== --- .idea/jsLibraryMappings.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) +++ .idea/jsLibraryMappings.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) @@ -0,0 +1,7 @@ + + + + + + + Index: .idea/misc.xml =================================================================== --- .idea/misc.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) +++ .idea/misc.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) @@ -0,0 +1,13 @@ + + + + + + + + + Index: .idea/modules.xml =================================================================== --- .idea/modules.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) +++ .idea/modules.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) @@ -0,0 +1,8 @@ + + + + + + + + Index: .idea/uiDesigner.xml =================================================================== --- .idea/uiDesigner.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) +++ .idea/uiDesigner.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) @@ -0,0 +1,124 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + Index: .idea/vcs.xml =================================================================== --- .idea/vcs.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) +++ .idea/vcs.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) @@ -0,0 +1,6 @@ + + + + + + Index: ckend/GlobeGuru-backend/frontend/css.css =================================================================== --- backend/GlobeGuru-backend/frontend/css.css (revision d4d8f6155e80421fe9fc8c1ee34e0b784226b96c) +++ (revision ) @@ -1,45 +1,0 @@ -.option{ - display: inline-flex; - justify-content: space-between; - width: 80%; - border: 1px solid black; - border-radius: 10px; - height: 300px; -} -.image{ - width: 30%; - height: 100%; -} -p{ - font-family: Arial; - font-size: 30px; -} -.btn{ - margin-top: 120%; - - display: inline-block; - outline: 0; - cursor: pointer; - border-radius: 8px; - box-shadow: 0 2px 5px 0 rgb(213 217 217 / 50%); - background: #FFD814; - border: 1px solid #FCD200; - font-size: 13px; - height: 31px; - padding: 0 11px; - text-align: center; - width: 100%; - min-width: 200px; - font-weight: 500; - color: #0F1111; - :hover{ - background: #F7CA00; - border-color: #F2C200; - box-shadow: 0 2px 5px 0 rgb(213 217 217 / 50%); - } - -} -#givenOptions{ - width: 100%; - align-self: center; -} Index: ckend/GlobeGuru-backend/frontend/index.html =================================================================== --- backend/GlobeGuru-backend/frontend/index.html (revision d4d8f6155e80421fe9fc8c1ee34e0b784226b96c) +++ (revision ) @@ -1,28 +1,0 @@ - - - - - Title - - - -

- - -

- - - - Index: ckend/GlobeGuru-backend/frontend/js/formHandler.js =================================================================== --- backend/GlobeGuru-backend/frontend/js/formHandler.js (revision d4d8f6155e80421fe9fc8c1ee34e0b784226b96c) +++ (revision ) @@ -1,82 +1,0 @@ -document.addEventListener('DOMContentLoaded', function() { - const form = document.getElementById('form-id'); // Ensure the form has the correct ID - - form.addEventListener('submit', function(event) { - event.preventDefault(); // Prevent the default form submission - - // Collect form data - const formData = new FormData(form); - const data = {}; - formData.forEach((value, key) => { - data[key] = value; - }); - - // Send form data to the server - fetch('/submit', { - method: 'POST', - headers: { - 'Content-Type': 'application/json' - }, - body: JSON.stringify(data) - }) - .then(response => response.json()) - .then(data => { - // Process the scraped data and update the page - const dataList = document.getElementById('givenOptions'); - dataList.innerHTML = ''; // Clear previous data - - data.forEach(item => { - // Create option container div - const optionDiv = document.createElement('div'); - optionDiv.classList.add('option'); - - // Create and append image element - const img = document.createElement('img'); - img.classList.add('image'); - img.src = item.imgSrc; // Use item.imageSrc if available - optionDiv.appendChild(img); - - // Create and append hotel name paragraph - const nameParagraph = document.createElement('p'); - nameParagraph.id = 'name'; - nameParagraph.textContent = item.hotelName; - optionDiv.appendChild(nameParagraph); - - // Create and append country paragraph - const countryParagraph = document.createElement('p'); - countryParagraph.id = 'country'; - countryParagraph.style.fontSize = '20px'; - countryParagraph.textContent = item.country; - optionDiv.appendChild(countryParagraph); - - // Create and append price heading and paragraph - const priceHeading = document.createElement('h1'); - priceHeading.textContent = 'Цена:'; - optionDiv.appendChild(priceHeading); - const priceParagraph = document.createElement('h2'); - priceParagraph.id = 'price'; - priceParagraph.textContent = item.price; - optionDiv.appendChild(priceParagraph); - - // Create link and button - const link = document.createElement('a'); - link.id = 'link'; - link.href = item.link; // Use item.link if available - link.target = '_blank'; // Open link in new tab - - const button = document.createElement('button'); - button.classList.add('btn'); - button.textContent = 'Линк до страна'; - - link.appendChild(button); - optionDiv.appendChild(link); - - // Append option div to dataList - dataList.appendChild(optionDiv); - }); - }) - .catch(error => { - console.error('Error fetching data:', error); - }); - }); -}); Index: ckend/GlobeGuru-backend/frontend/package.json =================================================================== --- backend/GlobeGuru-backend/frontend/package.json (revision d4d8f6155e80421fe9fc8c1ee34e0b784226b96c) +++ (revision ) @@ -1,6 +1,0 @@ -{ - "name": "frontend", - "version": "1.0.0", - "dependencies": { - } -} Index: ckend/GlobeGuru-backend/frontend/results.html =================================================================== --- backend/GlobeGuru-backend/frontend/results.html (revision d4d8f6155e80421fe9fc8c1ee34e0b784226b96c) +++ (revision ) @@ -1,13 +1,0 @@ - - - - - - Scraped Data Display - - -

Scraped Data

- - - Index: backend/GlobeGuru-backend/pom.xml =================================================================== --- backend/GlobeGuru-backend/pom.xml (revision d4d8f6155e80421fe9fc8c1ee34e0b784226b96c) +++ backend/GlobeGuru-backend/pom.xml (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) @@ -52,8 +52,49 @@ 1.17.2 - - - - + + org.xerial + sqlite-jdbc + 3.34.0 + + + com.google.api-client + google-api-client + 1.30.10 + + + com.google.auth + google-auth-library-oauth2-http + 0.21.0 + + + com.google.api-client + google-api-client-gson + 1.30.10 + + + com.google.http-client + google-http-client + 1.36.0 + + + org.slf4j + slf4j-api + 2.0.16 + + + org.slf4j + slf4j-simple + 2.0.16 + + + javax.servlet + javax.servlet-api + 3.1.0 + + + javax.websocket + javax.websocket-all + 1.1 + Index: backend/GlobeGuru-backend/src/main/java/AccountHandler.java =================================================================== --- backend/GlobeGuru-backend/src/main/java/AccountHandler.java (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) +++ backend/GlobeGuru-backend/src/main/java/AccountHandler.java (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) @@ -0,0 +1,217 @@ +import com.fasterxml.jackson.databind.ObjectMapper; +import com.google.api.client.googleapis.auth.oauth2.GoogleIdToken; +import com.google.api.client.googleapis.auth.oauth2.GoogleIdTokenVerifier; +import com.google.api.client.http.HttpTransport; +import com.google.api.client.http.javanet.NetHttpTransport; +import com.google.api.client.json.JsonFactory; +import com.google.api.client.json.jackson2.JacksonFactory; +import com.sun.net.httpserver.HttpExchange; +import com.sun.net.httpserver.HttpHandler; + +import java.io.IOException; +import java.security.GeneralSecurityException; +import java.sql.SQLException; +import java.util.*; +import java.util.concurrent.ConcurrentHashMap; + +public class AccountHandler implements HttpHandler { + + // Simple in-memory session management + private static final Map sessions = new ConcurrentHashMap<>(); + private static final String CLIENT_ID = "376204422797-s8f05nn6drmec1cko2h4kg1nk24abgc9.apps.googleusercontent.com"; + + @Override + public void handle(HttpExchange exchange) throws IOException { + String path = exchange.getRequestURI().getPath(); + String method = exchange.getRequestMethod(); + + if ("POST".equalsIgnoreCase(method)) { + switch (path) { + case "/account/register": + handleRegister(exchange); + break; + case "/account/login": + handleLogin(exchange); + break; + case "/account/logout": + handleLogout(exchange); + break; + case "/account/delete": + handleDeleteAccount(exchange); + break; + default: + Server.sendResponse(exchange, 404, "Endpoint not found"); + } + } else if ("GET".equalsIgnoreCase(method) && path.equalsIgnoreCase("/account/session")) { + handleSession(exchange); + } else { + Server.sendResponse(exchange, 405, "Method not allowed"); + } + } + + private void handleSession(HttpExchange exchange) throws IOException { + String sessionId = getSessionId(exchange); + ObjectMapper mapper = new ObjectMapper(); + Map response = new HashMap<>(); + if (sessionId != null && sessions.containsKey(sessionId)) { + response.put("loggedIn", true); + response.put("user", sessions.get(sessionId)); + try { + response.put("isAdmin", DatabaseUtil.isAdmin(sessions.get(sessionId))); + } catch (SQLException e) { + e.printStackTrace(); + response.put("isAdmin", false); + } + } else { + response.put("loggedIn", false); + } + + String jsonResponse = mapper.writeValueAsString(response); + Server.sendResponse(exchange, 200, jsonResponse); + } + + private String getSessionId(HttpExchange exchange) { + List cookies = exchange.getRequestHeaders().get("Cookie"); + if (cookies != null) { + for (String cookie : cookies) { + if (cookie.contains("sessionId=")) { + return cookie.replaceAll("g_state=\\{\"i_l\":0\\}; sessionId=", ""); + } + } + } + return null; + } + + + private void handleRegister(HttpExchange exchange) throws IOException { + String requestBody = new String(exchange.getRequestBody().readAllBytes()); + ObjectMapper mapper = new ObjectMapper(); + Map formData = mapper.readValue(requestBody, Map.class); + String username = formData.get("username"); + String email = formData.get("email"); + String password = formData.get("password"); + + try { + if (DatabaseUtil.registerUser(username, email, password)) { + Server.sendResponse(exchange, 200, "{\"message\": \"Registration successful!\"}"); + } else { + Server.sendResponse(exchange, 400, "{\"message\": \"Registration failed! User may already exist.\"}"); + } + } catch (SQLException e) { + e.printStackTrace(); + Server.sendResponse(exchange, 500, "{\"message\": \"Internal server error\"}"); + } + } + + private void handleLogin(HttpExchange exchange) throws IOException { + String requestBody = new String(exchange.getRequestBody().readAllBytes()); + ObjectMapper mapper = new ObjectMapper(); + Map formData = mapper.readValue(requestBody, Map.class); + + if (formData.containsKey("id_token")) { + handleGoogleSignIn(exchange, formData.get("id_token")); + } else { + handleFormLogin(exchange, formData.get("email"), formData.get("password")); + } + } + + private void handleGoogleSignIn(HttpExchange exchange, String idTokenString) throws IOException { + HttpTransport transport = new NetHttpTransport(); + JsonFactory jsonFactory = JacksonFactory.getDefaultInstance(); + + GoogleIdTokenVerifier verifier = new GoogleIdTokenVerifier.Builder(transport, jsonFactory) + .setAudience(Collections.singletonList(CLIENT_ID)).build(); + + try { + GoogleIdToken idToken = verifier.verify(idTokenString); + if (idToken != null) { + GoogleIdToken.Payload payload = idToken.getPayload(); + String email = payload.getEmail(); + if (DatabaseUtil.userExists(email)) { + System.out.println("User exists, logging in"); + handleFormLogin(exchange, email, null); + } else { + System.out.println("User does not exist, creating new user"); + String name = (String) payload.get("name"); + DatabaseUtil.registerUser(name, email, null); // Password is null for Google login + String response = createSession(email); + Server.sendResponse(exchange, 200, response); + } + } else { + String response = "{\"message\": \"Invalid ID token\"}"; + System.out.println(response); + Server.sendResponse(exchange, 401, response); + } + } catch (SQLException e) { + e.printStackTrace(); + String response = "{\"message\": \"Database error\"}"; + System.out.println(response); + Server.sendResponse(exchange, 500, response); + } catch (GeneralSecurityException e) { + throw new RuntimeException(e); + } + } + + private void handleFormLogin(HttpExchange exchange, String email, String password) throws IOException { + try { + if (DatabaseUtil.userExists(email)) { + if (DatabaseUtil.authenticateUser(email, password)) { + String response = createSession(email); + Server.sendResponse(exchange, 200, response); + } else { + String response = "{\"message\": \"Invalid password\"}"; + System.out.println(response); + Server.sendResponse(exchange, 401, response); + } + } else { + String response = "{\"message\": \"User does not exist\"}"; + System.out.println(response); + Server.sendResponse(exchange, 404, response); + } + } catch (SQLException e) { + e.printStackTrace(); + String response = "{\"message\": \"Database error: " + e.getMessage() + "\"}"; + System.out.println(response); + Server.sendResponse(exchange, 500, response); + } + } + + private void handleLogout(HttpExchange exchange) throws IOException { + String sessionId = getSessionId(exchange); + if (sessionId != null && sessions.containsKey(sessionId)) { + sessions.remove(sessionId); + Server.sendResponse(exchange, 200, "{\"message\": \"Logout successful\"}"); + } else { + Server.sendResponse(exchange, 401, "{\"message\": \"Not logged in\"}"); + } + } + + private void handleDeleteAccount(HttpExchange exchange) throws IOException { + String userIdStr = new String(exchange.getRequestBody().readAllBytes()).replaceAll("\"", ""); + int userId = Integer.parseInt(userIdStr); + Map response = new HashMap<>(); + try { + boolean success = DatabaseUtil.deleteUser(userId); + response.put("success", success); + if (!success) { + response.put("message", "User not found"); + } + } catch (SQLException e) { + e.printStackTrace(); + response.put("success", false); + response.put("message", "Database error: " + e.getMessage()); + } + + String jsonResponse = new ObjectMapper().writeValueAsString(response); + Server.sendResponse(exchange, 200, jsonResponse); + } + + + private String createSession(String email) throws SQLException { + String sessionId = UUID.randomUUID().toString(); + sessions.put(sessionId, email); + boolean isAdmin = DatabaseUtil.isAdmin(email); + return "{\"message\": \"" + email + " logged in!\", \"sessionId\": \"" + sessionId + "\", \"isAdmin\": " + isAdmin + "}"; + } + +} Index: backend/GlobeGuru-backend/src/main/java/DatabaseUtil.java =================================================================== --- backend/GlobeGuru-backend/src/main/java/DatabaseUtil.java (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) +++ backend/GlobeGuru-backend/src/main/java/DatabaseUtil.java (revision c164f8f00c59f28d9cb253011c0a27c7471171ee) @@ -0,0 +1,345 @@ +import java.io.IOException; +import java.sql.*; +import java.time.LocalDateTime; +import java.util.ArrayList; +import java.util.List; + +public class DatabaseUtil { + + private static final String DB_URL = "jdbc:sqlite:globe_guru.db"; + + public static Connection getConnection() throws SQLException { + return DriverManager.getConnection(DB_URL); + } + public static void initializeDatabase() throws SQLException { + try (Connection conn = getConnection(); + PreparedStatement stmt1 = conn.prepareStatement( + "CREATE TABLE IF NOT EXISTS users (" + + "id INTEGER PRIMARY KEY AUTOINCREMENT, " + + "username TEXT NOT NULL UNIQUE, " + + "email TEXT NOT NULL UNIQUE, " + + "password TEXT, " + + "isAdmin BOOLEAN NOT NULL DEFAULT FALSE)" + ); + PreparedStatement stmt2 = conn.prepareStatement( + "CREATE TABLE IF NOT EXISTS options (" + + "id INTEGER PRIMARY KEY AUTOINCREMENT, " + + "link TEXT, " + + "imgSrc TEXT, " + + "hotelName TEXT, " + + "country TEXT, " + + "price REAL, " + + "dateRange TEXT, " + + "isPriceChanged BOOLEAN DEFAULT 0, " + + "newPrice REAL DEFAULT 0)" + ); + + PreparedStatement stmt3 = conn.prepareStatement( + "CREATE TABLE IF NOT EXISTS savedOptions (" + + "userId INTEGER, " + + "optionId INTEGER, " + + "FOREIGN KEY(userId) REFERENCES users(id), " + + "FOREIGN KEY(optionId) REFERENCES options(id), " + + "UNIQUE(userId, optionId))" + )) { + stmt1.executeUpdate(); + stmt2.executeUpdate(); + stmt3.executeUpdate(); + } + } + + public static boolean registerUser(String username, String email, String password) throws SQLException { + String sql = "INSERT INTO users (username, email, password) VALUES (?, ?, ?)"; + try (Connection conn = getConnection(); + PreparedStatement stmt = conn.prepareStatement(sql)) { + stmt.setString(1, username); + stmt.setString(2, email); + stmt.setString(3, password); // Store hashed + return stmt.executeUpdate() > 0; + } + } + + public static boolean authenticateUser(String email, String password) throws SQLException { + String sql = "SELECT password FROM users WHERE email = ?"; + try (Connection conn = getConnection(); + PreparedStatement stmt = conn.prepareStatement(sql)) { + stmt.setString(1, email); + try (ResultSet rs = stmt.executeQuery()) { + if (rs.next()) { + String storedPassword = rs.getString("password"); + if (password == null) { + // Assume this is a Google login + return storedPassword == null; + } + return password.equals(storedPassword); // Check hashed password + } + } + } + return false; + } + + public static boolean deleteUser(int userId) throws SQLException { + String selectSql = "SELECT userId FROM users WHERE userId = ?"; + String deleteSql = "DELETE FROM users WHERE userId = ?"; + String deleteFavoritesSql = "DELETE FROM savedOptions WHERE userId = ?"; + + try (Connection conn = getConnection(); + PreparedStatement selectStmt = conn.prepareStatement(selectSql); + PreparedStatement deleteStmt = conn.prepareStatement(deleteSql); + PreparedStatement deleteFavoritesStmt = conn.prepareStatement(deleteFavoritesSql)) { + + selectStmt.setInt(1, userId); + try (ResultSet rs = selectStmt.executeQuery()) { + if (rs.next()) { + // User exists, delete the user and their favourite options + deleteStmt.setInt(1, userId); + int rowsAffected = deleteStmt.executeUpdate(); + + deleteFavoritesStmt.setInt(1, userId); + deleteFavoritesStmt.executeUpdate(); + + return rowsAffected > 0; + } else { + // User does not exist + return false; + } + } + } + } + + public static boolean userExists(String email) throws SQLException { + String query = "SELECT COUNT(*) FROM users WHERE email = ?"; + try (Connection connection = getConnection(); + PreparedStatement statement = connection.prepareStatement(query)) { + statement.setString(1, email); + ResultSet resultSet = statement.executeQuery(); + if (resultSet.next()) { + return resultSet.getInt(1) > 0; + } + } + return false; + } + + public static boolean isAdmin(String email) throws SQLException { + String selectSql = "SELECT isAdmin FROM users WHERE email = ?"; + try (Connection conn = getConnection(); + PreparedStatement stmt = conn.prepareStatement(selectSql)) { + stmt.setString(1, email); + try (ResultSet rs = stmt.executeQuery()) { + if (rs.next()) { + return rs.getBoolean("isAdmin"); + } + } + } + return false; + } + + public static List

Scraped Data

Admin Panel

Update Info

WARNING

Saved Trips

Price Changes

Scraped Data

Admin Panel

Update Info

WARNING

Saved Trips

Price Changes

Login

Register

My account

Are you sure you want to delete your account?