client/src/sagas/SessionSyncronizer.js
author ymh <ymh.work@gmail.com>
Fri, 28 Jul 2017 19:40:35 +0200
changeset 129 d48946d164c6
child 132 906a6c7c7943
permissions -rw-r--r--
Add a first version of synchronisation Remove redux-offline dependency make the redux state fully immutable TODO: better error management TODO: make syncronization work automatically

import { select } from 'redux-saga/effects'
import { getCreatedSessions, getUpdatedSessions, getDeletedSessions } from './selectors';
import { ActionEnum } from '../constants';
import moment from 'moment';
import SessionRecord from '../store/sessionRecord';
import { doDeleteSession, loadSession, resetActionSession } from '../actions/sessionsActions';
import Immutable from 'immutable';
import SyncMixin from './BaseSyncronizer';

class SessionSyncBase {

  // local diffs (immutable)
  * getLocalDiffs() {
    return Immutable.Map({
      created: yield select(getCreatedSessions),
      updated: yield select(getUpdatedSessions),
      deleted: yield select(getDeletedSessions)
    })
  }

  // remote urls
  getRemoteLoadUrl() {
    return "/api/notes/sessions/";
  }

  getRemoteDeleteUrl(localObjInst) {
    return `/api/notes/sessions/${localObjInst.get('_id')}/`;
  }

  getRemoteCreateUrl(localObjInst) {
    return "/api/notes/sessions/";
  }

  getRemoteUpdateUrl(localObjInst) {
    return `/api/notes/sessions/${localObjInst.get('_id')}/`;
  }

  // build remote json message
  getRemoteData(localObjInst) {
    return {
      ext_id: localObjInst.get('_id'),
      date: localObjInst.get('date'),
      title: localObjInst.get('title'),
      description: localObjInst.get('description'),
      protocol: ''
    };
  }

  getLocalRecord(remoteObj) {
    return new SessionRecord({
        _id: remoteObj.ext_id,
        title: remoteObj.title,
        description: remoteObj.description,
        date: moment(remoteObj.date).toDate(),
        action: ActionEnum.NONE,
        group: null
    });
  }

  // actions
  doDeleteLocalObj(localObjId) {
    return doDeleteSession(localObjId);
  }

  resetLocalObj(localObjInst) {
    return resetActionSession(localObjInst);
  }

  loadObj(objRecord) {
    return loadSession(objRecord);
  }

}

export class SessionSynchronizer extends SyncMixin(SessionSyncBase) {}

export default SessionSynchronizer;