1 files changed, 92 insertions, 0 deletions
diff --git a/mavigator-index/src/main/scala/vfd/index/Main.scala b/mavigator-index/src/main/scala/vfd/index/Main.scala
new file mode 100644
index 0000000..d5b3f64
--- /dev/null
+++ b/mavigator-index/src/main/scala/vfd/index/Main.scala
@@ -0,0 +1,92 @@
+package vfd.index
+
+import org.mavlink.Parser
+import org.mavlink.messages.Message
+import org.mavlink.messages.Heartbeat
+
+import org.scalajs.dom
+import org.scalajs.dom.html
+
+import rx._
+
+import scala.scalajs.js
+import scala.scalajs.js.annotation.JSExport
+
+import scalatags.JsDom.all._
+
+@JSExport("Main")
+object Main {
+  import Util._
+
+  val active = Var(Set.empty[ActiveVehicle])
+
+  val parser = new Parser(
+    packet => {
+      val m: Message = Message.unpack(packet.messageId, packet.payload)
+      println(m)
+      m match {
+        case hb: Heartbeat =>
+          active() += ActiveVehicle.fromHeartbeat(packet.systemId, hb)
+        case _ => ()
+      }
+    }
+  )
+
+  @JSExport
+  def main(root: html.Element, baseAssets: String, args: js.Dictionary[String]): Unit = {
+
+    val connection = new dom.WebSocket(args("socketUrl"))
+
+    connection.binaryType = "arraybuffer"
+    connection.onmessage = (e: dom.MessageEvent) => {
+      val buffer = e.data.asInstanceOf[js.typedarray.ArrayBuffer]
+      val view = new js.typedarray.DataView(buffer)
+
+      for (i <- 0 until view.byteLength) {
+        parser.push(view.getInt8(i))
+      }
+    }
+
+    connection.onclose = (e: dom.Event) => {
+      while (root.firstChild != null) {
+        root.removeChild(root.firstChild);
+      }
+      root.appendChild(
+        div(`class`:="alert alert-danger")(
+          "Connection to server unexpectedly closed. Check server logs for errors."
+        ).render
+      )
+
+    }
+
+    root.appendChild(div(
+      table(`class` := "table table-hover")(
+        thead(
+          tr(
+            th("System ID"),
+            th("Type"),
+            th("Autopilot"),
+            th("State"),
+            th("")
+          )
+        ),
+        Rx {
+          tbody(
+            for (vehicle <- active().toSeq) yield {
+              tr(
+                td(vehicle.systemId),
+                td(vehicle.vehicleType),
+                td(vehicle.autopilot),
+                td(vehicle.state),
+                td(a(href := "/dashboard/" + vehicle.systemId, `class` := "btn btn-default")("Pilot"))
+              )
+            }
+          )
+        }
+      ),
+      i(`class`:="fa fa-spinner fa-spin")(),
+      " Listening for heartbeats..."
+    ).render)
+  }
+
+}
+\ No newline at end of file