import { put, take, all, select } from 'redux-saga/effects'

import * as types from '../constants/actionTypes';

import { getLastSync } from './selectors';

import moment from 'moment';

import { endSynchronize, updateLastSync } from '../actions/syncActions';

import SessionSynchronizer from './SessionSyncronizer';

import NoteSynchronizer from './NoteSyncronizer';

function* watchSync(context) {

  while (true) {

    yield take(types.SYNC_DO_SYNC);

    const lastSync = yield select(getLastSync);

    //const sessions = yield context.client.get('/api/notes/sessions/', {modified_since: lastSync});

    const nextLastSync = moment().unix()

    // TODO: manage errors

    try {

      const syncObjects = yield context.client.get('/api/notes/sync/', { modified_since: lastSync });

      const sessionSynchronizer = new SessionSynchronizer(syncObjects.sessions, context.client);

      yield sessionSynchronizer.syncObjects();

      const noteSynchronizer = new NoteSynchronizer(syncObjects.notes, context.client);

      yield noteSynchronizer.syncObjects();

      yield put(updateLastSync(nextLastSync));

    } finally {

      yield put(endSynchronize());

    }

  }

}

//--- The root saga

export default function* rootSaga(context) {

  yield all([

    watchSync(context)

  ]);

}