KashefTech commited on
Commit
3a379b2
·
verified ·
1 Parent(s): 066adcd

Upload app_fixed_v2.py

Browse files
Files changed (1) hide show
  1. app_fixed_v2.py +950 -0
app_fixed_v2.py ADDED
@@ -0,0 +1,950 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ import gradio as gr
2
+ import re
3
+ import os
4
+ import requests
5
+ import json
6
+ import logging
7
+ from typing import Dict, List, Tuple, Optional
8
+ from llm_sender_unified import create_llm_sender
9
+
10
+ # ✅ مدل‌های موجود - به‌روزرسانی نوامبر 2024
11
+ AVAILABLE_MODELS = {
12
+ "chatgpt": [
13
+ # GPT-5 Series (جدیدترین)
14
+ "gpt-5.1", # بهترین برای کدنویسی و وظایف agentic
15
+ "gpt-5", # مدل reasoning قبلی
16
+ # GPT-4 Series
17
+ "gpt-4.1", # هوشمندترین non-reasoning
18
+ "gpt-4o", # قدرتمند
19
+ "gpt-4o-mini", # سریع و ارزان
20
+ "gpt-4-turbo", # سریع‌تر از GPT-4
21
+ ],
22
+ "grok": [
23
+ # Grok-4 Series (جدیدترین)
24
+ "grok-4-fast-reasoning", # سریع با reasoning
25
+ "grok-4-fast-non-reasoning", # سریع بدون reasoning
26
+ "grok-4-0709", # نسخه پایدار
27
+ # Grok-3 Series
28
+ "grok-3", # قدرتمند
29
+ "grok-3-mini", # سبک
30
+ # Grok-2 Series
31
+ "grok-2-vision-1212", # با قابلیت بینایی
32
+ "grok-2-1212", # نسخه پایدار
33
+ "grok-2" # نسخه قدیمی
34
+ ]
35
+ }
36
+
37
+ logging.basicConfig(level=logging.INFO)
38
+ logger = logging.getLogger(__name__)
39
+
40
+ class AnonymizerAdvanced:
41
+ """ناشناس‌ساز پیشرفته با روش‌های متعدد"""
42
+
43
+ def __init__(
44
+ self,
45
+ cerebras_key: str = None,
46
+ llm_provider: str = "chatgpt",
47
+ llm_model: str = None,
48
+ entities_to_anonymize: List[str] = None
49
+ ):
50
+ self.cerebras_key = cerebras_key or os.getenv("CEREBRAS_API_KEY")
51
+ self.llm_provider = llm_provider
52
+ self.llm_model = llm_model
53
+ self.entities_to_anonymize = entities_to_anonymize or ["person", "company", "amount", "percent"]
54
+ self.mapping_table = {}
55
+ self.reverse_mapping = {}
56
+
57
+ # ایجاد LLM sender
58
+ self._create_llm_sender()
59
+
60
+ logger.info(f"✅ Anonymizer Advanced مقداردهی شد با {llm_provider}")
61
+
62
+ def _create_llm_sender(self):
63
+ """ایجاد LLM sender مناسب"""
64
+ try:
65
+ # ✅ همیشه از Hugging Face Secrets استفاده کن
66
+ if self.llm_provider == "chatgpt":
67
+ api_key = os.getenv("OPENAI_API_KEY")
68
+ logger.info("🔑 استفاده از OPENAI_API_KEY از Secrets")
69
+ elif self.llm_provider == "grok":
70
+ api_key = os.getenv("XAI_API_KEY")
71
+ logger.info("🔑 استفاده از XAI_API_KEY از Secrets")
72
+ else:
73
+ api_key = None
74
+ logger.warning("⚠️ Provider ناشناخته")
75
+
76
+ # ایجاد sender
77
+ self.llm_sender = create_llm_sender(
78
+ provider=self.llm_provider,
79
+ api_key=api_key,
80
+ model=self.llm_model
81
+ )
82
+
83
+ logger.info(f"✅ LLM Sender ایجاد شد: {self.llm_provider} - {self.llm_sender.model}")
84
+
85
+ except Exception as e:
86
+ logger.error(f"❌ خطا در ایجاد LLM Sender: {e}")
87
+ # fallback to ChatGPT
88
+ self.llm_sender = create_llm_sender("chatgpt")
89
+
90
+ def set_llm_provider(self, provider: str, model: str = None, entities: List[str] = None):
91
+ """تغییر provider و مدل LLM و موجودیت‌های ناشناس‌سازی"""
92
+ self.llm_provider = provider
93
+ self.llm_model = model
94
+ if entities is not None:
95
+ self.entities_to_anonymize = entities
96
+ self._create_llm_sender()
97
+ logger.info(f"✅ LLM تغییر یافت به: {provider} - {model}")
98
+ logger.info(f"✅ موجودیت‌های ناشناس‌سازی: {self.entities_to_anonymize}")
99
+
100
+ def anonymize_with_cerebras(self, text: str) -> Tuple[str, Dict]:
101
+ """ناشناس‌سازی با Cerebras - بر اساس موجودیت‌های انتخابی"""
102
+ logger.info("🧠 روش Cerebras...")
103
+
104
+ if not self.cerebras_key:
105
+ logger.error("❌ Cerebras API Key موجود نیست")
106
+ raise ValueError("Cerebras API Key مورد نیاز است")
107
+
108
+ # ✅ ساخت دستورات بر اساس موجودیت‌های انتخابی
109
+ instructions = []
110
+ instruction_number = 1
111
+
112
+ if "person" in self.entities_to_anonymize:
113
+ instructions.append(f"{instruction_number}. اسامی اشخاص → person-01, person-02, ...")
114
+ instruction_number += 1
115
+
116
+ if "company" in self.entities_to_anonymize:
117
+ instructions.append(f"{instruction_number}. نام شرکت‌ها/سازمان‌ها → company-01, company-02, ...")
118
+ instruction_number += 1
119
+
120
+ if "amount" in self.entities_to_anonymize:
121
+ instructions.append(f"{instruction_number}. مقادیر پولی → amount-01, amount-02, ...")
122
+ instruction_number += 1
123
+
124
+ if "percent" in self.entities_to_anonymize:
125
+ instructions.append(f"{instruction_number}. درصدها → percent-01, percent-02, ...")
126
+ instruction_number += 1
127
+
128
+ # اگه هیچی انتخاب نشده، متن رو همون‌طور برگردون
129
+ if not instructions:
130
+ logger.warning("⚠️ هیچ موجودیتی برای ناشناس‌سازی انتخاب نشده!")
131
+ return text, {}
132
+
133
+ instructions_text = "\n".join(instructions)
134
+ instructions_text += f"\n{instruction_number}. فقط این توکن‌ها استفاده کنید"
135
+ instructions_text += f"\n{instruction_number + 1}. شماره‌های نسخه را درست حفظ کنید"
136
+ instructions_text += f"\n{instruction_number + 2}. اگر موجودیت تکرار شود از شماره قدیمی استفاده کنید"
137
+
138
+ try:
139
+ # مرحله 1: ناشناس‌سازی متن
140
+ prompt1 = f"""متن زیر را ناشناس کنید. قوانین:
141
+ {instructions_text}
142
+
143
+ متن:
144
+ {text}
145
+
146
+ خروجی: فقط متن ناشناس شده"""
147
+
148
+ response1 = requests.post(
149
+ "https://api.cerebras.ai/v1/chat/completions",
150
+ headers={
151
+ "Authorization": f"Bearer {self.cerebras_key}",
152
+ "Content-Type": "application/json"
153
+ },
154
+ json={
155
+ "model": "llama-3.3-70b",
156
+ "messages": [{"role": "user", "content": prompt1}],
157
+ "max_tokens": 4096,
158
+ "temperature": 0.1
159
+ },
160
+ timeout=60
161
+ )
162
+
163
+ if response1.status_code != 200:
164
+ logger.error(f"❌ Cerebras Error: {response1.status_code}")
165
+ raise Exception(f"Cerebras API Error: {response1.status_code}")
166
+
167
+ anonymized_text = response1.json()['choices'][0]['message']['content'].strip()
168
+ logger.info("✅ Cerebras: ناشناس‌سازی موفق")
169
+
170
+ # مرحله 2: استخراج mapping - فقط برای موجودیت‌های انتخابی
171
+ mapping_instructions = []
172
+ json_example = "{\n"
173
+
174
+ if "person" in self.entities_to_anonymize:
175
+ mapping_instructions.append('- برای person-XX: نام کامل شخص (مثلاً "علی احمدی")')
176
+ json_example += ' "person-01": "متن اصلی کامل",\n'
177
+
178
+ if "company" in self.entities_to_anonymize:
179
+ mapping_instructions.append('- برای company-XX: نام کامل شرکت/سازمان (مثلاً "شرکت پتروشیمی")')
180
+ json_example += ' "company-01": "متن اصلی کامل",\n'
181
+
182
+ if "amount" in self.entities_to_anonymize:
183
+ mapping_instructions.append('- برای amount-XX: عدد + واحد (مثلاً "80 هزار تومان" یا "50 میلیارد ریال")')
184
+ json_example += ' "amount-01": "متن اصلی کامل با واحد",\n'
185
+
186
+ if "percent" in self.entities_to_anonymize:
187
+ mapping_instructions.append('- برای percent-XX: عدد + کلمه "درصد" (مثلاً "40 درصد" نه فقط "40")')
188
+ json_example += ' "percent-01": "عدد + درصد",\n'
189
+
190
+ json_example += " ...\n}"
191
+ mapping_instructions_text = "\n".join(mapping_instructions)
192
+
193
+ prompt2 = f"""متن اصلی:
194
+ {text}
195
+
196
+ متن ناشناس شده:
197
+ {anonymized_text}
198
+
199
+ لطفاً یک جدول mapping برای همه توکن‌های ناشناس ایجاد کن.
200
+ برای هر توکن، متن اصلی کامل آن را مشخص کن.
201
+
202
+ **مهم:**
203
+ {mapping_instructions_text}
204
+
205
+ خروجی را به این فرمت JSON بده (فقط JSON، بدون توضیح اضافی):
206
+ {json_example}"""
207
+
208
+ response2 = requests.post(
209
+ "https://api.cerebras.ai/v1/chat/completions",
210
+ headers={
211
+ "Authorization": f"Bearer {self.cerebras_key}",
212
+ "Content-Type": "application/json"
213
+ },
214
+ json={
215
+ "model": "llama-3.3-70b",
216
+ "messages": [{"role": "user", "content": prompt2}],
217
+ "max_tokens": 2048,
218
+ "temperature": 0.1
219
+ },
220
+ timeout=60
221
+ )
222
+
223
+ if response2.status_code == 200:
224
+ mapping_text = response2.json()['choices'][0]['message']['content'].strip()
225
+ mapping_text = mapping_text.replace('```json', '').replace('```', '').strip()
226
+
227
+ try:
228
+ self.mapping_table = json.loads(mapping_text)
229
+ self._fix_percent_mapping()
230
+ self.reverse_mapping = {v: k for k, v in self.mapping_table.items()}
231
+ logger.info(f"✅ Mapping استخراج شد: {len(self.mapping_table)} موجودیت")
232
+ except json.JSONDecodeError:
233
+ logger.warning("⚠️ خطا در parse کردن JSON mapping - استفاده از روش fallback")
234
+ self._extract_mapping_from_text(text, anonymized_text)
235
+ else:
236
+ logger.warning("⚠️ خطا در دریافت mapping - استفاده از روش fallback")
237
+ self._extract_mapping_from_text(text, anonymized_text)
238
+
239
+ return anonymized_text, self.mapping_table
240
+
241
+ except Exception as e:
242
+ logger.error(f"❌ Cerebras Exception: {e}")
243
+ raise
244
+
245
+ def _fix_percent_mapping(self):
246
+ """اصلاح mapping برای درصدها"""
247
+ for token, value in self.mapping_table.items():
248
+ value_str = str(value).strip()
249
+
250
+ if token.startswith('percent-'):
251
+ if not re.search(r'(درصد|%|درصدی)', value_str):
252
+ self.mapping_table[token] = f"{value_str} درصد"
253
+ logger.info(f"✅ اصلاح {token}: '{value_str}' → '{value_str} درصد'")
254
+
255
+ elif token.startswith('amount-'):
256
+ if not re.search(r'(میلیارد|میلیون|هزار|تومان|ریال|دلار|یورو|تن)', value_str):
257
+ logger.warning(f"⚠️ {token}: فقط عدد '{value_str}' - واحد مشخص نیست")
258
+
259
+ def _extract_mapping_from_text(self, original: str, anonymized: str):
260
+ """استخراج mapping از متن‌های اصلی و ناشناس شده - فقط برای موجودیت‌های انتخابی"""
261
+
262
+ # ✅ استخراج فقط توکن‌های انتخابی
263
+ all_tokens = []
264
+ for entity_type in self.entities_to_anonymize:
265
+ tokens = re.findall(f'{entity_type}-\\d+', anonymized)
266
+ all_tokens.extend([(t, entity_type) for t in tokens])
267
+
268
+ all_tokens = sorted(set(all_tokens), key=lambda x: (x[1], int(x[0].split('-')[1])))
269
+
270
+ # ✅ الگوهای موجودیت - فقط برای انتخابی‌ها
271
+ patterns = {}
272
+ if "person" in self.entities_to_anonymize:
273
+ patterns['person'] = r'\b[ء-ي]+\s+[ء-ي]+(?:\s+[ء-ي]+)*\b'
274
+ if "company" in self.entities_to_anonymize:
275
+ patterns['company'] = r'(?:شرکت|بانک|سازمان|گروه|هلدینگ)\s+[ء-ي]+(?:\s+[ء-ي]+)*'
276
+ if "amount" in self.entities_to_anonymize:
277
+ patterns['amount'] = r'\d+(?:\.\d+)?\s*(?:میلیارد|میلیون|هزار|تومان|ریال|دلار|یورو|تن)'
278
+ if "percent" in self.entities_to_anonymize:
279
+ patterns['percent'] = r'\d+(?:\.\d+)?\s*(?:درصد|%|درصدی)'
280
+
281
+ original_entities = {}
282
+ for entity_type, pattern in patterns.items():
283
+ matches = list(re.finditer(pattern, original))
284
+ original_entities[entity_type] = [m.group().strip() for m in matches]
285
+
286
+ for token, entity_type in all_tokens:
287
+ if entity_type in original_entities and original_entities[entity_type]:
288
+ token_num = int(token.split('-')[1]) - 1
289
+
290
+ if token_num < len(original_entities[entity_type]):
291
+ original_text = original_entities[entity_type][token_num]
292
+ self.mapping_table[token] = original_text
293
+ self.reverse_mapping[original_text] = token
294
+ else:
295
+ original_text = original_entities[entity_type][-1]
296
+ if token not in self.mapping_table:
297
+ self.mapping_table[token] = original_text
298
+ self.reverse_mapping[original_text] = token
299
+
300
+ def analyze_with_llm(self, anonymized_text: str, analysis_prompt: str = None) -> str:
301
+ """استفاده از LLM یکپارچه"""
302
+ logger.info(f"🤖 {self.llm_provider.upper()} اجرای پرامپت...")
303
+
304
+ if not analysis_prompt or not analysis_prompt.strip():
305
+ logger.info("⚠️ پرامپت خالی - بدون تحلیل")
306
+ return "⚠️ هیچ دستور تحلیل داده نشده است"
307
+
308
+ # ✅ ساخت پیام توجه بر اساس موجودیت‌های انتخاب‌شده
309
+ tokens_instruction = []
310
+ examples = []
311
+
312
+ if "person" in self.entities_to_anonymize:
313
+ tokens_instruction.append("person-XX")
314
+ examples.append("✅ صحیح: person-01 در جلسه حضور داشت\n❌ غلط: آقای person-01 یا شخص person-01")
315
+
316
+ if "company" in self.entities_to_anonymize:
317
+ tokens_instruction.append("company-XX")
318
+ examples.append("✅ صحیح: company-01 فعالیت کرد\n❌ غلط: شرکت company-01 یا سازمان company-01")
319
+
320
+ if "amount" in self.entities_to_anonymize:
321
+ tokens_instruction.append("amount-XX")
322
+ examples.append("✅ صحیح: فروش amount-01 بود\n❌ غلط: فروش مبلغ amount-01 یا فروش با amount-01")
323
+ examples.append("⚠️ بسیار مهم: فقط amount-01 بنویس، نه 'مبلغ amount-01' یا 'با amount-01' یا 'به amount-01'")
324
+
325
+ if "percent" in self.entities_to_anonymize:
326
+ tokens_instruction.append("percent-XX")
327
+ examples.append("✅ صحیح: رشد percent-01 داشت\n❌ غلط: رشد درصد percent-01")
328
+
329
+ tokens_str = ", ".join(tokens_instruction)
330
+ examples_str = "\n".join(examples)
331
+
332
+ # ✅ اضافه کردن هشدار ویژه برای amount
333
+ special_warning = ""
334
+ if "amount" in self.entities_to_anonymize:
335
+ special_warning = """
336
+ 🚨 هشدار ویژه برای amount-XX:
337
+ - NEVER write: "مبلغ amount-01" → ONLY write: "amount-01"
338
+ - NEVER write: "فروش به amount-01" → ONLY write: "فروش amount-01"
339
+ - NEVER write: "با amount-02" → ONLY write: "amount-02"
340
+ - NEVER add ANY word before or after amount tokens!
341
+ """
342
+
343
+ combined_text = f"""متن ناشناس‌سازی شده:
344
+ {anonymized_text}
345
+
346
+ دستورات:
347
+ {analysis_prompt}
348
+
349
+ ⚠️ قوانین مهم:
350
+ 1. فقط از کدهای ناشناس موجود استفاده کن: {tokens_str}
351
+ 2. هیچ کلمه‌ای قبل یا بعد از این کدها اضافه نکن
352
+ 3. کد جدید ایجاد نکن
353
+ 4. ساختار دقیق متن را حفظ کن
354
+ 5. فرمت دقیق را حفظ کن: amount-01 نه amount- 01 یا amount -01
355
+
356
+ {special_warning}
357
+
358
+ مثال‌های صحیح و غلط:
359
+ {examples_str}
360
+
361
+ هشدار: اگر کلمه‌ای مثل "شرکت"، "آقای"، "مبلغ"، "با"، "به" قبل از کدها بگذاری، پاسخ غلط است!"""
362
+
363
+ try:
364
+ response = self.llm_sender.send_simple(combined_text, lang='fa')
365
+
366
+ # ✅ پاکسازی کلمات اضافی (لایه امنیتی دوم)
367
+ response = self._clean_llm_response(response)
368
+
369
+ logger.info(f"✅ {self.llm_provider.upper()}: {len(response)} کاراکتر")
370
+ return response
371
+ except Exception as e:
372
+ logger.error(f"❌ {self.llm_provider.upper()} Exception: {e}")
373
+ return f"❌ خطا در ارتباط با {self.llm_provider.upper()}: {str(e)}"
374
+
375
+ def _clean_llm_response(self, text: str) -> str:
376
+ """پاکسازی کلمات اضافی که LLM ممکن است قبل از موجودیت‌ها اضافه کرده باشد"""
377
+ logger.info("🧹 پاکسازی کلمات اضافی...")
378
+
379
+ cleaned = text
380
+ changes_made = 0
381
+
382
+ # الگوهای کلمات اضافی برای هر نوع موجودیت
383
+ patterns = []
384
+
385
+ if "person" in self.entities_to_anonymize:
386
+ patterns.extend([
387
+ (r'(?:آقای|خانم|شخص)\s+(person-\d+)', r'\1'),
388
+ (r'(person-\d+)\s+(?:نامدار|محترم)', r'\1'),
389
+ ])
390
+
391
+ if "company" in self.entities_to_anonymize:
392
+ patterns.extend([
393
+ (r'(?:شرکت|سازمان|گروه|هلدینگ|بانک)\s+(company-\d+)', r'\1'),
394
+ (r'(company-\d+)\s+(?:محترم)', r'\1'),
395
+ ])
396
+
397
+ if "amount" in self.entities_to_anonymize:
398
+ patterns.extend([
399
+ # ✅ الگوهای بیشتر برای amount
400
+ (r'(?:مبلغ|رقم|عدد|قیمت|ارزش|فروش|درآمد|هزینه|سود|زیان)\s+(amount-\d+)', r'\1'),
401
+ (r'(amount-\d+)\s+(?:ریال|تومان|دلار|یورو|میلیون|میلیارد|هزار)', r'\1'),
402
+ # ✅ حذف "به" قبل از amount
403
+ (r'\bبه\s+(amount-\d+)', r'\1'),
404
+ # ✅ حذف "با" قبل از amount
405
+ (r'\bبا\s+(amount-\d+)', r'\1'),
406
+ # ✅ حذف "از" قبل از amount
407
+ (r'\bاز\s+(amount-\d+)', r'\1'),
408
+ # ✅ حذف "تا" قبل از amount
409
+ (r'\bتا\s+(amount-\d+)', r'\1'),
410
+ ])
411
+
412
+ if "percent" in self.entities_to_anonymize:
413
+ patterns.extend([
414
+ (r'(?:درصد|%)\s+(percent-\d+)', r'\1'),
415
+ (r'(percent-\d+)\s+(?:درصد|درصدی|%)', r'\1'),
416
+ ])
417
+
418
+ # اعمال الگوها
419
+ for pattern, replacement in patterns:
420
+ new_text = re.sub(pattern, replacement, cleaned)
421
+ if new_text != cleaned:
422
+ changes_made += re.subn(pattern, replacement, cleaned)[1]
423
+ cleaned = new_text
424
+
425
+ if changes_made > 0:
426
+ logger.info(f"✅ {changes_made} کلمه اضافی حذف شد")
427
+ else:
428
+ logger.info("✅ کلمه اضافی یافت نشد")
429
+
430
+ return cleaned
431
+
432
+ def restore_text(self, anonymized_text: str) -> str:
433
+ """بازگردانی متن"""
434
+ logger.info("🔄 بازگردانی متن...")
435
+
436
+ if not self.mapping_table:
437
+ logger.warning("⚠️ جدول نگاشت خالی است")
438
+ return anonymized_text
439
+
440
+ logger.info(f"📋 تعداد موجودیت‌ها در mapping: {len(self.mapping_table)}")
441
+
442
+ # ✅ STEP 1: ابتدا normalize کن (فاصله‌ها را درست کن)
443
+ restored = self._normalize_tokens(anonymized_text)
444
+
445
+ # ✅ STEP 2: بعد clean کن (کلمات اضافی را حذف کن)
446
+ # این ترتیب مهمه چون بعد از normalize، clean بهتر کار می‌کنه
447
+ restored = self._clean_for_restore(restored)
448
+
449
+ replacements_count = 0
450
+
451
+ # جایگزینی با ترتیب از طولانی‌ترین به کوتاه‌ترین برای جلوگیری از جایگزینی اشتباه
452
+ for placeholder, original in sorted(self.mapping_table.items(), key=lambda x: len(x[0]), reverse=True):
453
+ if placeholder in restored:
454
+ restored = restored.replace(placeholder, original)
455
+ replacements_count += 1
456
+ logger.info(f"✅ {placeholder} → {original[:30]}...")
457
+ else:
458
+ logger.warning(f"⚠️ {placeholder} در متن یافت نشد!")
459
+
460
+ logger.info(f"✅ بازگردانی کامل - {replacements_count}/{len(self.mapping_table)} جایگزین شد")
461
+
462
+ # ✅ اگر amount ها جایگزین نشدن، سعی کن با regex پیداشون کنی
463
+ if replacements_count < len(self.mapping_table):
464
+ logger.info("🔍 تلاش برای یافتن توکن‌های گم‌شده با regex...")
465
+ restored = self._restore_with_regex(restored)
466
+
467
+ # اگر هیچ جایگزینی انجام نشد، احتمالاً مشکل وجود دارد
468
+ if replacements_count == 0 and len(self.mapping_table) > 0:
469
+ logger.error("❌ هیچ توکنی جایگزین نشد! متن ورودی احتمالاً متفاوت است.")
470
+
471
+ return restored
472
+
473
+ def _clean_for_restore(self, text: str) -> str:
474
+ """پاکسازی خاص برای بازگردانی (شبیه _clean_llm_response اما سبک‌تر)"""
475
+ logger.info("🧹 پاکسازی قبل از بازگردانی...")
476
+
477
+ cleaned = text
478
+ changes_made = 0
479
+
480
+ patterns = []
481
+
482
+ if "amount" in self.entities_to_anonymize:
483
+ patterns.extend([
484
+ (r'(?:مبلغ|رقم|عدد|قیمت|ارزش|فروش|درآمد|هزینه|سود|زیان)\s+(amount-\d+)', r'\1'),
485
+ (r'\bبه\s+(amount-\d+)', r'\1'),
486
+ (r'\bبا\s+(amount-\d+)', r'\1'),
487
+ (r'\bاز\s+(amount-\d+)', r'\1'),
488
+ (r'\bتا\s+(amount-\d+)', r'\1'),
489
+ ])
490
+
491
+ for pattern, replacement in patterns:
492
+ new_text = re.sub(pattern, replacement, cleaned)
493
+ if new_text != cleaned:
494
+ changes_made += re.subn(pattern, replacement, cleaned)[1]
495
+ cleaned = new_text
496
+
497
+ if changes_made > 0:
498
+ logger.info(f"✅ {changes_made} کلمه اضافی حذف شد")
499
+
500
+ return cleaned
501
+
502
+ def _restore_with_regex(self, text: str) -> str:
503
+ """بازگردانی با استفاده از regex برای پیدا کردن توکن‌های دارای کلمات اضافی"""
504
+ restored = text
505
+
506
+ for placeholder, original in self.mapping_table.items():
507
+ # اگر قبلاً جایگزین شده، رد شو
508
+ if placeholder not in text:
509
+ # الگوی regex: کلمه اضافی (اختیاری) + توکن
510
+ # مثلاً: "فروش amount-01" یا "مبلغ amount-05"
511
+ entity_type = placeholder.split('-')[0]
512
+ entity_num = placeholder.split('-')[1]
513
+
514
+ # الگوهای مختلف
515
+ patterns = [
516
+ # کلمه فارسی + فاصله + توکن
517
+ rf'[ء-ي]+\s+({entity_type}-{entity_num})\b',
518
+ # توکن + فاصله + کلمه فارسی
519
+ rf'\b({entity_type}-{entity_num})\s+[ء-ي]+',
520
+ # فاصله اضافی داخل توکن
521
+ rf'\b{entity_type}\s+-\s+{entity_num}\b',
522
+ ]
523
+
524
+ for pattern in patterns:
525
+ matches = list(re.finditer(pattern, restored))
526
+ if matches:
527
+ logger.info(f"✅ پیدا شد با regex: {pattern}")
528
+ for match in matches:
529
+ # جایگزینی کل عبارت با فقط original
530
+ full_match = match.group(0)
531
+ # اگر توکن داخل match هست، فقط اون رو جایگزین کن
532
+ if placeholder in full_match:
533
+ restored = restored.replace(full_match, full_match.replace(placeholder, original))
534
+ else:
535
+ # اگر فرمت توکن متفاوت بود
536
+ restored = restored.replace(full_match, original)
537
+ logger.info(f"✅ regex: {placeholder} → {original[:30]}...")
538
+ break
539
+
540
+ return restored
541
+
542
+ def _normalize_tokens(self, text: str) -> str:
543
+ """نرمال‌سازی توکن‌ها - حذف فاصله‌های اضافی"""
544
+ logger.info("🧹 نرمال‌سازی توکن‌ها...")
545
+
546
+ normalized = text
547
+ changes = 0
548
+
549
+ # الگوهای فاصله اضافی در توکن‌ها
550
+ patterns = [
551
+ # حذف فاصله‌های اضافی داخل توکن
552
+ (r'(person|company|amount|percent)\s*-\s*(\d+)', r'\1-\2'),
553
+ # حذف فاصله‌های اضافی بعد از توکن
554
+ (r'(person|company|amount|percent)-(\d+)\s+(?=[^\d])', r'\1-\2 '),
555
+ ]
556
+
557
+ for pattern, replacement in patterns:
558
+ new_text = re.sub(pattern, replacement, normalized)
559
+ if new_text != normalized:
560
+ changes += re.subn(pattern, replacement, normalized)[1]
561
+ normalized = new_text
562
+
563
+ if changes > 0:
564
+ logger.info(f"✅ {changes} فاصله اضافی حذف شد")
565
+
566
+ return normalized
567
+
568
+ def get_mapping_table_md(self) -> str:
569
+ """تبدیل جدول نگاشت به Markdown"""
570
+ if not self.mapping_table:
571
+ return "### 📋 جدول نگاشت\n\nهیچ موجودیتی شناسایی نشد"
572
+
573
+ table = "### 📋 جدول نگاشت\n\n"
574
+ table += "| شناسه | متن اصلی |\n"
575
+ table += "|-------|----------|\n"
576
+
577
+ for token, original in sorted(self.mapping_table.items()):
578
+ table += f"| **{token}** | {original} |\n"
579
+
580
+ return table
581
+
582
+ # متغیر سراسری
583
+ anonymizer = None
584
+
585
+ def process(
586
+ input_text: str,
587
+ analysis_prompt: str,
588
+ llm_provider: str,
589
+ llm_model: str,
590
+ anonymize_all: bool,
591
+ anonymize_person: bool,
592
+ anonymize_company: bool,
593
+ anonymize_amount: bool,
594
+ anonymize_percent: bool
595
+ ):
596
+ """پردازش متن - 4 مرحله"""
597
+ global anonymizer
598
+
599
+ if not input_text.strip():
600
+ return "", "", "", ""
601
+
602
+ # ✅ ساخت لیست موجودیت‌های انتخابی
603
+ if anonymize_all:
604
+ entities = ["person", "company", "amount", "percent"]
605
+ else:
606
+ entities = []
607
+ if anonymize_person:
608
+ entities.append("person")
609
+ if anonymize_company:
610
+ entities.append("company")
611
+ if anonymize_amount:
612
+ entities.append("amount")
613
+ if anonymize_percent:
614
+ entities.append("percent")
615
+
616
+ # اگه هیچی انتخاب نشده
617
+ if not entities:
618
+ return "", "❌ لطفاً حداقل یک موجودیت برای ناشناس‌سازی انتخاب کنید", "", ""
619
+
620
+ cerebras_key = os.getenv("CEREBRAS_API_KEY")
621
+
622
+ # ایجاد یا آپدیت anonymizer
623
+ if not anonymizer:
624
+ anonymizer = AnonymizerAdvanced(
625
+ cerebras_key,
626
+ llm_provider=llm_provider,
627
+ llm_model=llm_model,
628
+ entities_to_anonymize=entities
629
+ )
630
+ else:
631
+ anonymizer.set_llm_provider(llm_provider, llm_model, entities)
632
+ anonymizer.mapping_table = {}
633
+ anonymizer.reverse_mapping = {}
634
+
635
+ try:
636
+ logger.info("=" * 70)
637
+ logger.info(f"🚀 شروع پردازش - LLM: {llm_provider} ({llm_model})")
638
+ logger.info(f"🎯 موجودیت‌های انتخابی: {', '.join(entities)}")
639
+ logger.info("=" * 70)
640
+
641
+ # مرحله 1: ناشناس‌سازی
642
+ logger.info("🔐 مرحله 1: ناشناس‌سازی...")
643
+ anonymized_text, _ = anonymizer.anonymize_with_cerebras(input_text)
644
+ logger.info(f"✅ ناشناس‌سازی: {len(anonymized_text)} کاراکتر")
645
+
646
+ # مرحله 2: LLM (فقط اگر analysis_prompt داده شده باشد)
647
+ has_analysis = analysis_prompt and analysis_prompt.strip()
648
+
649
+ if has_analysis:
650
+ logger.info(f"🤖 مرحله 2: {llm_provider.upper()}...")
651
+ llm_response = anonymizer.analyze_with_llm(anonymized_text, analysis_prompt)
652
+ logger.info(f"✅ {llm_provider.upper()}: {len(llm_response)} کاراکتر")
653
+ else:
654
+ logger.info("⚠️ مرحله 2: بدون تحلیل LLM (پرامپت خالی)")
655
+ llm_response = "⚠️ هیچ دستور تحلیل داده نشده است"
656
+
657
+ # مرحله 3: بازگردانی
658
+ logger.info("🔄 مرحله 3: بازگردانی...")
659
+
660
+ # ✅ اصلاح: اگر تحلیل انجام نشده، متن ناشناس اصلی رو restore کن
661
+ if has_analysis:
662
+ # اگر LLM تحلیل کرده، خروجی LLM رو restore کن
663
+ restored_text = anonymizer.restore_text(llm_response)
664
+ else:
665
+ # اگر تحلیل نشده، متن ناشناس اصلی رو restore کن
666
+ restored_text = anonymizer.restore_text(anonymized_text)
667
+
668
+ logger.info("✅ بازگردانی کامل")
669
+
670
+ # مرحله 4: جدول نگاشت
671
+ logger.info("📋 مرحله 4: جدول نگاشت...")
672
+ mapping_str = anonymizer.get_mapping_table_md()
673
+ logger.info(f"✅ {len(anonymizer.mapping_table)} موجودیت")
674
+
675
+ logger.info("=" * 70)
676
+ logger.info("✅ تمام مراحل کامل!")
677
+ logger.info("=" * 70)
678
+
679
+ return restored_text, llm_response, anonymized_text, mapping_str
680
+
681
+ except Exception as e:
682
+ logger.error(f"❌ خطا: {str(e)}", exc_info=True)
683
+ return "", f"❌ خطا: {str(e)}", "", ""
684
+
685
+ def clear_all():
686
+ """پاک کردن همه"""
687
+ return "", "", "", "", "", "", True, False, False, False, False
688
+
689
+ # Gradio Interface
690
+ css_rtl = """
691
+ .input-box {
692
+ direction: rtl;
693
+ text-align: right;
694
+ }
695
+ .textbox textarea {
696
+ direction: rtl;
697
+ text-align: right;
698
+ font-family: 'Tahoma', serif;
699
+ }
700
+ .thick-divider {
701
+ border-top: 2px solid #333;
702
+ margin: 10px 0;
703
+ }
704
+ .compact-group {
705
+ margin: 0;
706
+ padding: 0;
707
+ }
708
+ .compact-checkbox label {
709
+ padding: 5px 10px !important;
710
+ margin: 3px 0 !important;
711
+ font-size: 0.95em !important;
712
+ }
713
+ """
714
+
715
+ with gr.Blocks(title="سیستم ناشناس‌سازی متون", theme=gr.themes.Soft(), css=css_rtl) as app:
716
+
717
+ gr.Markdown("# 🔐 پلتفرم امن چت با مدل‌های متنوع و ناشناس‌سازی داده‌ها", elem_classes="input-box")
718
+
719
+ # ردیف اول: تنظیمات مدل و انتخاب موجودیت‌ها
720
+ with gr.Row():
721
+ # سمت راست: تنظیمات مدل
722
+ with gr.Column(scale=1):
723
+ with gr.Group():
724
+ gr.Markdown("### ⚙️ تنظیمات مدل", elem_classes="input-box")
725
+
726
+ llm_provider = gr.Dropdown(
727
+ choices=["chatgpt", "grok"],
728
+ value="chatgpt",
729
+ label="🤖 انتخاب مدل زبانی",
730
+ interactive=True
731
+ )
732
+
733
+ llm_model = gr.Dropdown(
734
+ choices=AVAILABLE_MODELS["chatgpt"],
735
+ value="gpt-4o-mini",
736
+ label="📦 انتخاب نسخه مدل",
737
+ interactive=True
738
+ )
739
+
740
+ # سمت چپ: انتخاب موجودیت‌ها
741
+ with gr.Column(scale=1):
742
+ with gr.Group():
743
+ gr.Markdown("### 🎯 انتخاب موجودیت‌ها", elem_classes="input-box")
744
+
745
+ anonymize_all = gr.Checkbox(
746
+ label="✅ همه موجودیت‌ها",
747
+ value=True,
748
+ elem_classes="input-box compact-checkbox"
749
+ )
750
+
751
+ anonymize_person = gr.Checkbox(
752
+ label="👤 اسامی اشخاص",
753
+ value=False,
754
+ elem_classes="input-box compact-checkbox"
755
+ )
756
+
757
+ anonymize_company = gr.Checkbox(
758
+ label="🏢 نام شرکت‌ها",
759
+ value=False,
760
+ elem_classes="input-box compact-checkbox"
761
+ )
762
+
763
+ anonymize_amount = gr.Checkbox(
764
+ label="💰 ارقام مالی",
765
+ value=False,
766
+ elem_classes="input-box compact-checkbox"
767
+ )
768
+
769
+ anonymize_percent = gr.Checkbox(
770
+ label="📊 درصدها",
771
+ value=False,
772
+ elem_classes="input-box compact-checkbox"
773
+ )
774
+
775
+ # خط جداکننده پررنگ
776
+ gr.Markdown("---", elem_classes="thick-divider")
777
+
778
+ # ردیف دوم: دستورات پردازش و متن ورودی
779
+ with gr.Row():
780
+ # سمت راست: دستورات پردازش
781
+ with gr.Column(scale=1):
782
+ gr.Markdown("### 📋 دستورات پردازش", elem_classes="input-box")
783
+
784
+ analysis_prompt = gr.Textbox(
785
+ lines=22,
786
+ placeholder="مثال: این متن را خلاصه کن\nیا: نکات کلیدی را استخراج کن",
787
+ label="📋 دستورات LLM (اختیاری)",
788
+ elem_classes="textbox"
789
+ )
790
+
791
+ # سمت چپ: متن ورودی
792
+ with gr.Column(scale=1):
793
+ gr.Markdown("### 📝 متن ورودی", elem_classes="input-box")
794
+
795
+ input_text = gr.Textbox(
796
+ lines=22,
797
+ placeholder="متن مالی/خبری را وارد کنید...",
798
+ label="",
799
+ elem_classes="textbox"
800
+ )
801
+
802
+ # دکمه‌های پردازش و پاک کردن
803
+ with gr.Row():
804
+ process_btn = gr.Button(
805
+ "▶️ پردازش",
806
+ variant="primary",
807
+ size="lg",
808
+ scale=2
809
+ )
810
+
811
+ clear_btn = gr.Button(
812
+ "🗑️ پاک کردن",
813
+ variant="stop",
814
+ size="lg",
815
+ scale=1
816
+ )
817
+
818
+ # نتایج
819
+ gr.Markdown("## 📊 نتایج پردازش", elem_classes="input-box")
820
+
821
+ with gr.Row():
822
+ with gr.Column(scale=1):
823
+ restored_text = gr.Textbox(
824
+ lines=12,
825
+ label="✅ متن بازگردانی شده",
826
+ interactive=False,
827
+ elem_classes="textbox"
828
+ )
829
+
830
+ with gr.Column(scale=1):
831
+ llm_analysis = gr.Textbox(
832
+ lines=12,
833
+ label="🤖 تحلیل LLM",
834
+ interactive=False,
835
+ elem_classes="textbox"
836
+ )
837
+
838
+ with gr.Column(scale=1):
839
+ anonymized_text = gr.Textbox(
840
+ lines=12,
841
+ label="🔒 متن ناشناس‌شده",
842
+ interactive=False,
843
+ elem_classes="textbox"
844
+ )
845
+
846
+ mapping_table = gr.Markdown(
847
+ value="### 📋 جدول نگاشت\n\nهنوز پردازشی انجام نشده",
848
+ label="📋 جدول نگاشت",
849
+ elem_classes="input-box"
850
+ )
851
+
852
+
853
+ # Event Handler برای تغییر provider
854
+ def handle_provider_change(provider):
855
+ models = AVAILABLE_MODELS.get(provider, [])
856
+ default_model = models[0] if models else None
857
+ return gr.update(choices=models, value=default_model)
858
+
859
+ llm_provider.change(
860
+ fn=handle_provider_change,
861
+ inputs=[llm_provider],
862
+ outputs=[llm_model]
863
+ )
864
+
865
+ def handle_select_all(select_all):
866
+ if select_all:
867
+ return (
868
+ gr.update(value=False, interactive=False),
869
+ gr.update(value=False, interactive=False),
870
+ gr.update(value=False, interactive=False),
871
+ gr.update(value=False, interactive=False)
872
+ )
873
+ else:
874
+ return (
875
+ gr.update(value=False, interactive=True),
876
+ gr.update(value=False, interactive=True),
877
+ gr.update(value=False, interactive=True),
878
+ gr.update(value=False, interactive=True)
879
+ )
880
+
881
+ anonymize_all.change(
882
+ fn=handle_select_all,
883
+ inputs=[anonymize_all],
884
+ outputs=[anonymize_person, anonymize_company, anonymize_amount, anonymize_percent]
885
+ )
886
+
887
+ # پردازش
888
+ process_btn.click(
889
+ fn=process,
890
+ inputs=[
891
+ input_text,
892
+ analysis_prompt,
893
+ llm_provider,
894
+ llm_model,
895
+ anonymize_all,
896
+ anonymize_person,
897
+ anonymize_company,
898
+ anonymize_amount,
899
+ anonymize_percent
900
+ ],
901
+ outputs=[restored_text, llm_analysis, anonymized_text, mapping_table]
902
+ )
903
+
904
+ # پاک کردن
905
+ clear_btn.click(
906
+ fn=clear_all,
907
+ outputs=[
908
+ input_text,
909
+ analysis_prompt,
910
+ restored_text,
911
+ llm_analysis,
912
+ anonymized_text,
913
+ mapping_table,
914
+ anonymize_all,
915
+ anonymize_person,
916
+ anonymize_company,
917
+ anonymize_amount,
918
+ anonymize_percent
919
+ ]
920
+ )
921
+
922
+ if __name__ == "__main__":
923
+ print("=" * 70)
924
+ print("🚀 سیستم ناشناس‌سازی متون در حال راه‌اندازی...")
925
+ print("=" * 70)
926
+ print("\n📋 نحوه استفاده:\n")
927
+ print("1. API Keyها را در Hugging Face Secrets تنظیم کنید:")
928
+ print(" - CEREBRAS_API_KEY (ضروری برای ناشناس‌سازی)")
929
+ print(" - OPENAI_API_KEY (برای ChatGPT)")
930
+ print(" - XAI_API_KEY (برای Grok)")
931
+ print("2. http://localhost:7860 را باز کنید")
932
+ print("3. مدل زبانی (ChatGPT/Grok) و نسخه مدل را انتخاب کنید")
933
+ print("4. موجودیت‌های مورد نظر برای ناشناس‌سازی را انتخاب کنید")
934
+ print("5. متن و دستورات پردازش را وارد کنید")
935
+ print("6. 'پردازش' را کلیک کنید\n")
936
+ print("🔐 تمام API Keyها از Hugging Face Secrets خوانده می‌شوند")
937
+ print("📦 مدل‌های پشتیبانی شده:")
938
+ print(" • ChatGPT GPT-5: gpt-5.1, gpt-5")
939
+ print(" • ChatGPT GPT-4: gpt-4.1, gpt-4o, gpt-4o-mini, gpt-4-turbo")
940
+ print(" • Grok-4: grok-4-fast-reasoning, grok-4-fast-non-reasoning, grok-4-0709")
941
+ print(" • Grok-3: grok-3, grok-3-mini")
942
+ print(" • Grok-2: grok-2-vision-1212, grok-2-1212, grok-2")
943
+ print("=" * 70 + "\n")
944
+
945
+ app.launch(
946
+ server_name="0.0.0.0",
947
+ server_port=7860,
948
+ share=False,
949
+ show_error=True
950
+ )