# HG changeset patch
# User drewp@bigasterisk.com
# Date 1578297146 28800
# Node ID 4bd77a9548d66d28799906ff6db3f85ca41d41a0
# Parent  9ae34280218b556cd43f79037cdd3737ffd61a98
now roughly works. shows updates. only some workarounds.
Ignore-this: e591abe547e508c0e56102c124cf940b

diff -r 9ae34280218b -r 4bd77a9548d6 service/wifi/index.html
--- a/service/wifi/index.html	Sun Jan 05 23:18:27 2020 -0800
+++ b/service/wifi/index.html	Sun Jan 05 23:52:26 2020 -0800
@@ -20,12 +20,11 @@
           }
         </style>
         <streamed-graph
-          url="/sse_collector/graph/env"
-          n="network"
+          url="/sse_collector/graph/network"
           static="['demo.n3']"
           graph="{{graph}}"
         ></streamed-graph>
-        <wifi-display graph="[[g2]]" show-groups="true"></wifi-display>
+        <wifi-display graph="see element code for this"></wifi-display>
       </template>
     </dom-bind>
     <form method="POST" action="remoteSuspend">
diff -r 9ae34280218b -r 4bd77a9548d6 service/wifi/src/index.ts
--- a/service/wifi/src/index.ts	Sun Jan 05 23:18:27 2020 -0800
+++ b/service/wifi/src/index.ts	Sun Jan 05 23:52:26 2020 -0800
@@ -21,9 +21,12 @@
   ipAddress: Literal;
   dhcpHostname: string;
   macAddress: Literal;
-  packetsPerSec: string; //number; todo
-  bytesPerSec: string; //number;
+  packetsPerSec: number;
+  packetsPerSecDisplay: string;
+  bytesPerSec: number;
+  bytesPerSecDisplay: string;
 }
+const room = "http://projects.bigasterisk.com/room/";
 
 // workaround for uris that don't have good labels in the graph
 function labelFromUri(
@@ -40,6 +43,76 @@
   });
   return label;
 }
+function asString(x: Literal | undefined): string {
+  if (x && x.value) {
+    return x.value;
+  }
+  return "(unknown)";
+}
+
+function graphLiteral(
+  store: N3Store,
+  subj: NamedNode,
+  pred: string,
+  notFoundResult?: string
+): Literal {
+  const keep: Array<Literal> = [];
+  store.forEach(
+    q => {
+      if (!Util.isLiteral(q.object)) {
+        throw new Error("non literal found");
+      }
+      let seen = false;
+      for (let other of keep) {
+        if (other.equals(q.object)) {
+          seen = true;
+        }
+      }
+      if (!seen) {
+        keep.push(q.object as Literal);
+      }
+    },
+    subj,
+    namedNode(pred),
+    null,
+    null
+  );
+  if (keep.length == 0) {
+    return literal(notFoundResult || "(missing)");
+  }
+  if (keep.length == 1) {
+    return keep[0];
+  }
+  console.log(`${subj.value} ${pred} had ${keep.length} objects:`, keep);
+  return keep[0];
+}
+
+function graphUriValue(
+  store: N3Store,
+  subj: NamedNode,
+  pred: string
+): NamedNode | undefined {
+  const keep: Array<NamedNode> = [];
+  store.forEach(
+    q => {
+      if (!Util.isNamedNode(q.object)) {
+        throw new Error("non uri found");
+      }
+      keep.push(q.object as NamedNode);
+    },
+    subj,
+    namedNode(pred),
+    null,
+    null
+  );
+  if (keep.length == 0) {
+    return undefined;
+  }
+  if (keep.length == 1) {
+    return keep[0];
+  }
+  throw new Error("found multiple matches for pred");
+}
 
 @customElement("wifi-display")
 class WifiDisplay extends LitElement {
@@ -67,11 +140,11 @@
     return ["onGraphChanged(graph)"];
   }
 
-  @property({ type: Object }) //no longer a prop?
-  grouped: Map<string, DevGroup> = new Map();
+  @property({ type: Boolean })
+  showGroups = false;
 
   render() {
-    const grouped = this.graphView(this.graph.store!, false);
+    const grouped = this.graphView(this.graph.store!);
 
     return html`
       <div class="report">
@@ -86,11 +159,6 @@
     `;
   }
 
-  onGraphChanged(val: VersionedGraph, old: VersionedGraph) {
-    console.log("new graph value", this.graph);
-    this.grouped = this.graphView((val as VersionedGraph).store!, false);
-  }
-
   renderDevice(dev: Dev) {
     let agoReport = "";
     if (dev.agoMin === undefined) {
@@ -111,8 +179,8 @@
             >${dev.ipAddress && dev.ipAddress.value}</a
           ></span
         >
-        <span class="packets">${dev.packetsPerSec}</span>
-        <span class="bytes">${dev.bytesPerSec}</span>
+        <span class="packets">${dev.packetsPerSecDisplay}</span>
+        <span class="bytes">${dev.bytesPerSecDisplay}</span>
         <span class="hostname">${dev.dhcpHostname}</span>
         <span class="ago">${agoReport}</span>
         <span class="links">
@@ -156,7 +224,6 @@
       return ip.replace(/(\d+)/g, m => ("00" + m).slice(-3));
     }
     devs.sort((a, b) => {
-      return 0; //todo
       return padIp(a.ipAddress.value) > padIp(b.ipAddress.value) ? 1 : -1;
     });
     return html`
@@ -172,104 +239,65 @@
     `;
   }
 
-  graphView(store: N3Store, showGroups: boolean): Map<string, DevGroup> {
+  addGroupedDev(
+    store: N3Store,
+    grouped: Map<string, DevGroup>,
+    devUri: NamedNode
+  ) {
+    const getAgoMin = (connected: Literal | undefined): number | undefined => {
+      if (connected) {
+        const t = new Date(connected.value);
+        const agoMs = Date.now() - t.valueOf();
+        return agoMs / 1000 / 60;
+      }
+      return undefined;
+    };
+
+    const packetsPerSec = parseFloat(
+      graphLiteral(store, devUri, room + "packetsPerSec", "0").value
+    );
+    const bytesPerSec = parseFloat(
+      graphLiteral(store, devUri, room + "bytesPerSec", "0").value
+    );
+
+    const row: Dev = {
+      agoMin: getAgoMin(graphLiteral(store, devUri, room + "connected")),
+      ipAddress: graphLiteral(store, devUri, room + "ipAddress", "(unknown)"),
+      dhcpHostname: asString(
+        graphLiteral(store, devUri, room + "dhcpHostname")
+      ),
+      macAddress: graphLiteral(store, devUri, room + "macAddress"),
+      packetsPerSec: packetsPerSec,
+      packetsPerSecDisplay: packetsPerSec + " P/s",
+      bytesPerSec: bytesPerSec,
+      bytesPerSecDisplay: bytesPerSec + " B/s",
+    };
+
+    const wifiBand = graphUriValue(store, devUri, room + "wifiBand");
+    const connectedToAp = graphUriValue(store, devUri, room + "connectedToAp");
+    if (!this.showGroups || connectedToAp) {
+      const key = this.showGroups
+        ? `${connectedToAp!.value}-${wifiBand!.value}`
+        : "all";
+      if (!grouped.has(key)) {
+        grouped.set(key, {
+          connectedToAp: connectedToAp!,
+          wifiBand: wifiBand!,
+          devs: [],
+        });
+      }
+      grouped.get(key)!.devs.push(row);
+    } else {
+      console.log("lost row", row);
+    }
+  }
+
+  graphView(store: N3Store): Map<string, DevGroup> {
     const grouped: Map<string, DevGroup> = new Map();
-    const room = "http://projects.bigasterisk.com/room/";
     store.forEach(
       q => {
         const devUri: NamedNode = q.subject as NamedNode;
-
-        const graphLiteral = (
-          store: N3Store,
-          devUri: NamedNode,
-          pred: string,
-          notFoundResult?: string
-        ): Literal => {
-          const keep: Array<Literal> = [];
-          store.forEach(
-            q => {
-              if (!Util.isLiteral(q.object)) {
-                throw new Error("non literal found");
-              }
-              keep.push(q.object as Literal);
-            },
-            devUri,
-            namedNode(pred),
-            null,
-            null
-          );
-          if (keep.length == 0) {
-            return literal(notFoundResult || "(missing)");
-          }
-          if (keep.length == 1) {
-            return keep[0];
-          }
-          throw new Error("found multiple matches for pred");
-        };
-
-        const getAgoMin = (
-          connected: Literal | undefined
-        ): number | undefined => {
-          if (connected) {
-            const t = new Date(connected.value);
-            const agoMs = Date.now() - t.valueOf();
-            return agoMs / 1000 / 60;
-          }
-          return undefined;
-        };
-
-        const asString = (x: Literal | undefined): string => {
-          if (x && x.value) {
-            return x.value;
-          }
-          return "(unknown)";
-        };
-        const row: Dev = {
-          agoMin: getAgoMin(
-            literal("2020-01-01") //  graphLiteral(store, devUri, room + "connectedToAp")
-          ),
-          ipAddress: graphLiteral(
-            store,
-            devUri,
-            room + "ipAddress",
-            "(unknown)"
-          ),
-          dhcpHostname: asString(
-            graphLiteral(store, devUri, room + "dhcpHostname")
-          ),
-          macAddress: graphLiteral(store, devUri, room + "macAddress"),
-          packetsPerSec:
-            graphLiteral(store, devUri, room + "packetsPerSec", "? ").value +
-            " P/s", //number; todo
-          bytesPerSec:
-            graphLiteral(store, devUri, room + "bytesPerSec", "? ").value +
-            "B/s", //number;
-        };
-        if (row.dhcpHostname && (row.dhcpHostname as any).value) {
-          row.dhcpHostname = (row.dhcpHostname as any).value;
-        }
-        if (!showGroups || (row as any).connectedToAp) {
-          const key = showGroups
-            ? `${(row as any).connectedToAp.toNT()}-${(row as any).wifiBand.toNT()}`
-            : "all";
-          if (!grouped.has(key)) {
-            grouped.set(key, {
-              connectedToAp: (row as any).connectedToAp,
-              wifiBand: (row as any).wifiBand,
-              devs: [],
-            });
-          }
-          grouped.get(key)!.devs.push(row);
-        } else {
-          console.log("lost row", row);
-        }
-
-        if (row.bytesPerSec) {
-          row.bytesPerSec = row.bytesPerSec.valueOf() + " B/s";
-        }
-        if (row.packetsPerSec) {
-          row.packetsPerSec = row.packetsPerSec.valueOf() + " p/s";
-        }
+        this.addGroupedDev(store, grouped, devUri);
       },
       null,
       namedNode("http://www.w3.org/1999/02/22-rdf-syntax-ns#type"),