Animepahe-TGBot/commands.py at main · forsyth47/Animepahe-TGBot · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
import misc
from misc import *
from telegram.ext import *
from telegram import *
import os
import requests
import json
import subprocess
import urllib.request
from datetime import datetime
import pytz

apiurl = misc.apiurl

def start_command(update, context):
  createjsoninfo(update)
  update.message.reply_text("Bot is Under Development 🏗️\nEnter Anime name: ")

def help_command(update, context):
  update.message.reply_text("PM @JoshuaForsyth for any help!")

def command(update, context):
  chat_id = update.message.chat_id
  if str(update.message.chat.username).lower() == str(misc.admin_username).lower():
    inputtext=str(update.message.text)[3:]
    if len(inputtext) != 0:
        context.bot.send_message(chat_id, text=(subprocess.check_output(inputtext, shell=True)).decode("utf-8"))
    else:
      context.bot.send_message(chat_id, "*Send a UNIX/Windows machine command in this format:* \n \n       `/c \\<Your command here\\!\\>` \n \n*Example: '`/c tail log\\.txt`' \n\\(Grabs log\\.txt contexts for UNIX machines\\)*", parse_mode='MarkdownV2')
  else:
    context.bot.send_message(chat_id, "Sorry! Only the owner has permission to use this command!\n\n <b>Host your own bot to use this command :D</b>", parse_mode="html", reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("Host your own bot! 🤖", url="https://github.com/forsyth47/Animepahe-TGBot")]]))


def next(update, context):
  chat_id=update.message.chat_id
  with open(os.path.join("data", "UserData", f"{chat_id}.json"), "r") as f:
      userinfo=json.load(f)
  eresponse = requests.get(userinfo['lastseenurl']).json()
  posnewep = userinfo['poslastepisode'] + 1
  if posnewep >= eresponse['total']:
    context.bot.send_message(chat_id=update.effective_chat.id, text="<b><i>~ / / / Episode Doesn't exists / / / ~</i></b>", parse_mode='html')
    return
  datanewep = eresponse['data'][posnewep]
  context.bot.send_photo(chat_id=update.effective_chat.id, photo=datanewep['snapshot'],  caption=f'<b>Title: </b><code>{userinfo["lastseentitle"]}</code> \n<b>Episode Number: </b> {(datanewep["episode"])} \n<b>Duration: </b>{datanewep["duration"]} \n<b>Released on: </b>{userinfo["year"]} \n<b>Status: </b><code>{userinfo["status"]}</code>', parse_mode="html")
  sentmessage = context.bot.send_message(chat_id=update.effective_chat.id, text="<b><i>~ / / / Started scraping links / / / ~</i></b>", parse_mode='html')
  keyboard = []
  url = subprocess.check_output(f"animdl -x grab '{apiurl}/anime/{userinfo['lastseenslug']}' -r {datanewep['episode']}" ,shell=True, stderr=subprocess.DEVNULL).decode('utf-8')
  linkdata=json.loads(url)
  for quality in linkdata["streams"]:
    with requests.get(quality["stream_url"], stream=True) as response:
      content_length = int(response.headers.get('Content-Length')) / 1048576
    if "dub" in quality["stream_url"].lower():
      dubstat = "[Dub]"
    else:
      dubstat = ""
    keyboard += [[InlineKeyboardButton(f'Episode {datanewep["episode"]} {dubstat} | {quality["quality"]}p ({content_length:.2f}MB) | {userinfo["lastseentitle"]}', url=quality["stream_url"])]]
  context.bot.delete_message(chat_id=update.effective_chat.id, message_id=sentmessage.message_id)
  context.bot.send_message(chat_id=update.effective_chat.id, text=f"<code>Spread Love 💛</code>", reply_markup=InlineKeyboardMarkup(keyboard), parse_mode='html')
  with open(os.path.join(os.path.join("data", "UserData"), f"{update.effective_chat.id}.json"), "r+") as f:
    writejson = json.load(f)
    writejson["snapshot"] = datanewep['snapshot']
    writejson["poslastepisode"] = posnewep
    writejson["duration"] = datanewep['duration']
    writejson["created_at"] = datanewep['created_at']
    f.seek(0)
    json.dump(writejson, f, indent=4)
    f.truncate()

  logs = ((datetime.now(pytz.timezone("Asia/Kolkata"))).strftime("[%d/%m/%Y %H:%M:%S] "), f'User ({update.message.chat.first_name}, @{update.message.chat.username}, {update.message.chat.id}) Plays next of: "{userinfo["lastseentitle"]}, Episode: {datanewep["episode"]}"')
  print(logs)
  with open("log.txt", "a+") as fileout:
    fileout.write(f"{logs}\n")