Added Js code (40%)
authorjoelbandi <joelvivekbandi@gmail.com>
Tue, 26 Jul 2016 12:56:21 +0000 (05:56 -0700)
committerjoelbandi <joelvivekbandi@gmail.com>
Tue, 26 Jul 2016 12:56:21 +0000 (05:56 -0700)
20 files changed:
.gitignore
src/java/iotcloud/Slot.java
src/js/iotjs/.babelrc [new file with mode: 0644]
src/js/iotjs/.bowerrc [new file with mode: 0644]
src/js/iotjs/.editorconfig [new file with mode: 0644]
src/js/iotjs/.jshintrc [new file with mode: 0644]
src/js/iotjs/README.md [new file with mode: 0644]
src/js/iotjs/bower.json [new file with mode: 0644]
src/js/iotjs/examples/index.html [new file with mode: 0644]
src/js/iotjs/gulpfile.js [new file with mode: 0644]
src/js/iotjs/orig/entry.js [new file with mode: 0644]
src/js/iotjs/orig/slot.js [new file with mode: 0644]
src/js/iotjs/package.json [new file with mode: 0644]
src/js/iotjs/src/entry.js [new file with mode: 0644]
src/js/iotjs/src/iotstring.js [new file with mode: 0644]
src/js/iotjs/src/liveness.js [new file with mode: 0644]
src/js/iotjs/src/main.js [new file with mode: 0644]
src/js/iotjs/src/pair.js [new file with mode: 0644]
src/js/iotjs/src/slot.js [new file with mode: 0644]
src/js/iotjs/test/test.js [new file with mode: 0644]

index 68a8b77..b28f4ad 100644 (file)
@@ -3,3 +3,8 @@ build/
 compiled/
 *.o
 *~
+/src/js/iotjs/node_modules/
+node_modules/
+dist/
+bower_components
+test/bower_components
index 4db9133..ed577a6 100644 (file)
@@ -19,7 +19,7 @@ class Slot implements Liveness {
        static final int HMAC_SIZE=32;
 
        /** Sequence number of the slot. */
-       private long seqnum;
+       private long seqnum;//
        /** HMAC of previous slot. */
        private byte[] prevhmac;
        /** HMAC of this slot. */
diff --git a/src/js/iotjs/.babelrc b/src/js/iotjs/.babelrc
new file mode 100644 (file)
index 0000000..9d8d516
--- /dev/null
@@ -0,0 +1 @@
+{ "presets": ["es2015"] }
diff --git a/src/js/iotjs/.bowerrc b/src/js/iotjs/.bowerrc
new file mode 100644 (file)
index 0000000..baa91a3
--- /dev/null
@@ -0,0 +1,3 @@
+{
+  "directory": "bower_components"
+}
\ No newline at end of file
diff --git a/src/js/iotjs/.editorconfig b/src/js/iotjs/.editorconfig
new file mode 100644 (file)
index 0000000..e717f5e
--- /dev/null
@@ -0,0 +1,13 @@
+# http://editorconfig.org
+root = true
+
+[*]
+indent_style = space
+indent_size = 2
+end_of_line = lf
+charset = utf-8
+trim_trailing_whitespace = true
+insert_final_newline = true
+
+[*.md]
+trim_trailing_whitespace = false
diff --git a/src/js/iotjs/.jshintrc b/src/js/iotjs/.jshintrc
new file mode 100644 (file)
index 0000000..0959e67
--- /dev/null
@@ -0,0 +1,20 @@
+{
+    "node": true,
+    "esnext": true,
+    "bitwise": true,
+    "camelcase": true,
+    "curly": true,
+    "eqeqeq": true,
+    "immed": true,
+    "indent": 2,
+    "latedef": true,
+    "newcap": true,
+    "noarg": true,
+    "quotmark": "single",
+    "regexp": true,
+    "undef": true,
+    "unused": true,
+    "trailing": true,
+    "smarttabs": true,
+    "white": true
+}
diff --git a/src/js/iotjs/README.md b/src/js/iotjs/README.md
new file mode 100644 (file)
index 0000000..2e6e0a1
--- /dev/null
@@ -0,0 +1,21 @@
+iotjs
+==================================================
+
+What does your library do?
+
+Getting Started
+--------------------------------------
+
+- Install dependencies: `npm install`
+- Run `bower install` to install frontend dependencies
+- Run `gulp` to build your library
+
+Usage
+--------------------------------------
+
+How can I use it?
+
+Future Development
+--------------------------------------
+
+What would you like to do but don't have the time for?
diff --git a/src/js/iotjs/bower.json b/src/js/iotjs/bower.json
new file mode 100644 (file)
index 0000000..cb33217
--- /dev/null
@@ -0,0 +1,6 @@
+{
+  "name": "iotjs",
+  "version": "0.0.0",
+  "dependencies": {}
+}
+
diff --git a/src/js/iotjs/examples/index.html b/src/js/iotjs/examples/index.html
new file mode 100644 (file)
index 0000000..8613e8e
--- /dev/null
@@ -0,0 +1,11 @@
+<!DOCTYPE html>
+<html>
+<head>
+  <meta charset="utf-8">
+  <title>iotjs Example</title>
+</head>
+<body>
+
+<script src="../build/iotjs.js"></script>
+</body>
+</html>
\ No newline at end of file
diff --git a/src/js/iotjs/gulpfile.js b/src/js/iotjs/gulpfile.js
new file mode 100644 (file)
index 0000000..ed79d92
--- /dev/null
@@ -0,0 +1,49 @@
+var gulp = require('gulp');
+var gulpif = require('gulp-if');
+var clean = require('gulp-clean');
+var order = require('gulp-order');
+var rename = require('gulp-rename');
+var concat = require('gulp-concat');
+var jshint = require('gulp-jshint');
+var uglify = require('gulp-uglify');
+var stylish = require('jshint-stylish');
+var livereload = require('gulp-livereload');
+var sourcemaps = require('gulp-sourcemaps');
+var flags = require('minimist')(process.argv.slice(2));
+
+// Gulp command line arguments
+var production = flags.production || false;
+var debug = flags.debug || !production;
+var watch = flags.watch;
+
+gulp.task('build',  ['clean'], function() {
+  // Single entry point to browserify
+  gulp.src(['src/*.js', 'vendor/*.js'])
+      .pipe(order([ // The order of concatenation
+        'src/main.js'
+      ], {base: '.'}))
+      .pipe(gulpif(debug, sourcemaps.init()))
+      .pipe(gulpif(production, uglify()))
+      .pipe(concat('iotjs.js'))
+      .pipe(gulpif(debug, sourcemaps.write()))
+      .pipe(gulp.dest('./build/'))
+      .pipe(gulpif(watch, livereload()));
+});
+
+gulp.task('lint', function() {
+  return gulp.src('src/*.js')
+    .pipe(jshint())
+    .pipe(jshint.reporter(stylish))
+});
+
+gulp.task('clean', function() {
+   return gulp.src(['./build'], {read: false})
+          .pipe(clean({force: true}));
+});
+
+gulp.task('watch', function() {
+  livereload.listen();
+  gulp.watch('src/*', ['lint', 'build']);
+});
+
+gulp.task('default', ['clean', 'lint', 'build']);
diff --git a/src/js/iotjs/orig/entry.js b/src/js/iotjs/orig/entry.js
new file mode 100644 (file)
index 0000000..8ad481a
--- /dev/null
@@ -0,0 +1,54 @@
+class Entry{
+    constructor(slot) {
+        if (slot && slot instanceof Slot) {
+            
+            this.TypeKeyValue = 1;
+            this.TypeLastmessage = 2;
+            this.TypeRejectedMessage = 3;
+            this.TypeTableStatus = 4;
+            this.liveStatus = true;
+            this.parentslot = slot;
+            
+        }
+    }
+    static decode(slot, bytebuffer) {
+        if (slot instanceof Slot && bytebuffer instanceof ByteBuffer) {
+            var type = bytebuffer.readByte();
+            switch (type) {
+                case this.TypeKeyValue:
+                    return KeyValue.decode(slot, bytebuffer);
+                case this.TypeLastmessage:
+                    return LastMessage.decode(slot, bytebuffer);
+                case this.TypeRejectedMessage:
+                    return RejectedMessage.decode(slot, bytebuffer);
+                case this.TypeTableStatus:
+                    return TableStatus.decode(slot, bytebuffer);
+                default:
+                    throw new Error("Unrecognized Entry Type: " + type);
+            }
+        }
+    }
+    isLive(){
+       return this.liveStatus;
+    }
+    setDead() {
+               this.liveStatus = false;
+               parentslot.decrementLiveCount();
+       }
+
+       //must be overriden.
+       encode(bytebuffer){
+
+       }
+       getSize(){
+
+       }
+       getType(){
+
+       }
+       getCopy(slot){
+               if(slot && slot instanceof Slot){
+                       
+               }
+       }
+}
\ No newline at end of file
diff --git a/src/js/iotjs/orig/slot.js b/src/js/iotjs/orig/slot.js
new file mode 100644 (file)
index 0000000..72352d9
--- /dev/null
@@ -0,0 +1,10 @@
+class Slot{
+       constructor(seqnum,machineid,prevhmac,hmac){
+               this.SLOT_SIZE=2048;
+               this.RESERVED_SPACE=64;
+               this.HMAC_SIZE=32;
+               (typeof seqnum === "number")? this.seqnum = seqnum : throw new Error("seqnum should be a number");
+               (typeof machineid === "number")? this.machineid = seqnum : throw new Error("seqnum should be a number");
+
+       }
+}
\ No newline at end of file
diff --git a/src/js/iotjs/package.json b/src/js/iotjs/package.json
new file mode 100644 (file)
index 0000000..2b12bbe
--- /dev/null
@@ -0,0 +1,32 @@
+{
+  "name": "iotjs",
+  "version": "0.0.0",
+  "scripts": {
+    "test": "gulp && node ./test/test.js"
+  },
+  "dependencies": {
+    "bytebuffer": "^5.0.1",
+    "crypto-js": "^3.1.6",
+    "gulp": "3.8.11",
+    "gulp-clean": "0.3.1",
+    "gulp-concat": "2.5.2",
+    "gulp-if": "1.2.5",
+    "gulp-jshint": "1.9.4",
+    "gulp-livereload": "3.8.0",
+    "gulp-load-plugins": "0.8.1",
+    "gulp-order": "1.1.1",
+    "gulp-rename": "1.2.0",
+    "gulp-sourcemaps": "1.5.1",
+    "gulp-uglify": "1.1.0",
+    "jshint-stylish": "1.0.1",
+    "minimist": "1.1.1",
+    "object-hash": "^1.1.3",
+    "request": "^2.74.0",
+    "underscore": "^1.8.3"
+  },
+  "devDependencies": {
+    "babel-cli": "^6.11.4",
+    "babel-preset-es2015": "^6.9.0",
+    "browserify": "^13.1.0"
+  }
+}
diff --git a/src/js/iotjs/src/entry.js b/src/js/iotjs/src/entry.js
new file mode 100644 (file)
index 0000000..e4a47a3
--- /dev/null
@@ -0,0 +1,72 @@
+"use strict";
+
+var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
+
+function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
+
+var Entry = function () {
+    function Entry(slot) {
+        _classCallCheck(this, Entry);
+
+        if (slot && slot instanceof Slot) {
+
+            this.TypeKeyValue = 1;
+            this.TypeLastmessage = 2;
+            this.TypeRejectedMessage = 3;
+            this.TypeTableStatus = 4;
+            this.liveStatus = true;
+            this.parentslot = slot;
+        }
+    }
+
+    _createClass(Entry, [{
+        key: "isLive",
+        value: function isLive() {
+            return this.liveStatus;
+        }
+    }, {
+        key: "setDead",
+        value: function setDead() {
+            this.liveStatus = false;
+            parentslot.decrementLiveCount();
+        }
+
+        //must be overriden.
+
+    }, {
+        key: "encode",
+        value: function encode(bytebuffer) {}
+    }, {
+        key: "getSize",
+        value: function getSize() {}
+    }, {
+        key: "getType",
+        value: function getType() {}
+    }, {
+        key: "getCopy",
+        value: function getCopy(slot) {
+            if (slot && slot instanceof Slot) {}
+        }
+    }], [{
+        key: "decode",
+        value: function decode(slot, bytebuffer) {
+            if (slot instanceof Slot && bytebuffer instanceof ByteBuffer) {
+                var type = bytebuffer.readByte();
+                switch (type) {
+                    case this.TypeKeyValue:
+                        return KeyValue.decode(slot, bytebuffer);
+                    case this.TypeLastmessage:
+                        return LastMessage.decode(slot, bytebuffer);
+                    case this.TypeRejectedMessage:
+                        return RejectedMessage.decode(slot, bytebuffer);
+                    case this.TypeTableStatus:
+                        return TableStatus.decode(slot, bytebuffer);
+                    default:
+                        throw new Error("Unrecognized Entry Type: " + type);
+                }
+            }
+        }
+    }]);
+
+    return Entry;
+}();
\ No newline at end of file
diff --git a/src/js/iotjs/src/iotstring.js b/src/js/iotjs/src/iotstring.js
new file mode 100644 (file)
index 0000000..05f35dc
--- /dev/null
@@ -0,0 +1,66 @@
+var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
+
+function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
+
+var IoTString = function () {
+  function IoTString(arg) {
+    _classCallCheck(this, IoTString);
+
+    if (arg === undefined) {
+      this.array = new Uint8Array();
+      this.hashcode;
+    } else if (arg && typeof arg === "string") {
+      this.array = new Uint8Array(arg.length);
+      for (var i = 0; i < arg.length; ++i) {
+        this.array[i] = arg.charCodeAt(i);
+      }
+      this.hashcode = hash(this.array);
+    } else if (arg && arg instanceof Uint8Array) {
+      this.array = arg;
+      this.hashcode = hashcode(arg);
+    }
+  }
+
+  _createClass(IoTString, [{
+    key: "shallow",
+    value: function shallow(arg) {
+      if (arg && arg instanceof Uint8Array) {
+        var i = new IotString(arg);
+        return i;
+      }
+    }
+  }, {
+    key: "internalBytes",
+    value: function internalBytes() {
+      return this.array;
+    }
+  }, {
+    key: "hashCode",
+    value: function hashCode() {
+      return this.hashcode;
+    }
+  }, {
+    key: "toString",
+    value: function toString() {
+      return this.array.toString();
+    }
+  }, {
+    key: "getBytes",
+    value: function getBytes() {
+      var obj;
+      return _.extend(obj, this.array);
+    }
+  }, {
+    key: "equals",
+    value: function equals(arr) {
+      return _.isEqual(arr, this.array);
+    }
+  }, {
+    key: "length",
+    value: function length() {
+      return this.array.length;
+    }
+  }]);
+
+  return IoTString;
+}();
\ No newline at end of file
diff --git a/src/js/iotjs/src/liveness.js b/src/js/iotjs/src/liveness.js
new file mode 100644 (file)
index 0000000..22cbd3f
--- /dev/null
@@ -0,0 +1,5 @@
+function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
+
+var Liveness = function Liveness() {
+  _classCallCheck(this, Liveness);
+};
\ No newline at end of file
diff --git a/src/js/iotjs/src/main.js b/src/js/iotjs/src/main.js
new file mode 100644 (file)
index 0000000..78e6a07
--- /dev/null
@@ -0,0 +1,67 @@
+/* jshint devel:true */
+"use strict";
+console.log('Welcome to iotjs-www','\n\n');
+
+// set up the base line..
+// Using browserify to set up browser exports
+var crypto = require('crypto-js');
+var hash = require('object-hash');
+var _ = require('underscore');
+var ByteBuffer = require("bytebuffer");
+
+
+(function() {
+    
+    var root = this;
+
+
+    // iot namespace main constructor
+    var iot = function(obj) {
+        if (obj instanceof iot) return obj;
+        if (!(this instanceof iot)) return new iot(obj);
+        this.iot = obj;
+    };
+    
+    // export iot to the global exports
+    if (typeof exports !== 'undefined') {
+        if (typeof module !== 'undefined' && module.exports) {
+            exports = module.exports = iot;
+        }
+        exports.iot = iot;
+    } else {
+        root.iot = iot;
+    }
+
+    iot.baselinetest = function(){
+       // baseline test
+        console.log('its alive!!!');
+        console.log();
+
+        //local hash test
+        console.log(hash('hello man'));
+        console.log(typeof hash('hello man'));
+        console.log();
+
+        //Pair test
+        var p = new Pair(1,2);
+        console.log(p.toString());
+        console.log();
+
+        //iotstring test
+        var i = new IoTString('hello');
+        console.log(i.length());
+        console.log();
+    }
+
+    
+
+
+
+
+
+
+
+
+
+
+}())
\ No newline at end of file
diff --git a/src/js/iotjs/src/pair.js b/src/js/iotjs/src/pair.js
new file mode 100644 (file)
index 0000000..e2467e3
--- /dev/null
@@ -0,0 +1,32 @@
+var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
+
+function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
+
+var Pair = function () {
+  function Pair(a, b) {
+    _classCallCheck(this, Pair);
+
+    this.a = a;
+    this.b = b;
+  }
+
+  _createClass(Pair, [{
+    key: 'getFirst',
+    value: function getFirst() {
+      return this.a;
+    }
+  }, {
+    key: 'getSecond',
+    value: function getSecond() {
+      return this.b;
+    }
+  }, {
+    key: 'toString',
+    value: function toString() {
+      var str = '<' + this.a + ',' + this.b + '>';
+      return str;
+    }
+  }]);
+
+  return Pair;
+}();
\ No newline at end of file
diff --git a/src/js/iotjs/src/slot.js b/src/js/iotjs/src/slot.js
new file mode 100644 (file)
index 0000000..e69de29
diff --git a/src/js/iotjs/test/test.js b/src/js/iotjs/test/test.js
new file mode 100644 (file)
index 0000000..7d78e72
--- /dev/null
@@ -0,0 +1,6 @@
+var iot = require('../build/iotjs.js');
+
+iot.baselinetest();
+
+
+