feathers-reactive with Angular Universal - rx universal

frxau_rx-universal.ts

import { Observable } from 'rxjs/Observable'

export function rxUniversal(options = {}) {
  const mixin = function (service) {
    const app = this

    const serviceMixin = {
      watch(watchOptions = {}) {
        const methods = {}

        app.methods.forEach(method => {
          if (typeof service[method] === 'function') {
            methods[method] = (...args) => {
              const serviceMethod = service[method].bind(service)
              return Observable.from(serviceMethod(...args))
            }
          }
        })

        return methods
      }
    }

    // get the extended service object
    const newService = service.mixin(serviceMixin)

    // workaround for Firefox
    // FF defines Object.prototype.watch(), so uberproto doesn't recognize the mixin's .watch()
    // see https://github.com/feathersjs-ecosystem/feathers-reactive/issues/67
    if ((Object.prototype as any).watch && (Object.prototype as any).watch === newService.watch) {
      newService.watch = serviceMixin.watch
    }
  }

  return function (app) {
    app.mixins.push(mixin)
  }
}