micro-framework for reactive react with actors

command.coffee

# actions handlers are actors running in dedicated web workers
# send_event is their only way to return result

emit = (params...) -> this.postMessage params

handler = (func)->
  this.onmessage = (e)->
    try
      func.apply this, e.data
    finally
      close()

module.exports = {handler, emit}

event.coffee

channel = require 'pubsub-js'
store   = require 'framework/store'

handler = (evt_name, func) ->
  channel.subscribe "event.#{evt_name}", (ignored, params)->
    try
      func.apply store, params
    finally
      store.commit()

module.exports = {handler, store}

reactor.coffee

# Demo

# commands/sign_up.coffee
# action handler
# can use synchronized IO 

{handler, emit} = require 'framework/command'

handler (username, password)->
  emit 'signing_up', username, password

# events/signing_up.coffee
# changes store

{handler, store} = require 'framework/event'

handler 'signing_up', (username, password)->
  console.log 'signing_up', username, password

# sign_in.cjsx
# call @start() to emit actions
# actions runs in other threads

View = require 'framework/view'

module.exports = View
  render: ->
    <button onClick={=> @start 'sign_up', 'bob', 'alice'}/>

view.coffee

React = require 'react'

channel = require 'pubsub-js'
store = require 'framework/store'

emit = require 'commands/emit'

# A React component mixin
react_mixin =
  mixins: [store.mixin]

  start: (cmd_name, params...)->
    worker = require.context('..')("./commands/#{cmd_name}")
    handler = new worker
    handler.onmessage = (e) ->
      evt_name = e.data[0]
      params = e.data[1..-1]
      channel.publish "event.#{evt_name}", params

    handler.postMessage(params)

  emit: (params...)-> # shortcut
    start emit, params

  read: (query, params...)->
    query params

module.exports = (obj)->
  obj.mixins = [react_mixin].add obj.mixins
  React.createClass obj