Notification driver for cycle-diversity implemented in coffeescript.

diversity_notification_driver.coffee

notificationDriver = (sink$, runSA)->
  {observer, stream} = runSA.makeSubject()
  
  handler = (event)-> observer.next event

  showNotification = (content)->
    show = ->
      notification = new Notification(content.title, content)
      notification.onclick = notification.onerror = handler

    if not window.Notification?
      observer.error {type: 'unsopported'}
      return

    Notification.requestPermission (p)->
      if p is 'granted'
        do show
      else observer.error {type: 'denied'}
  
  runSA.streamSubscribe(
    sink$,
    {
      next: showNotification
      error: ->
      complete: -> observer.complete()
    }
  )
  
  get = (e_type)-> stream.filter ({type})-> type is e_type
  {get}

module.exports = {notificationDriver}