muse-hack/server.js at master · cimbriano/muse-hack · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
var io = require('socket.io-client');
var dgram = require("dgram");
var osc = require('osc-min');

var server = dgram.createSocket("udp4");
// var socket = io('http://104.131.10.60:8080');
var socket = io('http://localhost:8080');


var oscObj;

var message_counter = 0;
var batch = [];

var lock = 0;
var hold = 0;
var calm = 0;
server.on("message", function(msg, rinfo) {
  var error;
  try {
    oscObj = osc.fromBuffer(msg);
    oscObj['timeInMs'] = Date.now();

    batch.push(oscObj);
    // socket.emit('oscdata', oscObj);
    console.log(oscObj);


    //START ALPHA PROCESSING CODE
    // var total = 0;
    // var active = 0;
    // var avgAlpha = 0;
    // if(oscObj.address == "/muse/dsp/elements/alpha"){
    //   oscObj.args.forEach(function(datum){
    //     if(datum.value){
    //       total = total + datum.value;
    //       active = active + 1;
    //     }
    //     avgAlpha = total/active;
    //   });
    //   console.log("alpha: "+avgAlpha);
    //   if(avgAlpha > 0.32){
    //     calm = calm + 1;
    //     if(calm == 6){
    //       socket.emit('threefour', 1);
    //     }
    //   }else{
    //     calm = 0;
    //   }
    // }
    //END ALPHA PROCESSING CODE
    //START JAWCLENCH PROCESSING
    // if(oscObj.address == "/muse/dsp/elements/jaw_clench"){
    //   console.log(oscObj.args[0].value);
    //   if(oscObj.args[0].value == 1){
    //     if((Date.now() - lock) > 4000 ){
    //       hold = 0;
    //       socket.emit('threefour', 0);
    //       lock = Date.now();
    //     }else{
    //       hold = hold+1;
    //       if(hold == 10){
    //         hold = 0;
    //         socket.emit('threefour', 1);
    //         lock = Date.now();
    //       }
    //     }
    //   }
    // }
    //END JAWCLENCH

    message_counter += 1;

		if(message_counter % 2000 == 0) {
      console.log('Recieved 2k messages ' + message_counter / 2000);
      socket.emit('oscbatch', batch);
      // console.log(batch);
      batch = [];
		}


  } catch (_error) {
    error = _error;
    socket.emit('err', "invalid OSC packet");
  }
});

server.on("listening", function () {
  var address = server.address();
  console.log("server listening " +
      address.address + ":" + address.port);
});


server.bind(5001);
// server listening 0.0.0.0:5001