real world fixes
This commit is contained in:
parent
d1175cbe2f
commit
1a37af5aa9
64
main.rb
64
main.rb
@ -1,23 +1,52 @@
|
|||||||
require 'discordrb'
|
require 'discordrb'
|
||||||
|
require 'video_info'
|
||||||
require 'uri'
|
require 'uri'
|
||||||
require 'optparse'
|
require 'optparse'
|
||||||
require 'shellwords'
|
require 'shellwords'
|
||||||
|
|
||||||
def parse_songs_from_string(mpd,message)
|
def sanity_check_video(url)
|
||||||
|
if !url.include?("youtube")
|
||||||
|
return false
|
||||||
|
end
|
||||||
|
video = VideoInfo.new(url)
|
||||||
|
title = video.title
|
||||||
|
title.slice! " - YouTube Music"
|
||||||
|
if video.duration > 1200
|
||||||
|
puts "skipping #{url} since it's over 20 minutes"
|
||||||
|
return false
|
||||||
|
elsif File.exists?("tracks/#{title}.mp3") || File.exists?("spool/#{title}.mp3")
|
||||||
|
puts "#{url} already downloaded, not downloading again"
|
||||||
|
return false
|
||||||
|
end
|
||||||
|
return true
|
||||||
|
end
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
def parse_songs_from_string(message)
|
||||||
urls = URI.extract(message)
|
urls = URI.extract(message)
|
||||||
if urls.length != 0
|
if urls.length != 0
|
||||||
puts "Found #{urls}; downloading"
|
puts "Found #{urls}; downloading"
|
||||||
urls.each do |url|
|
urls.each do |url|
|
||||||
res = `youtube-dl --ignore-errors --output \"spool/%(title)s.%(ext)s\" --extract-audio --audio-format mp3 #{url}`
|
if sanity_check_video(url)
|
||||||
if res
|
res = `youtube-dl --ignore-errors --output \"spool/%(title)s.%(ext)s\" --extract-audio --audio-format mp3 #{url}`
|
||||||
puts "Downloaded #{url}"
|
if res
|
||||||
else
|
puts "Downloaded #{url}"
|
||||||
puts "error downloading #{url}"
|
else
|
||||||
|
puts "error downloading #{url}"
|
||||||
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
if mpd
|
end
|
||||||
puts "telling mpd to refresh"
|
nil
|
||||||
|
end
|
||||||
|
|
||||||
|
def update_mpd()
|
||||||
new_songs = Dir["spool/*.mp3"]
|
new_songs = Dir["spool/*.mp3"]
|
||||||
|
if new_songs.length <= 0
|
||||||
|
return true
|
||||||
|
end
|
||||||
|
puts "telling mpd to refresh"
|
||||||
system("mv spool/*.mp3 tracks/")
|
system("mv spool/*.mp3 tracks/")
|
||||||
system("mpc update")
|
system("mpc update")
|
||||||
new_songs.each do |song|
|
new_songs.each do |song|
|
||||||
@ -29,9 +58,6 @@ def parse_songs_from_string(mpd,message)
|
|||||||
puts "error adding #{s} to mpd"
|
puts "error adding #{s} to mpd"
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
|
||||||
end
|
|
||||||
nil
|
|
||||||
end
|
end
|
||||||
|
|
||||||
options = {}
|
options = {}
|
||||||
@ -49,7 +75,6 @@ puts "creating spool and tracks directories"
|
|||||||
system("mkdir -p spool")
|
system("mkdir -p spool")
|
||||||
system("mkdir -p tracks")
|
system("mkdir -p tracks")
|
||||||
|
|
||||||
mpd = false
|
|
||||||
if File.exists?("/usr/bin/mpd")
|
if File.exists?("/usr/bin/mpd")
|
||||||
if !File.exists?("/usr/bin/mpc")
|
if !File.exists?("/usr/bin/mpc")
|
||||||
puts "Bailing since mpd exists but not mpc (which is needed to control mpd)"
|
puts "Bailing since mpd exists but not mpc (which is needed to control mpd)"
|
||||||
@ -59,8 +84,8 @@ if File.exists?("/usr/bin/mpd")
|
|||||||
system("systemctl start mpd") unless `ps aux | grep mpd` != ""
|
system("systemctl start mpd") unless `ps aux | grep mpd` != ""
|
||||||
system("mpc clear")
|
system("mpc clear")
|
||||||
system("mpc add /")
|
system("mpc add /")
|
||||||
|
system("mpc shuffle")
|
||||||
system("mpc repeat")
|
system("mpc repeat")
|
||||||
mpd = true
|
|
||||||
end
|
end
|
||||||
|
|
||||||
bot = Discordrb::Commands::CommandBot.new token: options[:bot_token], prefix: '!radio '
|
bot = Discordrb::Commands::CommandBot.new token: options[:bot_token], prefix: '!radio '
|
||||||
@ -81,6 +106,7 @@ bot.command :reload do |event|
|
|||||||
system("mpc clear")
|
system("mpc clear")
|
||||||
system("mpc update")
|
system("mpc update")
|
||||||
system("mpc add /")
|
system("mpc add /")
|
||||||
|
event.respond("queue reloaded")
|
||||||
nil
|
nil
|
||||||
end
|
end
|
||||||
|
|
||||||
@ -96,19 +122,27 @@ bot.command :skip do |event|
|
|||||||
nil
|
nil
|
||||||
end
|
end
|
||||||
|
|
||||||
|
bot.command :shuffle do |event|
|
||||||
|
system("mpc shuffle")
|
||||||
|
event.respond("shuffled queue")
|
||||||
|
nil
|
||||||
|
end
|
||||||
|
|
||||||
bot.command :initialize do |event|
|
bot.command :initialize do |event|
|
||||||
event.respond("loading last 50 messages from channel")
|
event.respond("loading last 50 messages from channel")
|
||||||
channel = bot.channel(options[:channel_id])
|
channel = bot.channel(options[:channel_id])
|
||||||
messages = channel.history(50)
|
messages = channel.history(50)
|
||||||
messages.each do |msg|
|
messages.each do |msg|
|
||||||
parse_songs_from_string(mpd,msg.content)
|
parse_songs_from_string(msg.content)
|
||||||
end
|
end
|
||||||
|
update_mpd()
|
||||||
event.respond("done loading")
|
event.respond("done loading")
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
||||||
bot.message(in: options[:channel_id],contains: "youtube.com") do |event|
|
bot.message(in: options[:channel_id],contains: "youtube.com") do |event|
|
||||||
parse_songs_from_string(mpd,event.content)
|
parse_songs_from_string(event.content)
|
||||||
|
update_mpd()
|
||||||
end
|
end
|
||||||
|
|
||||||
bot.run
|
bot.run
|
||||||
|
Loading…
Reference in New Issue
Block a user