diff options
Diffstat (limited to 'crystal/bungmobott.cr')
| -rwxr-xr-x | crystal/bungmobott.cr | 330 |
1 files changed, 268 insertions, 62 deletions
diff --git a/crystal/bungmobott.cr b/crystal/bungmobott.cr index 124d983..1d91bf7 100755 --- a/crystal/bungmobott.cr +++ b/crystal/bungmobott.cr @@ -105,7 +105,8 @@ else settings["chat_user"] = settings["channel"] end -obsipc = Channel( String ).new +obs4ipc = Channel( String ).new +obs5ipc = Channel( String ).new ircipc = Channel( Tuple( String, String ) ).new t2sipc = Channel( Tuple( String, String ) ).new twitchipc = Channel( Tuple( String, Union( String, UInt64 ) ) ).new @@ -143,12 +144,15 @@ snifflast = Int64.new(0) def urbandef( term : String ) + ssl_context = OpenSSL::SSL::Context::Client.new + {% if flag?(:windows) %} + ssl_context.verify_mode = OpenSSL::SSL::VerifyMode::NONE + {% end %} #http://api.urbandictionary.com/v0/define?term=waifu - client = HTTP::Client.new( "api.urbandictionary.com" ) - response = client.exec( "GET", "/v0/define?term=pawg" + URI.encode_www_form( term ) ) + response = HTTP::Client.exec( "GET", "https://api.urbandictionary.com/v0/define?term=#{term}", tls: ssl_context ) puts response.status_code json = JSON.parse( response.body ) - return json["list"][0]["definition"].to_s.gsub( /[\[\]]/, "" ).gsub( /\n/, "" ) + return json["list"][0]["definition"].to_s.gsub( /[\[\]]/, "" ).gsub( /(\r|\n)/, " " ) end # Currently only used in flag?(:unix) @@ -303,7 +307,7 @@ def reversesource( scenes : Hash( String, Hash( String, Hash( String, Int64 | Fl scenes[currentscene].each do | source, sourcedata | # maybe make this recurse later sourcemap[source.to_s] = currentscene - if sourcedata["type"] == "scene" + if ( ( ! sourcedata.has_key?("type") ) || ( sourcedata["type"] == "scene" ) ) scenes[source.to_s].each do | metasource, metasourcedata | sourcemap[metasource.to_s] = source.to_s end @@ -405,6 +409,7 @@ lastvoice = Array(String).new #streamstatus = Hash(String, Union( Bool, Float64, Int64, UInt64, String ) ).new streamstatus = Hash(String, JSON::Any).new +outputstatus = Hash(String, JSON::Any).new # Put tts stuff into the same thread so each playback blocks the next spawn do @@ -480,12 +485,216 @@ spawn do end end -# obs-websocket thread +def obsrequest( type : String, id : String, data : ( String | Nil | JSON::Any ) = nil ) + request = JSON.build do |json| + json.object do + json.field "op", 6 + json.field "d" do + json.object do + json.field "requestType", type + json.field "requestId", id + if data + json.field "requestData", data + end + end + end + end + end + return request.to_s +end + +# obs-websocket-5 thread spawn do loop do begin - obs_pubsub = HTTP::WebSocket.new( URI.parse( "ws://127.0.0.1:4444/" ), HTTP::Headers{"Cookie" => "SESSIONID=1234"} ) + obs5_pubsub = HTTP::WebSocket.new( URI.parse( "ws://127.0.0.1:4455/" ), HTTP::Headers{"Cookie" => "SESSIONID=1235", "Sec-WebSocket-Protocol" => "obswebsocket.json"} ) + # Outgoing + # state + currentscene = "unknown" + canvas = { 1280, 720 } + + # inputname => { property => value } + inputs = Hash( String, Hash( String, String | Int64 | Float64 | Bool ) ) + # GetInputList + # GetInputSettings + + # scenename => { sceneitemid => { property => value } + scenes = Hash( String, Hash( String, Hash( String, Int64 | Float64 | Bool | String ) ) ).new + # GetSceneList + # GetSceneItemList + # GetSceneItemTransform + + spawn do + while msg = obs5ipc.receive + pp msg + if ( match = msg.match( /^\x10source(-notransition|) ([a-z0-9-_]+)/ ) ) + transition = ( match[1] != "-notransition" ) + source = match[2] + sources = reversesource( scenes, currentscene ) + pp sources + unless ( scene = sources[source]? ) + ircipc.send( { "#" + settings["channel"], "| obs5: source not found: #{source}" } ) + next + end + obs5_pubsub.send( obsrequest( "GetSceneItemEnabled", "GetSceneItemTransform", JSON.parse( { "sceneName" => scene, "sceneItemId" => scenes[scene][source]["id"] }.to_json ) ) ) + if ( match = msg.match( /^\x10source[-a-zA-Z0-9_]* ([a-z0-9-_]+) (true|false)/ ) ) + obs5_pubsub.send( obsrequest( "SetSceneItemEnabled", "SetSceneItemEnabled", JSON.parse( { "sceneName" => scene, "sceneItemId" => scenes[scene][source]["id"], "sceneItemEnabled" => ( match[2] == "true" ) }.to_json ) ) ) + elsif ( match = msg.match( /^\x10source[-a-zA-Z0-9_]* ([a-z0-9-_]+)/ ) ) + obs5_pubsub.send( obsrequest( "SetSceneItemEnabled", "SetSceneItemEnabled", JSON.parse( { "sceneName" => scene, "sceneItemId" => scenes[scene][source]["id"], "sceneItemEnabled" => ! scenes[scene][source]["render"] }.to_json ) ) ) + end +# if transition +# request = Hash( String, String | Bool ).new +# request["request-type"] = "SetPreviewScene" +# request["message-id"] = "SetPreviewScene" +# request["scene-name"] = currentscene +# obs4_pubsub.send( request.to_json ) +# sleep 0.1 # somehow these get out-of-order otherwise? >:( +# request = Hash( String, String ).new +# request["request-type"] = "TransitionToProgram" +# request["message-id"] = "TransitionToProgram" +# obs4_pubsub.send( request.to_json ) +# end + elsif ( match = msg.match( /^\x10source/ ) ) + pp scenes + pp currentscene + sources = reversesource( scenes, currentscene ) + #ircipc.send( { "#" + settings["channel"], "| obs: " + sources.keys.join(", ") } ) + obs5_pubsub.send( obsrequest( "GetSceneItemList", "GetSceneItemList", JSON.parse( { "sceneName" => currentscene }.to_json ) ) ) + else + obs5_pubsub.send( msg ) + end + end + end + # Incoming + obs5_pubsub.on_message do | message | + json = JSON.parse( message ) + if json["error"]? + puts json["error"] + ircipc.send( { "#" + settings["channel"], "| obs5: #{json["error"]}" } ) + next + end + case json["op"].as_i + when 0 # hello + json_text = %({"op":1,"d":{"rpcVersion":1}}) + obs5_pubsub.send( json_text ) + when 5 # event + edata = json["d"]["eventData"] + case json["d"]["eventType"].as_s + when "CurrentProgramSceneChanged" + ircipc.send( { "#" + settings["channel"], "| obs5: switched scene to " + ( edata["sceneName"]?.as_s? || "unknown" ) } ) + puts "SwitchScenes: currentscene is " + currentscene + currentscene = edata["sceneName"].as_s + puts "SwitchScenes: currentscene is " + currentscene + when "SceneItemEnableStateChanged" + # FIXME: No sceneItemName? need to convert scenes/sceneitems into a proper object interface or build a new index so we can lookup name by id + edata["sceneItemEnabled"].as_bool + edata["sceneItemId"].as_i + edata["sceneName"].as_s + end + when 7 # requestResponse + case json["d"]["requestType"].as_s + when "GetStats" # FIXME: RequestBatch this with GetOutputStatus? + streamstatus = json["d"]["responseData"].as_h + + obs5_pubsub.send( obsrequest( "GetOutputList", "GetOutputList" )) + when "GetOutputList" + output_name = String.new + json["d"]["responseData"]["outputs"].as_a.each do | output | + if output["outputKind"].as_s == "rtmp_output" + output_name = output["outputName"].as_s + end + end + unless output_name.empty? + obs5_pubsub.send( obsrequest( "GetOutputStatus", "GetOutputStatus", JSON.parse( { "outputName" => output_name }.to_json ) )) + end + when "GetOutputStatus" + streamstatus = streamstatus.merge( json["d"]["responseData"].as_h ) + ircipc.send( { "##{settings["channel"]}", "| #{streamstatus["outputTimecode"].as_s[0..7]} #{streamstatus["activeFps"].as_f.to_s[0,2]}fps Usage: #{streamstatus["cpuUsage"].as_f.to_i64}% #{streamstatus["memoryUsage"].as_f.to_i64}MiB Frame losses: #{streamstatus["outputSkippedFrames"].as_i64} #{streamstatus["outputSkippedFrames"].as_i64}" } ) + when /^GetSceneItemList/ + pp json + rdata = json["d"]["responseData"] + ( match = json["d"]["requestId"].as_s.match( /^GetSceneItemList-([A-Za-z0-9-_\/]+)/ ) ) || next + # scenename => { sourcename => { property => value } + # scenes = Hash( String, Hash( String, Hash( String, Int64 | Float64 | Bool | String ) ) ).new + rdata["sceneItems"].as_a.each do | source | + + scenes[match[1]][source["sourceName"]]? || ( scenes[match[1]][source["sourceName"].as_s] = Hash( String, Int64 | Float64 | Bool | String ).new ) + source["sceneItemEnabled"].as_bool != Nil && ( scenes[match[1]][source["sourceName"].as_s]["render"] = source["sceneItemEnabled"].as_bool ) + source["sceneItemId"].as_i64? && ( scenes[match[1]][source["sourceName"].as_s]["id"] = source["sceneItemId"].as_i64 ) + source["inputKind"].as_s? && ( scenes[match[1]][source["sourceName"].as_s]["type"] = source["inputKind"].as_s ) + source["sceneItemTransform"]["positionX"].as_f? && ( scenes[match[1]][source["sourceName"].as_s]["x"] = source["sceneItemTransform"]["positionX"].as_f ) + source["sceneItemTransform"]["positionY"].as_f? && ( scenes[match[1]][source["sourceName"].as_s]["y"] = source["sceneItemTransform"]["positionY"].as_f ) + source["sceneItemTransform"]["sourceWidth"].as_f? && ( scenes[match[1]][source["sourceName"].as_s]["source_cx"] = source["sceneItemTransform"]["sourceWidth"].as_f ) + source["sceneItemTransform"]["sourceHeight"].as_f? && ( scenes[match[1]][source["sourceName"].as_s]["source_cy"] = source["sceneItemTransform"]["sourceHeight"].as_f ) + if source["sceneItemTransform"]["width"].as_i64? + scenes[match[1]][source["sourceName"].as_s]["cx"] = source["sceneItemTransform"]["cx"].as_i64 + else + scenes[match[1]][source["sourceName"].as_s]["cx"] = 0.to_i64 + end + if source["sceneItemTransform"]["height"].as_i64? + scenes[match[1]][source["sourceName"].as_s]["cy"] = source["sceneItemTransform"]["cy"].as_i64 + else + scenes[match[1]][source["sourceName"].as_s]["cy"] = 0.to_i64 + end + end + when "GetSceneList" + rdata = json["d"]["responseData"] + currentscene = rdata["currentProgramSceneName"].as_s + pp rdata["scenes"] + rdata["scenes"].as_a.each do |scene| + scenes[scene["sceneName"].as_s] = Hash( String, Hash( String, Int64 | Float64 | Bool | String ) ).new + end + if json["d"]["requestId"].as_s =~ /Quietly/ # We need to populate the scenes table once at startup + scenes.keys.each do |scene| + obs5_pubsub.send( obsrequest( "GetSceneItemList", "GetSceneItemList-#{scene}", JSON.parse( { "sceneName" => scene }.to_json ) )) + end + else # Loudly + ircipc.send( { "#" + settings["channel"], "| obs5: " + rdata["scenes"].as_a.map{ |scene| scene["sceneName"] }.join(", ") } ) + end + when "GetVideoSettings" + rdata = json["d"]["responseData"] + canvas = { rdata["baseWidth"].as_i.to_u64 , rdata["baseHeight"].as_i.to_u64 } + pp canvas + end + end + print( "5 RECEIVED: ") + print( json.to_pretty_json ) + print( "\n") + end + spawn do + # authentication + sleep 1 + obs5_pubsub.send( obsrequest( "GetVideoSettings", "GetVideoSettings" )) + obs5_pubsub.send( obsrequest( "GetStats", "GetStats" )) + sleep 1 + obs5_pubsub.send( obsrequest( "GetSceneList", "GetSceneList Quietly" )) + end + obs5_pubsub.run + rescue ex : Socket::ConnectError + # these are a bit noisy + #pp ex + obs5_pubsub && obs5_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 + pp ex + pp ex.backtrace? + ircipc.send( { "#" + settings["channel"], "irc.cr:obs: " + ex.to_s.gsub(/\r|\n/, ' ') } ) + obs5_pubsub && obs5_pubsub.close + end + sleep 10 + next + end +end + +# obs-websocket-4 thread +spawn do + loop do + begin + + obs4_pubsub = HTTP::WebSocket.new( URI.parse( "ws://127.0.0.1:4444/" ), HTTP::Headers{"Cookie" => "SESSIONID=1234"} ) # Outgoing # state currentscene = "unknown" @@ -493,7 +702,7 @@ spawn do # scenename => { sourcename => { property => value } scenes = Hash( String, Hash( String, Hash( String, Int64 | Float64 | Bool | String ) ) ).new spawn do - while msg = obsipc.receive + while msg = obs4ipc.receive pp msg if ( match = msg.match( /^\x10source(-notransition|) ([a-z0-9-_]+)/ ) ) transition = ( match[1] != "-notransition" ) @@ -504,7 +713,7 @@ spawn do request["request-type"] = "SetSceneItemProperties" request["message-id"] = "SetSceneItemProperties" unless ( scene = sources[source]? ) - ircipc.send( { "#" + settings["channel"], "| obs: source not found: #{source}" } ) + ircipc.send( { "#" + settings["channel"], "| obs4: source not found: #{source}" } ) next end request["scene-name"] = scene @@ -526,19 +735,19 @@ spawn do end end end - obs_pubsub.send( request.to_json ) + obs4_pubsub.send( request.to_json ) puts "x10source: currentscene is " + currentscene if transition request = Hash( String, String | Bool ).new request["request-type"] = "SetPreviewScene" request["message-id"] = "SetPreviewScene" request["scene-name"] = currentscene - obs_pubsub.send( request.to_json ) + obs4_pubsub.send( request.to_json ) sleep 0.1 # somehow these get out-of-order otherwise? >:( request = Hash( String, String ).new request["request-type"] = "TransitionToProgram" request["message-id"] = "TransitionToProgram" - obs_pubsub.send( request.to_json ) + obs4_pubsub.send( request.to_json ) end elsif ( match = msg.match( /^\x10sceneitem ([a-z0-9-_]+)/ ) ) source = match[1] @@ -548,18 +757,18 @@ spawn do request["request-type"] = "GetSceneItemProperties" request["message-id"] = "GetSceneItemProperties" unless ( scene = sources[source]? ) - ircipc.send( { "#" + settings["channel"], "| obs: source not found: #{source}" } ) + ircipc.send( { "#" + settings["channel"], "| obs4: source not found: #{source}" } ) next end request["scene-name"] = scene request["item"] = source - obs_pubsub.send( request.to_json ) + obs4_pubsub.send( request.to_json ) elsif ( match = msg.match( /^\x10source/ ) ) request = Hash( String, String ){ "request-type" => "GetCurrentScene", "message-id" => "GetCurrentScene", } - obs_pubsub.send( request.to_json ) + obs4_pubsub.send( request.to_json ) elsif ( match = msg.match( /^\x10newsource(-temporary|) ([a-zA-Z0-9-_]+)/ ) ) temporary = ( match[1]? ) @@ -581,26 +790,26 @@ spawn do }, } ircipc.send( { "##{settings["channel"]}", "Creating #{sourcename}" } ) - obs_pubsub.send( request.to_json ) + obs4_pubsub.send( request.to_json ) else - obs_pubsub.send( msg ) + obs4_pubsub.send( msg ) end end end # Incoming - obs_pubsub.on_message do | message | + obs4_pubsub.on_message do | message | json = JSON.parse( message ) if json["error"]? puts json["error"] - ircipc.send( { "#" + settings["channel"], "| obs: #{json["error"]}" } ) + ircipc.send( { "#" + settings["channel"], "| obs4: #{json["error"]}" } ) next end case json["update-type"]? when "StreamStatus" # these are a bit noisy, - streamstatus = json + streamstatus = json.as_h next # so skip them when "SwitchScenes" - ircipc.send( { "#" + settings["channel"], "| obs: switched scene to " + ( json["scene-name"]?.as_s? || "unknown" ) } ) + ircipc.send( { "#" + settings["channel"], "| obs4: switched scene to " + ( json["scene-name"]?.as_s? || "unknown" ) } ) puts "SwitchScenes: currentscene is " + currentscene currentscene = json["scene-name"].as_s puts "SwitchScenes: currentscene is " + currentscene @@ -617,8 +826,8 @@ spawn do "item" => source, "visible" => false } - ircipc.send( { "##{settings["channel"]}", "| obs: Media ended; disabling #{source}" } ) - obsipc.send( request.to_json ) + ircipc.send( { "##{settings["channel"]}", "| obs4: Media ended; disabling #{source}" } ) + obs4ipc.send( request.to_json ) end end if ( source =~ /^media-temporary-/ ) @@ -629,21 +838,21 @@ spawn do "item" => { "name" => json["sourceName"].as_s }, } ircipc.send( { "##{settings["channel"]}", "Deleting #{source}" } ) - obsipc.send( request.to_json ) + obs4ipc.send( request.to_json ) end when "SourceFilterVisibilityChanged" - ircipc.send( { "##{settings["channel"]}", "| obs: source #{json["sourceName"]} filter #{json["filterName"]} visibility is currently #{json["filterEnabled"]}" } ) + ircipc.send( { "##{settings["channel"]}", "| obs4: source #{json["sourceName"]} filter #{json["filterName"]} visibility is currently #{json["filterEnabled"]}" } ) when "SceneItemAdded" request = Hash( String, String ){ "request-type" => "GetCurrentScene", "message-id" => "GetCurrentScene Quietly", } - obsipc.send( request.to_json) + obs4ipc.send( request.to_json) request = Hash( String, String ){ "request-type" => "GetSceneList", "message-id" => "GetSceneList Quietly", } - obsipc.send( request.to_json ) + obs4ipc.send( request.to_json ) if json["item-name"].as_s =~ /media-temporary/ request = Hash( String, String | Bool ).new @@ -651,7 +860,7 @@ spawn do request["message-id"] = "GetSceneItemProperties" request["scene-name"] = json["scene-name"].as_s request["item"] = json["item-name"].as_s - obs_pubsub.send( request.to_json ) + obs4_pubsub.send( request.to_json ) end #scenes[json["scene-name"].as_s][json["item-name"].as_s] when "SourceRenamed" @@ -669,10 +878,10 @@ spawn do print( json.to_pretty_json ) if json["item-name"].as_s !~ /media-temporary/ scenes[json["scene-name"].as_s][json["item-name"].as_s]["render"] = json["item-visible"].as_bool - ircipc.send( { "##{settings["channel"]}", "| obs: source #{json["item-name"]} visibility is now #{json["item-visible"].as_bool}" } ) + ircipc.send( { "##{settings["channel"]}", "| obs4: source #{json["item-name"]} visibility is now #{json["item-visible"].as_bool}" } ) end end - print( "RECEIVED: ") + print( "4 RECEIVED: ") print( json.to_pretty_json ) print( "\n") case json["message-id"]?.as_s? @@ -688,11 +897,11 @@ spawn do # We should probably just preprocess these values into explosionslist :/ # ffprobe -show_entries stream=width,height big_explosion_1.webm request["position"] = { - "x" => (rand(canvas[0]) - ( size[0] / 2 ) ).to_f , + "x" => (rand(canvas[0]) - ( size[0] / 2 ) ).to_f, "y" => (rand(canvas[1]) - ( size[1] / 2 ) ).to_f, } - obsipc.send( request.to_json ) - #ircipc.send( { "##{settings["channel"]}", "| obs: #{request.to_json}" } ) + obs4ipc.send( request.to_json ) + #ircipc.send( { "##{settings["channel"]}", "| obs4: #{request.to_json}" } ) end when /^GetVideoInfo/ @@ -703,13 +912,13 @@ spawn do puts "GetCurrentScene: currentscene is " + currentscene if json["message-id"].as_s? !~ /Quietly/ sources = reversesource( scenes, currentscene ) - ircipc.send( { "#" + settings["channel"], "| obs: " + sources.keys.join(", ") } ) + ircipc.send( { "#" + settings["channel"], "| obs4: " + sources.keys.join(", ") } ) end when "GetSourceFilters" - ircipc.send( { "#" + settings["channel"], "| obs: " + json["filters"].as_a.map{ |filter| "#{filter["name"].as_s}: #{filter["enabled"].as_bool}" }.join(", ") } ) + ircipc.send( { "#" + settings["channel"], "| obs4: " + json["filters"].as_a.map{ |filter| "#{filter["name"].as_s}: #{filter["enabled"].as_bool}" }.join(", ") } ) when /^GetSceneList/ if json["message-id"].as_s? !~ /Quietly/ - ircipc.send( { "#" + settings["channel"], "| obs: " + json["scenes"].as_a.map{ |scene| scene["name"] }.join(", ") } ) + ircipc.send( { "#" + settings["channel"], "| obs4: " + json["scenes"].as_a.map{ |scene| scene["name"] }.join(", ") } ) end 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 ) @@ -743,32 +952,32 @@ spawn do "request-type" => "GetCurrentScene", "message-id" => "GetCurrentScene Quietly", } - obsipc.send( request.to_json ) + obs4ipc.send( request.to_json ) request = Hash( String, String ){ "request-type" => "GetSceneList", "message-id" => "GetSceneList Quietly", } - obsipc.send( request.to_json) + obs4ipc.send( request.to_json) sleep 1 request = Hash( String, String ){ "request-type" => "GetVideoInfo", "message-id" => "GetVideoInfo Quietly", } - obsipc.send( request.to_json) + obs4ipc.send( request.to_json) end - obs_pubsub.run + obs4_pubsub.run rescue ex : Socket::ConnectError # these are a bit noisy #pp ex - obs_pubsub && obs_pubsub.close + obs4_pubsub && obs4_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?" } ) + ircipc.send( { "#" + settings["channel"], "obs.cr:obs4: " + ex.to_s.gsub(/\r|\n/, ' ') + ": Maybe try again in 10 seconds?" } ) rescue ex pp ex pp ex.backtrace? - ircipc.send( { "#" + settings["channel"], "irc.cr:obs: " + ex.to_s.gsub(/\r|\n/, ' ') } ) - obs_pubsub && obs_pubsub.close + ircipc.send( { "#" + settings["channel"], "irc.cr:obs4: " + ex.to_s.gsub(/\r|\n/, ' ') } ) + obs4_pubsub && obs4_pubsub.close end sleep 10 next @@ -899,33 +1108,30 @@ loop do else end elsif ( cmd =~ /^uptime$/ ) - ircipc.send( { "##{settings["channel"]}", "| #{streamstatus["stream-timecode"].as_s[0..7]} Usage: #{streamstatus["cpu-usage"].as_f.to_i64}% #{streamstatus["memory-usage"].as_f.to_i64}MiB #{streamstatus["kbits-per-sec"].as_i64}kbps Frame losses: #{streamstatus["render-missed-frames"].as_i64} #{streamstatus["num-dropped-frames"].as_i64} #{streamstatus["output-skipped-frames"].as_i64}" } ) + obs5ipc.send( obsrequest( "GetStats", "GetStats" )) # !newimage [name] [url] (random|top|bottom|left|right|center) # download url, verify mimetype with libmagic, duplicate existing medialoop source, change "file" SourceSetting elsif ( ( cmd =~ /^sourcesettings$/ ) && ( mod || own || vip ) ) if ( match[2]? && match[2] =~ /^[a-zA-Z0-9-_]+$/ ) - obsipc.send( "{ \"request-type\": \"GetSourceSettings\", \"message-id\": \"GetSourceSettings\", \"sourceName\": \"#{match[2]}\" }" ) + + obs5ipc.send( obsrequest( "GetInputSettings", "GetInputSettings", JSON.parse( { "inputName" => match[2] }.to_json ) )) end + elsif ( ( cmd =~ /^inputlist$/ ) && ( mod || own || vip ) ) + obs5ipc.send( obsrequest( "GetInputList", "GetInputList" ) ) elsif ( ( cmd =~ /^scene$/ ) && ( mod || own || vip ) ) if ( match[2]? && match[2] =~ /^[a-zA-Z0-9-_]+$/ ) - obsipc.send( "{ \"request-type\": \"SetCurrentScene\", \"message-id\": \"SetCurrentScene\", \"scene-name\": \"" + match[2] + "\" }" ) - else - obsipc.send( "{ \"request-type\": \"GetSceneList\", \"message-id\": \"GetSceneList\" }" ) - end - elsif ( ( cmd =~ /^sceneitem$/ ) && ( mod || own || vip ) ) - if ( match[2]? && match[2] =~ /^[a-zA-Z0-9-_]+$/ ) - obsipc.send( "\x10sceneitem #{match[2]}" ) + obs5ipc.send( obsrequest( "SetCurrentProgramScene", "SetCurrentProgramScene", JSON.parse( { "sceneName" => match[2] }.to_json ) )) else - ircipc.send( { "##{settings["channel"]}", "Must provide provide a scene name as argument." } ) + obs5ipc.send( obsrequest( "GetSceneList", "GetSceneList" ) ) end elsif ( ( cmd =~ /^source$/ ) && ( mod || own || vip ) ) request = Hash( String, String | Bool ).new if ( match[2]? ) && ( sourceargs = match[2].match( /^([a-zA-Z0-9-_]+) +(true|false)$/ ) ) - obsipc.send( "\x10source #{match[2]}" ) + obs5ipc.send( "\x10source #{match[2]}" ) elsif ( match[2]? && match[2] =~ /^[a-zA-Z0-9-_]+$/ ) - obsipc.send( "\x10source #{match[2]}" ) + obs5ipc.send( "\x10source #{match[2]}" ) else - obsipc.send( "\x10source" ) + obs5ipc.send( "\x10source" ) end elsif ( ( cmd =~ /^filter$/ ) && ( mod || own ) ) request = Hash( String, String | Bool ){ @@ -939,29 +1145,29 @@ loop do #request["filterEnabled"] = filterargs[3] filterargs[3] == "true" && ( request["filterEnabled"] = true ) filterargs[3] == "false" && ( request["filterEnabled"] = false ) - obsipc.send( request.to_json ) + obs4ipc.send( request.to_json ) elsif ( match[2]? ) && ( filterargs = match[2].match( /^([a-zA-Z0-9-_]+) +([a-zA-Z0-9-_]+)/ ) ) ircipc.send( { "##{settings["channel"]}", "Must provide provide a value of true or false as the third argument." } ) elsif ( match[2]? && match[2] =~ /^[a-zA-Z0-9-_]+$/ ) request["sourceName"] = match[2] request["message-id"] = "GetSourceFilters" - obsipc.send( request.to_json ) + obs4ipc.send( request.to_json ) else ircipc.send( { "##{settings["channel"]}", "Must provide at least one source name as argument, and optionally one filter name and a value of true or false." } ) end elsif ( cmd == "create" && ( mod || own || vip ) ) if ( match[2]? ) && ( match[2] =~ /^([a-zA-Z0-9-_]+)/ ) - obsipc.send( "\x10newsource-temporary #{match[2]}" ) + obs4ipc.send( "\x10newsource-temporary #{match[2]}" ) else ircipc.send( { "##{settings["channel"]}", "Must provide at least one source name as argument." } ) end elsif ( cmd =~ /^(metaminute|youdied)$/ ) - obsipc.send( "\x10source-notransition media-#{cmd}" ) + obs4ipc.send( "\x10source-notransition media-#{cmd}" ) elsif ( cmd =~ /^explosion$/ ) if explosions explosion = explosions.sample( 1 )[0][1] puts explosion - obsipc.send( "\x10newsource-temporary #{explosion}" ) + obs4ipc.send( "\x10newsource-temporary #{explosion}" ) else puts "explosions undefined" end |