wipmacros

3 files changed, 186 insertions, 10 deletions

diff --git a/alv-lib/glsl.moon b/alv-lib/glsl.moon
new file mode 100644
index 0000000..3f973ae
--- /dev/null
+++ b/alv-lib/glsl.moon
@@ -0,0 +1,66 @@
+import Constant, Op, Builtin, Input, T, Struct, const, any from require 'alv.base'
+import new_message, add_item from require 'alv-lib._osc'
+import dns, udp from require 'socket'
+
+glsl_type = (type) ->
+  switch type
+    when T.num then 'float'
+    when T.str then 'sampler3D'
+    when T.bool then 'bool'
+    else
+      error "unknown primitive type"
+
+resubst = (str, fn) ->
+  str = str\gsub '##', '#'
+  str\gsub '#{(%d+)}', fn
+
+shader = Constant.meta
+  meta:
+    name: 'gate'
+    summary: "gate from note-on and note-off messages."
+    examples: { '(midi/gate [port] note [chan])' }
+
+  value: class extends Op
+    pattern = const.str + any!^0
+
+    setup: (inputs, scope) =>
+      { code, params } = pattern\match inputs
+
+      super [Input.hot param for param in *params]
+
+      uniforms = {}
+      inputs = {}
+
+      for i, input in ipairs @inputs
+        table.insert uniforms, "uniform #{glsl_type input\type!} alv_param_#{i};"
+
+      code = code.result!
+      code = resubst code, (i) -> "alv_param_#{i}"
+
+      table.insert uniforms, code
+      code = table.concat uniforms, '\n'
+
+      print code
+
+      @state or= with sock = udp!
+        \setpeername '127.0.0.1', 9000
+
+      msg = new_message "/-/shader"
+      add_item msg, T.str, code
+      @state\send msg.pack msg.content
+
+    tick: (setup) =>
+      for i, input in ipairs @inputs
+        if setup or input\dirty!
+          msg = new_message "/alv_param_#{i}"
+          print "/alv_param_#{i}", input!
+          add_item msg, input\type!, input!
+          @state\send msg.pack msg.content
+
+Constant.meta
+  meta:
+    name: 'glsl-view'
+    summary: "glsl-view integration via OSC."
+
+  value:
+    :shader
diff --git a/alv-lib/osc.moon b/alv-lib/osc.moon
index 8c93b07..a1c7c5d 100644
--- a/alv-lib/osc.moon
+++ b/alv-lib/osc.moon
@@ -1,7 +1,23 @@
-import Op, PureOp, Constant, Input, T, sig, any from require 'alv.base'
+import Op, PureOp, Constant, Input, T, Array, sig, const, any from require 'alv.base'
 import new_message, add_item from require 'alv-lib._osc'
 import dns, udp from require 'socket'
 
+losc = require 'losc'
+losc_Pattern = require 'losc.pattern'
+
+class LoscPlugin
+  new: (host, port) =>
+    @handle = udp!
+    assert @handle\setsockname host, port
+    @handle\settimeout 0
+
+  poll: =>
+    data = @handle\receive!
+    if data
+      losc_Pattern.dispatch data, @
+
+  close: => @handle\close!
+
 unpack or= table.unpack
 
 connect = Constant.meta
@@ -18,7 +34,7 @@ connect = Constant.meta
         host: Input.hot host
         port: Input.hot port
 
-      @setup_out '~', T['udp/socket']
+      @setup_out '~', T['osc/out']
 
     tick: =>
       { :host, :port } = @unwrap_all!
@@ -27,6 +43,98 @@ connect = Constant.meta
       @out\set with sock = udp!
         \setpeername ip, port
 
+listen = Constant.meta
+  meta:
+    name: 'listen'
+    summary: "Create a UDP server."
+    examples: { '(osc/listen port bind-addr)' }
+
+  value: class extends Op
+    pattern = sig.num + -sig.str
+    setup: (inputs) =>
+      { port, host } = pattern\match inputs
+      super
+        host: Input.hot host or Constant.str ''
+        port: Input.hot port
+
+      @setup_out '~', T['osc/in']
+
+    tick: =>
+      { :host, :port } = @unwrap_all!
+
+      @out\set with p = losc.new plugin: losc_udp2.new!
+        print \open host, port
+
+recv_evt = Constant.meta
+  meta:
+    name: 'recv!'
+    summary: "Receive OSC messages."
+    examples: { '(osc/recv! [socket] path [type-str])' }
+
+  value: class extends Op
+    pattern: any!^0
+
+    full_pattern = -sig['osc/in'] + sig.str + sig.str
+    setup: (inputs, scope) =>
+      { port, path, types } = full_pattern\match inputs
+      types = types or Constant.str 'f'
+      super
+        port: Input.hot message or scope\get '*oscin*'
+        path: Input.hot path
+        types: Input.cold types
+
+        io: Input.hot (@get_type types.result!)\mk_evt!
+
+      @setup_out '!', @get_type types.result!
+      @state or= {}
+
+    poll: => @inputs.io\dirty!
+
+    handler: (data) =>
+      { :message } = data
+      print "handler called", message
+      types = @inputs.types!
+      assert types == message\types!
+
+      if @out\type!.__class == Array
+        @inputs.io.result\set message\args!
+      else
+        @inputs.io.result\set message[1]
+
+    tick: =>
+      if @inputs.port\dirty! or @inputs.path\dirty!
+        @state.port\remove_handler @state.path if @state.port
+        print "del handler", @state.path
+
+        @state.port, @state.path = @inputs.port!, @inputs.path!
+        @state.port\add_handler @state.path, @\handler
+        print "add handler", @state.path
+
+      if @inputs.io\dirty!
+        @out\set @inputs.io!
+
+    destroy: => if @state then @state.port\remove_handler @state.path
+
+    get_type: (types) =>
+      types = types\gsub '[%[%]]', ''
+      first = types\sub 1, 1
+      assert first, "empty type string"
+
+      for i=2, #types
+        assert first == (types\sub i, 1), "mixed types in array"
+
+      typ = switch first
+        when 'f', 'i' then T.num
+        when 's', 'S', 'c' then T.str
+        when 'T', 'F' then T.bool
+        when 'I' then T.bang
+        else error "unknown typetag"
+
+      if #types
+        Array #types, typ
+      else
+        typ
+
 send = Constant.meta
   meta:
     name: 'send'
@@ -35,13 +143,13 @@ send = Constant.meta
     description: "Sends an OSC message to `path` with `val…` as arguments.
 
 - `socket` should be a `udp/socket` value. This argument can be omitted and the
-  value be passed as a dynamic definition in `*sock*` instead.
+  value be passed as a dynamic definition in `*oscout*` instead.
 - `path` is the OSC path to send the message to. It should be a string-value.
 - the arguments can be any type:
   - `num` will be sent as `f`
   - `str` will be sent as `s`
   - `bool` will be sent as `T`/`F`
-  - `bang` will be sent as `T`
+  - `bang` will be sent as `I`
   - arrays will be unwrapped
   - structs will be sent as a series of key/value tuples
 
@@ -50,11 +158,11 @@ This is a pure op, so between the values at most one !-stream input is allowed."
   value: class extends PureOp
     pattern: any!^0
 
-    full_pattern = -sig['udp/socket'] + sig.str + any!^0
+    full_pattern = -sig['osc/in'] + sig.str + any!^0
     setup: (inputs, scope) =>
       { socket, path, values } = full_pattern\match inputs
       super values, scope, {
-        socket: Input.cold socket or scope\get '*sock*'
+        socket: Input.cold socket or scope\get '*oscout*'
         path:   Input.cold path
       }
 
@@ -74,7 +182,7 @@ send_arr = Constant.meta
     description: "Sends an OSC message to `path` with `val…` as arguments.
 
 - `socket` should be a `udp/socket` value. This argument can be omitted and the
-  value be passed as a dynamic definition in `*sock*` instead.
+  value be passed as a dynamic definition in `*oscout*` instead.
 - `path` is the OSC path to send the message to. It should be a string-value.
 - the arguments can be any type:
   - `num` will be sent as `f`
@@ -89,11 +197,11 @@ This is a pure op, so between the values at most one !-stream input is allowed."
   value: class extends PureOp
     pattern: any!^0
 
-    full_pattern = -sig['udp/socket'] + sig.str + any!^0
+    full_pattern = -sig['udp/out'] + sig.str + any!^0
     setup: (inputs, scope) =>
       { socket, path, values } = full_pattern\match inputs
       super values, scope, {
-        socket: Input.cold socket or scope\get '*sock*'
+        socket: Input.cold socket or scope\get '*oscout*'
         path:   Input.cold path
       }
 
@@ -112,5 +220,7 @@ Constant.meta
 
   value:
     :connect
+    :listen
     :send
     :sync
+    'recv!': recv_evt
diff --git a/alv-lib/time.moon b/alv-lib/time.moon
index 1f8e324..6b796ba 100644
--- a/alv-lib/time.moon
+++ b/alv-lib/time.moon
@@ -58,7 +58,7 @@ scale_time = Constant.meta
   and the stream be passed as a dynamic definition in `*clock*` instead.
 - `scale` should be a num~ stream."
   value: class extends Op
-    pattern = -evt.clock + sig.num + -sig.str
+    pattern = -evt.clock + sig.num
     setup: (inputs, scope) =>
       { clock, scale } = pattern\match inputs
       super