fix some kwin json issues. tweak values for influx.

client/brightness.py

@@ -24,7 +24,7 @@ def cal(v, c):
     return c[1] + c[0] * c_in[0] * max(0, c_in[1] + v)
 
 def filter_lux(old, new):
-    return (old * filter_fact) + (new * (1.0 - filter_fact))
+    return max(0.1, (old * filter_fact) + (new * (1.0 - filter_fact)))
 
 def lux_to_disp(name, val):
     if name in calibration:
@@ -93,10 +93,17 @@ if __name__ == "__main__":
         if (time.time() - time_window) > 20.0:
             time_window = time.time()
             info = window.query()
+
             if info["fullscreen"] and is_active:
-                print("App \"{}\" is now fullscreen! Pausing.".format(info["name"]))
+                print("{}: App \"{}\" is now fullscreen! Pausing.".format(time.ctime(), info["name"]))
+
             if (not info["fullscreen"]) and (not is_active):
-                print("No longer fullscreen. Continuing.")
+                print("{}: No longer fullscreen. Continuing.".format(time.ctime()))
+
+                # re-apply previous brightness values soon
+                for d in disps:
+                    d["prev"] = -1
+
             is_active = not info["fullscreen"]
 
         # set displays at most every 10s
@@ -114,4 +121,4 @@ if __name__ == "__main__":
                         print(e)
 
                         # set to zero to show display is disconnected
-                        d["prev"] = 0
+                        d["prev"] = -1

client/kwin_check.js

@@ -2,4 +2,5 @@ var win = workspace.activeWindow;
 var name = win.caption;
 var pid = win.pid;
 var state = (win.bufferGeometry == win.output.geometry);
-print('{ "name": "' + name + '", "pid": ' + pid + ', "fullscreen": ' + state + ' }');
+var obj = { name: name, pid: pid, fullscreen: state };
+print(JSON.stringify(obj));

client/window.py

@@ -4,6 +4,7 @@ import os
 import subprocess
 from datetime import datetime
 import json
+import time
 
 max_comm_retries = 5
 
@@ -44,7 +45,11 @@ def query_internal(verbose=False):
         print("Errs 4", result.stderr.decode("utf-8"))
 
     msg = result.stdout.decode().rstrip().split("\n")[0][4:]
-    return json.loads(msg)
+    try:
+        return json.loads(msg)
+    except Exception as e:
+        print("Failed msg: \"{}\"".format(msg))
+        raise e
 
 def query(verbose=False):
     for attempts in range(0, max_comm_retries):
@@ -53,6 +58,8 @@ def query(verbose=False):
         except Exception as e:
             if attempts >= (max_comm_retries - 1):
                 raise e
+            else:
+                time.sleep(0.5)
 
 if __name__ == "__main__":
     info = query()