import
asyncio
from
aiogram
import
Bot
,
Dispatcher
,
types
from
aiogram
.
types
import
InlineKeyboardMarkup
,
InlineKeyboardButton
,
ReplyKeyboardMarkup
,
KeyboardButton
from
aiogram
.
filters
.
command
import
Command
import
requests
import
json
import
logging

bot
=
Bot
(
token
=
'botfather'
)
dp
=
Dispatcher
(
)
CHANNEL_ID
=
"id and @"
def
create_subscription_keyboard
(
)
:
keyboard
=
InlineKeyboardMarkup
(
inline_keyboard
=
[
[
InlineKeyboardButton
(
text
=
"Подписаться на канал"
,
url
=
f"https://t.me/{CHANNEL_ID[1:]}"
)
]
,
[
InlineKeyboardButton
(
text
=
"Проверить подписку"
,
callback_data
=
"check_subscription"
)
]
]
)
return
keyboard
def
create_check_events_keyboard
(
)
:
keyboard
=
InlineKeyboardMarkup
(
inline_keyboard
=
[
[
InlineKeyboardButton
(
text
=
"Проверить события"
,
callback_data
=
"check_events"
)
]
]
)
return
keyboard
def
create_main_keyboard
(
)
:
keyboard
=
ReplyKeyboardMarkup
(
keyboard
=
[
[
KeyboardButton
(
text
=
"Телеграм Канал"
)
,
KeyboardButton
(
text
=
"Текущие Ивенты"
)
]
]
,
resize_keyboard
=
True
)
return
keyboard
async
def
check_subscription
(
user_id
:
int
)
-
>
bool
:
try
:
member
=
await
bot
.
get_chat_member
(
CHANNEL_ID
,
user_id
)
return
member
.
status
in
[
'member'
,
'administrator'
,
'creator'
]
except
:
return
False
async
def
fetch_events
(
)
:
try
:
url
=
"https://cheathub.tech/api/telegram-data"
headers
=
{
'Cookie'
:
'cookie'
}
response
=
requests
.
get
(
url
,
headers
=
headers
)
response
.
encoding
=
'utf-8'
data
=
response
.
text
.
encode
(
'utf-8'
)
.
decode
(
'utf-8'
)
json_data
=
json
.
loads
(
data
)
events
=
json_data
.
get
(
'events'
,
[
]
)
current_events
=
[
]
upcoming_events
=
[
]
for
event
in
events
:
event_type
=
event
.
get
(
'type'
,
''
)
.
replace
(
'❄️ Снежная бойня'
,
'🚀 Адская резня'
)
status
=
event
.
get
(
'status'
,
''
)
server
=
event
.
get
(
'server'
,
''
)
location
=
event
.
get
(
'location'
,
''
)
loot_level
=
event
.
get
(
'lootLevel'
,
''
)
location_text
=
location
if
not
location
or
location
.
strip
(
)
==
''
:
location_text
=
"Координаты пока не доступны"
elif
len
(
location
)
==
4
:
location_text
=
location
[
1
:
-
1
]
loot_level_text
=
loot_level
if
not
loot_level
or
loot_level
.
strip
(
)
==
''
:
loot_level_text
=
"Информация о луте пока не доступна"
formatted_event
=
f"*Тип:*{event_type}\n*Статус:*{status}\n*Сервер:*{server}\n*Локация:*{location_text}\n*Лут:*{loot_level_text}\n{'—'*20}"
if
'начнется через'
in
status
.
lower
(
)
:
upcoming_events
.
append
(
formatted_event
)
elif
not
any
(
x
in
status
for
x
in
[
'Сундуки открыты!'
,
'звергается'
,
'Сундуки открыты'
,
'Сундук открыт'
]
)
:
current_events
.
append
(
formatted_event
)
return
current_events
,
upcoming_events
except
Exception
as
e
:
logging
.
error
(
f"Error fetching events:{e}"
)
return
[
]
,
[
]
@dp.message
(
Command
(
"start"
)
)
async
def
cmd_start
(
message
:
types
.
Message
)
:
if
await
check_subscription
(
message
.
from_user
.
id
)
:
welcome_text
=
"Привет! Я бот для отслеживания Funtime событий.\n"
await
message
.
reply
(
welcome_text
,
reply_markup
=
create_main_keyboard
(
)
)
else
:
text
=
"Привет! Для использования бота необходимо подписаться на наш канал."
await
message
.
reply
(
text
,
reply_markup
=
create_subscription_keyboard
(
)
)
@dp.message
(
lambda
message
:
message
.
text
in
[
"Телеграм Канал"
,
"Текущие Ивенты"
]
)
async
def
handle_events_buttons
(
message
:
types
.
Message
)
:
if
not
await
check_subscription
(
message
.
from_user
.
id
)
:
text
=
"Для использования бота необходимо подписаться на наш канал."
await
message
.
reply
(
text
,
reply_markup
=
create_subscription_keyboard
(
)
)
return
current_events
,
upcoming_events
=
await
fetch_events
(
)
if
message
.
text
==
"Телеграм Канал"
:
if
upcoming_events
:
combined_message
=
"\n\n"
.
join
(
upcoming_events
)
await
message
.
answer
(
combined_message
,
parse_mode
=
"Markdown"
)
else
:
await
message
.
answer
(
"Телеграм Канал: @ftevent_bot_kanal"
)
elif
message
.
text
==
"Текущие Ивенты"
:
if
current_events
:
combined_message
=
"\n\n"
.
join
(
current_events
)
await
message
.
answer
(
combined_message
,
parse_mode
=
"Markdown"
)
else
:
await
message
.
answer
(
"На данный момент нет текущих событий."
)
@dp.message
(
Command
(
"events"
)
)
async
def
cmd_events
(
message
:
types
.
Message
)
:
if
not
await
check_subscription
(
message
.
from_user
.
id
)
:
text
=
"Для использования бота необходимо подписаться на наш канал."
await
message
.
reply
(
text
,
reply_markup
=
create_subscription_keyboard
(
)
)
return
current_events
,
upcoming_events
=
await
fetch_events
(
)
all_events
=
current_events
+
upcoming_events
if
all_events
:
combined_message
=
"\n\n"
.
join
(
all_events
)
await
message
.
answer
(
combined_message
,
parse_mode
=
"Markdown"
)
else
:
await
message
.
answer
(
"На данный момент нет активных событий."
)
@dp.callback_query
(
lambda
c
:
c
.
data
==
"check_subscription"
)
async
def
callback_check_subscription
(
callback_query
:
types
.
CallbackQuery
)
:
if
await
check_subscription
(
callback_query
.
from_user
.
id
)
:
await
callback_query
.
message
.
delete
(
)
welcome_text
=
"Спасибо за подписку! Теперь вы можете использовать бота.\n\nВыберите тип событий:"
await
callback_query
.
message
.
answer
(
welcome_text
,
reply_markup
=
create_main_keyboard
(
)
)
else
:
await
callback_query
.
answer
(
"Вы не подписались на канал!"
,
show_alert
=
True
)
@dp.callback_query
(
lambda
c
:
c
.
data
==
"check_events"
)
async
def
callback_check_events
(
callback_query
:
types
.
CallbackQuery
)
:
if
not
await
check_subscription
(
callback_query
.
from_user
.
id
)
:
text
=
"Для использования бота необходимо подписаться на наш канал."
await
callback_query
.
message
.
answer
(
text
,
reply_markup
=
create_subscription_keyboard
(
)
)
return
current_events
,
upcoming_events
=
await
fetch_events
(
)
all_events
=
current_events
+
upcoming_events
if
all_events
:
combined_message
=
"\n\n"
.
join
(
all_events
)
await
callback_query
.
message
.
answer
(
combined_message
,
parse_mode
=
"Markdown"
)
else
:
await
callback_query
.
message
.
answer
(
"На данный момент нет активных событий."
)
await
callback_query
.
answer
(
)
async
def
main
(
)
:
logging
.
basicConfig
(
level
=
logging
.
INFO
)
await
dp
.
start_polling
(
bot
)
if
__name__
==
"__main__"
:
asyncio
.
run
(
main
(
)
)