Compare commits
No commits in common. "c86eecfad1ec904b7a1892c3300fb18e94a5d21a" and "11a639be5d6b3260aee80da5a8ecd44da29f397e" have entirely different histories.
c86eecfad1
...
11a639be5d
@ -1,7 +0,0 @@
|
|||||||
config {
|
|
||||||
'server_url': 'https://example.com',
|
|
||||||
'username': '',
|
|
||||||
'password': '',
|
|
||||||
'yt_dlp_format': 'bestvideo[ext=webm]+bestaudio[ext=webm]/best[ext=mp4]/best',
|
|
||||||
'download_dir': './videos',
|
|
||||||
}
|
|
65
main.py
65
main.py
@ -1,9 +1,20 @@
|
|||||||
|
from __future__ import unicode_literals
|
||||||
import simplematrixbotlib as botlib
|
import simplematrixbotlib as botlib
|
||||||
from re import search
|
from re import search
|
||||||
from urllib.parse import quote as sanitize_url
|
import urllib.parse
|
||||||
import yt_dlp
|
import youtube_dl
|
||||||
|
import os
|
||||||
|
|
||||||
from config import config
|
try:
|
||||||
|
passfile = open("pass.txt", "r")
|
||||||
|
passw = passfile.read().translate({ord(c): None for c in '\n'})
|
||||||
|
except:
|
||||||
|
print("Put the password in pass.txt in this directory")
|
||||||
|
|
||||||
|
creds = botlib.Creds("https://chat.trygve.me", "video_bot", passw)
|
||||||
|
bot = botlib.Bot(creds)
|
||||||
|
|
||||||
|
prefix = 'https://'
|
||||||
|
|
||||||
class MyLogger(object):
|
class MyLogger(object):
|
||||||
def debug(self, msg):
|
def debug(self, msg):
|
||||||
@ -16,46 +27,40 @@ class MyLogger(object):
|
|||||||
print(msg)
|
print(msg)
|
||||||
|
|
||||||
|
|
||||||
creds = botlib.Creds(config['url'], config['username'], config['password'])
|
def my_hook(d):
|
||||||
bot = botlib.Bot(creds)
|
if d['status'] == 'finished':
|
||||||
|
|
||||||
def progress_hook(d):
|
|
||||||
if d['status'] == 'started':
|
|
||||||
print('Started downloading')
|
|
||||||
elif d['status'] == 'finished':
|
|
||||||
print('Done downloading')
|
print('Done downloading')
|
||||||
|
|
||||||
|
|
||||||
ydl_opts = {
|
ydl_opts = {
|
||||||
'format': config['yt_dlp_format'],
|
'format': 'bestvideo[ext=webm]+bestaudio[ext=webm]/best[ext=mp4]/best',
|
||||||
'outtmpl': config['download_dir'] + '/%(title)s.%(ext)s',
|
'outtmpl': '/var/www/html/video_bot/%(title)s.%(ext)s',
|
||||||
'restrictfilenames': True,
|
'restrictfilenames': False,
|
||||||
'logger': MyLogger(),
|
'logger': MyLogger(),
|
||||||
'progress_hooks': [progress_hook],
|
'progress_hooks': [my_hook],
|
||||||
}
|
}
|
||||||
|
|
||||||
def get_yt_vid_id(word):
|
def filterfunc(variable):
|
||||||
if search('www.youtube.com/watch', word):
|
if search('www.youtube.com/watch', variable):
|
||||||
return word
|
return True
|
||||||
elif search('youtu.be', word):
|
|
||||||
return word.replace('https://youtu.be/', 'https://www.youtube.com/watch?v=')
|
|
||||||
else:
|
else:
|
||||||
return False
|
return False
|
||||||
|
|
||||||
@bot.listener.on_message_event
|
|
||||||
async def youtube(room, message):
|
async def youtube(room, message):
|
||||||
match = botlib.MessageMatch(room, message, bot)
|
match = botlib.MessageMatch(room, message, bot)
|
||||||
pieces = str(message).split()
|
pieces = str(message).split()
|
||||||
|
links = filter(filterfunc, pieces)
|
||||||
try:
|
try:
|
||||||
for i in pieces:
|
for i in links:
|
||||||
yt_url = get_yt_vid_id(i)
|
with youtube_dl.YoutubeDL(ydl_opts) as ydl:
|
||||||
if yt_url:
|
info_dict = ydl.extract_info(i, download=False)
|
||||||
with yt_dlp.YoutubeDL(ydl_opts) as ydl:
|
fname = urllib.parse.quote(info_dict.get('title', None).replace('|', '_'))
|
||||||
info_dict = ydl.extract_info(yt_url, download=False)
|
url = 'https://trygve.me/video_bot/' + fname + '.webm'
|
||||||
fname = sanitize_url(yt_dlp.utils.sanitize_filename(info_dict.get('title', None), restricted=True))
|
ydl.download([i])
|
||||||
url = 'https://trygve.me/video_bot/' + fname + '.webm'
|
await bot.api.send_text_message(room.room_id, url)
|
||||||
ydl.download([yt_url])
|
|
||||||
await bot.api.send_text_message(room.room_id, url)
|
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
await bot.api.send_text_message(room.room_id, str(e))
|
await bot.api.send_text_message(room.room_id, str(e))
|
||||||
|
|
||||||
|
bot.add_message_listener(youtube)
|
||||||
|
|
||||||
bot.run()
|
bot.run()
|
||||||
|
Loading…
Reference in New Issue
Block a user