Cycle.js PouchDB driver (WIP)

cycle-pouchdb.js

import xs from 'xstream'
import XStreamAdapter from '@cycle/xstream-adapter'

export function makePouchDBDriver(PouchDB, dbName, dbOptions) {
  PouchDB.plugin(require('relational-pouch'))

  const db = new PouchDB(dbName, dbOptions)  
  const api = ['put', 'get', 'allDocs' , 'destroy', 'setSchema', 'rel.save', 'rel.find', 'rel.del']

  return (sinks, streamAdapter) =>
    Object.assign({}, 
      ...api
        .filter(m => !m.includes('.'))
        .map(method => ({
          [method]() {
            const data$ = xs.fromPromise(db[method].apply(db, arguments))
            return streamAdapter.adapt(data$, XStreamAdapter.streamSubscribe)
          }
        })),
      ...api
        .filter(m => m.includes('.'))
        .map(objMethod => {
          const [obj, method] = objMethod.split('.')
          return {
            [obj]: {
              [method]() {
                const data$ = xs.fromPromise(db[method].apply(db, arguments))
                return streamAdapter.adapt(data$, XStreamAdapter.streamSubscribe)
              }
            }
          }
        })
    )

}