Basic project setup files with package.json and gulp build system

Author: sweetpi

.gitignore

@@ -0,0 +1 @@
+node_modules

gulpfile.coffee

@@ -0,0 +1,11 @@
+gulp = require('gulp')
+watch = require('gulp-watch')
+plumber = require('gulp-plumber')
+coffee = require('gulp-coffee')
+
+gulp.task('default', ->
+  watch(glob: 'src/**/*.coffee', verbose: true)
+    .pipe(plumber()) # This will keeps pipes working after error event
+    .pipe(coffee(bare: yes))
+    .pipe(gulp.dest('lib'))
+)

gulpfile.js

@@ -0,0 +1,2 @@
+require('coffee-script-redux/register');
+require('./gulpfile.coffee')

index.js

@@ -0,0 +1 @@
+module.exports = require('lib/controller')

lib/controller.js

@@ -0,0 +1,124 @@
+var doesProtocolMatch, helper, protocols, sortIndices;
+
+helper = require('./helper');
+
+protocols = ['weather1', 'weather2', 'switch1', 'switch2', 'switch3', 'switch4'];
+
+protocols = protocols.map((function(_this) {
+  return function(p) {
+    return require("../protocols/" + p + ".coffee")(helper);
+  };
+})(this));
+
+doesProtocolMatch = function(pulseLengths, pulses, protocol) {
+  var i, maxDelta;
+  if (pulses.length !== protocol.pulseCount) {
+    return false;
+  }
+  if (pulseLengths.length !== protocol.pulseLengths.length) {
+    return false;
+  }
+  i = 0;
+  while (i < pulseLengths.length) {
+    maxDelta = pulseLengths[i] * 0.25;
+    if (Math.abs(pulseLengths[i] - protocol.pulseLengths[i]) > maxDelta) {
+      return false;
+    }
+    i++;
+  }
+  return true;
+};
+
+sortIndices = function(array) {
+  var e, i, indices, j, tuple, tuples, _i, _j, _len, _len1;
+  tuples = new Array(array.length);
+  for (i = _i = 0, _len = array.length; _i < _len; i = ++_i) {
+    e = array[i];
+    tuples[i] = [e, i];
+  }
+  tuples.sort(function(left, right) {
+    if (left[0] < right[0]) {
+      return -1;
+    } else {
+      return 1;
+    }
+  });
+  indices = new Array(array.length);
+  for (j = _j = 0, _len1 = tuples.length; _j < _len1; j = ++_j) {
+    tuple = tuples[j];
+    indices[tuple[1]] = j;
+  }
+  return indices;
+};
+
+module.exports = {
+  compressTimings: function(timings) {
+    var bucket, buckets, counts, hasMatch, i, j, pulses, sums, timing, _i, _j, _k, _len, _len1, _len2;
+    pulses = '';
+    buckets = [];
+    sums = [];
+    counts = [];
+    for (i = _i = 0, _len = timings.length; _i < _len; i = ++_i) {
+      timing = timings[i];
+      hasMatch = false;
+      for (j = _j = 0, _len1 = buckets.length; _j < _len1; j = ++_j) {
+        bucket = buckets[j];
+        if (Math.abs(bucket - timing) < bucket * 0.5) {
+          pulses += j;
+          sums[j] += timing;
+          counts[j]++;
+          hasMatch = true;
+        }
+      }
+      if (!hasMatch) {
+        pulses += buckets.length;
+        buckets.push(timing);
+        sums.push(timing);
+        counts.push(1);
+      }
+    }
+    for (j = _k = 0, _len2 = buckets.length; _k < _len2; j = ++_k) {
+      bucket = buckets[j];
+      buckets[j] = Math.round(sums[j] / counts[j]);
+    }
+    return {
+      buckets: buckets,
+      pulses: pulses
+    };
+  },
+  prepareCompressedPulses: function(input) {
+    var parts, pulseLengths, pulses;
+    parts = input.split(' ');
+    pulseLengths = parts.slice(0, 8);
+    pulses = parts[8];
+    pulseLengths = pulseLengths.filter(function(puls) {
+      return puls !== '0';
+    }).map(function(puls) {
+      return parseInt(puls, 10);
+    });
+    sortIndices = sortIndices(pulseLengths);
+    pulseLengths.sort(function(l, r) {
+      return l - r;
+    });
+    pulses = helper.mapByArray(pulses, sortIndices);
+    return {
+      pulseLengths: pulseLengths,
+      pulses: pulses
+    };
+  },
+  parsePulseSquence: function(pulseLengths, pulses) {
+    var p, results, values, _i, _len;
+    results = [];
+    for (_i = 0, _len = protocols.length; _i < _len; _i++) {
+      p = protocols[_i];
+      if (doesProtocolMatch(pulseLengths, pulses, p)) {
+        values = p.parse(pulses);
+        results.push({
+          protocol: p.name,
+          values: values
+        });
+      }
+    }
+    return results;
+  }
+};

lib/helper.js

@@ -0,0 +1,59 @@
+module.exports = {
+  map: function(data, mapping) {
+    var hadMatch, i, replace, result, search;
+    i = 0;
+    result = '';
+    while (i < data.length) {
+      hadMatch = false;
+      for (search in mapping) {
+        replace = mapping[search];
+        if (data.length - i >= search.length) {
+          if (data.substr(i, search.length) === search) {
+            result += replace;
+            i += search.length;
+            hadMatch = true;
+            break;
+          }
+        }
+      }
+      if (!hadMatch) {
+        throw new Error("Data did not match mapping");
+      }
+    }
+    return result;
+  },
+  mapByArray: function(data, mapping) {
+    var d, result, _i, _len;
+    result = '';
+    for (_i = 0, _len = data.length; _i < _len; _i++) {
+      d = data[_i];
+      result += mapping[parseInt(d, 10)];
+    }
+    return result;
+  },
+  binaryToNumber: function(data, b, e) {
+    var i, number;
+    number = 0;
+    i = b;
+    while (i <= e) {
+      number <<= 1;
+      number |= parseInt(data[i], 10);
+      i++;
+    }
+    return number;
+  },
+  binaryToNumberRevert: function(data, b, e) {
+    var i, number;
+    number = 0;
+    i = e;
+    while (i >= b) {
+      number <<= 1;
+      number |= parseInt(data[i], 10);
+      i--;
+    }
+    return number;
+  },
+  binaryToBoolean: function(data, i) {
+    return data[i] === '1';
+  }
+};

package.json

@@ -0,0 +1,28 @@
+{
+  "name": "rfcontroljs",
+  "version": "0.0.0",
+  "description": "Protocol support for different 433mhz switches and weather stations for the RFControl Arduino library",
+  "main": "index.js",
+  "directories": {
+    "test": "test"
+  },
+  "scripts": {
+    "test": "gulp test"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git://github.com/pimatic/rfcontroljs.git"
+  },
+  "author": "Oliver Schneider <[email protected]>",
+  "license": "GPLv3",
+  "bugs": {
+    "url": "https://github.com/pimatic/rfcontroljs/issues"
+  },
+  "devDependencies": {
+    "gulp": "~3.8.6",
+    "gulp-coffee": "~2.1.1",
+    "coffee-script-redux": "~2.0.0-beta8",
+    "gulp-plumber": "~0.6.4",
+    "gulp-watch": "~0.6.9"
+  }
+}