Add search music on Spotify and add log
This commit is contained in:
stef-devs
parent
1abccd1661
commit
94466c4fba
|
|
@ -1,3 +1,8 @@
|
|||
ffmpeg.exe
|
||||
.env
|
||||
test.py
|
||||
.cache
|
||||
music_cache
|
||||
nuvola.py
|
||||
debug.log
|
||||
nuvola.txt
|
||||
124
index.py
124
index.py
|
|
@ -18,6 +18,9 @@ import urllib.request
|
|||
import urllib.parse
|
||||
import logging
|
||||
import deepl
|
||||
import spotipy
|
||||
from spotipy.oauth2 import SpotifyClientCredentials
|
||||
from youtube_search import YoutubeSearch
|
||||
from dotenv import load_dotenv
|
||||
from yt_dlp import YoutubeDL
|
||||
from platform import system
|
||||
|
|
@ -29,27 +32,40 @@ from telebot import types, telebot
|
|||
from pytube import YouTube
|
||||
from bs4 import BeautifulSoup
|
||||
from gc import callbacks
|
||||
import logging
|
||||
import sys
|
||||
|
||||
logging.basicConfig(
|
||||
level=logging.INFO,
|
||||
format="%(asctime)s [%(levelname)s] %(message)s",
|
||||
handlers=[
|
||||
logging.FileHandler("debug.log"),
|
||||
logging.StreamHandler(sys.stdout)
|
||||
]
|
||||
)
|
||||
|
||||
load_dotenv()
|
||||
API_TOKEN = os.getenv('BOT_TOKEN')
|
||||
|
||||
bot = telebot.TeleBot(API_TOKEN)
|
||||
print("Il bot si è avviato con successo!")
|
||||
logging.info("Il bot si è avviato con successo!")
|
||||
|
||||
|
||||
#Command /start
|
||||
@bot.message_handler(commands=['start'])
|
||||
def send_welcome(message):
|
||||
chat_id = message.chat.id
|
||||
print("Triggered command START.")
|
||||
logging.info("Triggered command START.")
|
||||
bot.send_photo(chat_id, photo='https://i.imgur.com/6YPJBze.png')
|
||||
messageText = "✋ Benvenuto su <b>RetniNet!</b>\n\n<b>RetniNet</b> è un bot privato per <b>automatizzare</b> e <b>semplificare</b> cose che facciamo quotidianamente. \n\n👨💻 Creato & sviluppato da @Stef58_Official"
|
||||
bot.send_message(chat_id, messageText, parse_mode="HTML")
|
||||
|
||||
#Command /music
|
||||
|
||||
|
||||
@bot.message_handler(commands=['music'])
|
||||
def select_music(pm):
|
||||
print("Triggered command MUSIC.")
|
||||
logging.info("Triggered command MUSIC.")
|
||||
sent_msg = bot.send_message(pm.chat.id, "Inserisci il link della canzone:")
|
||||
bot.register_next_step_handler(sent_msg, music_step)
|
||||
|
||||
|
|
@ -58,32 +74,79 @@ def music_step(pm):
|
|||
if pm.text.startswith('https://www.youtube.com/') or pm.text.startswith('https://youtu.be/'):
|
||||
ytdl_opts = {
|
||||
'format': 'bestaudio/best',
|
||||
'outtmpl': '%(title)s.%(ext)s',
|
||||
'outtmpl': 'music_cache/%(title)s.%(ext)s',
|
||||
'postprocessors': [{
|
||||
'key': 'FFmpegExtractAudio',
|
||||
'preferredcodec': 'mp3',
|
||||
'preferredquality': '192',
|
||||
}],
|
||||
}
|
||||
elif pm.text.startswith('https://open.spotify.com/track/'):
|
||||
ytdl_opts = {
|
||||
'format': 'bestaudio/best',
|
||||
'outtmpl': 'music_cache/%(title)s.%(ext)s',
|
||||
'postprocessors': [{
|
||||
'key': 'FFmpegExtractAudio',
|
||||
'preferredcodec': 'mp3',
|
||||
'preferredquality': '192',
|
||||
}],
|
||||
}
|
||||
with YoutubeDL(ytdl_opts) as ydl:
|
||||
message = pm.text
|
||||
sp = spotipy.Spotify(auth_manager=SpotifyClientCredentials(client_id=os.getenv('SPOTIFY_ID'), client_secret=os.getenv('SPOTIFY_SECRET')))
|
||||
track = sp.track(message)
|
||||
name = track["name"]
|
||||
artist = track["artists"][0]["name"]
|
||||
results = YoutubeSearch(artist + " - " + name, max_results=1).to_json()
|
||||
get_link = json.loads(results)
|
||||
link = get_link['videos'][0]['url_suffix']
|
||||
print_link = 'https://youtube.com' + link
|
||||
url = print_link
|
||||
info = ydl.extract_info(url, download=False)
|
||||
name = info.get('title')
|
||||
id = info.get('id')
|
||||
ydl.download([id])
|
||||
send_message = "🎶 La canzone <b>" + name + \
|
||||
"</b> è stata scaricata con successo!"
|
||||
bot.send_message(pm.chat.id, send_message, parse_mode="HTML")
|
||||
bot.send_audio(pm.chat.id, audio=open("music_cache/" + name + '.mp3', 'rb'))
|
||||
os.remove("music_cache/" + name + '.mp3')
|
||||
logging.info("\"" + name + "\" è stato scaricato ed eliminato con successo!")
|
||||
elif pm.text.startswith('https://youtube.com/') or pm.text.startswith('youtube.com/'):
|
||||
bot.send_message(
|
||||
pm.chat.id, "🚫 <b>Errore</b>\n\n<b>Il link</b> inserito non è valido!")
|
||||
else:
|
||||
try:
|
||||
with YoutubeDL(ytdl_opts) as ydl:
|
||||
url = pm.text
|
||||
info = ydl.extract_info(url, download=False)
|
||||
name = info.get('title')
|
||||
id = info.get('id')
|
||||
ydl.download([id])
|
||||
send_message = "🎶 La canzone <b>" + name + "</b> è stata scaricata con successo!"
|
||||
send_message = "🎶 La canzone <b>" + name + \
|
||||
"</b> è stata scaricata con successo!"
|
||||
bot.send_message(pm.chat.id, send_message, parse_mode="HTML")
|
||||
bot.send_audio(pm.chat.id, audio=open(name + '.mp3', 'rb'))
|
||||
bot.send_audio(pm.chat.id, audio=open("music_cache/" + name + '.mp3', 'rb'))
|
||||
os.remove("music_cache/" + name + '.mp3')
|
||||
except:
|
||||
chat = pm.chat.id
|
||||
send_msg = "🚫 Errore!\n\n<b>Errore:</b> <i>Impossibile scaricare la canzone</i>"
|
||||
bot.send_message(chat, send_msg, parse_mode="HTML")
|
||||
|
||||
else:
|
||||
bot.send_message(pm.chat.id, "🚫 Devi inserire un <b>link</b> valido!")
|
||||
chat = pm.chat.id
|
||||
bot.send_message(chat, pm.chat.id,
|
||||
"🚫 Devi inserire un <b>link</b> valido!")
|
||||
|
||||
|
||||
#Command /meteo
|
||||
@bot.message_handler(commands=['meteo'])
|
||||
def meteo(pm):
|
||||
print("Triggered command METEO.")
|
||||
logging.info("Triggered command METEO.")
|
||||
sent_msg = bot.send_message(pm.chat.id, "🏙️ Inserisci la città:")
|
||||
bot.register_next_step_handler(sent_msg, meteo_step)
|
||||
|
||||
|
||||
def meteo_step(message):
|
||||
translator = deepl.Translator(os.getenv('DEEPL_TOKEN'))
|
||||
result = translator.translate_text('hi', target_lang='IT')
|
||||
|
|
@ -91,7 +154,7 @@ def meteo_step(message):
|
|||
city = message.text
|
||||
token_weather = os.environ.get('WEATHER_TOKEN')
|
||||
response = requests.get("https://api.openweathermap.org/data/2.5/weather?q="+city+",it&APPID="+token_weather).json()
|
||||
weather = response['weather'][0]['main'] #
|
||||
weather = response['weather'][0]['main']
|
||||
temp = response['main']['temp']
|
||||
temp = temp - 273.15
|
||||
weather_translate = translator.translate_text(weather, target_lang='IT')
|
||||
|
|
@ -100,6 +163,8 @@ def meteo_step(message):
|
|||
bot.send_message(message.chat.id, "🌧️ La condizione è " + result_weather)
|
||||
|
||||
#Command /stats
|
||||
|
||||
|
||||
@bot.message_handler(commands=['stats'])
|
||||
def uptime(message):
|
||||
print("Triggered command STATS.")
|
||||
|
|
@ -120,37 +185,45 @@ In uso = {} %\n'''.format(cpuUsage,ramTotal,ramUsage,ramFree,ramUsagePercent)
|
|||
bot.send_message(message.chat.id, msg)
|
||||
|
||||
#Command /pastebin
|
||||
|
||||
|
||||
@bot.message_handler(commands=['pastebin'])
|
||||
def pastebin(message):
|
||||
print("Triggered command PASTEBIN.")
|
||||
logging.info("Triggered command PASTEBIN.")
|
||||
sent_msg = bot.send_message(message.chat.id, "📋 Inserisci il testo:")
|
||||
bot.register_next_step_handler(sent_msg, pastebin_step)
|
||||
|
||||
|
||||
def pastebin_step(message):
|
||||
chat = message.chat.id
|
||||
text = message.text
|
||||
site = 'https://pastebin.com/api/api_post.php'
|
||||
dev_key = os.environ.get('PASTEBIN_TOKEN')
|
||||
code = text
|
||||
our_data = urllib.parse.urlencode({"api_dev_key": dev_key, "api_option": "paste", "api_paste_code": code})
|
||||
our_data = urllib.parse.urlencode(
|
||||
{"api_dev_key": dev_key, "api_option": "paste", "api_paste_code": code})
|
||||
our_data = our_data.encode()
|
||||
resp = urllib.request.urlopen(site, our_data)
|
||||
resp = resp.read()
|
||||
send_msg = "📋 Il tuo <b>codice</b> è stato inviato con successo!\n\n<b>Link:</b> " + str(resp)
|
||||
send_msg = "📋 Il tuo <b>codice</b> è stato inviato con successo!\n\n<b>Link:</b> " + \
|
||||
str(resp)
|
||||
bot.send_message(chat, send_msg, parse_mode="HTML")
|
||||
|
||||
#Command /epicgames
|
||||
|
||||
|
||||
@bot.message_handler(commands=['epicgames'])
|
||||
def epicgames(message):
|
||||
text = message.text
|
||||
bot.send_message(message.chat.id, "🎮 Vuoi vedere il gioco disponibile al momento o quello futuro? (disponibile/futuro)")
|
||||
bot.send_message(
|
||||
message.chat.id, "🎮 Vuoi vedere il gioco disponibile al momento o quello futuro? (disponibile/futuro)")
|
||||
bot.register_next_step_handler(message, epicgames_step)
|
||||
|
||||
|
||||
def epicgames_step(message):
|
||||
text = message.text
|
||||
if text == 'disponibile':
|
||||
print("Triggered command EPICGAMES DISPONIBILE.")
|
||||
if text == 'disponibile' or text == 'Disponibile':
|
||||
logging.info("Triggered command EPICGAMES DISPONIBILE.")
|
||||
# URL API
|
||||
url = "https://api.plenusbot.xyz/epic_games?country=IT"
|
||||
response = requests.get(url).json()
|
||||
|
|
@ -163,12 +236,14 @@ def epicgames_step(message):
|
|||
# Token for translate
|
||||
translator = deepl.Translator(os.getenv('DEEPL_TOKEN'))
|
||||
# Translate description current games
|
||||
description_translate = translator.translate_text(current_games_description, target_lang='IT')
|
||||
description_translate = translator.translate_text(
|
||||
current_games_description, target_lang='IT')
|
||||
result_description = description_translate.text
|
||||
send_img = bot.send_photo(message.chat.id, image_currentgames)
|
||||
sent_msg = bot.send_message(message.chat.id, "🎮 Il gioco gratis di oggi è " + current_games + "\n\n" + result_description)
|
||||
sent_msg = bot.send_message(
|
||||
message.chat.id, "🎮 Il gioco gratis di oggi è " + current_games + "\n\n" + result_description)
|
||||
else:
|
||||
print("Triggered command EPICGAMES FUTURO.")
|
||||
logging.info("Triggered command EPICGAMES FUTURO.")
|
||||
# URL API
|
||||
url = "https://api.plenusbot.xyz/epic_games?country=IT"
|
||||
response = requests.get(url).json()
|
||||
|
|
@ -180,10 +255,12 @@ def epicgames_step(message):
|
|||
future_games_description1 = response['nextGames'][0]['description']
|
||||
# Token for translate
|
||||
translator = deepl.Translator(os.getenv('DEEPL_TOKEN'))
|
||||
description_translate1 = translator.translate_text(future_games_description1, target_lang='IT')
|
||||
description_translate1 = translator.translate_text(
|
||||
future_games_description1, target_lang='IT')
|
||||
result_description1 = description_translate1.text
|
||||
send_img = bot.send_photo(message.chat.id, image_futuregames1)
|
||||
sent_msg = bot.send_message(message.chat.id, "🎮 Il gioco futuro è " + future_games1 + "\n\n" + result_description1)
|
||||
sent_msg = bot.send_message(
|
||||
message.chat.id, "🎮 Il gioco futuro è " + future_games1 + "\n\n" + result_description1)
|
||||
# Title of future games
|
||||
future_games2 = response['nextGames'][1]['title']
|
||||
# Image future games
|
||||
|
|
@ -191,9 +268,12 @@ def epicgames_step(message):
|
|||
# Description future games
|
||||
future_games_description2 = response['nextGames'][1]['description']
|
||||
# Traslate description future games
|
||||
description_translate2 = translator.translate_text(future_games_description2, target_lang='IT')
|
||||
description_translate2 = translator.translate_text(
|
||||
future_games_description2, target_lang='IT')
|
||||
result_description2 = description_translate2.text
|
||||
send_img = bot.send_photo(message.chat.id, image_futuregames2)
|
||||
sent_msg = bot.send_message(message.chat.id, "🎮 Il gioco futuro è " + future_games2 + "\n\n" + result_description2)
|
||||
sent_msg = bot.send_message(
|
||||
message.chat.id, "🎮 Il gioco futuro è " + future_games2 + "\n\n" + result_description2)
|
||||
|
||||
|
||||
bot.polling()
|
||||
|
|
@ -1,4 +1,3 @@
|
|||
|
||||
bs4 == 0.0.1
|
||||
|
||||
deepl == 1.8.0
|
||||
|
|
@ -21,10 +20,14 @@ pytube == 12.1.0
|
|||
|
||||
requests == 2.25.1
|
||||
|
||||
spotipy == 2.20.0
|
||||
|
||||
telebot == 0.0.4
|
||||
|
||||
tqdm == 4.64.0
|
||||
|
||||
youtube_search == 2.1.0
|
||||
|
||||
yt_dlp == 2022.5.18
|
||||
|
||||
pytelegrambotapi == 4.5.1
|
||||
Loading…
Reference in New Issue