cycle-fire

cycle-fire

A Firebase driver for Cycle.js.

Example

import firebaseConfig from './firebaseConfig'
import { button, div, h2 } from '@cycle/dom'
import { firebaseActions, makeFirebaseDriver } from 'cycle-fire'
import { run } from '@cycle/run'

function main (sources) {
  const action$ = sources.DOM.select('.shuffle').events('click')
    .map(() => Math.ceil(Math.random() * 99))
    .map(firebaseActions.database.ref('test').set)

  const vdom$ = sources.firebase.database.ref('test').value
    .map(value =>
      div([
        h2(value),
        button('.shuffle', 'Shuffle')
      ])
    )

  return {
    DOM: vdom$,
    firebase: action$
  }
}

run(main, {
  DOM: makeDOMDriver('Application'),
  firebase: makeFirebaseDriver(firebaseConfig)
})

API

firebaseActions

Write effects to the connected Firebase database are requested by calling an action generator—a function defined on the firebaseActions object—and passed to the firebase sink.

• firebaseActions: object containing:
  • auth: object containing:
    • applyActionCode(code: string) – triggers Auth.applyActionCode
    • checkActionCode(code: string) – triggers Auth.checkActionCode
    • confirmPasswordReset(code: string, newPassword: string) – triggers Auth.confirmPasswordReset
    • createUserWithEmailAndPassword(email: string, password: string) – triggers Auth.createUserWithEmailAndPassword
    • sendPasswordResetEmail(email: string) – triggers Auth.sendPasswordResetEmail
    • signInAndRetrieveDataWithCredential(credential: AuthCredential) – triggers Auth.signInAndRetrieveDataUsingCredential
    • signInAnonymously() – triggers Auth.signInAnonymously
    • signInWithCredential(credential: AuthCredential) – triggers Auth.signInWithCredential
    • signInWithCustomToken(token: string) – triggers Auth.signInWithCustomToken
    • signInWithEmailAndPassword(email: string, password: string) – triggers Auth.signInWithEmailAndPassword
    • signInWithPhoneNumber(phoneNumber: string, verifier: ApplicationVerifier) – triggers Auth.signInWithPhoneNumber
    • signInWithPopup(provider: AuthProvider) – triggers Auth.signInWithPopup
    • signInWithRedirect(provider: AuthProvider) – triggers Auth.signInWithRedirect
    • signOut() – triggers Auth.signOut
    • verifyPasswordResetCode(code: string) – triggers Auth.verifyPasswordResetCode
  • database: object containing:
    • goOffline() – triggers Database.goOffline
    • goOnline() – triggers Database.goOnline
    • ref(path: string) => object containing:
      • push(value: any) – triggers Reference.push
      • remove() – triggers Reference.remove
      • set(value: any) – triggers Reference.set
      • setPriority(priority: (null|number|string)) – triggers Reference.setPriority
      • setWithPriority(value: any, priority: (null|number|string)) – triggers Reference.setWithPriority
      • transaction(updateFn: (value: any) => any) – triggers Reference.transaction
      • update(values: any) – triggers Reference.update

<action>.as(name: string)

Effectively attaches a name to the action's response stream, allowing for lookup using the source's responses().

import { firebaseActions } from 'cycle-fire'
import xs from 'xstream'

function Cycle (sources) {
  const setAction = firebaseActions.database.ref('test')
    .set('newValue')
    .as('setTestValue')

  sources.firebase.responses('setTestValue').addListener({
    error: err => { console.error(err) },
    next: response => { console.log(response) }
  })

  return {
    firebase: xs.of(setAction)
  }
}

makeFirebaseDriver(config, name?)

• config: object
  • apiKey: string
  • authDomain: string
  • databaseURL: string
  • messagingSenderId: string
  • projectId: string
  • storageBucket: string
• name?: string

Initializes a connection to a Firebase database by calling firebase.initializeApp(), returning a source object containing the following:

• auth: object containing:
  • authState: MemoryStream emitting values from Auth.onAuthStateChanged
  • currentUser: MemoryStream emitting changed values of Auth.currentUser when triggered by Auth.onIdTokenChanged
  • idToken: MemoryStream emitting values from Auth.onIdTokenChanged
  • providersForEmail(email: string): MemoryStream emitting values from Auth.fetchProvidersForEmail
  • redirectResult: MemoryStream emitting values from Auth.getRedirectResult
• database: object containing:
  • ref(path: string): ReferenceSource containing:
    • child(path: string): ReferenceSource
    • events(eventType: string): MemoryStream of the ref's eventType events, using Reference.on
    • value: MemoryStream – a shortcut stream equivalent to events('value')
  • refFromURL(url: string): ReferenceSource
• responses(name: string): Stream of responses from action requests that were named using <action>.as().