rewrite in livescript

Author: kryptt

.npmignore

@@ -1 +1,3 @@
-/dist
+/src
+/spec
+/gulpfile.ls

dist/maps/resolver.js.map

@@ -0,0 +1,11 @@
+gulp       = require 'gulp'
+gutil      = require 'gulp-util'
+livescript = require 'gulp-livescript'
+sourcemaps = require 'gulp-sourcemaps'
+
+gulp.task 'default', ->
+  gulp.src './src/*.ls'
+  .pipe sourcemaps.init()
+  .pipe livescript bare: true .on('error', gutil.log)
+  .pipe sourcemaps.write('./maps')
+  .pipe gulp.dest('./dist')

dist/react-bacon.js

@@ -1,31 +1,40 @@
 {
   "name": "react-bacon",
-  "version": "0.0.4",
-  "description": "A little module for using React with Bacon.js",
-  "main": "src/react-bacon.js",
+  "version": "0.1.0",
+  "description": "Incorporate BaconJS into the ReactJS render cycle",
+  "main": "dist/index.js",
+  "author": "Rodolfo Hansen",
+  "homepage": "https://github.com/kryptt/react-bacon",
+  "license": "MIT",
+  "keywords": [
+    "async",
+    "react",
+    "bacon",
+    "reactive",
+    "streams",
+    "isomorphic"
+  ],
   "repository": {
     "type": "git",
-    "url": "https://github.com/jamesmacaulay/react-bacon"
+    "url": "https://github.com/kryptt/react-bacon"
   },
-  "author": "James MacAulay",
-  "license": "MIT",
   "bugs": {
-    "url": "https://github.com/jamesmacaulay/react-bacon/issues"
+    "url": "https://github.com/kryptt/react-bacon/issues"
+  },
+  "scripts": {
+    "build": "gulp"
   },
-  "homepage": "https://github.com/jamesmacaulay/react-bacon",
   "devDependencies": {
-    "react": "~0.10.0",
-    "grunt": "~0.4.4",
-    "grunt-contrib-jasmine": "~0.6.3",
-    "browserify": "~3.44.2",
-    "grunt-browserify": "~2.0.8",
-    "reactify": "~0.13.1",
-    "browserify-shim": "~3.4.1"
+    "gulp": "^3.9.0",
+    "gulp-livescript": "^2.4.0",
+    "gulp-sourcemaps": "^1.5.2",
+    "gulp-util": "^3.0.6",
+    "livescript": "^1.4.0"
   },
   "dependencies": {
-    "baconjs": "~0.7.10"
+    "baconjs": "^0.7.70"
   },
-  "browserify-shim": {
-    "baconjs": "global:Bacon"
+  "peerDependencies": {
+    "react": "~0.13"
   }
 }

dist/resolver.js

@@ -0,0 +1,8 @@
+mixin    = require './mixin'
+resolver = require './resolver'
+
+module.exports =
+  BaconMixin    : mixin
+  BaconResolver : resolver
+  Mixin         : mixin
+  Resolver      : resolver

gruntfile.js

@@ -0,0 +1,51 @@
+Bacon = require 'baconjs'
+
+ensure-unsub = ->
+  it._bacon ?= {}
+  it._bacon.unsub ?= []
+ensure-buses = ->
+  it._bacon ?= {}
+  it._bacon.buses ?= {}
+ensure-props = ->
+  ensure-buses it .props ?= new Bacon.Bus!
+ensure-state = ->
+  ensure-buses it .state ?= new Bacon.Bus!
+
+event-obj = -> "#{it.target.name}": it.target.value
+event-bus = (it, name, generator) ->
+  bus = ensure-buses it .["event_#name"] ?= new Bacon.Bus!
+  if it[name] then throw "Cannot re-implement the event-bus end-point"
+  it[name] = generator(bus)
+  bus
+
+module.exports =
+  # offer a bacon event stream for the component's properties.
+  stream-props  : (pn) -> if pn? then ensure-props @ else ensure-props @ .map -> it[pn]
+  # offer a bacon event stream for the component's state.
+  stream-state  : (sn) -> if sn? then ensure-state @ else ensure-state @ .map -> it[sn]
+  # register a callback hook and offer a stream on the other end of it.
+  event-stream  : (en) -> event-bus @, en, (bus) -> !-> bus.push it
+  # similar to event-stream except we push it.target.value through the stream.
+  value-stream  : (en) -> event-bus @, en, (bus) -> !-> bus.push it.target.value
+  # similar to event-stream except we push {it.target.name : it.target.value} through.
+  input-stream  : (en) -> event-bus @, en, (bus) -> !-> bus.push (it |> event-obj)
+  # links the unsub function to the component's lifecycle.
+  # unsub will be run in component-will-unmount.
+  subscribe-to  : (unsub) -> ensure-unsub @ .push unsub; unsub
+  # plugs a stream into the components state.
+  # either under a specific key, or overriding the entire state object.
+  plug          : (stream, key) -> @subscribe-to stream.on-value do
+    if key? then !~> @set-state "#key": it else !~> @set-state it
+  # push values to the props and state streams if they exist.
+  component-did-update : !->
+    if @_bacon?buses?
+      @_bacon.buses.props?push @props
+      @_bacon.buses.state?push @state
+  # cleanup whenever the component unmounts.
+  component-will-unmount : !->
+    if @_bacon?
+      if @_bacon.buses?
+        for b of @_bacon.buses
+          @_bacon.buses[b].end!
+      @_bacon.unsub?for-each !-> it!
+      @_bacon = {}