Continued development:

1. Renamed "nodejs-mongodb" to "mongodb"
2. Added support for Kafka-Node
3. Moved express into its own sub-project
4. Updated examples
5. Cleanup

Author: ldaniels528

angularjs/src/main/scala/com/github/ldaniels528/meansjs/angularjs/extensions/FileUpload.scala

@@ -1,6 +1,7 @@
 package com.github.ldaniels528.meansjs.angularjs.extensions
 
 import com.github.ldaniels528.meansjs.angularjs.core.HttpPromise
+import com.github.ldaniels528.meansjs.util.ScalaJsHelper._
 import org.scalajs.dom._
 
 import scala.scalajs.js
@@ -35,17 +36,16 @@ trait FileUploadConfig extends js.Object {
   * File Upload Configuration Singleton
   * @author [email protected]
   */
-@js.native
-object FileUploadConfig extends js.Object {
+object FileUploadConfig {
 
-  def apply[T](url: String, file: File, data: Option[T] = None) = {
+  def apply(url: String, file: File, data: js.Any = js.undefined) = {
     require(url != null || url.isEmpty, "Required property 'url' is missing")
     require(file != null, "Required property 'file' is missing")
 
-    val config = new js.Object().asInstanceOf[FileUploadConfig]
+    val config = makeNew[FileUploadConfig]
     config.url = url
     config.file = file
-    data.foreach(config.data = _)
+    config.data = data
     config
   }
 }

build.sbt

@@ -4,7 +4,7 @@ import sbt.Keys._
 import sbt.Project.projectToRef
 import sbt._
 
-val apiVersion = "0.0.5"
+val apiVersion = "0.0.6"
 val paradisePluginVersion = "2.1.0"
 val _scalaVersion = "2.11.8"
 val scalaJsDomVersion = "0.9.0"
@@ -15,7 +15,7 @@ val commonSettings = Seq(
   version := apiVersion,
   scalaVersion := _scalaVersion,
   scalacOptions ++= Seq("-feature", "-deprecation"),
-  homepage := Some(url("http://github.com.ldaniels528/means")),
+  homepage := Some(url("http://github.com.ldaniels528/MEANS.js")),
   addCompilerPlugin("org.scalamacros" % "paradise" % paradisePluginVersion cross CrossVersion.full),
   libraryDependencies ++= Seq(
     "be.doeraene" %%% "scalajs-jquery" % scalaJsJQueryVersion,
@@ -25,14 +25,14 @@ val commonSettings = Seq(
 )
 
 lazy val root = (project in file(".")).
-  aggregate(core, angularjs, facebook, linkedin, nodejs, nodejs_mongodb)
+  aggregate(core, angularjs, express, facebook, kafkanode, linkedin, mongodb, nodejs)
 
 lazy val core = (project in file("core")).
   enablePlugins(ScalaJSPlugin).
   settings(commonSettings: _*).
   settings(
     name := "means",
-    description := "Core utilities for MEANS.js"
+    description := "Core bindings for MEANS.js"
   )
 
 lazy val angularjs = (project in file("angularjs")).
@@ -53,6 +53,15 @@ lazy val facebook = (project in file("facebook")).
     description := "Facebook buildings for Scala.js"
   )
 
+lazy val express = (project in file("express")).
+  enablePlugins(ScalaJSPlugin).
+  dependsOn(core, nodejs).
+  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).
@@ -62,28 +71,37 @@ lazy val linkedin = (project in file("linkedin")).
     description := "LinkedIn buildings for Scala.js"
   )
 
-lazy val nodejs = (project in file("nodejs")).
+lazy val kafkanode = (project in file("kafkanode")).
   enablePlugins(ScalaJSPlugin).
-  dependsOn(core).
+  dependsOn(core, nodejs).
   settings(commonSettings: _*).
   settings(
-    name := "means-nodejs",
-    description := "Node.js bindings for Scala.js"
+    name := "means-kafka-node",
+    description := "Kafka bindings for Scala.js"
   )
 
-lazy val nodejs_mongodb = (project in file("nodejs-mongodb")).
+lazy val mongodb = (project in file("mongodb")).
   enablePlugins(ScalaJSPlugin).
   dependsOn(core, nodejs).
   settings(commonSettings: _*).
   settings(
-    name := "means-nodejs-mongodb",
-    description := "MongoDB bindings for Node.js"
+    name := "means-mongodb",
+    description := "MongoDB bindings for Scala.js"
+  )
+
+lazy val nodejs = (project in file("nodejs")).
+  enablePlugins(ScalaJSPlugin).
+  dependsOn(core).
+  settings(commonSettings: _*).
+  settings(
+    name := "means-nodejs",
+    description := "Node.js bindings for Scala.js"
   )
 
 lazy val examples = (project in file("examples")).
-  aggregate(core, nodejs, nodejs_mongodb).
+  aggregate(core, express, kafkanode, mongodb, nodejs).
   enablePlugins(ScalaJSPlugin).
-  dependsOn(core, nodejs, nodejs_mongodb).
+  dependsOn(core, express, kafkanode, mongodb, nodejs).
   enablePlugins(ScalaJSPlugin).
   settings(commonSettings: _*).
   settings(

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

@@ -120,7 +120,7 @@ object ScalaJsHelper {
   implicit class JsAnyExtensions(val obj: js.Any) extends AnyVal {
 
     def New[T <: js.Any](args: js.Any*): T = {
-      js.Dynamic.newInstance(obj.asInstanceOf[js.Dynamic])(args).asInstanceOf[T]
+      js.Dynamic.newInstance(obj.asInstanceOf[js.Dynamic])(args: _*).asInstanceOf[T]
     }
 
     def ===[T](value: T): Boolean = {

examples/package.json

@@ -0,0 +1,15 @@
+{
+  "name": "skilldepth",
+  "version": "0.0.4",
+  "private": true,
+  "dependencies": {
+    "azure": "^0.10.6",
+    "body-parser": "^1.15.0",
+    "engine.io": "^1.6.8",
+    "express": "4.13.4",
+    "express-ws": "^2.0.0-beta",
+    "fs": "0.0.2",
+    "html": "0.0.10",
+    "mongoose": "4.4.11"
+  }
+}

examples/src/main/javascript/nodejs/events/EventEmitting.js

@@ -1,8 +1,10 @@
+/**
+ * Event Emitting
+ * @author [email protected]
+ */
 (function() {
     const EventEmitter = require("events");
     const ee = new EventEmitter();
-    
-    console.log(Error);
 
     setImmediate(function () {
         // This will crash the process because no "error" event

examples/src/main/javascript/nodejs/kafka/ProducerExample.js

@@ -0,0 +1,31 @@
+/**
+ * Producer Example
+ * @author [email protected]
+ */
+(function () {
+
+    const kafka = require('kafka-node'),
+        Producer = kafka.Producer,
+        client = new kafka.Client('dev528:2181'),
+        producer = new Producer(client);
+
+    const payloads = [
+        {topic: 'test', messages: 'This is the First Message I am sending'/*, partition: 0*/}
+    ];
+
+
+    // producer 'on' ready to send payload to kafka.
+    producer.on('ready', function () {
+        console.log("Received ready:");
+
+        producer.send(payloads, function (err, data) {
+            console.log("Received data:");
+            console.log(data)
+        });
+    });
+
+    producer.on('error', function (err) {
+        console.log("Received error:");
+        console.log(err)
+    });
+});

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

@@ -4,6 +4,7 @@ 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
@@ -24,11 +25,13 @@ object Examples extends js.JSApp {
 
   def start(require: Require) = {
     process.argv.drop(2) foreach {
-      case "events" => new EventEmitting(require)
+      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 arg =>
         console.warn(s"No example found for $arg - Choose from ${names.mkString(", ")}")

examples/src/main/scala/examples/nodejs/events/EventEmitting.scala

@@ -2,25 +2,19 @@ package examples.nodejs.events
 
 import com.github.ldaniels528.meansjs.nodejs._
 import com.github.ldaniels528.meansjs.nodejs.events.EventEmitter
-import com.github.ldaniels528.meansjs.util.ScalaJsHelper._
-import org.scalajs.dom.console
-
-import scala.scalajs.js
 
 /**
-  * Event Emitting
+  * Event Emitting Example
   * @author [email protected]
   */
 class EventEmitting(require: Require) {
-  val eventEmitter = require[js.Function0[EventEmitter]]("events")
-  val ee = eventEmitter.New[EventEmitter]()
-
-  console.log(Error)
+  val eventEmitter = require[EventEmitter]("events")
+  val ee = eventEmitter()
 
   setImmediate(() => {
     // This will crash the process because no "error" event
     // handler has been added.
-    ee.emit("error", Error.New("This will crash"))
+    ee.emit("error", Error("This will crash"))
   })
 
 }

examples/src/main/scala/examples/nodejs/http/HttpServerTest.scala

@@ -6,7 +6,7 @@ import com.github.ldaniels528.meansjs.nodejs.http._
 import scala.scalajs.js
 
 /**
-  * Http Server Test
+  * Http Server Example
   * @author [email protected]
   */
 class HttpServerTest(require: Require) {

examples/src/main/scala/examples/nodejs/kafka/ProducerEnhanced.scala

@@ -0,0 +1,40 @@
+package examples.nodejs.kafka
+
+import com.github.ldaniels528.meansjs.kafkanode.KafkaNode._
+import com.github.ldaniels528.meansjs.kafkanode.{KafkaNode, Payload}
+import com.github.ldaniels528.meansjs.nodejs.Require
+import org.scalajs.dom._
+
+import scala.scalajs.concurrent.JSExecutionContext.Implicits.queue
+import scala.scalajs.js
+
+/**
+  * Producer Scala.js-enhanced Example
+  * @author [email protected]
+  */
+class ProducerEnhanced(require: Require) {
+
+  val kafka = require[KafkaNode]("kafka-node")
+  val client = kafka.Client("dev528:2181")
+  val producer = kafka.Producer(client)
+
+  val payloads = js.Array(Payload(
+    topic = "test", messages = "This is the First Message I am sending", partition = 1
+  ))
+
+  // producer "on" ready to send payload to kafka.
+  producer.onReady(() => {
+    console.log("Received ready:")
+
+    producer.sendAsync(payloads) foreach { data =>
+      console.log("Received data:")
+      console.log(data)
+    }
+  })
+
+  producer.onError((err: KafkaError) => {
+    console.log("Received error:")
+    console.log(err)
+  })
+
+}

examples/src/main/scala/examples/nodejs/kafka/ProducerExample.scala

@@ -0,0 +1,39 @@
+package examples.nodejs.kafka
+
+import com.github.ldaniels528.meansjs.kafkanode.KafkaNode._
+import com.github.ldaniels528.meansjs.kafkanode._
+import com.github.ldaniels528.meansjs.nodejs.Require
+import org.scalajs.dom.console
+
+import scala.scalajs.js
+
+/**
+  * Producer Example
+  * @author [email protected]
+  */
+class ProducerExample(require: Require) {
+
+  val kafka = require[KafkaNode]("kafka-node")
+  val client = kafka.Client("dev528:2181")
+  val producer = kafka.Producer(client)
+
+  val payloads = js.Array(Payload(
+    topic = "test", messages = "This is the First Message I am sending", partition = 1
+  ))
+
+  // producer "on" ready to send payload to kafka.
+  producer.on("ready", () => {
+    console.log("Received ready:")
+
+    producer.send(payloads, (err: KafkaError, data: js.Any) => {
+      console.log("Received data:")
+      console.log(data)
+    })
+  })
+
+  producer.on("error", (err: KafkaError) => {
+    console.log("Received error:")
+    console.log(err)
+  })
+
+}

examples/src/main/scala/examples/nodejs/mongodb/MongoClientTest.scala

@@ -1,8 +1,8 @@
 package examples.nodejs.mongodb
 
+import com.github.ldaniels528.meansjs.mongodb.MongoDB.MongoError
+import com.github.ldaniels528.meansjs.mongodb.{MongoDB, MongoDatabase}
 import com.github.ldaniels528.meansjs.nodejs._
-import com.github.ldaniels528.meansjs.nodejs.mongodb.MongoDB.MongoError
-import com.github.ldaniels528.meansjs.nodejs.mongodb.{MongoDB, MongoDatabase}
 import org.scalajs.dom.console
 
 /**