Skip to main content

mkt_ksa_geo_sec/api/
behavior.rs

1/******************************************************************************************
2      📍 منصة تحليل الأمان الجغرافي MKT KSA – تطوير منصور بن خالد
3* 📄 رخصة Apache 2.0 – يسمح بالاستخدام والتعديل بشرط النسبة وعدم تقديم ضمانات.
4* MKT KSA Geolocation Security – Developed by Mansour Bin Khalid (KSA 🇸🇦)
5* Licensed under Apache 2.0 – https://www.apache.org/licenses/LICENSE-2.0
6* © 2025 All rights reserved.
7
8     اسم الملف: behavior.rs
9    المسار: src/api/behavior.rs
10
11    وظيفة الملف:
12    هذا الملف مسؤول عن جميع العمليات المتعلقة بتحليل سلوك المستخدم أو الجهاز عبر واجهة برمجة التطبيقات (API).
13    يوفر نقطة نهاية (Endpoint) لتحليل السلوك، حيث يستقبل الطلبات التي تحتوي على بيانات سلوكية،
14    ثم يمررها إلى محرك التحليل في طبقة core (BehaviorEngine)، ويعيد النتيجة النهائية بشكل JSON.
15    يتحقق من صلاحية المستخدم عبر JWT قبل تنفيذ التحليل، ويضمن أن كل عملية تحليل تتم بشكل آمن وموثوق.
16    الملف مصمم ليكون نقطة مركزية لأي نظام خارجي أو واجهة مستخدم ترغب في تحليل سلوك المستخدمين أو الأجهزة.
17
18    File name: behavior.rs
19    Path: src/api/behavior.rs
20
21    File purpose:
22    This file is responsible for all operations related to user or device behavior analysis via the API.
23    It provides an endpoint for behavior analysis, receiving requests containing behavioral data,
24    then passing them to the analysis engine in the core layer (BehaviorEngine), and returning the final result as JSON.
25    It verifies user authorization via JWT before performing the analysis, ensuring every analysis operation is secure and reliable.
26    The file is designed as a central point for any external system or user interface wishing to analyze user or device behavior.
27******************************************************************************************/
28use crate::api::api_error;
29use crate::api::authorize_request;
30use crate::api::ok_json_with_trace;
31use crate::api::parse_json_payload;
32use crate::api::BearerToken;
33use crate::core::behavior_bio::BehaviorInput;
34use crate::AppState;
35use actix_web::http::StatusCode;
36use actix_web::{post, web, HttpRequest, Responder};
37use serde::Deserialize;
38
39/// نموذج الطلب لتحليل السلوك.
40/// Request model for behavior analysis.
41#[derive(Deserialize)]
42pub struct BehaviorAnalyzeRequest {
43    pub input: BehaviorInput, // بيانات السلوك المراد تحليلها
44                              // Behavioral data to be analyzed
45}
46
47/// نقطة نهاية لتحليل السلوك عبر POST /behavior/analyze
48/// Endpoint to analyze behavior via POST /behavior/analyze
49#[post("/behavior/analyze")]
50pub async fn analyze_behavior(
51    app_data: web::Data<AppState>,
52    req: HttpRequest,
53    bearer: BearerToken,
54    payload_bytes: web::Bytes,
55) -> impl Responder {
56    if let Err(resp) = authorize_request(&app_data, &req, &bearer, &payload_bytes).await {
57        return resp;
58    }
59
60    let payload: BehaviorAnalyzeRequest = match parse_json_payload(&payload_bytes) {
61        Ok(v) => v,
62        Err(resp) => return resp,
63    };
64
65    // --- تمرير الطلب لمحرك core ---
66    let engine = &app_data.x_engine.behavior_engine;
67    match engine.process(payload.input.clone()).await {
68        Ok(result) => ok_json_with_trace(&req, result), // إعادة نتيجة التحليل بنجاح
69        // Return analysis result on success
70        Err(_) => api_error(
71            StatusCode::INTERNAL_SERVER_ERROR,
72            "BEHAVIOR_ANALYSIS_INTERNAL_ERROR",
73            "Internal error while analyzing behavior",
74        ),
75    }
76}