tcp_server.hpp

이 파일의 Documentation 페이지로 가기

 
#pragma once
 
#include <stdlib.h>
 
#include <algorithm>
#include <chrono>
#include <cstdint>  // uint32_t
#include <ctime>
#include <iomanip>
#include <iostream>  // 표준 입출력 (std::cout, std::cerr)
#include <mutex>
#include <string>  // 문자열 처리 (std::string)
#include <thread>
#include <vector>  // 동적 배열 (std::vector, 여기서는 사용되지 않지만 이전 컨텍스트에서 포함됨)
 
// POSIX 소켓 API 관련 헤더
#include <arpa/inet.h>  // inet_ntoa
#include <curl/curl.h>
#include <netinet/in.h>  // sockaddr_in
#include <sys/socket.h>  // socket, bind, listen, accept
#include <unistd.h>      // close
 
// 오류 처리를 위한 추가 헤더
#include <cerrno>   // errno
#include <cstring>  // memset, strerror
#include <stdexcept>
#include <system_error>  // strerror
 
// json 처리를 위한 외부 헤더파일
#include "json.hpp"
 
// OpenSSL 관련 헤더
#include "ssl.hpp"
 
// DB 관련 헤더
#include "db_management.hpp"
 
// 카메라에 line을 설정하기 위한 헤더
#include "curl_camera.hpp"
 
#include "metadata_parser.hpp"
#include <atomic>
#include <queue>
 
// OTP 관련 헤더
#include "otp/otp_manager.hpp"
 
// 비밀번호 / 복구코드 해싱을 위한 헤더 파일
#include "hash.hpp"
 
using namespace std;
using json = nlohmann::json;
 
const int PORT = 8080;
 
// ==================== 기존 함수들 ====================
string getLines();
 
string putLines(CrossLine);
 
string deleteLines(int index);
 
int tcp_run();
 
// ==================== 새로운 유틸리티 함수들 ====================
SSL* setup_ssl_connection(int client_socket);
 
void initialize_database_tables(SQLite::Database& db);
 
bool receive_json_message(SSL* ssl, json& received_json);
 
// ==================== 요청 처리 함수들 ====================
void handle_detection_request(SSL* ssl, const json& received_json, SQLite::Database& db, std::mutex& db_mutex);
 
void handle_line_insert_request(SSL* ssl, const json& received_json, SQLite::Database& db, std::mutex& db_mutex);
 
void handle_line_select_all_request(SSL* ssl, const json& received_json, SQLite::Database& db, std::mutex& db_mutex);
 
void handle_line_delete_all_request(SSL* ssl, const json& received_json, SQLite::Database& db, std::mutex& db_mutex);
 
void handle_baseline_insert_request(SSL* ssl, const json& received_json, SQLite::Database& db, std::mutex& db_mutex);
 
void handle_vertical_line_insert_request(SSL* ssl, const json& received_json, SQLite::Database& db, std::mutex& db_mutex);
 
void handle_baseline_select_all_request(SSL* ssl, const json& received_json, SQLite::Database& db, std::mutex& db_mutex);
 
void handle_login_step1_request(SSL* ssl, const json& received_json, SQLite::Database& db, std::mutex& db_mutex);
 
void handle_login_step2_request(SSL* ssl, const json& received_json, SQLite::Database& db, std::mutex& db_mutex);
 
void handle_signup_request(SSL* ssl, const json& received_json, SQLite::Database& db, std::mutex& db_mutex);
 
void handle_bbox_start_request(SSL* ssl, std::atomic<bool>& bbox_push_enabled, std::thread& push_thread, std::thread& metadata_thread);
 
void handle_bbox_stop_request(SSL* ssl, std::atomic<bool>& bbox_push_enabled, std::thread& push_thread, std::thread& metadata_thread);
 
// ==================== 요청 라우터 및 정리 함수들 ====================
void route_request(SSL* ssl, const json& received_json, SQLite::Database& db, std::mutex& db_mutex, 
                   std::atomic<bool>& bbox_push_enabled, std::thread& push_thread, std::thread& metadata_thread);
 
void cleanup_client_connection(SSL* ssl, int client_socket, std::atomic<bool>& bbox_push_enabled, 
                               std::thread& push_thread, std::thread& metadata_thread);
 
// ==================== 메인 클라이언트 처리 함수 ====================
void handle_client(int client_socket, SQLite::Database& db, std::mutex& db_mutex);