feat: Planar Clarity Video Wall

drivers/planar/clarity_matrix.cr

@@ -0,0 +1,91 @@
+module Planar; end
+
+require "placeos-driver/interface/powerable"
+
+# Documentation: https://aca.im/driver_docs/Planar/020-1028-00%20RS232%20for%20Matrix.pdf
+#  also https://aca.im/driver_docs/Planar/020-0567-05_WallNet_guide.pdf
+
+class Planar::ClarityMatrix < PlaceOS::Driver
+  include Interface::Powerable
+
+  # Discovery Information
+  generic_name :VideoWall
+  descriptive_name "Planar Clarity Matrix Video Wall"
+
+  def on_load
+    # Communication settings
+    queue.wait = false
+    transport.tokenizer = Tokenizer.new("\r")
+  end
+
+  def connected
+    schedule.every(60.seconds, true) { do_poll }
+  end
+
+  def disconnected
+    # Disconnected may be called without calling connected
+    #   Hence the check if timer is nil here
+
+    schedule.clear
+  end
+
+  def power?
+    # options[:emit] = block if block_given?
+    # options[:wait] = true
+    # options[:name] = :pwr_query
+    send "op A1 display.power ? \r", name: :pwr_query #, wait: true
+  end
+
+  # def power(state, broadcast_ip = false, options = {}) # what does broadcast_ip do here??
+  def power(state : Bool = false)
+    self[:power] = state
+    # send("op A1 display.power = off \r")
+    if state == true
+      send("op A1 display.power = on \r")
+      schedule.in(20.seconds) { recall(0) }
+    else
+      send("op A1 display.power = off \r")
+    end
+  end
+
+  def switch_to
+    send "op A1 slot.recall(0) \r"
+
+    # this is called when we want the whole wall to show the one thing
+    # We'll just recall the one preset and have a different function for
+    # video wall specific functions
+  end
+
+  def recall(preset : Int32)
+      # options[:name] = :recall
+      send "op ** slot.recall #{preset} \r", name: :recall
+  end
+
+  def input_status
+    # options[:wait] = true
+    send "op A1 slot.current ? \r", wait: true, priority: 0
+  end
+
+  def received(data, task)
+    data = String.new(data) # OPA1DISPLAY.POWER=ON || OPA1SLOT.CURRENT=0
+    logger.debug { "Vid Wall: #{data}" }
+    data = data.split(".")[1].split("=") # [POWER, ON] || [CURRENT, 0]
+
+    status = data[0].downcase # power || current
+    value = data[1]           # ON || 0
+
+    case status
+    when "power"
+      self[:power] = value == "ON"
+    when "current"
+      self[:input] = value.to_i
+    end
+
+    task.try &.success(data)
+  end
+
+  protected def do_poll
+    power?
+    input_status if self["power"] == "ON"
+  end
+end

drivers/planar/clarity_matrix_spec.cr

@@ -0,0 +1,19 @@
+DriverSpecs.mock_driver "Planar::ClarityMatrix" do
+  # on connect it should do_poll the device
+  should_send("op A1 display.power ? \r")
+  responds("A1 display.power ? ")
+  # status[:power].should eq(true)
+
+  exec(:power)
+  should_send("op A1 display.power = off \r")
+
+  exec(:switch_to)
+  should_send("op A1 slot.recall(0) \r")
+
+  transmit("OPA1DISPLAY.POWER=ON")
+  # .get.should eq("ON")
+  # responds("ON")
+  # response = exec(:received)
+
+  status["power"].should eq(false)
+end