@@ -40,12 +40,12 @@ public static void Initialize(string apikey)
40
40
41
41
if ( string . IsNullOrEmpty ( apikey ) )
42
42
{
43
- Data . Utils . Logging . AddLog ( new Models . SystemLog ( )
43
+ Logging . AddLog ( new SystemLog ( )
44
44
{
45
45
LoggerName = CacheData . LoggerName ,
46
46
Date = DateTime . Now ,
47
47
Function = "Unifiedban Terminal Startup" ,
48
- Level = Models . SystemLog . Levels . Fatal ,
48
+ Level = SystemLog . Levels . Fatal ,
49
49
Message = "API KEY must be set!" ,
50
50
UserId = - 1
51
51
} ) ;
@@ -65,24 +65,24 @@ public static void Initialize(string apikey)
65
65
var me = BotClient . GetMeAsync ( ) . Result ;
66
66
Username = me . Username ;
67
67
MyId = me . Id ;
68
- Data . Utils . Logging . AddLog ( new Models . SystemLog ( )
68
+ Logging . AddLog ( new SystemLog ( )
69
69
{
70
70
LoggerName = CacheData . LoggerName ,
71
71
Date = DateTime . Now ,
72
72
Function = "Unifiedban Terminal Startup" ,
73
- Level = Models . SystemLog . Levels . Warn ,
73
+ Level = SystemLog . Levels . Warn ,
74
74
Message = $ "Hello, World! I am user { me . Id } and my name is { me . FirstName } .",
75
75
UserId = - 1
76
76
} ) ;
77
77
78
78
Console . Title = $ "Unifiedban - Username: { me . Username } - Instance ID: { instanceId } ";
79
79
80
- Data . Utils . Logging . AddLog ( new Models . SystemLog ( )
80
+ Logging . AddLog ( new SystemLog ( )
81
81
{
82
82
LoggerName = CacheData . LoggerName ,
83
83
Date = DateTime . Now ,
84
84
Function = "Unifiedban Terminal Startup" ,
85
- Level = Models . SystemLog . Levels . Info ,
85
+ Level = SystemLog . Levels . Info ,
86
86
Message = "Bot Client initialized" ,
87
87
UserId = - 2
88
88
} ) ;
@@ -106,30 +106,30 @@ await BotClient.SendTextMessageAsync(
106
106
var infoUrl = $ "https://api.telegram.org/bot{ APIKEY } /getWebhookInfo";
107
107
var infoClient = new HttpClient ( ) ;
108
108
var infoRes = await infoClient . GetAsync ( infoUrl ) ;
109
- Data . Utils . Logging . AddLog ( new Models . SystemLog ( )
109
+ Logging . AddLog ( new SystemLog ( )
110
110
{
111
111
LoggerName = CacheData . LoggerName ,
112
112
Date = DateTime . Now ,
113
113
Function = "StartReceiving" ,
114
- Level = Models . SystemLog . Levels . Warn ,
114
+ Level = SystemLog . Levels . Warn ,
115
115
Message = infoRes . Content . ReadAsStringAsync ( ) . Result ,
116
116
UserId = - 2
117
117
} ) ;
118
- Data . Utils . Logging . AddLog ( new Models . SystemLog ( )
118
+ Logging . AddLog ( new SystemLog ( )
119
119
{
120
120
LoggerName = CacheData . LoggerName ,
121
121
Date = DateTime . Now ,
122
122
Function = "StartReceiving" ,
123
- Level = Models . SystemLog . Levels . Warn ,
123
+ Level = SystemLog . Levels . Warn ,
124
124
Message = $ "Skipping pending updates older than: { pastHoursToSkip } hour(s)",
125
125
UserId = - 2
126
126
} ) ;
127
- Data . Utils . Logging . AddLog ( new Models . SystemLog ( )
127
+ Logging . AddLog ( new SystemLog ( )
128
128
{
129
129
LoggerName = CacheData . LoggerName ,
130
130
Date = DateTime . Now ,
131
131
Function = "StartReceiving" ,
132
- Level = Models . SystemLog . Levels . Warn ,
132
+ Level = SystemLog . Levels . Warn ,
133
133
Message = $ "Throwing pending updates: { throwPendingUpdates } ",
134
134
UserId = - 2
135
135
} ) ;
@@ -202,6 +202,16 @@ ApiRequestException apiRequestException
202
202
=> $ "Telegram API Error:\n [{ apiRequestException . ErrorCode } ]\n { apiRequestException . Message } ",
203
203
_ => ex . ToString ( )
204
204
} ;
205
+
206
+ Logging . AddLog ( new SystemLog ( )
207
+ {
208
+ LoggerName = CacheData . LoggerName ,
209
+ Date = DateTime . Now ,
210
+ Function = "PollingErrorHandler" ,
211
+ Level = SystemLog . Levels . Error ,
212
+ Message = errMsg ,
213
+ UserId = - 1
214
+ } ) ;
205
215
206
216
if ( ! Cts . IsCancellationRequested )
207
217
Restart ( ex . Message ) ;
@@ -295,12 +305,12 @@ private static async Task HandleCallbackQuery(CallbackQuery callbackQuery)
295
305
{
296
306
if ( callbackQuery . Message ! . Date < DateTime . Now . AddHours ( - pastHoursToSkip ) )
297
307
{
298
- Data . Utils . Logging . AddLog ( new Models . SystemLog ( )
308
+ Logging . AddLog ( new SystemLog ( )
299
309
{
300
310
LoggerName = CacheData . LoggerName ,
301
311
Date = DateTime . Now ,
302
312
Function = "Unifiedban.Bot.Manager.BotClient_OnCallbackQuery" ,
303
- Level = Models . SystemLog . Levels . Debug ,
313
+ Level = SystemLog . Levels . Debug ,
304
314
Message = $ "Skipping callback older than { pastHoursToSkip } hour(s)",
305
315
UserId = - 1
306
316
} ) ;
@@ -310,14 +320,14 @@ private static async Task HandleCallbackQuery(CallbackQuery callbackQuery)
310
320
await Task . Run ( ( ) => CacheData . IncrementHandledMessages ( ) ) ;
311
321
312
322
if ( CacheData . Groups [ callbackQuery . Message . Chat . Id ] . State !=
313
- Models . Group . TelegramGroup . Status . Active ) return ;
323
+ TelegramGroup . Status . Active ) return ;
314
324
315
- Data . Utils . Logging . AddLog ( new Models . SystemLog ( )
325
+ Logging . AddLog ( new SystemLog ( )
316
326
{
317
327
LoggerName = CacheData . LoggerName ,
318
328
Date = DateTime . Now ,
319
329
Function = "Unifiedban.Bot.Manager.BotClient_OnCallbackQuery" ,
320
- Level = Models . SystemLog . Levels . Debug ,
330
+ Level = SystemLog . Levels . Debug ,
321
331
Message = "CallbackQuery received" ,
322
332
UserId = - 1
323
333
} ) ;
@@ -335,37 +345,36 @@ private static async Task HandleUpdateAsync(Message message)
335
345
{
336
346
if ( message . Date < DateTime . Now . AddHours ( - pastHoursToSkip ) )
337
347
{
338
- Data . Utils . Logging . AddLog ( new Models . SystemLog ( )
348
+ Logging . AddLog ( new SystemLog ( )
339
349
{
340
350
LoggerName = CacheData . LoggerName ,
341
351
Date = DateTime . Now ,
342
352
Function = "Unifiedban.Bot.Manager.BotClient_OnMessage" ,
343
- Level = Models . SystemLog . Levels . Debug ,
353
+ Level = SystemLog . Levels . Debug ,
344
354
Message = $ "Skipping update older than { pastHoursToSkip } hour(s)",
345
355
UserId = - 1
346
356
} ) ;
347
357
return ;
348
358
}
349
359
350
360
await Task . Run ( CacheData . IncrementHandledMessages ) ;
361
+ await Task . Run ( ( ) => Functions . CacheUsername ( message ) ) ;
351
362
352
- if ( CacheData . Groups . Keys . Contains ( message . Chat . Id ) )
353
- if ( CacheData . Groups [ message . Chat . Id ] . State !=
354
- Models . Group . TelegramGroup . Status . Active &&
355
- message . Text != "/enable" ) return ;
356
-
357
- Data . Utils . Logging . AddLog ( new Models . SystemLog ( )
363
+ Logging . AddLog ( new SystemLog ( )
358
364
{
359
365
LoggerName = CacheData . LoggerName ,
360
366
Date = DateTime . Now ,
361
367
Function = "Unifiedban.Bot.Manager.BotClient_OnMessage" ,
362
- Level = Models . SystemLog . Levels . Debug ,
368
+ Level = SystemLog . Levels . Debug ,
363
369
Message = "Message received" ,
364
370
UserId = - 1
365
371
} ) ;
366
372
367
- await Task . Run ( ( ) => Functions . CacheUsername ( message ) ) ;
368
-
373
+ if ( CacheData . Groups . Keys . Contains ( message . Chat . Id ) )
374
+ if ( CacheData . Groups [ message . Chat . Id ] . State !=
375
+ TelegramGroup . Status . Active &&
376
+ message . Text != "/enable" ) return ;
377
+
369
378
if ( message . MigrateToChatId is not null )
370
379
{
371
380
Functions . MigrateToChatId ( message ) ;
@@ -398,7 +407,7 @@ private static async Task HandleUpdateAsync(Message message)
398
407
message . Chat . Id ,
399
408
message . Chat . Id . ToString ( ) . Replace ( "-" , "" ) ,
400
409
Guid . NewGuid ( ) ) ;
401
- MessageQueueManager . EnqueueLog ( new Models . ChatMessage ( )
410
+ MessageQueueManager . EnqueueLog ( new ChatMessage ( )
402
411
{
403
412
ParseMode = ParseMode . Markdown ,
404
413
Text = logMessage
@@ -410,16 +419,15 @@ await BotClient.SendTextMessageAsync(message.Chat.Id,
410
419
"We're sorry but an error has occurred while retrieving this chat on our database.\n " +
411
420
"Please add again the bot if you want to continue to use it.\n " +
412
421
"For any doubt reach us in our support group @unifiedban_group" ) ;
413
-
414
422
}
415
423
catch ( Exception ex )
416
424
{
417
- Logging . AddLog ( new Models . SystemLog ( )
425
+ Logging . AddLog ( new SystemLog ( )
418
426
{
419
427
LoggerName = CacheData . LoggerName ,
420
428
Date = DateTime . Now ,
421
429
Function = "Unifiedban.Bot.Manager.BotClient_OnMessage" ,
422
- Level = Models . SystemLog . Levels . Warn ,
430
+ Level = SystemLog . Levels . Warn ,
423
431
Message = $ "Can't send left notification due to missing permission.\n \n { ex } ",
424
432
UserId = - 1
425
433
} ) ;
@@ -461,6 +469,7 @@ await BotClient.SendTextMessageAsync(message.Chat.Id,
461
469
Controls . Manager . DoCheck ( message ) ;
462
470
}
463
471
}
472
+
464
473
if ( message . NewChatMembers != null )
465
474
{
466
475
Functions . UserJoinedAction ( message ) ;
0 commit comments