Continued development:

1. Implemented the node-zookeeper module
2. Refactored the kafka-node module
3. Renamed the xxxFactory classes to xxxClass
4. Improved the compatibility of various modules

Author: ldaniels528

README.md

@@ -47,7 +47,7 @@ MEANS.js goes to great lengths to make all the things you love about writing Sca
 ```bash
  $ sbt "project examples" clean fastOptJS
  $ cd examples
- $ node ./examples.js timers
+ $ node ./examples.js IntermediateTimers
 ```
 
 <a name="NodeJS"></a>
@@ -62,13 +62,16 @@ modules implemented for most web applications.
 The following modules have been implemented thus far:
 
 * body-parser
+* buffer
 * events
 * express
 * express-ws
 * fs
 * http
+* kafka-node
 * mongodb
 * net
+* node-zookeeper-client
 * stream
 * util
 

angularjs/src/main/scala/com/github/ldaniels528/meansjs/angularjs/JQLite.scala

@@ -18,7 +18,7 @@ trait JQLite extends Element {
     * @param className the given class name
     * @return the [[JQLite instance]]
     */
-  def addClass(className: String): this.type
+  def addClass(className: String): this.type = js.native
 
   /**
     * A function returning one or more space-separated class names to be added to the existing class name(s).

build.sbt

@@ -4,7 +4,7 @@ import sbt.Keys._
 import sbt.Project.projectToRef
 import sbt._
 
-val apiVersion = "0.0.6"
+val apiVersion = "0.0.7"
 val paradisePluginVersion = "2.1.0"
 val _scalaVersion = "2.11.8"
 val scalaJsDomVersion = "0.9.0"
@@ -25,7 +25,7 @@ val commonSettings = Seq(
 )
 
 lazy val root = (project in file(".")).
-  aggregate(core, angularjs, express, facebook, kafkanode, linkedin, mongodb, nodejs)
+  aggregate(core, angularjs, express, facebook, kafka_node, linkedin, mongodb, nodejs)
 
 lazy val core = (project in file("core")).
   enablePlugins(ScalaJSPlugin).
@@ -36,72 +36,80 @@ lazy val core = (project in file("core")).
   )
 
 lazy val angularjs = (project in file("angularjs")).
-  enablePlugins(ScalaJSPlugin).
   dependsOn(core).
+  enablePlugins(ScalaJSPlugin).
   settings(commonSettings: _*).
   settings(
     name := "means-angularjs",
     description := "AngularJS bindings for Scala.js"
   )
 
 lazy val facebook = (project in file("facebook")).
-  enablePlugins(ScalaJSPlugin).
   dependsOn(core, angularjs).
+  enablePlugins(ScalaJSPlugin).
   settings(commonSettings: _*).
   settings(
     name := "means-facebook",
     description := "Facebook buildings for Scala.js"
   )
 
 lazy val express = (project in file("express")).
-  enablePlugins(ScalaJSPlugin).
   dependsOn(core, nodejs).
+  enablePlugins(ScalaJSPlugin).
   settings(commonSettings: _*).
   settings(
     name := "means-express",
     description := "Express.js bindings for Scala.js"
   )
 
 lazy val linkedin = (project in file("linkedin")).
-  enablePlugins(ScalaJSPlugin).
   dependsOn(core, angularjs).
+  enablePlugins(ScalaJSPlugin).
   settings(commonSettings: _*).
   settings(
     name := "means-linkedin",
     description := "LinkedIn buildings for Scala.js"
   )
 
-lazy val kafkanode = (project in file("kafkanode")).
+lazy val kafka_node = (project in file("kafka_node")).
+  dependsOn(core, nodejs, node_zookeeper).
   enablePlugins(ScalaJSPlugin).
-  dependsOn(core, nodejs).
   settings(commonSettings: _*).
   settings(
     name := "means-kafka-node",
     description := "Kafka bindings for Scala.js"
   )
 
 lazy val mongodb = (project in file("mongodb")).
-  enablePlugins(ScalaJSPlugin).
   dependsOn(core, nodejs).
+  enablePlugins(ScalaJSPlugin).
   settings(commonSettings: _*).
   settings(
     name := "means-mongodb",
     description := "MongoDB bindings for Scala.js"
   )
 
 lazy val nodejs = (project in file("nodejs")).
-  enablePlugins(ScalaJSPlugin).
   dependsOn(core).
+  enablePlugins(ScalaJSPlugin).
   settings(commonSettings: _*).
   settings(
     name := "means-nodejs",
     description := "Node.js bindings for Scala.js"
   )
 
-lazy val examples = (project in file("examples")).
-  aggregate(core, express, kafkanode, mongodb, nodejs).
+lazy val node_zookeeper = (project in file("node_zookeeper")).
+  dependsOn(core, nodejs).
   enablePlugins(ScalaJSPlugin).
-  dependsOn(core, express, kafkanode, mongodb, nodejs).
+  settings(commonSettings: _*).
+  settings(
+    name := "means-node-zookeeper-client",
+    description := "Zookeeper client bindings for Scala.js"
+  )
+
+lazy val examples = (project in file("examples")).
+  aggregate(core, express, kafka_node, mongodb, nodejs, node_zookeeper).
+  dependsOn(core, express, kafka_node, mongodb, nodejs, node_zookeeper).
   enablePlugins(ScalaJSPlugin).
   settings(commonSettings: _*).
   settings(

core/src/main/scala/com/github/ldaniels528/meansjs/util/ScalaJsHelper.scala

@@ -36,11 +36,11 @@ object ScalaJsHelper {
   ////////////////////////////////////////////////////////////////////////
 
   /**
-    * Exception Enrichment
+    * Exception Extensions
     * @param cause the given [[Throwable exception]]
     * @author [email protected]
     */
-  implicit class ExceptionEnrichment(val cause: Throwable) extends AnyVal {
+  implicit class ExceptionExtensions(val cause: Throwable) extends AnyVal {
 
     def displayMessage = Option(cause.getMessage) match {
       case Some(s) if s.startsWith(HttpError) => cleanUp(s.drop(HttpError.length))
@@ -69,11 +69,11 @@ object ScalaJsHelper {
   }
 
   /**
-    * Time Measurement Enrichment
+    * Time Measurement Extensions
     * @param task the given [[Future task]]
     * @tparam T the return type of the task
     */
-  implicit class TimeEnrichment[T](val task: Future[T]) extends AnyVal {
+  implicit class TimeExtensions[T](val task: Future[T]) extends AnyVal {
 
     def withTimer(action: String, showHeader: Boolean = true)(implicit ec: ExecutionContext) = time(action, task, showHeader)
 
@@ -233,10 +233,6 @@ object ScalaJsHelper {
       case index => Some(index)
     }
 
-    @inline def isBlank: Boolean = string == null || string.trim.isEmpty
-
-    @inline def nonBlank: Boolean = string != null && string.trim.nonEmpty
-
     @inline def isValidEmail: Boolean = string.matches("^[_A-Za-z0-9-\\+]+(\\.[_A-Za-z0-9-]+)*@[A-Za-z0-9-]+(\\.[A-Za-z0-9]+)*(\\.[A-Za-z]{2,})$")
 
     @inline def parseAs[T] = JSON.parse(string).asInstanceOf[T]

examples/package.json

@@ -10,6 +10,8 @@
     "express-ws": "^2.0.0-beta",
     "fs": "0.0.2",
     "html": "0.0.10",
-    "mongoose": "4.4.11"
+    "kafka-node": "^0.3.2",
+    "mongoose": "4.4.11",
+    "node-zookeeper-client": "^0.2.2"
   }
 }

examples/src/main/javascript/nodejs/buffers/Buffers.js

@@ -0,0 +1,33 @@
+/**
+ * Buffers Example
+ * @author [email protected]
+ */
+(function () {
+
+    const buf1 = Buffer.from('ABC');
+    const buf2 = Buffer.from('BCD');
+    const buf3 = Buffer.from('ABCD');
+
+    // Prints: 0
+    console.log(buf1.compare(buf1));
+    // Prints: -1
+    console.log(buf1.compare(buf2));
+    // Prints: 1
+    console.log(buf1.compare(buf3));
+    // Prints: 1
+    console.log(buf2.compare(buf1));
+    // Prints: 1
+    console.log(buf2.compare(buf3));
+
+    // produces sort order [buf1, buf3, buf2]
+    console.log([buf1, buf2, buf3].sort(Buffer.compare));
+
+    // iterate the 3rd buffer
+    const it = buf3.entries();
+    var result = null;
+    do {
+        result = it.next();
+        console.log(result);
+    } while (!result.done);
+
+})();

examples/src/main/javascript/nodejs/zookeeper/TransactionExample.js

@@ -0,0 +1,36 @@
+/**
+ * Transaction Example
+ * @author [email protected]
+ */
+(function() {
+
+    const zookeeper = require("node-zookeeper-client");
+    const client = zookeeper.createClient(process.argv[2] || 'localhost:2181');
+
+    client.once('connected', function () {
+        console.log("Creating '/txn'...");
+        client.transaction().
+        create('/txn').
+        create('/txn/1', new Buffer('transaction')).
+        setData('/txn/1', new Buffer('test'), -1).
+        check('/txn/1').
+        remove('/txn/1', -1).
+        remove('/txn').
+        commit(function (error, results) {
+            if (error) {
+                console.log(
+                    'Failed to execute the transaction: %s, results: %j',
+                    error,
+                    results
+                );
+
+                return;
+            }
+
+            console.log('Transaction completed.');
+            client.close();
+        });
+    });
+
+    client.connect();
+})();

examples/src/main/scala/examples/Examples.scala

@@ -1,13 +1,7 @@
 package examples
 
 import com.github.ldaniels528.meansjs.nodejs._
-import examples.nodejs.events.EventEmitting
-import examples.nodejs.express.ExpressTest
-import examples.nodejs.http.HttpServerTest
-import examples.nodejs.kafka.{ProducerEnhanced, ProducerExample}
-import examples.nodejs.mongodb.MongoClientTest
-import examples.nodejs.net.NetServerTest
-import examples.nodejs.timers.IntermediateTimers
+import examples.nodejs.{buffers, events, express, http, kafka, mongodb, net, timers, zookeeper}
 import org.scalajs.dom.console
 
 import scala.scalajs.js
@@ -19,23 +13,28 @@ import scala.scalajs.js.annotation.JSExportAll
   */
 @JSExportAll
 object Examples extends js.JSApp {
-  private val names = js.Array("events", "express", "http", "mongodb", "net", "timers")
+  private val names = js.Array(
+    "Buffers", "EventEmitting", "ExpressTest", "HttpServerTest", "IntermediateTimers", "MongoClientTest",
+    "NetServerTest", "ProducerExample", "ProducerEnhanced", "TransactionExample"
+  )
 
   override def main(): Unit = ()
 
   def start(require: Require) = {
     process.argv.drop(2) foreach {
-      case "EventEmitting" => new EventEmitting(require)
-      case "express" => new ExpressTest(require)
-      case "http" => new HttpServerTest(require)
-      case "mongodb" => new MongoClientTest(require)
-      case "net" => new NetServerTest(require)
-      case "ProducerExample" => new ProducerExample(require)
-      case "ProducerEnhanced" => new ProducerEnhanced(require)
-      case "timers" => new IntermediateTimers(require)
+      case "Buffers" => new buffers.Buffers(require)
+      case "EventEmitting" => new events.EventEmitting(require)
+      case "ExpressTest" => new express.ExpressTest(require)
+      case "HttpServerTest" => new http.HttpServerTest(require)
+      case "IntermediateTimers" => new timers.IntermediateTimers(require)
+      case "MongoClientTest" => new mongodb.MongoClientTest(require)
+      case "NetServerTest" => new net.NetServerTest(require)
+      case "ProducerExample" => new kafka.ProducerExample(require)
+      case "ProducerEnhanced" => new kafka.ProducerEnhanced(require)
+      case "StateExample" => new zookeeper.StateExample(require)
+      case "TransactionExample" => new zookeeper.TransactionExample(require)
       case arg =>
-        console.warn(s"No example found for $arg - Choose from ${names.mkString(", ")}")
-        new IntermediateTimers(require)
+        console.warn(s"Syntax: examples.js <exampleName> - Choose one: ${names.mkString(", ")}")
     }
   }
 

examples/src/main/scala/examples/nodejs/buffers/Buffers.scala

@@ -0,0 +1,41 @@
+package examples.nodejs.buffers
+
+import com.github.ldaniels528.meansjs.nodejs.JsIterator.IteratorResult
+import com.github.ldaniels528.meansjs.nodejs.Require
+import com.github.ldaniels528.meansjs.nodejs.buffer._
+import org.scalajs.dom.console
+
+import scala.scalajs.js
+
+/**
+  * Buffers Example
+  * @author [email protected]
+  */
+class Buffers(require: Require) {
+
+  val buf1 = Buffer.from("ABC")
+  val buf2 = Buffer.from("BCD")
+  val buf3 = Buffer.from("ABCD")
+
+  // Prints: 0
+  console.log(buf1.compare(buf1))
+  // Prints: -1
+  console.log(buf1.compare(buf2))
+  // Prints: 1
+  console.log(buf1.compare(buf3))
+  // Prints: 1
+  console.log(buf2.compare(buf1))
+  // Prints: 1
+  console.log(buf2.compare(buf3))
+
+  // produces sort order [buf1, buf3, buf2]
+  console.log(js.Array(buf1, buf2, buf3).sort((buf1: Buffer, buf2: Buffer) => Buffer.compare(buf1, buf2)))
+
+  // iterate the 3rd buffer
+  val it = buf3.entries()
+  var result: IteratorResult = _
+  do {
+    result = it.next()
+    console.log(result)
+  } while (!result.done)
+}