music.py 2.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667
  1. from __future__ import unicode_literals
  2. from urllib.parse import urlparse
  3. import os
  4. import youtube_dl
  5. from pyrogram import filters
  6. from pyrogram.types import Message
  7. from wbb.utils import cust_filter
  8. from wbb import app, OWNER_ID
  9. __MODULE__ = "Music"
  10. __HELP__ = "/music [link] To Download Music From Various Websites"
  11. ydl_opts = {
  12. 'format': 'bestaudio/best',
  13. 'writethumbnail': True,
  14. 'postprocessors': [{
  15. 'key': 'FFmpegExtractAudio',
  16. 'preferredcodec': 'mp3',
  17. 'preferredquality': '192'
  18. }]
  19. }
  20. @app.on_message(cust_filter.command(commands=("music")) & ~filters.edited & filters.user(OWNER_ID))
  21. async def music(_, message: Message):
  22. if len(message.command) != 2:
  23. await message.reply_text("`/music` needs a link as argument")
  24. return
  25. link = message.text.split(None, 1)[1]
  26. m = await message.reply_text(f"Downloading {link}",
  27. disable_web_page_preview=True)
  28. try:
  29. with youtube_dl.YoutubeDL(ydl_opts) as ydl:
  30. info_dict = ydl.extract_info(link, download=False)
  31. audio_file = ydl.prepare_filename(info_dict)
  32. ydl.process_info(info_dict)
  33. # .webm -> .weba
  34. basename = audio_file.rsplit(".", 1)[-2]
  35. thumbnail_url = info_dict['thumbnail']
  36. thumbnail_file = basename + "." + \
  37. get_file_extension_from_url(thumbnail_url)
  38. if info_dict['ext'] == 'webm':
  39. audio_file_weba = basename + ".mp3"
  40. os.rename(audio_file, audio_file_weba)
  41. audio_file = audio_file_weba
  42. except Exception as e:
  43. await m.edit(str(e))
  44. return
  45. # info
  46. title = info_dict['title']
  47. webpage_url = info_dict['webpage_url']
  48. performer = info_dict['uploader']
  49. duration = int(float(info_dict['duration']))
  50. caption = f"[{title}]({webpage_url})"
  51. await m.delete()
  52. await message.reply_chat_action("upload_document")
  53. await message.reply_audio(audio_file, caption=caption,
  54. duration=duration, performer=performer,
  55. title=title, thumb=thumbnail_file)
  56. os.remove(audio_file)
  57. os.remove(thumbnail_file)
  58. def get_file_extension_from_url(url):
  59. url_path = urlparse(url).path
  60. basename = os.path.basename(url_path)
  61. return basename.split(".")[-1]