require "perfect_toml"

require_relative "../../lib/obsws"

OBSWS::LOGGER.debug!

class Observer
  attr_reader :running

  def initialize(**kwargs)
    @r_client = OBSWS::Requests::Client.new(**kwargs)
    @e_client = OBSWS::Events::Client.new(**kwargs)
    @e_client.add_observer(self)

    puts info.join("\n")
    @running = true
  end

  def info
    resp = @r_client.get_version
    [
      "Using obs version:",
      resp.obs_version,
      "With websocket version:",
      resp.obs_web_socket_version
    ]
  end

  def on_current_program_scene_changed(data)
    puts "Switched to scene #{data.scene_name}"
  end

  def on_scene_created(data)
    puts "scene #{data.scene_name} has been created"
  end

  def on_input_mute_state_changed(data)
    puts "#{data.input_name} mute toggled"
  end

  def on_exit_started
    puts "OBS closing!"
    @r_client.close
    @e_client.close
    @running = false
  end
end

def conn_from_toml
  PerfectTOML.load_file("obs.toml", symbolize_names: true)[:connection]
end

def main
  o = Observer.new(**conn_from_toml)

  sleep(0.1) while o.running
end

main if $0 == __FILE__