var co = require('co');
var monk = require('monk');
var sleep = require('co-sleep');

// Change '../' to 'monkster' to use this code outside of the package
var monkster = require('../');

// Initialize Monk with your MongoDB connection string
var db = monk('localhost/test');

// Initialize Monkster and customize its error handling behavior
monkster({
    // If a query fails more than X times, give up on it
    maxTries: 60,
    // Number of milliseconds to wait before retrying a failed query
    retryInterval: 1000,
    // Optionally log slow queries 
    logSlowQueries: false,
    // Only log slow queries taking longer than the following threshold (in ms)
    logSlowQueryThreshold: 100
});

// Use Monk as you normally would
var users = db.get('users');

// ES6 generator control flow
co(function* () {
    // Run forever
    // Feel free to step down your replica set
    // or cut the network momentarily while this runs
    while (true) {
        try {
            // Insert a document into the collection
            yield users.insert({ name: 'Hello World' });

            // Count number of documents in the collection
            var count = yield users.count({});

            // Print current document count
            console.log('collection.count:', count);

            // Sleep for 1s
            yield sleep(1000);
        }
        catch (err) {
            // Query failed for more than X tries
            console.log('Query Failed', err);
        }
    }
});