CycleJS Snippets

CSRF-HTTPDriver.js

import {makeHTTPDriver} from '@cycle/http';

function makeCustomHTTPDriver( options ) {
  const HTTPDriver = makeHTTPDriver( options );
  const token = document.querySelector('meta[name=csrf-token]').getAttribute('content');

  return function customHTTPDriver( sink$, streamAdapter ) {
    const csrf_request$ = sink$.map(request => ({
      ...request,
      headers: { 'X-CSRF-Token' : token }
    }));

    const source = HTTPDriver( csrf_request$, streamAdapter );

    return source;
  };
}

export default makeCustomHTTPDriver;

logger.js

import xs from 'xstream'

export default function makeLogDriver(prepend = 'DEBUG:') {
  return function logDriver(msg$) {
    msg$.addListener({
      next: function log( msg ) {
        console.log(prepend, msg)
      }
    })
    
    return xs.never()
  }
}

preventDefault.js

import xs from 'xstream'

export default function makePreventDefaultDriver() {
  return function preventDefaultDriver(event$) {
    event$.addListener({
      next: function preventDefault( e ) {
        e.preventDefault();
      }
    })
    
    return xs.never()
  }
}