Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
export default function* configurationSaga() {
// Watches for LOAD_CONFIGURATIONS actions and calls getConfigurations when one comes in.
// By using `takeLatest` only the result of the latest API call is applied.
// It returns task descriptor (just like fork) so we can continue execution
// It will be cancelled automatically on component unmount
yield takeLatest(LOAD_CONFIGURATIONS, getConfigurations);
yield takeLatest(CHANGE_CONFIGURATIONS, patchConfigurations);
}
export default function* notificationSaga() {
// Listeners
yield fork(pushNotificationsListener)
// Notification
yield takeLatest(
notificationActions.notification.DELETE,
lessduxSaga,
{
flow: 'delete',
collection: notificationActions.notifications.self,
find: ({ payload: { ID } }) => n => ID === n.ID
},
notificationActions.notification,
null
)
}
export default function* network() {
yield takeLatest(networkActions.INIT_USER, getUserEthBalance);
yield takeLatest(networkActions.INIT_USER, setR3);
yield takeLatest(networkActions.SET_R3_INSTANCE, getUserStellarBalance);
yield takeLatest(networkActions.SET_R3_INSTANCE, getIssuerStellarBalance);
yield takeLatest(networkActions.INIT_ISSUER, getIssuerEthBalance);
yield takeLatest(networkActions.INIT_ISSUER, setR3);
yield takeLatest(issuerActions.FETCH_ETH_TO_STELLAR, fetchE2SFromStellar);
yield takeLatest(issuerActions.FETCH_STELLAR_TO_ETH, fetchS2EFromEth);
// yield takeLatest(networkActions.INIT_ISSUER, setUp);
}
export default function* defaultSaga() {
yield takeLatest(LOAD_NETWORK, loadNetwork);
// yield takeLatest(LOAD_NETWORK, checkFaucetApi);
yield takeLatest(COMFIRM_SEND_TRANSACTION, confirmSendTransaction);
yield takeLatest(SEND_TRANSACTION, SendTransaction);
yield takeLatest(GET_EXCHANGE_RATES, getRates);
yield takeLatest(CHECK_FAUCET, checkFaucetApi);
yield takeLatest(ASK_FAUCET, askFaucetApi);
/* poll check balances */
yield [
fork(watchPollData),
takeLatest(CHECK_BALANCES, checkAllBalances),
];
/* End of poll check balances */
}
function* watchForLogin() {
yield takeLatest(ActionNames.login.logIn, loginAzure);
}
export default function * hideNode() {
yield takeLatest(actionTypes.CR.Nodes.HIDE, function * performPropertyChange(action) {
const contextPath = action.payload;
markNodeAsHidden(contextPath);
yield put(actions.Changes.persistChanges([{
type: 'Neos.Neos.Ui:Property',
subject: contextPath,
payload: {
propertyName: '_hidden',
value: true
}
}]));
});
yield takeLatest(actionTypes.CR.Nodes.HIDE_MULTIPLE, function * performPropertyChange(action) {
const contextPaths = action.payload;
const changes = [...contextPaths].map(contextPath => {
function* watchQuit() {
yield takeLatest('QUIT', close);
}
export function* userSaga() {
yield takeLatest(loginActions.request, login);
yield takeLatest(reloginAction, relogin);
}
export function* deploymentSaga() {
yield takeLatest(DEPLOY_TO_POOL_REQUEST, handleDeployToPoolRequest)
yield takeLatest(DEPLOY_TO_LAND_REQUEST, handleDeployToLandRequest)
yield takeLatest(CLEAR_DEPLOYMENT_REQUEST, handleClearDeploymentRequest)
yield takeLatest(QUERY_REMOTE_CID, handleQueryRemoteCID)
yield takeLatest(ADD_ITEM, handleMarkDirty)
yield takeLatest(DROP_ITEM, handleMarkDirty)
yield takeLatest(RESET_ITEM, handleMarkDirty)
yield takeLatest(DUPLICATE_ITEM, handleMarkDirty)
yield takeLatest(DELETE_ITEM, handleMarkDirty)
yield takeLatest(SET_GROUND, handleMarkDirty)
yield takeLatest(UPDATE_TRANSFORM, handleMarkDirty)
yield takeLatest(SET_PROJECT, handleMarkDirty)
yield takeLatest(LOAD_DEPLOYMENTS_REQUEST, handleFetchDeploymentsRequest)
yield takeLatest(AUTH_SUCCESS, handleAuthSuccess)
}
export default function* loadAgents() {
yield takeLatest(LOAD_AGENTS, getAgents);
yield takeLatest(LOAD_CONNECTIONS, getConnections);
yield takeLatest(LOAD_CHANNELS, getChannels);
yield takeLatest(EXPORT_AGENT, getAgentExport);
yield takeLatest(IMPORT_AGENT, postAgentImport);
}