From 676ac97aa5b37b2cd7553bddd72e3a16093d3282 Mon Sep 17 00:00:00 2001
From: Owen Green <gungwho@gmail.com>
Date: Sun, 24 Nov 2019 23:48:33 +0000
Subject: [PATCH] release-packaging/Classes/FluidDataSet.sc :  first reasonble
 dataset client

---
 release-packaging/Classes/FluidDataSet.sc | 79 +++++++++++++++++++++++
 1 file changed, 79 insertions(+)
 create mode 100644 release-packaging/Classes/FluidDataSet.sc

diff --git a/release-packaging/Classes/FluidDataSet.sc b/release-packaging/Classes/FluidDataSet.sc
new file mode 100644
index 0000000..41afa2a
--- /dev/null
+++ b/release-packaging/Classes/FluidDataSet.sc
@@ -0,0 +1,79 @@
+FluidDataSet : UGen {
+
+   var  <> synth, <> server;
+
+    *kr{ |name, dims|
+        ^this.multiNew('control',name, dims);
+	}
+
+    *new{ |server, name, dims|
+        var synth, instance;
+        server = server ? Server.default;
+        synth = {instance = FluidDataSet.kr(name,dims)}.play(server);
+        instance.server = server;
+        instance.synth = synth;
+        ^instance
+    }
+
+    *new1 { |rate, name, dims|
+        var ascii = name.ascii;
+        ^super.new1(*[rate, ascii.size].addAll(ascii)++dims);
+    }
+
+    init { |size...chars|
+        //Send the number of inputs (size of provider string) as specialIndex,
+        //so server plugin knows what's going on
+        specialIndex = -1;
+        inputs = [size].addAll(chars);
+    }
+
+    addPoint{|label, buffer, action|
+        this.pr_sendMsg(this.server, this.synth, 'addPoint',[label,buffer.asUGenInput],action);
+    }
+
+    getPoint{|label, buffer, action|
+        this.pr_sendMsg(this.server, this.synth, 'getPoint',[label,buffer.asUGenInput],action);
+    }
+
+    updatePoint{|label, buffer, action|
+        this.pr_sendMsg(this.server, this.synth, 'updatePoint',[label,buffer.asUGenInput],action);
+    }
+
+    deletePoint{|label,buffer action|
+        this.pr_sendMsg(this.server, this.synth,  'deletePoint',[label,buffer.asUGenInput],action);
+    }
+
+    cols {|action|
+        this.pr_sendMsg(this.server, this.synth, \cols,[],action,[numbers(FluidMessageResponse,_,1,_)]);
+    }
+
+    read{|filename,action|
+        this.pr_sendMsg(this.server, this.synth, \read,[filename],action);
+    }
+
+    write{|filename,action|
+        this.pr_sendMsg(this.server, this.synth, \write,[filename],action);
+    }
+
+    size { |action|
+        this.pr_sendMsg(this.server, this.synth, \size,[],action,[numbers(FluidMessageResponse,_,1,_)]);
+    }
+
+    clear { |server,node,action|
+        this.pr_sendMsg(server, node, \clear,[],action);
+    }
+
+    pr_sendMsg { |server, node, msg, args, action,parser|
+
+        server = server ? Server.default;
+
+        OSCFunc(
+            { |msg|
+                var result = FluidMessageResponse.collectArgs(parser,msg.drop(3));
+                if(result.notNil){action.value(result)}{action.value};
+            },'/'++msg
+        ).oneShot;
+
+        server.listSendMsg(['/u_cmd',node.nodeID,this.synthIndex,msg].addAll(args));
+    }
+}   
\ No newline at end of file