bot.py

import requests
import telegram
from telegram import ParseMode
from telegram.ext import Updater, CallbackContext, CommandHandler, MessageHandler, Filters
from telegram.update import Update
from bs4 import BeautifulSoup
import re 
import os
import openai
import subprocess
import json


#Admin default status 
global admin
admin = False

openai.api_key = os.getenv('OPENAI_TOKEN')
#Telegram token
token = os.getenv('TELEGRAM_TOKEN')
updater = Updater(token,use_context=True)
rapidapi_key = os.getenv('RAPIDAPI_KEY')



def start(update: Update, context: CallbackContext):
  update.message.reply_text("TI-TIM-TIMMY !! \n\n🇺🇸\n Hey ! Make a /help if you are lost !\n\n🇫🇷\nSalut ! Fait un /help si t'es perdu !")
  poukave(update, context)
  
#Pour stocker les chat_id  
def poukave(update: Update, context: CallbackContext):
  chat_id = str(update.effective_user.id)
  
  with open("chat_id.txt", "r") as f:
    if chat_id not in f.read():
      f.write(f"{chat_id}\n")
      print("C'est bon j'ai le chat_id ajouté batard")
      return
    else:
      print("pas besoin du chat_id TMTC")
      return



#Admin auth for admin ressources        
def auth(update: Update, context: CallbackContext):
  passwd = update.message.text.replace('/auth ', '')
  if passwd == os.getenv('HEHEHEHA'):
    global admin
    admin = True
    update.message.reply_text("Wesh l'admin")
    
    # Supprimer le MDP du chat
    update.message.delete()
    
    
  else :
    chat_id = str(update.effective_user.id)
    msg = f"UN CONNARD FAIT DES /auth !!! ID : {chat_id} & sont mdp : {passwd}"
    
    update.message.reply_text("HAHAHAHAHA nope.")
    update.message.bot.send_message(
          chat_id = os.getenv('ID'),
          text=msg,
          disable_web_page_preview=True,
          parse_mode='HTML'
        ) 
      
# Admin ressources  
'''FONCTIONS AVEC AUTH'''

def console(update: Update, context: CallbackContext):
  if admin == True:
    poukave(update, context)
    cmd = update.message.text.replace('/oulah', '')
    prompt = str(cmd)
    p = subprocess.Popen(f'{prompt}', stdout=subprocess.PIPE, shell=True)
    output, error = p.communicate()
    if error:
      update.message.reply_text(f'Erreur : {error.decode()}')
    else:
       # Divise l'output en plusieurs parties
      parts = output.decode().split('\n')
      
      # Envoie chaque partie de l'output au chat
      for part in parts:
        chat_id = str(update.effective_user.id)
        if part:
          update.message.bot.send_message(
            chat_id = chat_id,
            text=part) 
        else: 
          #if part empty or just space, nothing append
  else : 
    update.message.reply_text("🚫 ERROR : Timmy ! Admin 🚫")


  #./nikto/program/nikto.pl -host {prompt} -Tuning 1 2 3 4 5 7 8 9 0  
def nikto(update: Update, context: CallbackContext):
  poukave(update, context)
  if admin == True:
    #GIF
    chat_id = str(update.effective_user.id)
    msg = "https://i.giphy.com/YQitE4YNQNahy.gif"
    message = ('https://api.telegram.org/bot'+ token + '/sendVideo?chat_id=' + chat_id + '&video=' + msg)
    requests.post(message)
    
    site = update.message.text.replace('/nikto', '')
    prompt = str(site)
    update.message.reply_text("Scan en cours... (15mins Max)")
    p = subprocess.Popen(f'./nikto/program/nikto.pl -host {prompt} -Tuning 1 2 3 4 5 7 8 9 0', stdout=subprocess.PIPE, shell=True)
    output, error = p.communicate()
    
    
    if error:
      update.message.reply_text(f'Erreur : {error.decode()}')
    else:
       # Divise l'output en plusieurs parties
      parts = output.decode().split('\n')
      
      # Envoie chaque partie de l'output au chat
      for part in parts:
        chat_id = str(update.effective_user.id)
        update.message.bot.send_message(
          chat_id = chat_id,
          text=part,
          disable_web_page_preview=True,
          parse_mode='HTML'
        )    
  else: 
    update.message.reply_text("🚫 ERROR : Timmy ! Admin !? 🚫")
  
#MSG for All users              
def msg_all(update: Update, context: CallbackContext):  
  if admin == True:
    chat_id_list = open("chat_id.txt", "r+")
    
    for _id in chat_id_list:
      msg = update.message.text.replace('/msgall', '')
      message = ('https://api.telegram.org/bot'+ token + '/sendMessage?chat_id=' + _id + '&text=' + msg)
      requests.post(message)
  else:
    update.message.reply_text("🚫 ERROR : Timmy ! Admin !? 🚫")

#def des fonctions du bot
   

def moviesearch(update: Update, context: CallbackContext):#STREAMING function
#USER INPUT 
        poukave(update, context)
  
        URL = ["https://www.wiflixfr.com/", "https://www.wiflix.wine/", "https://www.wawacity.homes/", "https://www.ocine.online/", "https://www.megastream.bond/index.php", "https://www.french-stream.uno/", "https://wwvv.cpasmieux.one/", "https://www.cpasmieux.bid/", "https://www.waystreaming.com/", "https://ww1.33seriestreaming.lol/", "https://www.french-stream.ltd/", "https://www.juststream.cam/","https://www.lebonstream.xyz/", "https://www.zonestreaming.top/"  ]

        film_old = update.message.text.replace('/search ', '')#User input - "/search"
        #log des recherches
        with open("search_log.txt", "a+") as f:
            f.write(f"{film_old}\n")
        
        film = film_old.replace(' ', '-')
        update.message.reply_text(f"🔎 Timmy ! Timmy... 🔎")
        search_lower = film.lower()
        search = search_lower.replace(' ', '+')#POST Payload convert
        
#LEGAL SEARCH
        API = "https://streaming-availability.p.rapidapi.com/v2/search/title"
        querystring = {"title":search,"country":"fr","type":"all","output_language":"en"}
        headers = {
	        "X-RapidAPI-Key": rapidapi_key,
	        "X-RapidAPI-Host": "streaming-availability.p.rapidapi.com"
        }

      
        request = requests.request("GET", API, headers=headers, params=querystring)
        data_rep = request.json()
        if len(data_rep['result']) > 0:
            movie_title = data_rep['result'][0]['title']
            streaming_info = data_rep['result'][0]['streamingInfo']
            
            urls = re.findall('(http\S+)', str(streaming_info))#ICI FAIRE UNE REGEX QUI PREND PRIME VIDEO NETFLIX ETC
            urls_final = '\n\n'.join(urls)
            update.message.reply_text(f"*⚖️ Legal search for {movie_title}⚖️ : \n\n{urls_final}*", parse_mode=ParseMode.MARKDOWN)   
  
    
    
#NORMAL SEARCH 
        data = {"do":"search", "subaction":"search", "story": {search}}
        
        for i in URL:
            error_url = i.replace('https://', '')
            page = requests.post(i, data=data)
            soup = BeautifulSoup(page.content, 'html.parser')
            url_list = re.findall('(http\S+)', str(soup))
            #print(url_list)
                  
            #pour rechercher le nom du film dans la liste d'url  
            for __ in search.split():
                links_temp = list(filter(lambda x: re.search(__, x), url_list))
                links_data = '\n\n'.join(links_temp)
                
                #Traitement du result
                pattern = r'https?://[^"\s]+'
                
                links_final = re.findall(pattern, links_data)
                
                links = '\n\n `[+]` '.join(links_final)#saut de ligne entre chaque éléments
            update.message.reply_text(f"💊 Normal search 💊 :\n\n`[+]` {links}\n\n *Status de la request :{error_url} {page.status_code}*", parse_mode=ParseMode.MARKDOWN)
            

            
 #QR CODE Function                  
def qr():
    import qrcode
    global qr_img
    qr_img = qrcode.make(link)
    qr_img.save('TEMP.png')

global qrcode
def qrcode(update: Update, context: CallbackContext):
    poukave(update, context)
    global get_qrcode
    global link
    link = update.message.text.replace('/qr', '')
    def get_qrcode():
            global chat_id
            chat_id = str(update.effective_user.id)
            qr()
            path = 'TEMP.png'
            file = {'photo': open(path, 'rb')}

            print(f'Text pour le QR : {link}') 
            message = ('https://api.telegram.org/bot'+ token + '/sendPhoto?chat_id=' + chat_id)
            requests.post(message, files = file)
            os.remove('TEMP.png')
    get_qrcode()
              
 
  
def games(update: Update, context: CallbackContext):#GAMES function
        poukave(update, context)
        URL = ["https://crohasit.net/", "https://gogunlocked.com/", "https://igg-games.com/"]
        jeux = update.message.text.replace('/crack', '')
      
        update.message.reply_text(f"Timmy ! Timmy... 🔎")
        update.message.reply_text(f"En cours de dev...")
        search_lower = jeux.lower()
        search = search_lower.replace(' ', '+')#POST Payload convert
        
        data = f"?/s={search}"
        result = search_lower.split()#fait une liste avec le nom du jeux si plusieurs mots pour chercher dans les URL
        
        for i in URL:
            error_url = i.replace('https://', '')
            page = requests.post(i + data)
            soup = BeautifulSoup(page.content, 'html.parser').find_all(lambda t: t.name == "a")
            url_list = [a["href"] for a in soup]#https://stackoverflow.com/questions/65168254/how-to-get-href-link-by-text-in-python
            
            for __ in result:
                links_temp = list(filter(lambda x: re.search(__, x), url_list))
                links = '\n\n'.join(links_temp)#saut de ligne entre chaque éléments
            update.message.reply_text(f"TIMMY !! : \n{links}\n\n Request Status :{error_url} {page.status_code}")

            

def help(update: Update, context: CallbackContext):
    poukave(update, context)
    update.message.reply_text("🇫🇷\n/link : Permet d'avoir le lien du bot. \n\n/search [Nom du film / serie] : Pour rechercher un film ou une serie sur des sites pas hyper légaux... mais bon c'est gratuit !\n\n/qr [Mot ou URL] Permet de convertir en QRCODE tout ce que tu lui donne.\n\n/crack [Nom du jeux] Pour chercher des jeux cracké\n\n🇺🇸\n/link: Provides the bot's link.\n\n/search [Movie / series name]: To search for a movie or series on not-so-legal websites... but well, it's free!\n\n/qr [Word or URL]: Converts whatever you give it into a QR code.\n\n/crack [Game name]: To look for cracked games.")

#permet de log les fail de commandes et les msg sans commandes dans un fichier poukave.txt
def unknown(update: Update, context: CallbackContext):
    chat_id = str(update.effective_user.id)
    msg = str(update.message.text)
    print(msg)
    with open("poukave.txt", "a+") as f:
      f.write(f"{msg} --> {chat_id}\n")  
  
    poukave(update, context)
    chat_id = str(update.effective_user.id)
    msg = "https://i.giphy.com/3o7aTskHEUdgCQAXde.gif"
    message = ('https://api.telegram.org/bot'+ token + '/sendVideo?chat_id=' + chat_id + '&video=' + msg)
    requests.post(message)
    update.message.reply_text("Timmy ? \n\n/help !\n\n\nFor movie search make a /search !!")
                              
                              
def secret_help(update: Update, context: CallbackContext):
    chat_id = str(update.effective_user.id)
    msg = "https://i.giphy.com/B4dt6rXq6nABilHTYM.gif"
    message = ('https://api.telegram.org/bot'+ token + '/sendVideo?chat_id=' + chat_id + '&video=' + msg)
    requests.post(message)
    update.message.reply_text("U2kgdHUgdHJvdXZlIMOnYSBwYXIgaGF6YXJkIEdHICEgc2lub24gdnJhaW1lbnQgZmFpdCBnYWZmZSDDoCB0b3V0IMOnYSBjJ2VzdCBkYW5nZXJldXguCgovbmlrdG8gW1VSTCBzaXRlIGVuIEhUVFBdIFBvdXIgbGFuY2VyIHVuIHNjYW4gYXZlYyBOaWt0byBzdXIgdW4gc2l0ZSBXZWIuCgovb3VsYWggW1NIRUxMIGNvbW1hbmRdIFBvdXIgbGFuY2VyIGRlcyBjb21tYW5kZXMgc2hlbGw=\n\n/MsG__AlL")
  
  
    
def telegram_link(update: Update, context: CallbackContext):
    poukave(update, context)
    update.message.reply_text("Telegram link : t.me/Mehliug_bot\n\nWebApp Link: https://mehliug-bot.glitch.me/")



#Trigger des fonctions
updater.dispatcher.add_handler(CommandHandler('start', start))
updater.dispatcher.add_handler(CommandHandler('help', help))
updater.dispatcher.add_handler(CommandHandler('msgall', msg_all))  
updater.dispatcher.add_handler(CommandHandler('auth', auth))

updater.dispatcher.add_handler(CommandHandler('H4X0R', secret_help))
updater.dispatcher.add_handler(CommandHandler('nikto', nikto))
updater.dispatcher.add_handler(CommandHandler('oulah', console))

updater.dispatcher.add_handler(CommandHandler('link', telegram_link))
updater.dispatcher.add_handler(CommandHandler('search', moviesearch))
updater.dispatcher.add_handler(CommandHandler('crack', games))

updater.dispatcher.add_handler(CommandHandler('qr', qrcode))

updater.dispatcher.add_handler(MessageHandler(Filters.command, unknown))
updater.dispatcher.add_handler(MessageHandler(Filters.text, unknown))   
#Run the bot
updater.start_polling()