CallAgain

This package help you to deal with function that:

• should be called again with same arguments in case of some specific errors;
• should not be called more than N time in some time unit;
• should not be called simultaneously more then N times;

Installing

$ npm install callagain

Basic usage example

// Here is function, it makes direct call to some API
const {loadItemsFromRemoteServer} = requires('./lib');
 
// Import helper
const {CallAgain} = require('callagain');
 
// Create instance
const c = new CallAgain({
    // Concurrency settings
    maxConcurrentCalls: 10, // Extrernal API allows only 10 concurrent calls
 
    // Retry on error settings
    maxRetryAttempts: 5, // Try 5 time before throw error
    delayOnRetry: 5000, // If some call fails, wait 5 sec and try again
    
    // Rate limit settings
    maxCallsPerInterval: 50, // External API allows 50 calls per minute
    intervalLength: 60000 // External API allows 50 calls per minute
});
 
// Use helper's *wrap* method to create safe version of needed function
const safeLoadItems = c.wrap(loadItemsFromRemoteServer);
 
// Now we can simply call our function
for (int page=0; page<100; page++) {
    safeLoadItems(page)
        .then(items => {
    		// ...    
        })
    	.catch(e => console.error(e.message))
}
 

Error handling

You can specify error handlers

const c = new CallAgain({...});
 
// wrapping axios get call
const getItems = c.wrap(url => axios.get);
 
 
c.onError((err, next) => {
    // here err is axios error
    
    // this function must return boolean value
    // indicating should CallAgain retry or not
    
    
    if (err.response.status >= 500) {
            // Unknown server error, retry in *delayOnRetry* milliseconds
            return true
    }  
        
    
    // if you do not know, how to deal with error, you should pass it to next handler
    return next(err)
});
 
//handlers han be chained
c.onError(...).onError(...).onError(...)

Rejecting all

You can reject all pending calls by calling rejectAll method

const c = new CallAgain({...});
 
c.wrap(() => new Promise(resolve => setTimeout(resolve, 1000)))().catch(e => {
    console.log(e) // "Reject reason"
});
 
 
setTimeout(() => {
   c.rejectAll("Reject reason") // optional value to pass to catch handler 
}, 500)