#!/usr/bin/env rspec
# frozen_string_literal: true

require_relative "spec_helper"
require "dbus"

# FIXME: factor out DBus::TestFixtures::Value in spec_helper
require "ostruct"
require "yaml"

data_dir = File.expand_path("data", __dir__)
marshall_yaml_s = File.read("#{data_dir}/marshall.yaml")
marshall_yaml = YAML.safe_load(marshall_yaml_s)

describe "PropertyTest" do
  before(:each) do
    @session_bus = DBus::ASessionBus.new
    @svc = @session_bus.service("org.ruby.service")
    @obj = @svc.object("/org/ruby/MyInstance")
    @iface = @obj["org.ruby.SampleInterface"]
  end

  it "tests property reading" do
    expect(@iface["ReadMe"]).to eq("READ ME")
  end

  it "tests property reading on a V1 object" do
    obj = @svc["/org/ruby/MyInstance"]
    iface = obj["org.ruby.SampleInterface"]

    expect(iface["ReadMe"]).to eq("READ ME")
  end

  context "when reading a property fails" do
    it "gets an error, mentioning the qualified property name" do
      expect { @iface["Explosive"] }
        .to raise_error(DBus::Error, /getting.*SampleInterface.Explosive.*Something failed/)
    end
  end

  it "tests property nonreading" do
    expect { @iface["WriteMe"] }.to raise_error(DBus::Error, /not readable/)
  end

  context "writing properties" do
    it "tests property writing" do
      @iface["ReadOrWriteMe"] = "VALUE"
      expect(@iface["ReadOrWriteMe"]).to eq("VALUE")
    end

    context "when writing a read-only property" do
      it "gets an error, mentioning the qualified property name" do
        expect { @iface["ReadMe"] = "WROTE" }
          .to raise_error(DBus::Error, /SampleInterface.ReadMe.*not writable/)
      end
    end

    context "when writing a property fails" do
      it "gets an error, mentioning the qualified property name" do
        expect { @iface["WriteMe"] = "Bruno is a city in Czechia" }
          .to raise_error(DBus::Error, /setting.*SampleInterface.WriteMe/)
      end
    end
  end

  # https://github.com/mvidner/ruby-dbus/pull/19
  it "tests service select timeout", slow: true do
    @iface["ReadOrWriteMe"] = "VALUE"
    expect(@iface["ReadOrWriteMe"]).to eq("VALUE")
    # wait for the service to become idle
    sleep 6
    # fail:  "Property value changed; perhaps the service died and got restarted"
    expect(@iface["ReadOrWriteMe"]).to eq("VALUE")
  end

  it "tests get all" do
    all = @iface.all_properties
    expect(all.keys.sort).to eq(["MyArray", "MyByte", "MyDict", "MyStruct", "MyVariant", "ReadMe", "ReadOrWriteMe"])
  end

  it "tests get all on a V1 object" do
    obj = @svc["/org/ruby/MyInstance"]
    iface = obj["org.ruby.SampleInterface"]

    all = iface.all_properties
    expect(all.keys.sort).to eq(["MyArray", "MyByte", "MyDict", "MyStruct", "MyVariant", "ReadMe", "ReadOrWriteMe"])
  end

  it "tests unknown property reading" do
    expect { @iface["Spoon"] }.to raise_error(DBus::Error, /not found/)
  end

  it "tests unknown property writing" do
    expect { @iface["Spoon"] = "FPRK" }.to raise_error(DBus::Error, /not found/)
  end

  it "errors for a property on an unknown interface" do
    # our idiomatic way would error out on interface lookup already,
    # so do it the low level way
    prop_if = @obj[DBus::PROPERTY_INTERFACE]
    expect { prop_if.Get("org.ruby.NoSuchInterface", "SomeProperty") }.to raise_error(DBus::Error) do |e|
      expect(e.name).to match(/UnknownProperty/)
      expect(e.message).to match(/no such interface/)
    end
  end

  it "errors for GetAll on an unknown interface" do
    # no idiomatic way?
    # so do it the low level way
    prop_if = @obj[DBus::PROPERTY_INTERFACE]
    expect { prop_if.GetAll("org.ruby.NoSuchInterface") }.to raise_error(DBus::Error) do |e|
      expect(e.name).to match(/UnknownProperty/)
      expect(e.message).to match(/no such interface/)
    end
  end

  it "receives a PropertiesChanged signal", slow: true do
    received = {}

    # TODO: for client side, provide a helper on_properties_changed,
    # or automate it even more in ProxyObject, ProxyObjectInterface
    prop_if = @obj[DBus::PROPERTY_INTERFACE]
    prop_if.on_signal("PropertiesChanged") do |_interface_name, changed_props, _invalidated_props|
      received.merge!(changed_props)
    end

    @iface["ReadOrWriteMe"] = "VALUE"
    @iface.SetTwoProperties("REAMDE", 255)

    # loop to process the signal. complicated :-( see signal_spec.rb
    loop = DBus::Main.new
    loop << @session_bus
    quitter = Thread.new do
      sleep 1
      loop.quit
    end
    loop.run
    # quitter has told loop.run to quit
    quitter.join

    expect(received["ReadOrWriteMe"]).to eq("VALUE")
    expect(received["ReadMe"]).to eq("REAMDE")
    expect(received["MyByte"]).to eq(255)
  end

  context "a struct-typed property" do
    it "gets read as a struct, not an array (#97)" do
      struct = @iface["MyStruct"]
      expect(struct).to be_frozen
    end

    it "Get returns the correctly typed value (check with dbus-send)" do
      # As big as the DBus::Data branch is,
      # it still does not handle the :exact mode on the client/proxy side.
      # So we resort to parsing dbus-send output.
      cmd = "dbus-send --print-reply " \
            "--dest=org.ruby.service " \
            "/org/ruby/MyInstance " \
            "org.freedesktop.DBus.Properties.Get " \
            "string:org.ruby.SampleInterface " \
            "string:MyStruct"
      reply = `#{cmd}`
      expect(reply).to match(/variant\s+struct {\s+string "three"\s+string "strings"\s+string "in a struct"\s+}/)
    end

    it "GetAll returns the correctly typed value (check with dbus-send)" do
      cmd = "dbus-send --print-reply " \
            "--dest=org.ruby.service " \
            "/org/ruby/MyInstance " \
            "org.freedesktop.DBus.Properties.GetAll " \
            "string:org.ruby.SampleInterface "
      reply = `#{cmd}`
      expect(reply).to match(/variant\s+struct {\s+string "three"\s+string "strings"\s+string "in a struct"\s+}/)
    end
  end

  context "an array-typed property" do
    it "gets read as an array" do
      val = @iface["MyArray"]
      expect(val).to eq([42, 43])
    end
  end

  context "a dict-typed property" do
    it "gets read as a hash" do
      val = @iface["MyDict"]
      expect(val).to eq({
                          "one" => 1,
                          "two" => "dva",
                          "three" => [3, 3, 3]
                        })
    end

    it "Get returns the correctly typed value (check with dbus-send)" do
      cmd = "dbus-send --print-reply " \
            "--dest=org.ruby.service " \
            "/org/ruby/MyInstance " \
            "org.freedesktop.DBus.Properties.Get " \
            "string:org.ruby.SampleInterface " \
            "string:MyDict"
      reply = `#{cmd}`
      # a bug about variant nesting lead to a "variant variant int32 1" value
      match_rx = /variant \s+ array \s \[ \s+
         dict \s entry\( \s+
            string \s "one" \s+
            variant \s+ int32 \s 1 \s+
         \)/x
      expect(reply).to match(match_rx)
    end
  end

  context "a variant-typed property" do
    it "gets read at all" do
      obj = @svc.object("/org/ruby/MyDerivedInstance")
      iface = obj["org.ruby.SampleInterface"]
      val = iface["MyVariant"]
      expect(val).to eq([42, 43])
    end
  end

  context "a byte-typed property" do
    # Slightly advanced RSpec:
    # https://rspec.info/documentation/3.9/rspec-expectations/RSpec/Matchers.html#satisfy-instance_method
    let(:a_byte_in_a_variant) do
      satisfying { |x| x.is_a?(DBus::Data::Variant) && x.member_type.to_s == DBus::Type::BYTE }
      # ^ This formatting keeps the matcher on a single line
      # which enables RSpec to cite it if it fails, instead of saying "block".
    end

    let(:prop_iface) { @obj[DBus::PROPERTY_INTERFACE] }

    it "gets set with a correct type (#108)" do
      expect(prop_iface).to receive(:Set).with(
        "org.ruby.SampleInterface",
        "MyByte",
        a_byte_in_a_variant
      )
      @iface["MyByte"] = 1
    end

    it "gets set with a correct type (#108), when using the DBus.variant workaround" do
      expect(prop_iface).to receive(:Set).with(
        "org.ruby.SampleInterface",
        "MyByte",
        a_byte_in_a_variant
      )
      @iface["MyByte"] = DBus.variant("y", 1)
    end
  end

  context "marshall.yaml round-trip via a VARIANT property" do
    marshall_yaml.each do |test|
      t = OpenStruct.new(test)
      next if t.val.nil?

      # Round trips do not work yet because the properties
      # must present a plain Ruby value so the exact D-Bus type is lost.
      # Round trips will work once users can declare accepting DBus::Data
      # in properties and method arguments.
      it "Sets #{t.sig.inspect}:#{t.val.inspect} and Gets something back" do
        before = DBus::Data.make_typed(t.sig, t.val)
        expect { @iface["MyVariant"] = before }.to_not raise_error
        expect { _after = @iface["MyVariant"] }.to_not raise_error
        # round-trip:
        # expect(after).to eq(before.value)
      end
    end
  end
end