Committing so I can work remotely

source/app.d

@@ -63,6 +63,8 @@ void main(string[] args)
 
     mainWindow.show();
     Main.run();
+
+	controller.disconnect();
 }
 
 void initUI()
@@ -198,6 +200,7 @@ void configureUI()
         }
     );
 
+	configureWindows();
     configurePuppeteerConfigWindow();
     //TODO: these default values will have to do by now
     configurePWMOutputListBox(10);
@@ -210,6 +213,30 @@ void configureUI()
     debug writeln("Done configuring UI");
 }
 
+void configureWindows()
+{
+	import gdk.Event;
+	import gtk.Widget;
+
+	mainWindow.addOnDelete(
+	(Event e, Widget w)
+		{
+			Main.quit();
+			return false;
+		}
+	);
+
+	auto hideWindowDelegate = delegate bool(Event e, Widget w)
+	{
+		w.hide();
+		return true;
+	};
+
+	puppeteerConfigWindow.addOnDelete(hideWindowDelegate);
+	loadPuppeteerConfigDialog.addOnDelete(hideWindowDelegate);
+	savePuppeteerConfigDialog.addOnDelete(hideWindowDelegate);
+}
+
 void configurePWMOutputListBox(int entries)
 {
     PWMOutputListBox.removeAll();

source/plotter.d

@@ -0,0 +1,51 @@
+module plotter;
+
+import ggplotd.ggplotd;
+import ggplotd.aes;
+import ggplotd.geom;
+
+import std.stdio;
+
+
+class Plotter
+{
+    private GGPlotD receivedPlot;
+    private GGPlotD adaptedPlot;
+
+    enum plotWidth = 1000;
+    enum plotHeight = 800;
+
+    this()
+    {
+
+    }
+
+    void savePlots()
+    {
+        writeln("Saving plots...");
+
+        receivedPlot.save("received.png", plotWidth, plotHeight);
+        adaptedPlot.save("adapted.png", plotWidth, plotHeight);
+
+        writeln("Plots have been saved");
+    }
+
+    void addAIRead(ubyte pin, float receivedValue, float adaptedValue, long readTimeMSecs)
+    {
+        enum pinColors = ["a", "b", "c", "d", "e", "f"];
+
+        auto receivedAes = Aes!(long[], "x", float[], "y", string, "colour")
+                            ([readTimeMSecs], [receivedValue], pinColors[pin]);
+
+        auto adaptedAes = Aes!(long[], "x", float[], "y", string, "colour")
+                            ([readTimeMSecs], [adaptedValue], pinColors[pin]);
+
+        receivedPlot.put(geomPoint(receivedAes));
+        adaptedPlot.put(geomPoint(adaptedAes));
+    }
+
+    void addVarMonitorRead(T)(ubyte varIndex, T receivedValue, T adaptedValue, long mSecs)
+    {
+
+    }
+}

source/puppeteer_controller.d

@@ -36,7 +36,11 @@ public class PuppeteerController
 
     void disconnect()
     {
-        puppeteer.endCommunication();
+        if(isPuppeteerConnected)
+        {
+            puppeteer.endCommunication();
+            listener.finish();
+        }
     }
 
     void setPWM(ubyte pin, ubyte value)

source/puppeteer_listener.d

@@ -0,0 +1,56 @@
+module puppeteer_listener;
+
+import plotter;
+
+import std.concurrency;
+import std.stdio;
+
+public shared class PuppeteerListener
+{
+    __gshared Tid drawer;
+
+    this()
+    {
+        drawer = spawn(&drawLoop);
+    }
+
+    public void finish()
+    {
+        drawer.send(cast(int)0);
+    }
+
+    public void AIListener(ubyte pin, float realValue, float adaptedValue, long mSecs)
+    {
+        drawer.send(DrawAIMessage(pin, realValue, adaptedValue, mSecs));
+    }
+
+    public void varListener(T)(ubyte varIndex, T realValue, T adaptedValue, long mSecs)
+    {
+
+    }
+}
+
+void drawLoop()
+{
+    Plotter plotter = new Plotter();
+
+    bool shouldLoop = true;
+    while(shouldLoop)
+    {
+        receive(
+            (DrawAIMessage msg) {plotter.addAIRead(msg.pin, msg.realValue, msg.adaptedValue, msg.mSecs);},
+            (int i) {if (i==0) shouldLoop = false;}
+        );
+    }
+
+    writeln("Finishing drawLoop");
+    plotter.savePlots();
+}
+
+private struct DrawAIMessage
+{
+    ubyte pin;
+    float realValue;
+    float adaptedValue;
+    long mSecs;
+}