mirror of
https://github.com/yasirarism/MissKatyPyro.git
synced 2026-01-06 20:04:51 +00:00
Fix more
This commit is contained in:
parent
ca71b19be1
commit
ac2f497cdc
2 changed files with 30 additions and 33 deletions
|
|
@ -129,6 +129,8 @@ async def dkick(client, message):
|
||||||
|
|
||||||
@app.on_message(filters.incoming & ~filters.private & filters.command(["instatus"], COMMAND_HANDLER))
|
@app.on_message(filters.incoming & ~filters.private & filters.command(["instatus"], COMMAND_HANDLER))
|
||||||
async def instatus(client, message):
|
async def instatus(client, message):
|
||||||
|
if message.sender_chat:
|
||||||
|
return await message.reply("Not supported channel.")
|
||||||
start_time = time.perf_counter()
|
start_time = time.perf_counter()
|
||||||
user = await app.get_chat_member(message.chat.id, message.from_user.id)
|
user = await app.get_chat_member(message.chat.id, message.from_user.id)
|
||||||
count = await app.get_chat_members_count(message.chat.id)
|
count = await app.get_chat_members_count(message.chat.id)
|
||||||
|
|
|
||||||
|
|
@ -43,24 +43,24 @@ def split_arr(arr, size: 5):
|
||||||
return arrs
|
return arrs
|
||||||
|
|
||||||
# Terbit21 GetData
|
# Terbit21 GetData
|
||||||
async def getDataTerbit21(msg, kueri, CurrentPage):
|
async def getDataTerbit21(msg, idpesan, kueri, CurrentPage):
|
||||||
if not SCRAP_DICT.get(msg.id):
|
if not SCRAP_DICT.get(idpesan):
|
||||||
if not kueri:
|
if not kueri:
|
||||||
terbitjson = (await http.get('https://yasirapi.eu.org/terbit21')).json()
|
terbitjson = (await http.get('https://yasirapi.eu.org/terbit21')).json()
|
||||||
else:
|
else:
|
||||||
terbitjson = (await http.get(f'https://yasirapi.eu.org/terbit21?q={kueri}')).json()
|
terbitjson = (await http.get(f'https://yasirapi.eu.org/terbit21?q={kueri}')).json()
|
||||||
if not terbitjson.get("result"):
|
if not terbitjson.get("result"):
|
||||||
return await msg.reply("Sorry, could not find any results!")
|
return await msg.reply("Sorry, could not find any results!")
|
||||||
SCRAP_DICT[msg.id] = [split_arr(terbitjson["result"], 6), kueri]
|
SCRAP_DICT[idpesan] = [split_arr(terbitjson["result"], 6), kueri]
|
||||||
try:
|
try:
|
||||||
index = int(CurrentPage - 1)
|
index = int(CurrentPage - 1)
|
||||||
PageLen = len(SCRAP_DICT[msg.id][0])
|
PageLen = len(SCRAP_DICT[idpesan][0])
|
||||||
|
|
||||||
if kueri:
|
if kueri:
|
||||||
TerbitRes = f"<b>#Terbit21 Results For:</b> <code>{kueri}</code>\n\n"
|
TerbitRes = f"<b>#Terbit21 Results For:</b> <code>{kueri}</code>\n\n"
|
||||||
else:
|
else:
|
||||||
TerbitRes = "<b>#Terbit21 Latest:</b>\n🌀 Use /terbit21 [title] to start search with title.\n\n"
|
TerbitRes = "<b>#Terbit21 Latest:</b>\n🌀 Use /terbit21 [title] to start search with title.\n\n"
|
||||||
for c, i in enumerate(SCRAP_DICT[msg.id][0][index], start=1):
|
for c, i in enumerate(SCRAP_DICT[idpesan][0][index], start=1):
|
||||||
TerbitRes += f"<b>{c}. <a href='{i['link']}'>{i['judul']}</a></b>\n<b>Category:</b> <code>{i['kategori']}</code>\n"
|
TerbitRes += f"<b>{c}. <a href='{i['link']}'>{i['judul']}</a></b>\n<b>Category:</b> <code>{i['kategori']}</code>\n"
|
||||||
TerbitRes += "\n" if re.search(r"Complete|Ongoing", i["kategori"]) else f"💠 <b><a href='{i['dl']}'>Download</a></b>\n\n"
|
TerbitRes += "\n" if re.search(r"Complete|Ongoing", i["kategori"]) else f"💠 <b><a href='{i['dl']}'>Download</a></b>\n\n"
|
||||||
IGNORE_CHAR = "[]"
|
IGNORE_CHAR = "[]"
|
||||||
|
|
@ -70,24 +70,24 @@ async def getDataTerbit21(msg, kueri, CurrentPage):
|
||||||
await msg.reply("Sorry, could not find any results!")
|
await msg.reply("Sorry, could not find any results!")
|
||||||
|
|
||||||
# LK21 GetData
|
# LK21 GetData
|
||||||
async def getDatalk21(msg, kueri, CurrentPage):
|
async def getDatalk21(msg, idpesan, kueri, CurrentPage):
|
||||||
if not SCRAP_DICT.get(msg.id):
|
if not SCRAP_DICT.get(idpesan):
|
||||||
if not kueri:
|
if not kueri:
|
||||||
lk21json = (await http.get('https://yasirapi.eu.org/lk21')).json()
|
lk21json = (await http.get('https://yasirapi.eu.org/lk21')).json()
|
||||||
else:
|
else:
|
||||||
lk21json = (await http.get(f'https://yasirapi.eu.org/lk21?q={kueri}')).json()
|
lk21json = (await http.get(f'https://yasirapi.eu.org/lk21?q={kueri}')).json()
|
||||||
if not lk21json.get("result"):
|
if not lk21json.get("result"):
|
||||||
return await msg.reply("Sorry could not find any matching results!")
|
return await msg.reply("Sorry could not find any matching results!")
|
||||||
SCRAP_DICT[msg.id] = [split_arr(lk21json["result"], 6), kueri]
|
SCRAP_DICT[idpesan] = [split_arr(lk21json["result"], 6), kueri]
|
||||||
try:
|
try:
|
||||||
index = int(CurrentPage - 1)
|
index = int(CurrentPage - 1)
|
||||||
PageLen = len(SCRAP_DICT[msg.id][0])
|
PageLen = len(SCRAP_DICT[idpesan][0])
|
||||||
|
|
||||||
if kueri:
|
if kueri:
|
||||||
lkResult = f"<b>#Layarkaca21 Results For:</b> <code>{kueri}</code>\n\n"
|
lkResult = f"<b>#Layarkaca21 Results For:</b> <code>{kueri}</code>\n\n"
|
||||||
else:
|
else:
|
||||||
lkResult = "<b>#Layarkaca21 Latest:</b>\n🌀 Use /lk21 [title] to start search with title.\n\n"
|
lkResult = "<b>#Layarkaca21 Latest:</b>\n🌀 Use /lk21 [title] to start search with title.\n\n"
|
||||||
for c, i in enumerate(SCRAP_DICT[msg.id][0][index], start=1):
|
for c, i in enumerate(SCRAP_DICT[idpesan][0][index], start=1):
|
||||||
lkResult += f"<b>{c}. <a href='{i['link']}'>{i['judul']}</a></b>\n<b>Category:</b> <code>{i['kategori']}</code>\n"
|
lkResult += f"<b>{c}. <a href='{i['link']}'>{i['judul']}</a></b>\n<b>Category:</b> <code>{i['kategori']}</code>\n"
|
||||||
lkResult += "\n" if re.search(r"Complete|Ongoing", i["kategori"]) else f"💠 <b><a href='{i['dl']}'>Download</a></b>\n\n"
|
lkResult += "\n" if re.search(r"Complete|Ongoing", i["kategori"]) else f"💠 <b><a href='{i['dl']}'>Download</a></b>\n\n"
|
||||||
IGNORE_CHAR = "[]"
|
IGNORE_CHAR = "[]"
|
||||||
|
|
@ -97,18 +97,18 @@ async def getDatalk21(msg, kueri, CurrentPage):
|
||||||
await msg.reply("Sorry could not find any matching results!")
|
await msg.reply("Sorry could not find any matching results!")
|
||||||
|
|
||||||
# Pahe GetData
|
# Pahe GetData
|
||||||
async def getDataPahe(msg, kueri, CurrentPage):
|
async def getDataPahe(msg, idpesan, kueri, CurrentPage):
|
||||||
if not SCRAP_DICT.get(msg.id):
|
if not SCRAP_DICT.get(idpesan):
|
||||||
pahejson = (await http.get(f'https://yasirapi.eu.org/pahe?q={kueri}')).json()
|
pahejson = (await http.get(f'https://yasirapi.eu.org/pahe?q={kueri}')).json()
|
||||||
if not pahejson.get("result"):
|
if not pahejson.get("result"):
|
||||||
return await msg.reply("Sorry could not find any matching results!", quote=True)
|
return await msg.reply("Sorry could not find any matching results!", quote=True)
|
||||||
SCRAP_DICT[msg.id] = [split_arr(pahejson["result"], 6), kueri]
|
SCRAP_DICT[idpesan] = [split_arr(pahejson["result"], 6), kueri]
|
||||||
try:
|
try:
|
||||||
index = int(CurrentPage - 1)
|
index = int(CurrentPage - 1)
|
||||||
PageLen = len(SCRAP_DICT[msg.id][0])
|
PageLen = len(SCRAP_DICT[idpesan][0])
|
||||||
|
|
||||||
paheResult = f"<b>#Pahe Results For:</b> <code>{kueri}</code>\n\n" if kueri else f"<b>#Pahe Latest:</b>\n🌀 Use /pahe [title] to start search with title.\n\n"
|
paheResult = f"<b>#Pahe Results For:</b> <code>{kueri}</code>\n\n" if kueri else f"<b>#Pahe Latest:</b>\n🌀 Use /pahe [title] to start search with title.\n\n"
|
||||||
for c, i in enumerate(SCRAP_DICT[msg.id][0][index], start=1):
|
for c, i in enumerate(SCRAP_DICT[idpesan][0][index], start=1):
|
||||||
paheResult += f"<b>{c}. <a href='{i['link']}'>{i['judul']}</a></b>\n\n"
|
paheResult += f"<b>{c}. <a href='{i['link']}'>{i['judul']}</a></b>\n\n"
|
||||||
IGNORE_CHAR = "[]"
|
IGNORE_CHAR = "[]"
|
||||||
paheResult = ''.join(i for i in paheResult if not i in IGNORE_CHAR)
|
paheResult = ''.join(i for i in paheResult if not i in IGNORE_CHAR)
|
||||||
|
|
@ -117,8 +117,8 @@ async def getDataPahe(msg, kueri, CurrentPage):
|
||||||
await msg.reply("Sorry could not find any matching results!")
|
await msg.reply("Sorry could not find any matching results!")
|
||||||
|
|
||||||
# GoMov GetData
|
# GoMov GetData
|
||||||
async def getDataGomov(msg, kueri, CurrentPage):
|
async def getDataGomov(msg, idpesan, kueri, CurrentPage):
|
||||||
if not SCRAP_DICT.get(msg.id):
|
if not SCRAP_DICT.get(idpesan):
|
||||||
gomovv = await http.get(f'https://185.173.38.216/?s=')
|
gomovv = await http.get(f'https://185.173.38.216/?s=')
|
||||||
text = BeautifulSoup(gomovv.text, "lxml")
|
text = BeautifulSoup(gomovv.text, "lxml")
|
||||||
entry = text.find_all(class_="entry-header")
|
entry = text.find_all(class_="entry-header")
|
||||||
|
|
@ -134,13 +134,13 @@ async def getDataGomov(msg, kueri, CurrentPage):
|
||||||
judul = i.find(class_="entry-title").find("a").text
|
judul = i.find(class_="entry-title").find("a").text
|
||||||
link = i.find(class_="entry-title").find("a").get("href")
|
link = i.find(class_="entry-title").find("a").get("href")
|
||||||
data.append({"judul": judul, "link": link, "genre": genre})
|
data.append({"judul": judul, "link": link, "genre": genre})
|
||||||
SCRAP_DICT[msg.id] = [split_arr(data, 6), kueri]
|
SCRAP_DICT[idpesan] = [split_arr(data, 6), kueri]
|
||||||
try:
|
try:
|
||||||
index = int(CurrentPage - 1)
|
index = int(CurrentPage - 1)
|
||||||
PageLen = len(SCRAP_DICT[msg.id][0])
|
PageLen = len(SCRAP_DICT[idpesan][0])
|
||||||
|
|
||||||
gomovResult = f"<b>#Gomov Results For:</b> <code>{kueri}</code>\n\n" if kueri else f"<b>#Gomov Latest:</b>\n🌀 Use /{msg.command[0]} [title] to start search with title.\n\n"
|
gomovResult = f"<b>#Gomov Results For:</b> <code>{kueri}</code>\n\n" if kueri else f"<b>#Gomov Latest:</b>\n🌀 Use /{msg.command[0]} [title] to start search with title.\n\n"
|
||||||
for c, i in enumerate(SCRAP_DICT[msg.id][0][index], start=1):
|
for c, i in enumerate(SCRAP_DICT[idpesan][0][index], start=1):
|
||||||
gomovResult += f"<b>{c}. <a href='{i['link']}'>{i['judul']}</a></b>\n<b>Genre:</b> <code>{i['genre']}</code>\n"
|
gomovResult += f"<b>{c}. <a href='{i['link']}'>{i['judul']}</a></b>\n<b>Genre:</b> <code>{i['genre']}</code>\n"
|
||||||
gomovResult += "\n" if re.search(r"Series", i["genre"]) else f"<b>Extract:</b> <code>/{msg.command[0]}_scrap {i['link']}</code>\n\n"
|
gomovResult += "\n" if re.search(r"Series", i["genre"]) else f"<b>Extract:</b> <code>/{msg.command[0]}_scrap {i['link']}</code>\n\n"
|
||||||
IGNORE_CHAR = "[]"
|
IGNORE_CHAR = "[]"
|
||||||
|
|
@ -152,13 +152,12 @@ async def getDataGomov(msg, kueri, CurrentPage):
|
||||||
# Terbit21 CMD
|
# Terbit21 CMD
|
||||||
@app.on_message(filters.command(['terbit21'], COMMAND_HANDLER))
|
@app.on_message(filters.command(['terbit21'], COMMAND_HANDLER))
|
||||||
async def terbit21_s(client, message):
|
async def terbit21_s(client, message):
|
||||||
chat_id = message.chat.id
|
|
||||||
kueri = ' '.join(message.command[1:])
|
kueri = ' '.join(message.command[1:])
|
||||||
if not kueri:
|
if not kueri:
|
||||||
kueri = None
|
kueri = None
|
||||||
pesan = await message.reply("Getting data from Terbit21..")
|
pesan = await message.reply("Getting data from Terbit21..")
|
||||||
CurrentPage = 1
|
CurrentPage = 1
|
||||||
terbitres, PageLen = await getDataTerbit21(message, kueri, CurrentPage)
|
terbitres, PageLen = await getDataTerbit21(message, pesan.id, kueri, CurrentPage)
|
||||||
keyboard = InlineKeyboard()
|
keyboard = InlineKeyboard()
|
||||||
keyboard.paginate(PageLen, CurrentPage, 'page_terbit21#{number}' + f'#{pesan.id}#{message.from_user.id}')
|
keyboard.paginate(PageLen, CurrentPage, 'page_terbit21#{number}' + f'#{pesan.id}#{message.from_user.id}')
|
||||||
keyboard.row(
|
keyboard.row(
|
||||||
|
|
@ -175,7 +174,7 @@ async def lk21_s(client, message):
|
||||||
kueri = None
|
kueri = None
|
||||||
pesan = await message.reply("Getting data from LK21..")
|
pesan = await message.reply("Getting data from LK21..")
|
||||||
CurrentPage = 1
|
CurrentPage = 1
|
||||||
lkres, PageLen = await getDatalk21(message, kueri, CurrentPage)
|
lkres, PageLen = await getDatalk21(message, pesan.id, kueri, CurrentPage)
|
||||||
keyboard = InlineKeyboard()
|
keyboard = InlineKeyboard()
|
||||||
keyboard.paginate(PageLen, CurrentPage, 'page_lk21#{number}' + f'#{pesan.id}#{message.from_user.id}')
|
keyboard.paginate(PageLen, CurrentPage, 'page_lk21#{number}' + f'#{pesan.id}#{message.from_user.id}')
|
||||||
keyboard.row(
|
keyboard.row(
|
||||||
|
|
@ -192,7 +191,7 @@ async def pahe_s(client, message):
|
||||||
kueri = ""
|
kueri = ""
|
||||||
pesan = await message.reply("Getting data from Pahe Web..")
|
pesan = await message.reply("Getting data from Pahe Web..")
|
||||||
CurrentPage = 1
|
CurrentPage = 1
|
||||||
paheres, PageLen = await getDataPahe(message, kueri, CurrentPage)
|
paheres, PageLen = await getDataPahe(message, pesan.id, kueri, CurrentPage)
|
||||||
keyboard = InlineKeyboard()
|
keyboard = InlineKeyboard()
|
||||||
keyboard.paginate(PageLen, CurrentPage, 'page_pahe#{number}' + f'#{pesan.id}#{message.from_user.id}')
|
keyboard.paginate(PageLen, CurrentPage, 'page_pahe#{number}' + f'#{pesan.id}#{message.from_user.id}')
|
||||||
keyboard.row(
|
keyboard.row(
|
||||||
|
|
@ -203,13 +202,12 @@ async def pahe_s(client, message):
|
||||||
# Gomov CMD
|
# Gomov CMD
|
||||||
@app.on_message(filters.command(['gomov'], COMMAND_HANDLER))
|
@app.on_message(filters.command(['gomov'], COMMAND_HANDLER))
|
||||||
async def gomov_s(client, message):
|
async def gomov_s(client, message):
|
||||||
chat_id = message.chat.id
|
|
||||||
kueri = ' '.join(message.command[1:])
|
kueri = ' '.join(message.command[1:])
|
||||||
if not kueri:
|
if not kueri:
|
||||||
kueri = ""
|
kueri = ""
|
||||||
pesan = await message.reply("Getting data from Gomov Web..")
|
pesan = await message.reply("Getting data from Gomov Web..")
|
||||||
CurrentPage = 1
|
CurrentPage = 1
|
||||||
gomovres, PageLen = await getDataGomov(message, kueri, CurrentPage)
|
gomovres, PageLen = await getDataGomov(message, pesan.id, kueri, CurrentPage)
|
||||||
keyboard = InlineKeyboard()
|
keyboard = InlineKeyboard()
|
||||||
keyboard.paginate(PageLen, CurrentPage, 'page_gomov#{number}' + f'#{pesan.id}#{message.from_user.id}')
|
keyboard.paginate(PageLen, CurrentPage, 'page_gomov#{number}' + f'#{pesan.id}#{message.from_user.id}')
|
||||||
keyboard.row(
|
keyboard.row(
|
||||||
|
|
@ -223,7 +221,6 @@ async def terbit21page_callback(client, callback_query):
|
||||||
if callback_query.from_user.id != int(callback_query.data.split('#')[3]):
|
if callback_query.from_user.id != int(callback_query.data.split('#')[3]):
|
||||||
return await callback_query.answer("Not yours..", True)
|
return await callback_query.answer("Not yours..", True)
|
||||||
message_id = int(callback_query.data.split('#')[2])
|
message_id = int(callback_query.data.split('#')[2])
|
||||||
chat_id = callback_query.message.chat.id
|
|
||||||
CurrentPage = int(callback_query.data.split('#')[1])
|
CurrentPage = int(callback_query.data.split('#')[1])
|
||||||
try:
|
try:
|
||||||
kueri = SCRAP_DICT[message_id][1]
|
kueri = SCRAP_DICT[message_id][1]
|
||||||
|
|
@ -231,7 +228,7 @@ async def terbit21page_callback(client, callback_query):
|
||||||
return await callback_query.answer("Invalid callback data, please send CMD again..")
|
return await callback_query.answer("Invalid callback data, please send CMD again..")
|
||||||
|
|
||||||
try:
|
try:
|
||||||
terbitres, PageLen = await getDataTerbit21(callback_query.message, kueri, CurrentPage)
|
terbitres, PageLen = await getDataTerbit21(callback_query.message, message_id, kueri, CurrentPage)
|
||||||
except TypeError:
|
except TypeError:
|
||||||
return
|
return
|
||||||
|
|
||||||
|
|
@ -248,7 +245,6 @@ async def lk21page_callback(client, callback_query):
|
||||||
if callback_query.from_user.id != int(callback_query.data.split('#')[3]):
|
if callback_query.from_user.id != int(callback_query.data.split('#')[3]):
|
||||||
return await callback_query.answer("Not yours..", True)
|
return await callback_query.answer("Not yours..", True)
|
||||||
message_id = int(callback_query.data.split('#')[2])
|
message_id = int(callback_query.data.split('#')[2])
|
||||||
chat_id = callback_query.message.chat.id
|
|
||||||
CurrentPage = int(callback_query.data.split('#')[1])
|
CurrentPage = int(callback_query.data.split('#')[1])
|
||||||
try:
|
try:
|
||||||
kueri = SCRAP_DICT[message_id][1]
|
kueri = SCRAP_DICT[message_id][1]
|
||||||
|
|
@ -256,7 +252,7 @@ async def lk21page_callback(client, callback_query):
|
||||||
return await callback_query.answer("Invalid callback data, please send CMD again..")
|
return await callback_query.answer("Invalid callback data, please send CMD again..")
|
||||||
|
|
||||||
try:
|
try:
|
||||||
lkres, PageLen = await getDatalk21(callback_query.message, kueri, CurrentPage)
|
lkres, PageLen = await getDatalk21(callback_query.message, message_id, kueri, CurrentPage)
|
||||||
except TypeError:
|
except TypeError:
|
||||||
return
|
return
|
||||||
|
|
||||||
|
|
@ -273,7 +269,6 @@ async def pahepage_callback(client, callback_query):
|
||||||
if callback_query.from_user.id != int(callback_query.data.split('#')[3]):
|
if callback_query.from_user.id != int(callback_query.data.split('#')[3]):
|
||||||
return await callback_query.answer("Not yours..", True)
|
return await callback_query.answer("Not yours..", True)
|
||||||
message_id = int(callback_query.data.split('#')[2])
|
message_id = int(callback_query.data.split('#')[2])
|
||||||
chat_id = callback_query.message.chat.id
|
|
||||||
CurrentPage = int(callback_query.data.split('#')[1])
|
CurrentPage = int(callback_query.data.split('#')[1])
|
||||||
try:
|
try:
|
||||||
kueri = SCRAP_DICT[message_id][1]
|
kueri = SCRAP_DICT[message_id][1]
|
||||||
|
|
@ -281,7 +276,7 @@ async def pahepage_callback(client, callback_query):
|
||||||
return await callback_query.answer("Invalid callback data, please send CMD again..")
|
return await callback_query.answer("Invalid callback data, please send CMD again..")
|
||||||
|
|
||||||
try:
|
try:
|
||||||
lkres, PageLen = await getDataPahe(callback_query.message, kueri, CurrentPage)
|
lkres, PageLen = await getDataPahe(callback_query.message, message_id, kueri, CurrentPage)
|
||||||
except TypeError:
|
except TypeError:
|
||||||
return
|
return
|
||||||
|
|
||||||
|
|
@ -305,7 +300,7 @@ async def pahepage_callback(client, callback_query):
|
||||||
return await callback_query.answer("Invalid callback data, please send CMD again..")
|
return await callback_query.answer("Invalid callback data, please send CMD again..")
|
||||||
|
|
||||||
try:
|
try:
|
||||||
gomovres, PageLen = await getDataGomov(callback_query.message, kueri, CurrentPage)
|
gomovres, PageLen = await getDataGomov(callback_query.message, message_id, kueri, CurrentPage)
|
||||||
except TypeError:
|
except TypeError:
|
||||||
return
|
return
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue