#h9
d Z ddlZddlZddlZddlmZ ddlmZmZmZm Z ddl
m Z ddl ddl
mZ G d d Z e Zd$d
ed ed efd
Zd%ded
eded efdZd&deded efdZdeee f d efdZd&deded efdZdeeef d efdZded ed eded ef
d Z d ed ed efd!Z d" Z e d#k( r ej@ e yy)'zy
Telegram Notification Utility for SOL API
Provides functions to send messages, alerts, and reports to Telegram channels
N)datetime)OptionalDictListAny)quote)*) tg_loggerc
e Zd ZdZd dededefdZ d!deded ed
efd Zd"d eded
ed
efdZde ee
f d
efdZ d#de de
d
efdZde eef d
efdZd#deded
efdZde
de
de de
d
ef
d Zd ed ed
efd Zy)$TelegramNotifierzp
Telegram notification handler for SOL API
Supports sending messages, formatted reports, and alerts
N bot_tokenchat_idtopic_idc |xs t | _ |xs t | _ |xs t | _ | j rd| j nd| _ | j r | j st j d yy)z
Initialize Telegram notifier
Args:
bot_token: Telegram bot token (from BotFather)
chat_id: Target chat/channel ID
topic_id: Optional topic ID for groups with topics
z https://api.telegram.org/botNu* ⚠️ Telegram credentials not configured) TELEGRAM_BOT_TOKENr
TELEGRAM_CHAT_IDr TELEGRAM_TOPIC_IDr base_urltelegram_loggerwarning)selfr
r r s >/home/ubuntu/SOL_API/sol_API/src/v3/utils/telegram_notifier.py__init__zTelegramNotifier.__init__ si #8&8 2"2 5$5
KO>>6t~~6FG_c
~~T\\ # #$P Q &2 message
parse_modedisable_web_page_previewreturnc L K | j st j d y | j d}| j |||d}| j r| j |d< t j 4 d{ }|j || 4 d{ }|j dk( r|j d{ }|j d r7t j d
ddd d{ ddd d{ y t j d | ddd d{ ddd d{ y|j d{ } t j d
|j d| ddd d{ ddd d{ y7 )7 7 7 7 7 7 r7 [7 '7 # 1 d{ 7 sw Y nxY wddd d{ 7 y# 1 d{ 7 sw Y yxY w# t $ r$}
t j d|
d Y d}
~
yd}
~
ww xY ww)a[
Send a message to the configured Telegram chat
Args:
message: Message text to send
parse_mode: Parsing mode (HTML, Markdown, or None)
disable_web_page_preview: Whether to disable link previews
Returns:
bool: True if successful, False otherwise
u ❌ Telegram not configuredFz /sendMessage)r textr r message_thread_idN)json oku* 📱 Message sent to Telegram successfullyTu ❌ Telegram API error: u ❌ HTTP error : u$ ❌ Error sending Telegram message: exc_info)r r errorr r aiohttp
ClientSessionpoststatusr" getinfor Exception) r r r r urlpayloadsessionresponseresult
error_textes r send_messagez TelegramNotifier.send_message' s }} ! !"? @ ]]O<0C << (,D G }}/3}}+, ,,.
%
%'"<<'<: % %h #-'/}}!6!::d+ + 0 01] ^#' % %
%
%
% , 1 14LVH2U V#( % %
%
%
% ,4==?%:
'--?PPRS]R^._` $ % %
%
%
% %!6 %
% %
% &; %
% % % %
%
%
%
%
% ! !$H"LW[ \ s #H$AG4 9F":G4 =G F%G #F8<F(=+F8( G 3F*4G 8 G4 F,G4 H$ F8" G -F..G 2 G4 =F0>G4 H$F8F2*F8 G F4
G G4 F6 G4 !H$"G4 %G (F8*G ,G4 .G 0G4 2F84G 6G4 8G
>G?G
G
G4 GG4 H$ G1%G( &G1-G4 0H$1G4 4 H!=H H$ H!!H$titlelevelc K dddddd}|j |j d }t j j d }d | d
| d | d | d
| d j }| j
| d{ S 7 w)a
Send a formatted alert message
Args:
title: Alert title
message: Alert message
level: Alert level (INFO, WARNING, ERROR, SUCCESS)
Returns:
bool: True if successful, False otherwise
u ℹ️u ⚠️u ❌u ✅u 🚨)INFOWARNINGERRORSUCCESSCRITICALu 📢%Y-%m-%d %H:%M:%S
z z
Time: z
Level:
N)r- upperr nowstrftimestripr7 )r r8 r r9 emoji_mapemoji timestampformatted_messages r
send_alertzTelegramNotifier.send_alertX s
ekkmV4 LLN++,?@ !tE7
'
EG &&'89999s B B BB statsc K |j dd }|j dd }|j dd }|j dd }|j dd }|j dd }|dkD r||z dz nd}d | d
| d | d | d
|dd| d| dj } | j | d{ S 7 # t $ r$}
t j
d|
d Y d}
~
yd}
~
ww xY ww)z
Send a token processing completion report
Args:
stats: Statistics dictionary from token processing
Returns:
bool: True if successful, False otherwise
total_processedr good_tokens
bad_tokensalready_processedgood_pump_tokensgood_bonk_tokensd uU
🏁 Token Processing Complete
📊 Statistics:
• Total processed: u
• ✅ Good tokens: u
• ❌ Bad tokens: u
• ⚠️ Already processed: u
🎯 Success Rate: .1fu9 %
💰 Token Distribution:
• 🔵 PUMP tokens: u
• 🟠 BONK tokens: z?
Next: Processing wallets for valid tokens
Nu ❌ Error sending token report: Tr& F)r- rG r7 r/ r r( ) r rM totalgoodbadrR pump_tokens bonk_tokens success_rater r6 s r send_token_processing_reportz-TelegramNotifier.send_token_processing_reportz s0 ! II /3E99]A.D))L!,C % *=q A ))$6:K ))$6:K3819D5L3 .!L W V E 0 1 2', - #m $"m $
!
$ **733 33 ! !$DQC"HSW X sA C1B6C :B?;C >C1?C C.
C)$C1)C..C1 wallet_countprocessing_timec K |rd|ddnd}d| | dj }| j | d{ S 7 # t $ r$}t j d| d
Y d}~y d}~ww xY ww) a
Send a wallet processing completion report
Args:
wallet_count: Number of wallets processed
processing_time: Time taken in seconds
Returns:
bool: True if successful, False otherwise
u
⏱️ Processing Time: rV z seconds uU
👛 Wallet Processing Complete
📊 Results:
• Wallets processed: uM
✅ All wallet transactions have been analyzed and classified.
Nu! ❌ Error sending wallet report: Tr& FrG r7 r/ r r( )r r^ r_ time_strr r6 s r send_wallet_processing_reportz.TelegramNotifier.send_wallet_processing_report s \k:?3:OxXqsH %~hZ 0
**733 33 ! !$EaS"ITX Y ; A05A >A A0A A- A(#A0(A--A0servicesc K g }|j D ]5 \ }}|j dv rdnd}|j d| d| d| 7 dt d j | d t j j d
d j }| j | d { S 7 # t $ r$}t j d
| d Y d }~yd }~ww xY ww)z
Send system status report
Args:
services: Dictionary of service_name -> status
Returns:
bool: True if successful, False otherwise
)runningactiver$ u 🟢u 🔴u • r% u&
🖥️ System Status Report
z
Timestamp: r@ z
Nu! ❌ Error sending status report: Tr& F)
itemslowerappendchrjoinr rE rF rG r7 r/ r r( )r rf status_linesservicer, rI r r6 s r send_system_statusz#TelegramNotifier.send_system_status s L#+>>#3
H"(,,.4O"OU[ ##d5'7)2fX$FG
H R l ||~&&':;< =
**733 33 ! !$EaS"ITX Y sA C)B.B9 2B73B9 6C)7B9 9 C&C! C)!C&&C)r( contextc K |rd| nd}d| | dt j j d dj }| j d|d d { S 7 w)
z
Send an error alert
Args:
error: Error message
context: Additional context information
Returns:
bool: True if successful, False otherwise
z
Context: ra u(
🚨 Error Alert
Error: rB r@ rC z System Errorr= N)r rE rF rG rL )r r( rt context_strr s r send_error_alertz!TelegramNotifier.send_error_alert sz ;B,WI6r gk] #
,,.
!
!"5
6 7 8
EG
__^WgFFFFs AA# A! A#rps
efficiencytotal_requestsc K d|dd|dd|dd|dd j }| j | d{ S 7 # t $ r$}t j d | d
Y d}~y d}~ww xY ww)
ak
Send performance metrics report
Args:
rps: Requests per second achieved
efficiency: Efficiency percentage
total_requests: Total requests processed
processing_time: Total processing time in seconds
Returns:
bool: True if successful, False otherwise
uG
⚡ Performance Report
📈 Metrics:
• RPS Achieved: rV u
• Efficiency: u %
• Total Requests: ,u
• Processing Time: u+ s
🎯 Target RPS: 200
Nu& ❌ Error sending performance report: Tr& Frb )r rx ry rz r_ r r6 s r send_performance_reportz(TelegramNotifier.send_performance_report s s) C !#A& '%c* +
**733 33 ! !$J1#"NY] ^ re
bonk_finished
pump_finishedc K |rdnd}|rdnd}|r|rd}d}nd}d}d| d| d | | d
j }| j | d { S 7 # t $ r$}t j d | d
Y d }~yd }~ww xY ww)a
Send coordination status update
Args:
bonk_finished: Whether BONK processing is finished
pump_finished: Whether PUMP processing is finished
Returns:
bool: True if successful, False otherwise
u ✅ Finishedu ⏳ Processingu 🎉 All Workers Completeu,
🚀 Triggering wallet processing...u 🔄 Worker Status Updateu2
⏳ Waiting for all workers to complete...rA u
🟠 BONK Worker: u
🔵 PUMP Worker: z
Nu' ❌ Error sending coordination update: Tr& Frb ) r r~ r bonk_status pump_statusheaderfooterr r6 s r send_coordination_updatez)TelegramNotifier.send_coordination_update s ,9.?OK,9.?OK ;H;N % '% vh /
**733 33 ! !$KA3"OZ^ _ sA BA A
AA BA B A<7B<BB)NNN)HTMLTr; N)__name__
__module__ __qualname____doc__strr boolr7 rL r r r] intfloatrd rs rw r} r r r r r s/
R# Rs RS R" BH;?/# /3 /48/DH/b :c :C : :QU :D+S#X +4 +Z V[ gk : c3h D <GC G# G G. E 47 JO TX B!D !QU !Z^ !r r r r r c J K t j | | d{ S 7 w)z
Send a simple message to Telegram
Args:
message: Message to send
parse_mode: Parsing mode (HTML, Markdown, or None)
Returns:
bool: True if successful, False otherwise
N)notifierr7 )r r s r send_telegram_messager @ s! &&w
; ;; ; #!#r8 r9 c L K t j | || d{ S 7 w)z
Send an alert to Telegram
Args:
title: Alert title
message: Alert message
level: Alert level
Returns:
bool: True if successful, False otherwise
N)r rL )r8 r r9 s r send_telegram_alertr M s# $$UGU; ;; ;s $"$r( rt c J K t j | | d{ S 7 w)z
Send an error alert to Telegram
Args:
error: Error message
context: Additional context
Returns:
bool: True if successful, False otherwise
N)r rw )r( rt s r send_telegram_errorr [ s! **5': :: :r rM c H K t j | d{ S 7 w)z
Send token processing report to Telegram
Args:
stats: Processing statistics
Returns:
bool: True if successful, False otherwise
N)r r] )rM s r send_token_reportr h s 66u= == = " "r^ r_ c J K t j | | d{ S 7 w)z
Send wallet processing report to Telegram
Args:
wallet_count: Number of wallets processed
processing_time: Processing time in seconds
Returns:
bool: True if successful, False otherwise
N)r rd )r^ r_ s r send_wallet_reportr t s! 77 oV VV Vr rf c H K t j | d{ S 7 w)z
Send system status report to Telegram
Args:
services: Dictionary of service statuses
Returns:
bool: True if successful, False otherwise
N)r rs )rf s r send_system_status_reportr s ,,X6 66 6r rx ry rz c N K t j | ||| d{ S 7 w)a
Send performance report to Telegram
Args:
rps: Requests per second
efficiency: Efficiency percentage
total_requests: Total requests
processing_time: Processing time
Returns:
bool: True if successful, False otherwise
N)r r} )rx ry rz r_ s r r} r} s& 11#z>Sbc cc cs %#%r~ r c J K t j | | d{ S 7 w)z
Send coordination status to Telegram
Args:
bonk_finished: BONK worker status
pump_finished: PUMP worker status
Returns:
bool: True if successful, False otherwise
N)r r )r~ r s r send_coordination_statusr s! 22=-P PP Pr c K t d d{ t ddd d{ dddd d
d d } t | d{ t d
y7 A7 .7 # t $ r}t d| Y d}~yd}~ww xY ww)z)Test Telegram notifications functionalityu= 🧪 Test Message
Telegram notifications are working!Nz
Test Alertz This is a test alert messager; rU K ( # )rO rP rQ rR rS rT u" ✅ Test messages sent to Telegramu ❌ Test failed: )r r r printr/ )
test_statsr6 s r test_telegram_notificationsr s '#$efff ",0NPVWWW # !" " "
+++
23! g X , '
!!%&&'s` A>A AA AA AA A>A A A A;#A61A>6A;;A>__main__)r r r )!r r) asyncior" r typingr r r r urllib.parser utils.config utils.loggerr
r r r r r r r r r r r r r r} r r r runr r r r s_
, , 5k k\ < <# <4 < 4S>
>d
> W3 W WRV W
7d38n
7
7du d% d03dFKdPTd Q$ Qt QPT Q '2 zGKK+-. r