concordia/app/src/redux/sagas/orbitSaga.js

import {all, call, put, take, takeLatest} from 'redux-saga/effects'
import { contract, getCurrentAccount} from './drizzleUtilsSaga';
import { loadDatabases } from '../../utils/orbitUtils'
import { DRIZZLE_UTILS_SAGA_INITIALIZED } from '../actions/drizzleUtilsActions';
import { IPFS_INITIALIZED, DATABASES_NOT_READY } from '../actions/orbitActions';

let latestAccount;

function* getOrbitDBInfo() {
    yield put({type: 'ORRBIT_GETTING_INFO', ...[]});
    const account = yield call(getCurrentAccount);
    if(account!==latestAccount) {
        const txObj1 = yield call(contract.methods["hasUserSignedUp"], ...[account]);
        try {
            const callResult = yield call(txObj1.call, {address:account});
            if(callResult) {
                // console.log("Deleting local storage..");
                // localStorage.clear();
                const txObj2 = yield call(contract.methods["getOrbitIdentityInfo"], ...[account]);
                const orbitIdentityInfo = yield call(txObj2.call, {address: account});
                const txObj3 = yield call(contract.methods["getOrbitDBInfo"], ...[account]);
                const orbitDBInfo = yield call(txObj3.call, {address: account});
                yield call(loadDatabases, orbitIdentityInfo[0], orbitIdentityInfo[1], orbitIdentityInfo[2],
                    orbitDBInfo[0], orbitDBInfo[1], orbitDBInfo[2], orbitDBInfo[3], orbitDBInfo[4]);
            }
            else
                yield put({type: DATABASES_NOT_READY, ...[]});

            latestAccount=account;
        }
        catch (error) {
            console.error(error);
            yield put({type: 'ORBIT_SAGA_ERROR', ...[]});
        }
    }
}

function* orbitSaga() {
    yield all([
        take(DRIZZLE_UTILS_SAGA_INITIALIZED),
        take(IPFS_INITIALIZED)
    ]);
    yield takeLatest("ACCOUNT_CHANGED", getOrbitDBInfo);
}

export default orbitSaga;