summaryrefslogtreecommitdiff
path: root/crystal/irc.cr
diff options
context:
space:
mode:
Diffstat (limited to 'crystal/irc.cr')
-rw-r--r--crystal/irc.cr490
1 files changed, 354 insertions, 136 deletions
diff --git a/crystal/irc.cr b/crystal/irc.cr
index 5d2283c..9ac7e8b 100644
--- a/crystal/irc.cr
+++ b/crystal/irc.cr
@@ -15,15 +15,37 @@ end
settings = Hash(String, String).new
+settings["configdir"] = Path.home./("/.config/bungmobott/").to_s
+settings["statedir"] = Path.home./("/.local/state/bungmobott/").to_s
+
+if ENV["LOCALAPPDATA"]?
+ settings["configdir"] = Path.windows( ENV["LOCALAPPDATA"] + "\\bungmobott\\" ).to_s
+ settings["statedir"] = Path.windows( ENV["LOCALAPPDATA"] + "\\bungmobott\\state\\" ).to_s
+end
+
+ENV["XDG_CONFIG_HOME"]? && ( settings["configdir"] = ENV["XDG_CONFIG_HOME"] + "/bungmobott/" )
+#ENV["XDG_DATA_HOME"]? && ( settings["datadir"] = ENV["XDG_DATA_HOME"] ) # unused?
+ENV["XDG_STATE_HOME"]? && ( settings["statedir"] = ENV["XDG_STATE_HOME"] + "/bungmobott/" )
+
+Dir.mkdir_p( settings["configdir"] )
+Dir.mkdir_p( settings["statedir"] )
+
settings["home"] = Path.home.to_s
["access_token", "channel", "channel_id", "client_id", "client_id_twitch"].each do |key|
begin
- settings[key] = File.read( settings["home"] + "/.config/twitch/" + key ).chomp
+ settings[key] = File.read( settings["configdir"] + key ).chomp
rescue IO::Error
- STDERR.puts "Warning: Missing " + settings["home"] + "/.config/twitch/" + key
+ STDERR.puts "Warning: Missing " + settings["configdir"] + key
end
end
+if File.exists?( settings["configdir"] + "chatuser" )
+ File.read( settings["configdir"] + "chat_user" ).chomp
+else
+ STDERR.puts "Warning: Missing " + settings["configdir"] + "chat_user; using configured channel instead."
+ settings["chat_user"] = settings["channel"]
+end
+
obsipc = Channel( String ).new
ircipc = Channel( Tuple( String, String ) ).new
@@ -40,65 +62,65 @@ def urbandef( term : String )
return json["list"][0]["definition"].to_s.gsub( /[\[\]]/, "" ).gsub( /\n/, "" )
end
-def ircmsg( home : String, channel : String, msg : String)
- if msg !~ /(\r|\n)/
- sock = Socket.unix
+#def ircmsg( home : String, channel : String, msg : String)
+# if msg !~ /(\r|\n)/
+# sock = Socket.unix
# sock.connect Socket::UNIXAddress.new( home + "/.irssi/twitch-socket".to_s, type: Socket::Type::DGRAM )
- sock.connect Socket::UNIXAddress.new( home + "/.irssi/twitch-socket".to_s )
- sock.puts( "#" + channel + " " + msg )
+# sock.connect Socket::UNIXAddress.new( home + "/.irssi/twitch-socket".to_s )
+# sock.puts( "#" + channel + " " + msg )
+# sock.close
+# end
+#end
+
+def t2smsg( settings : Hash(String, String), msg : String)
+ if File.exists?( settings["statedir"] + "/.t2s.sock" )
+ sock = Socket.unix
+ sock.connect Socket::UNIXAddress.new( settings["statedir"] + "/.t2s.sock" )
+ sock.puts( msg )
sock.close
end
-end
-
-def t2smsg( msg : String)
- sock = Socket.unix
- sock.connect Socket::UNIXAddress.new( ENV["HOME"] + "/.t2s.sock" )
- sock.puts( msg )
- sock.close
rescue ex
puts ex
end
-def effectsmsg( msg : String )
- sock = Socket.unix
- sock.connect Socket::UNIXAddress.new( ENV["HOME"] + "/.effects.sock" )
- sock.puts( msg )
- sock.close
+def effectsmsg( settings : Hash(String, String), msg : String )
+ if File.exists?( settings["statedir"] + "/.effects.sock" )
+ sock = Socket.unix
+ sock.connect Socket::UNIXAddress.new( settings["statedir"] + "/.effects.sock" )
+ sock.puts( msg )
+ sock.close
+ end
rescue ex
puts ex
end
-def userlog( settings : Hash(String, String), message : FastIRC::Message )
+def userlog( ircipc : Channel, settings : Hash(String, String), message : FastIRC::Message )
unless ( ( prefix = message.prefix ) && ( chatuser = prefix.source ) && ( uid = message.tags["user-id"]? ) )
return nil
end
- basedir = settings["home"] + "/.cache/twitchtools"
+ basedir = settings["statedir"]
userdir = basedir + "/uids/" + uid
- unless File.directory?( userdir )
- Dir.mkdir( userdir )
- end
- unless File.directory?( userdir + "/names" )
- Dir.mkdir( userdir + "/names" )
- end
- unless File.symlink?( userdir + "/names/" + chatuser )
- namelatest = ""
- datelatest = Time::UNIX_EPOCH
- Dir.each_child( userdir + "/names/" ) do |name|
- namedate = File.info( userdir + "/names/" + name ).modification_time
- if namedate > datelatest
- namelatest = name
- datelatest = namedate
- end
+ Dir.mkdir_p( basedir + "/names" )
+ Dir.mkdir_p( userdir + "/names" )
+ unless testrefuser2uid( userdir + "/names/" + chatuser )
+ namelatest = ""
+ datelatest = Time::UNIX_EPOCH
+ Dir.each_child( userdir + "/names/" ) do |name|
+ namedate = File.info( userdir + "/names/" + name ).modification_time
+ if namedate > datelatest
+ namelatest = name
+ datelatest = namedate
end
- unless namelatest.empty?
- ircmsg( settings["home"], settings["channel"], "Rename detected: #{uid}: #{namelatest} -> #{chatuser}" )
- end
- File.symlink( "../", userdir + "/names/" + chatuser )
end
- unless File.symlink?( basedir + "/names/" + chatuser )
- File.symlink( "../uids/" + uid, basedir + "/names/" + chatuser )
+ unless namelatest.empty?
+ ircipc.send( { "##{settings["channel"]}", "Rename detected: #{uid}: #{namelatest} -> #{chatuser}" } )
end
- unless ( message.params[0] == "#bungmonkey" )
+ genrefuser2uid( userdir + "/names/" + chatuser, uid, 3 )
+ end
+ unless testrefuser2uid( basedir + "/names/" + chatuser )
+ genrefuser2uid( basedir + "/names/" + chatuser, uid, 1 )
+ end
+ unless ( message.params[0] == "##{settings["channel"]}" )
return nil
end
return ( [ chatuser, uid, userdir ] )
@@ -111,7 +133,7 @@ def getvoice( settings : Hash(String, String), userdir : String, chatuser : Stri
voice_output = File.read( userdir + "/voice" ).chomp
voice_setting = voice_output
else
- voice_output = File.read( settings["home"] + "/voicelist.txt" ).chomp.split( "\n" ).sample( 1 )[0].chomp
+ voice_output = File.read( settings["configdir"] + "/voicelist.txt" ).chomp.split( "\n" ).sample( 1 )[0].chomp
voice_setting = "random"
end
if File.exists?( userdir + "/voicesub" )
@@ -126,17 +148,134 @@ end
def t2s( settings : Hash(String, String), userdir : String, chatuser : String, text : String )
if ( text !~ /^ *(!|\|)/ )
namesub, voice_setting, voice = getvoice( settings, userdir, chatuser )
- t2stext = text.gsub( /http(s|):\/\/([a-z0-9.]+)\/[a-zA-Z0-9\/&=%-_]+/, "link to ${2}" )
- t2stext = t2stext.gsub( /rrr.+/, "rr" )
- t2smsg( "#{voice} #{namesub} #{t2stext}" )
+ subs = Array( Tuple( Regex, String ) ){
+ { /http(s|):\/\/([a-z0-9.-]+)\/[a-zA-Z0-9\/&=%-_]+/, "link to \\2" },
+ { /([^a-zA-Z0-9])-/, "\\1 dash "},
+ { /\|/, " vertical bar "},
+ { /\`/, " grave accent "},
+ { /\+/, " plus "},
+ { /×/, " multiplied by "},
+ { /=/, " equals "},
+ { /\//, " slash "},
+ { /\\/, " backslash "},
+ { /@/, " at "},
+ { /&/, " and "},
+ { />/, " greater than "},
+ { /</, " less than "},
+ { /_/, " underscore "},
+ { /\.\.\./, " dot dot dot "},
+ { /\^/, " circumflex accent "},
+ { /\#/, " octothorpe "},
+ { /:([^ ])/, " colon \\1"},
+ { /;([^ ])/, " semicolon \\1"},
+ { /\.([^ ])/, " dot \\1"},
+ { /\%([^ ])/, " percent sign \\1"},
+ { /!([^ ])/, " tchik \\1"},
+ { /([^ ])\$/, "\\1 dollar sign "},
+ { /0/, " zero " },
+ { /1/, " one " },
+ { /2/, " two " },
+ { /3/, " three " },
+ { /4/, " four " },
+ { /5/, " five " },
+ { /6/, " six " },
+ { /7/, " seven " },
+ { /8/, " eight " },
+ { /9/, " nine " },
+ { /rrr.+/, "rr" },
+ }.each do | subtuple |
+ text = text.gsub( subtuple[0], subtuple[1] )
+ end
+ {% if flag?(:windows) %}
+ if ( match = voice.match( /^Microsoft-([A-Za-z]+)/ ) )
+ if ( match[1] =~ /Lili|Mary|Mike|Sam|Anna/ )
+ msttsvoice="Microsoft #{match[1]}"
+ else
+ msttsvoice="Microsoft #{match[1]} Desktop"
+ end
+ pp msttsvoice
+ p = Process.new( "powershell.exe", [ "-Command", "
+ echo test;
+ Add-Type -AssemblyName System.Speech;
+ $speak = New-Object System.Speech.Synthesis.SpeechSynthesizer;
+ $speak.SelectVoice(\"#{msttsvoice}\");
+ $speak.Speak($Input);
+ $speak.Finalize($Input);
+ "],
+ input: Process::Redirect::Pipe, output: STDOUT )
+ p.input.puts "#{namesub} #{text}"
+ p.input.close
+ end
+ {% elsif flag?(:unix) %}
+ t2smsg( settings, "#{voice} #{namesub} #{text}" )
+ {% end %}
return( voice )
else
return( nil )
end
end
+def reversesource( scenes : Hash( String, Hash( String, Hash( String, Int64 | Float64 | Bool | String ) ) ), currentscene : String )
+# "meta-cam-front" => {
+# "vidcap-c920" => {
+# "render" => true, "type" => "dshow_input", "x" => 0.0, "y" => 0.0
+# },
+# "gst-bungfront" => {
+# "type" => "gstreamer-source", "x" => 0.0, "y" => 0.0
+# }
+# }
+# # scenes[currentscene][source]["type"] => "scene"
+ sourcemap = Hash( String, String ).new
+ scenes[currentscene].each do | source, sourcedata |
+ # maybe make this recurse later
+ sourcemap[source.to_s] = currentscene
+ if sourcedata["type"] == "scene"
+ scenes[source.to_s].each do | metasource, metasourcedata |
+ sourcemap[metasource.to_s] = source.to_s
+ end
+ end
+ end
+ return sourcemap
+end
+
+macro testrefuser2uid( path )
+ {% if flag?(:windows) %}
+ File.exists?( {{path}} ) && ( File.read( {{ path }} ) =~ /^[0-9]+$/ )
+ {% elsif flag?(:unix) %}
+ File.symlink?( {{path}} )
+ {% end %}
+end
+
+macro genrefuser2uid( path, uid, depth )
+ {% if flag?(:windows) %}
+ File.write( {{path}}, {{uid}}.to_s )
+ {% elsif flag?(:unix) %}
+ pp "unix"
+ File.symlink( "../"*{{depth}} + "uids/#{{{uid}}}", {{path}} )
+ {% end %}
+end
+
+macro temporaryduplicate( item )
+ request = Hash( String, String | Bool ){
+ "request-type" => "SetSceneItemProperties",
+ "message-id" => "SetSceneItemProperties",
+ "scene-name" => "meta",
+ "item" => {{item}},
+ "visible" => true,
+ }
+ obsipc.send( request.to_json )
+ request = Hash( String, String | Hash( String, String ) ){
+ "request-type" => "DuplicateSceneItem",
+ "message-id" => "DuplicateSceneItem",
+ "item" => { "name" => {{item}} },
+ "fromScene" => "meta"
+ }
+ ircipc.send( { "##{settings["channel"]}", "Duplicating source #{match[2]}" } )
+ obsipc.send( request.to_json )
+end
+
voices = Hash(String, String).new
-File.each_line( settings["home"] + "/voicelist.txt" ) do |line|
+File.each_line( settings["configdir"] + "/voicelist.txt" ) do |line|
voices[ line.downcase ] = line
end
@@ -149,10 +288,36 @@ spawn do
obs_pubsub = HTTP::WebSocket.new( URI.parse( "ws://127.0.0.1:4444/" ), HTTP::Headers{"Cookie" => "SESSIONID=1234"} )
# Outgoing
+ # state
+ currentscene = "unknown"
+ # scenename => { sourcename => { property => value }
+ scenes = Hash( String, Hash( String, Hash( String, Int64 | Float64 | Bool | String ) ) ).new
spawn do
while msg = obsipc.receive
pp msg
- obs_pubsub.send( msg )
+ if ( match = msg.match( /^\x10source-toggle ([a-z0-9-_]+)/ ) )
+ source = match[1]
+ sources = reversesource( scenes, currentscene )
+ pp sources
+ request = Hash( String, String | Bool ).new
+ request["request-type"] = "SetSceneItemProperties"
+ request["message-id"] = "SetSceneItemProperties"
+ #request["request-type"] = "GetSceneItemProperties"
+ request["message-id"] = "toggle-source"
+ scene = sources[source]
+ request["scene-name"] = sources[source]
+ request["item"] = source
+ if scenes[scene][source]["render"] == true
+ request["visible"] = false
+ else
+ request["visible"] = true
+ end
+ obs_pubsub.send( request.to_json )
+ elsif ( match = msg.match( /^\x10source ([a-z0-9-_]+)/ ) )
+ # FIXME
+ else
+ obs_pubsub.send( msg )
+ end
end
end
# Incoming
@@ -168,6 +333,8 @@ spawn do
next # so skip them
when "SwitchScenes"
ircipc.send( { "#" + settings["channel"], "| obs: switched scene to " + ( json["scene-name"]?.as_s? || "unknown" ) } )
+ currentscene = json["scene-name"].as_s
+ puts "currentscene is " + currentscene
when "MediaEnded"
request = Hash( String, String | Bool ){
"request-type" => "SetSceneItemProperties",
@@ -175,8 +342,19 @@ spawn do
"item" => json["sourceName"].as_s,
"visible" => false
}
- #ircipc.send( { "##{settings["channel"]}", "Disabling #{json["sourceName"].as_s}" } )
+ ircipc.send( { "##{settings["channel"]}", "Disabling #{json["sourceName"].as_s}" } )
obsipc.send( request.to_json )
+ #"sourceName": "media-youdied"
+ puts "currentscene is " + currentscene
+ if ( ( json["sourceName"].as_s =~ /^media-/ ) && ( currentscene != "meta" ) )
+ request = Hash( String, String | Hash( String, String ) ){
+ "request-type" => "DeleteSceneItem",
+ "message-id" => "DeleteSceneItem",
+ "item" => { "name" => json["sourceName"].as_s },
+ }
+ ircipc.send( { "##{settings["channel"]}", "Deleting #{json["sourceName"].as_s}" } )
+ obsipc.send( request.to_json )
+ end
when "SourceFilterVisibilityChanged"
ircipc.send( { "##{settings["channel"]}", "| obs: source #{json["sourceName"]} filter #{json["filterName"]} visibility is now #{json["filterEnabled"]}" } )
when "SceneItemVisibilityChanged"
@@ -187,11 +365,27 @@ spawn do
print( "\n")
case json["message-id"]?
when "GetCurrentScene"
+ currentscene = json["name"].as_s
ircipc.send( { "#" + settings["channel"], "| obs: " + json["sources"].as_a.map{ |source| source["name"] }.join(", ") } )
when "GetSourceFilters"
ircipc.send( { "#" + settings["channel"], "| obs: " + json["filters"].as_a.map{ |filter| filter["name"] }.join(", ") } )
when "GetSceneList"
ircipc.send( { "#" + settings["channel"], "| obs: " + json["scenes"].as_a.map{ |scene| scene["name"] }.join(", ") } )
+ json["scenes"].as_a.each{ |scene|
+ scenes[scene["name"].as_s]? || ( scenes[scene["name"].as_s] = Hash( String, Hash( String, Int64 | Float64 | Bool | String ) ).new )
+ scene["sources"].as_a.each{ |source|
+ scenes[scene["name"].as_s][source["name"]]? || ( scenes[scene["name"].as_s][source["name"].as_s] = Hash( String, Int64 | Float64 | Bool | String ).new )
+ source["render"].as_bool != Nil && ( scenes[scene["name"].as_s][source["name"].as_s]["render"] = source["render"].as_bool )
+ source["type"].as_s? && ( scenes[scene["name"].as_s][source["name"].as_s]["type"] = source["type"].as_s )
+ source["x"].as_f? && ( scenes[scene["name"].as_s][source["name"].as_s]["x"] = source["x"].as_f )
+ source["y"].as_f? && ( scenes[scene["name"].as_s][source["name"].as_s]["y"] = source["y"].as_f )
+ source["cx"].as_i64? && ( scenes[scene["name"].as_s][source["name"].as_s]["cx"] = source["cx"].as_i64 )
+ source["cy"].as_i64? && ( scenes[scene["name"].as_s][source["name"].as_s]["cy"] = source["cy"].as_i64 )
+ source["source_cx"].as_f? && ( scenes[scene["name"].as_s][source["name"].as_s]["source_cx"] = source["source_cx"].as_f )
+ source["source_cy"].as_f? && ( scenes[scene["name"].as_s][source["name"].as_s]["source_cy"] = source["source_cy"].as_f )
+ }
+ }
+ pp scenes
when "toggle-filter"
name = json["filters"][0]["name"].as_s
visible = ( json["filters"][0]["enabled"].as_bool == false )
@@ -205,17 +399,24 @@ spawn do
obsipc.send( "{ \"request-type\": \"SetSceneItemProperties\", \"message-id\": \"SetSceneItemProperties\", \"item\": \"#{name}\", \"visible\": #{visible} }" )
end
end
+ request = Hash( String, String ){
+ "request-type" => "GetCurrentScene",
+ "message-id" => "GetCurrentScene",
+ }
+ obsipc.send( request.to_json )
+
obs_pubsub.run
- rescue ex : IO::Error
- pp ex
- ircipc.send( { "#" + settings["channel"], "obs.cr:obs: " + ex.to_s.gsub(/\r|\n/, ' ') + ": Maybe try again in 10 seconds?" } )
rescue ex : Socket::ConnectError
# these are a bit noisy
pp ex
obs_pubsub && obs_pubsub.close
+ rescue ex : IO::Error
+ pp ex
+ ircipc.send( { "#" + settings["channel"], "obs.cr:obs: " + ex.to_s.gsub(/\r|\n/, ' ') + ": Maybe try again in 10 seconds?" } )
rescue ex
- ircmsg( settings["home"], settings["channel"], "irc.cr:obs: " + ex.to_s.gsub(/\r|\n/, ' ') )
- puts ex
+ pp ex
+ pp ex.backtrace?
+ ircipc.send( { "#" + settings["channel"], "irc.cr:obs: " + ex.to_s.gsub(/\r|\n/, ' ') } )
obs_pubsub && obs_pubsub.close
end
sleep 10
@@ -227,24 +428,27 @@ end
loop do
begin
- bot = Twitch::IRC::Client.new( nick: settings["channel"], token: "oauth:" + settings["access_token"], log_mode: true )
+ bot = Twitch::IRC::Client.new( nick: settings["chat_user"], token: "oauth:" + settings["access_token"], log_mode: true )
bot.tags = [ "membership", "tags", "commands" ]
# Outgoing
+ # "Most IRC servers limit messages to 512 bytes in length, including the trailing CR-LF characters."
+ # PRIVMSG #channel message\r\n
spawn do
- while msgtuple = ircipc.receive
-bot.message( msgtuple[0], msgtuple[1][0..480] )
+ while msgtuple = ircipc.receive # why does this need to be a tuple?
+ sizelimit=( 512 - ( msgtuple[0].size + 11 ) )
+ bot.message( msgtuple[0], msgtuple[1][0..sizelimit] ) # limit size
end
end
# Create a handler to process incoming messages
bot.on_message do |message|
spawn do
- next unless ( userlogreturn = userlog( settings, message ) )
+ next unless ( userlogreturn = userlog( ircipc, settings, message ) )
chatuser, uid, userdir = userlogreturn
if ( chatuser == "pipne" ) && ( ( Time.utc.to_unix - snifflast ) >= 14400 )
snifflast = Time.utc.to_unix
- t2smsg( chatuser + " sniff null" )
+ t2smsg( settings, chatuser + " sniff null" )
end
if ( t2sreturn = t2s( settings, userdir, chatuser, message.params[1] ) )
lastvoice.insert( 0, t2sreturn )
@@ -260,9 +464,9 @@ bot.message( msgtuple[0], msgtuple[1][0..480] )
case message.params[1].split( " " ).size
when 1
if File.exists?( userdir + "/voicesub" )
- bot.message( "#bungmonkey", "| Current name substitution is \"#{File.read( userdir + "/voicesub" )}\"." )
+ bot.message( "##{settings["channel"]}", "| Current name substitution is \"#{File.read( userdir + "/voicesub" )}\"." )
else
- bot.message( "#bungmonkey", "| Current name substitution is disabled." )
+ bot.message( "##{settings["channel"]}", "| Current name substitution is disabled." )
end
else
if match[2]?
@@ -270,54 +474,54 @@ bot.message( msgtuple[0], msgtuple[1][0..480] )
if voicesub =~ /^(disabled|null|disable|none)$/
if File.exists?( userdir + "/voicesub" )
File.delete( userdir + "/voicesub" )
- bot.message( "#bungmonkey", "| Name substitution for #{chatuser} is now disabled." )
+ bot.message( "##{settings["channel"]}", "| Name substitution for #{chatuser} is now disabled." )
else
- bot.message( "#bungmonkey", "| Name substitution for #{chatuser} is already disabled." )
+ bot.message( "##{settings["channel"]}", "| Name substitution for #{chatuser} is already disabled." )
end
else
- File.directory?( userdir ) || Dir.mkdir( userdir )
+ Dir.mkdir_p( userdir )
File.write( userdir + "/voicesub", voicesub )
- bot.message( "#bungmonkey", "| Name substitution for #{chatuser} is now \"#{File.read( userdir + "/voicesub" )}\"." )
+ bot.message( "##{settings["channel"]}", "| Name substitution for #{chatuser} is now \"#{File.read( userdir + "/voicesub" )}\"." )
end
end
end
elsif ( cmd =~ /^(commands|help)$/ )
- bot.message( "#bungmonkey", "| https://bungmonkey.omgwallhack.org/txt/commands.txt" )
+ bot.message( "##{settings["channel"]}", "| https://bungmonkey.omgwallhack.org/txt/commands.txt" )
elsif ( cmd =~ /^(dexem)$/ )
- ircipc.send( { "#bungmonkey", "| You're doing great work, Dexem!" } )
+ ircipc.send( { "##{settings["channel"]}", "| You're doing great work, Dexem!" } )
elsif ( ( cmd == "lastvoice" ) && ( mod || sub ) )
unless lastvoice.empty?
- bot.message( "#bungmonkey", "| Last voices were " + lastvoice.join( ", " ) )
+ bot.message( "##{settings["channel"]}", "| Last voices were " + lastvoice.join( ", " ) )
else
- bot.message( "#bungmonkey", "| No voices used so far." )
+ bot.message( "##{settings["channel"]}", "| No voices used so far." )
end
elsif ( ( cmd =~ /^(voices|voicelist)$/ ) && ( mod || sub ) )
- bot.message( "#bungmonkey", "| https://bungmonkey.omgwallhack.org/voicelist.txt" )
+ bot.message( "##{settings["channel"]}", "| https://bungmonkey.omgwallhack.org/voicelist.txt" )
elsif ( ( cmd =~ /^(setvoice|voice)$/ ) && ( mod || sub ) )
case message.params[1].split( " " ).size
when 1
namesub, voice_setting, voice_output = getvoice( settings, userdir, chatuser )
- bot.message( "#bungmonkey", "| Current voice is #{voice_setting}" )
+ bot.message( "##{settings["channel"]}", "| Current voice is #{voice_setting}" )
when 2
if match[2]?
voice = match[2].downcase
if voice =~ /disabled|null|disable|none|random/
if File.exists?( userdir + "/voice" )
File.delete( userdir + "/voice" )
- bot.message( "#bungmonkey", "| Voice for #{chatuser} is now random." )
+ bot.message( "##{settings["channel"]}", "| Voice for #{chatuser} is now random." )
else
- bot.message( "#bungmonkey", "| Voice for #{chatuser} is already random." )
+ bot.message( "##{settings["channel"]}", "| Voice for #{chatuser} is already random." )
end
elsif voices.has_key?( voice )
csvoice = voices[voice]
- File.directory?( userdir ) || Dir.mkdir( userdir )
+ Dir.mkdir_p( userdir )
File.write( userdir + "/voice", csvoice )
pp userdir
- bot.message( "#bungmonkey", "| Voice for #{chatuser} is now #{File.read( userdir + "/voice" )}." )
+ bot.message( "##{settings["channel"]}", "| Voice for #{chatuser} is now #{File.read( userdir + "/voice" )}." )
# TODO: make separate script to print streamelements URLs to client machine
else
pp ( match )
- bot.message( "#bungmonkey", "| Invalid voice. To see list, use !voices" )
+ bot.message( "##{settings["channel"]}", "| Invalid voice. To see list, use !voices" )
end
end
when 3
@@ -332,23 +536,28 @@ bot.message( msgtuple[0], msgtuple[1][0..480] )
elsif ( ( cmd =~ /^source$/ ) && ( mod || own ) )
request = Hash( String, String | Bool ).new
if ( match[2]? ) && ( sourceargs = match[2].match( /^([a-zA-Z0-9-_]+) +(true|false)/ ) )
- request["request-type"] = "SetSceneItemProperties"
- request["message-id"] = "SetSceneItemProperties"
- request["item"] = sourceargs[1]
- sourceargs[2] == "true" && ( request["visible"] = true )
- sourceargs[2] == "false" && ( request["visible"] = false )
-
- ircipc.send( { "##{settings["channel"]}", "Setting source #{sourceargs[1]} visibility to #{sourceargs[2]}" } )
- obsipc.send( request.to_json )
+# request["request-type"] = "SetSceneItemProperties"
+# request["message-id"] = "SetSceneItemProperties"
+# request["item"] = sourceargs[1]
+# sourceargs[2] == "true" && ( request["visible"] = true )
+# sourceargs[2] == "false" && ( request["visible"] = false )
+#
+# ircipc.send( { "##{settings["channel"]}", "Setting source #{sourceargs[1]} visibility to #{sourceargs[2]}" } )
+ obsipc.send( "\x10source #{match[2]}" )
elsif ( match[2]? && match[2] =~ /^[a-zA-Z0-9-_]+$/ )
- request["request-type"] = "GetSceneItemProperties"
- request["message-id"] = "toggle-source"
- request["item"] = match[2]
- obsipc.send( request.to_json )
+ #sources = reversesource( scenes, currentscene )
+ #request["request-type"] = "SetSceneItemProperties"
+ #request["message-id"] = "SetSceneItemProperties"
+ #request["request-type"] = "GetSceneItemProperties"
+ #request["message-id"] = "toggle-source"
+ #request["item"] = match[2]
+ #obsipc.send( request.to_json )
+ obsipc.send( "\x10source-toggle #{match[2]}" )
else
- request["request-type"] = "GetCurrentScene"
- request["message-id"] = "GetCurrentScene"
- obsipc.send( request.to_json )
+# request["request-type"] = "GetCurrentScene"
+# request["message-id"] = "GetCurrentScene"
+# obsipc.send( request.to_json )
+ obsipc.send( "\x10source #{match[2]}" )
end
elsif ( ( cmd =~ /^filter$/ ) && ( mod || own ) )
request = Hash( String, String | Bool ){
@@ -375,6 +584,12 @@ bot.message( msgtuple[0], msgtuple[1][0..480] )
else
ircipc.send( { "##{settings["channel"]}", "Must provide at least one source name as argument, and optionally one filter name." } )
end
+ elsif ( cmd == "duplicate" && ( mod || own || vip ) )
+ if ( match[2]? ) && ( filterargs = match[2].match( /^([a-zA-Z0-9-_]+)/ ) )
+ temporaryduplicate( match[2] )
+ else
+ ircipc.send( { "##{settings["channel"]}", "Must provide at least one source name as argument." } )
+ end
elsif ( cmd =~ /^(metaminute|youdied)$/ )
request = Hash( String, String | Bool ).new
request["request-type"] = "SetSceneItemProperties"
@@ -393,13 +608,13 @@ bot.message( msgtuple[0], msgtuple[1][0..480] )
if match[2]?
client.put_channel!( settings["channel_id"].to_u64, title: match[2] )
json = JSON.parse( client.get_channel( settings["channel_id"].to_u64 ) )
- ircmsg( settings["home"], settings["channel"], "Title is now \"#{ json["data"][0]["title"] }\"")
+ ircipc.send( { "##{settings["channel"]}", "Title is now \"#{ json["data"][0]["title"] }\""} )
else
json = JSON.parse( client.get_channel( settings["channel_id"].to_u64 ) )
- ircmsg( settings["home"], settings["channel"], "| Title is currently \"#{ json["data"][0]["title"] }\"")
+ ircipc.send( { "##{settings["channel"]}", "| Title is currently \"#{ json["data"][0]["title"] }\""} )
end
rescue ex
- ircmsg( settings["home"], settings["channel"], "| An error occurred! " + ex.message.to_s )
+ ircipc.send( { "##{settings["channel"]}", "| An error occurred! " + ex.message.to_s } )
end
elsif ( ( cmd =~ /^(game|category)$/ ) && ( mod || own ) )
begin
@@ -407,85 +622,88 @@ bot.message( msgtuple[0], msgtuple[1][0..480] )
puts "2 matches"
client.put_channel!( settings["channel_id"].to_u64, game: match[2] )
json = JSON.parse( client.get_channel( settings["channel_id"].to_u64 ) )
- ircmsg( settings["home"], settings["channel"], "Game is now \"#{ json["data"][0]["game_name"] }\"")
+ ircipc.send( { "##{settings["channel"]}", "Game is now \"#{ json["data"][0]["game_name"] }\""} )
else
puts "1 matches"
json = JSON.parse( client.get_channel( settings["channel_id"].to_u64 ) )
- ircmsg( settings["home"], settings["channel"], "| Game is currently \"#{ json["data"][0]["game_name"] }\"")
+ ircipc.send( { "##{settings["channel"]}", "| Game is currently \"#{ json["data"][0]["game_name"] }\""} )
end
rescue ex
- ircmsg( settings["home"], settings["channel"], "| An error occurred! " + ex.message.to_s )
+ ircipc.send( { "##{settings["channel"]}", "| An error occurred! " + ex.message.to_s } )
end
elsif ( ( cmd == "urban" ) && ( mod || own || sub || vip ) )
if match[2]? && match[2] =~ /^([a-zA-Z0-9 -])+$/
definition = urbandef( match[2] )
- ircmsg( settings["home"], settings["channel"], definition[0,400] )
+ ircipc.send( { "##{settings["channel"]}", definition[0,400] } )
else
- ircmsg( settings["home"], settings["channel"], "| Urban Dictionary search term should consist of letters, numbers, spaces, and/or hyphens." )
+ ircipc.send( { "##{settings["channel"]}", "| Urban Dictionary search term should consist of letters, numbers, spaces, and/or hyphens." } )
end
elsif ( cmd == "matrix" )
- effectsmsg( "overlay glmatrix" )
+ effectsmsg( settings, "overlay glmatrix" )
elsif ( cmd =~ /juggle|juggler/ )
- effectsmsg( "overlay juggler3d" )
+ effectsmsg( settings, "overlay juggler3d" )
elsif ( cmd =~ /fireworks|firework/ )
- effectsmsg( "overlay fireworkx" )
+ effectsmsg( settings, "overlay fireworkx" )
elsif ( cmd == "pipes" )
if match[2]? && match[2] =~ /^(fast|faster)$/
- effectsmsg( "overlay pipes " + match[2] )
+ effectsmsg( settings, "overlay pipes " + match[2] )
else
- effectsmsg( "overlay pipes" )
+ effectsmsg( settings, "overlay pipes" )
end
elsif ( cmd == "jellyfish" )
- effectsmsg( "overlay hydrostat" )
+ effectsmsg( settings, "overlay hydrostat" )
elsif ( cmd == "gluten" )
- effectsmsg( "overlay flyingtoasters" )
+ effectsmsg( settings, "overlay flyingtoasters" )
elsif ( cmd =~ /^(glsnake|glmatrix|gibson|xmatrix|flyingtoasters|moebiusgears|fireworkx|hydrostat|hypertorus|jigsaw|juggler3d|kaleidocycle|kumppa|molecule|noof|polyhedra)$/ )
- effectsmsg( "overlay " + cmd )
- elsif ( cmd =~ /gltext|cowsay|xcowsay/ )
+ effectsmsg( settings, "overlay " + cmd )
+ elsif ( cmd =~ /gltext|cowsay|xcowsay|cowfuscious/ )
+ ( cmd == "cowfuscious" ) && ( cmd = "xcowsay" )
if ( match[2]? ) && ( gltextargs = match[2].match( /^([0-9]+) +(.+)$/ ) )
seconds=UInt64.new( 1 )
seconds=gltextargs[1].to_u64
if ( own || mod || vip )
- effectsmsg( "overlay #{cmd} #{match[2]}" )
+ effectsmsg( settings, "overlay #{cmd} #{match[2]}" )
puts "matched #{cmd} #{match[2]}"
elsif ( sub )
if ( seconds > 20 )
seconds=20
end
- effectsmsg( "overlay #{cmd} #{seconds} #{gltextargs[2]}" )
+ effectsmsg( settings, "overlay #{cmd} #{seconds} #{gltextargs[2]}" )
puts "matched #{cmd} #{seconds} #{gltextargs[2]}"
else
if ( seconds > 5 )
seconds=5
end
- effectsmsg( "overlay #{cmd} #{seconds} #{gltextargs[2]}" )
+ effectsmsg( settings, "overlay #{cmd} #{seconds} #{gltextargs[2]}" )
puts "matched #{cmd} #{seconds} #{gltextargs[2]}"
end
elsif match[2]? && match[2] =~ /^.+$/
- effectsmsg( "overlay #{cmd} #{match[2]}" )
+ effectsmsg( settings, "overlay #{cmd} #{match[2]}" )
puts "matched #{cmd} #{match[2]}"
else
- effectsmsg( "overlay #{cmd}" )
+ effectsmsg( settings, "overlay #{cmd}" )
puts "failed to match gltext"
end
- elsif ( cmd =~ /cow|cowabunga|holycow/ )
+ elsif ( cmd =~ /^(cow(s|)|cowabunga|holycow$)/ )
if match[2]? && match[2] =~ /^([0-9])+$/
- effectsmsg( "overlay bouncingcow #{match[2]}" )
+ effectsmsg( settings, "overlay bouncingcow #{match[2]}" )
else
- effectsmsg( "overlay bouncingcow" )
+ effectsmsg( settings, "overlay bouncingcow" )
end
elsif ( cmd == "overlay" )
if match[2]? && match[2] =~ /^[a-z]+$/
- ircmsg( settings["home"], settings["channel"], "| overlay requires an argument consisting wholly of lower case characters.")
- effectsmsg( "overlay #{match[2]}" )
+ ircipc.send( { "##{settings["channel"]}", "| overlay requires an argument consisting wholly of lower case characters."} )
+ effectsmsg( settings, "overlay #{match[2]}" )
else
end
+ elsif ( cmd =~ /^(system|dxdiag|computer)$/ )
+ ircipc.send( { "##{settings["channel"]}", "| https://bungmonkey.omgwallhack.org/tmp/DxDiag.txt" } )
elsif ( cmd == "hackerman" )
- ircmsg( settings["home"], settings["channel"], "| https://bungmonkey.omgwallhack.org/img/hackerman.jpg" )
+ ircipc.send( { "##{settings["channel"]}", "| https://bungmonkey.omgwallhack.org/img/hackerman.jpg" } )
elsif ( cmd =~ /^(songrequest|sr)$/ ) && match[2]?
puts ("song detected: #{match[2]}")
if ( ( match[2] =~ /list=/ ) && ( match[2] !~ /v=/ ) )
- ircmsg( settings["home"], settings["channel"], "| Lists are not accepted.\n" )
+ ircipc.send( { "##{settings["channel"]}", "| Lists are not accepted.\n" } )
elsif Process.run( "sraddsong.sh", {match[2]} )
m = MPD::Client.new
currentsong = m.currentsong
@@ -493,9 +711,9 @@ bot.message( msgtuple[0], msgtuple[1][0..480] )
m.next
end
if ( status = m.status ) && ( playlistinfo = m.playlistinfo )
- ircmsg( settings["home"], settings["channel"], "| " + playlistinfo[ status["playlistlength"].to_i - 1 ]["file"].to_s + " added in position " + status["playlistlength"].to_s )
+ ircipc.send( { "##{settings["channel"]}", "| " + playlistinfo[ status["playlistlength"].to_i - 1 ]["file"].to_s + " added in position " + status["playlistlength"].to_s } )
else
- ircmsg( settings["home"], settings["channel"], "| A failure occured." )
+ ircipc.send( { "##{settings["channel"]}", "| A failure occured." } )
end
m.disconnect
else
@@ -503,9 +721,9 @@ bot.message( msgtuple[0], msgtuple[1][0..480] )
elsif ( cmd =~ /^current(|song)$/ )
m = MPD::Client.new
if ( currentsong = m.currentsong )
- ircmsg( settings["home"], settings["channel"], "| Currently playing: " + currentsong["file"].to_s )
+ ircipc.send( { "##{settings["channel"]}", "| Currently playing: " + currentsong["file"].to_s } )
else
- ircmsg( settings["home"], settings["channel"], "| A failure occured." )
+ ircipc.send( { "##{settings["channel"]}", "| A failure occured." } )
end
m.disconnect
elsif ( cmd =~ /^seek$/ )
@@ -515,25 +733,25 @@ bot.message( msgtuple[0], msgtuple[1][0..480] )
if ( ( musicstatus = m.status ) && ( pos = musicstatus["elapsed"].to_f.to_u64 ) )
min=( pos / 60 ).to_u64
sec=( pos % 60 ).to_u64
- ircmsg( settings["home"], settings["channel"], "| " + sprintf( "2%d:2%d", min, sec ) )
+ ircipc.send( { "##{settings["channel"]}", "| " + sprintf( "2%d:2%d", min, sec ) } )
else
- ircmsg( settings["home"], settings["channel"], "| An error occurred. " )
+ ircipc.send( { "##{settings["channel"]}", "| An error occurred. " } )
end
m.disconnect
else
- ircmsg( settings["home"], settings["channel"], "| Seek requires an argument of an absolute position in integer number of seconds, or a relative position in in signed integer number of seconds such as +60" )
+ ircipc.send( { "##{settings["channel"]}", "| Seek requires an argument of an absolute position in integer number of seconds, or a relative position in in signed integer number of seconds such as +60" } )
end
elsif ( cmd =~ /^next(|song)$/ )
m = MPD::Client.new
m.next
if ( status = m.status ) && ( status["playlistlength"].to_i > 0 )
if ( currentsong = m.nextsong )
- ircmsg( settings["home"], settings["channel"], "| Currently playing: " + currentsong["file"].to_s )
+ ircipc.send( { "##{settings["channel"]}", "| Currently playing: " + currentsong["file"].to_s } )
else
- ircmsg( settings["home"], settings["channel"], "| A failure occured." )
+ ircipc.send( { "##{settings["channel"]}", "| A failure occured." } )
end
else
- ircmsg( settings["home"], settings["channel"], "| Playlist is now empty." )
+ ircipc.send( { "##{settings["channel"]}", "| Playlist is now empty." } )
end
m.disconnect
elsif ( cmd == "followage" )
@@ -545,27 +763,27 @@ bot.message( msgtuple[0], msgtuple[1][0..480] )
puts client.user_id( args[0] ).to_s
puts client.user_id( args[1] ).to_s
puts json
- ircmsg( settings["home"], settings["channel"], "| " + json["data"][0]["followed_at"].to_s )
+ ircipc.send( { "##{settings["channel"]}", "| " + json["data"][0]["followed_at"].to_s } )
elsif args[0]?
json = JSON.parse( client.get_user_follows( from: client.user_id( args[0] ).to_u64 , to: settings["channel_id"].to_u64 ) )
puts client.user_id( args[0] ).to_s
puts json
- ircmsg( settings["home"], settings["channel"], "| " + json["data"][0]["followed_at"].to_s )
+ ircipc.send( { "##{settings["channel"]}", "| " + json["data"][0]["followed_at"].to_s } )
end
else
json = JSON.parse( client.get_user_follows( from: uid.to_u64 , to: settings["channel_id"].to_u64 ) )
puts json
- ircmsg( settings["home"], settings["channel"], "| " + json["data"][0]["followed_at"].to_s )
+ ircipc.send( { "##{settings["channel"]}", "| " + json["data"][0]["followed_at"].to_s } )
end
rescue ex
- ircmsg( settings["home"], settings["channel"], "An error occurred! " + ex.message.to_s )
+ ircipc.send( { "##{settings["channel"]}", "An error occurred! " + ex.message.to_s } )
end
end
end
end
rooms = Array( String ).new
- rooms = [ "#bungmonkey", "kr3wzz" ]
+ rooms = [ "##{settings["channel"]}" ]
# Connect to Twitch
bot.run( rooms.map{ | room | room.sub( /^#/, "") } )
generated by cgit v1.2.3 (git 2.39.1) at 2024-12-26 07:27:59 +0000