import Rx from 'rx';

const boardId = 'LydFpONf';

function trelloSinkDriver ( input$ ) {
  return Rx.Observable.create( ( observer ) => {
    input$.subscribe( () => {
      Trello.get(
        '/boards/' + boardId + '/actions',
        {
          filter: 'createCard,deleteCard,updateCard',
          fields: 'data,date,type'
        },
        observer.onNext.bind( observer ),
        ( err ) => {
          console.log( 'Error when trying to retrieve board actions', err );
        }
      );
    } );
  } );
}

function makeTrelloDriver () {
  Trello.authorize( {
    type: 'popup',
    name: 'Trello Kanban',
    scope: { read: true },
    persist: true,
    expiration: 'never',
    success: () => console.log( 'Connected to Trello.' ),
    error: () => console.log( 'Error on Trello connexion.' )
  } );

  return trelloSinkDriver;
}

export {makeTrelloDriver};

import Rx from 'rx';

const boardId = 'LydFpONf';

function trelloSinkDriver ( input$ ) {
  return Rx.Observable.create( ( observer ) => {
    input$.subscribe( () => {
      Trello.get(
        '/boards/' + boardId + '/actions',
        {
          filter: 'createCard,deleteCard,updateCard',
          fields: 'data,date,type',
          limit: 300
        },
        observer.onNext.bind( observer ),
        ( err ) => {
          console.log( 'Error when trying to retrieve board actions', err );
        }
      );
    } );
  } );
}

function makeTrelloDriver () {
  Trello.authorize( {
    type: 'popup',
    name: 'Trello Kanban',
    scope: { read: true },
    persist: true,
    expiration: 'never',
    success: () => console.log( 'Connected to Trello.' ),
    error: () => console.log( 'Error on Trello connexion.' )
  } );

  return trelloSinkDriver;
}

export {makeTrelloDriver};

Set higher limit than default one (= 50)
Set higher limit than default one (= 50)
