var Roach = require('roachjs')

var client = new Roach({
    uri: 'http://127.0.0.1:8080'
})

module.exports = client

client.get("sample_key", function(err, value, res) {
    if(err) throw err

    client.put("other_key", value, function(err, res) {
        if(err) {
            // Failed
        }
        else {
            // Sucess
        }
    })
})

// You should prepare your queries and send them in a single batch
// For optimal performance
var c = client.prepare()

// This callback will be the first to be executed
c.get("sample_key", function(err, value, res) {
    if(err) throw err

    // Do something...
})

c.get("sample_key2", function(err, value, res) {
    if(err) throw err

    // Do something...
})

c.put("some_key", "some_value", function(err) {
    if(err) throw err

    // Do something
})

// The flush callback is the last one to be called
c.flush(function(err, res) {
    if(err) throw err

    console.log('Sucessfuly flushed %d queries.', res.responses.length)
})

var opts = {
    name: "transaction example",
}

var errNoApples = new Error('Insufficient apples!')

var transaction = function(txn, commit, abort) {
    txn.get("applesInStock", function(err, value, res) {
        if(err || applesInStock.err) {
                return abort(err)
            }

            var dispatch = 5
            var inStock = parseInt(applesInStock.value)

            if(inStock < dispatch) {
                return abort(errNoApples)
        }

        // Upgrade for a prepared client
        txn = txn.prepare()

        txn.increment("applesInStock", -dispatch)
        txn.increment("applesInRoute", +dispatch)

        // Commit automatically flushes
        commit()
    })
}

client.runTransaction(opts, transaction, function(err, res) {
    if(err === errNoApples) {
        // Alert user there are no more apples...
    }
    else if(err) {
        // Transaction failed...
    }
    else {
        // Transaction commited...
    }
})

client.get("key", function(err, value, res) {})

client.put("key", "value", function(err, res) {})

client.conditionalPut("status", "running", "stopped", function(err, actualValue, res) {})
client.conditionalPut("status", "new", null, function(err, actualValue, res) {})

client.contains("john", function(err, exists, res) {
    if(exists === true) {
        // john exists in the datastore
    }
})

client.increment("counter", 5, function(err, newValue, res) {
    console.log('counter current value is', newValue)
})

client.scan("a", "Z", 100, function(err, rows, res) {
    for(row as rows) {
        console.log(row)
    }
})

client.delete("key", function(err, res) {})

client.deleteRange("a", "Z", 100, function(err, deleted, res) {
    console.log('deleted %d entries', deleted)
})

var c = client.prepare()

c.get("key", function(err, value, res) {
    // Do something...
})

c.get("key2", function(err, value, res) {
    // Do something...
})

c.put("key3", "value", function(err, res) {
    // Do something...
})

c.flush()

client.flush(function(err, res) {
    if(err) {
        // Flush failed..
    }
    else {
        console.log('flushed %d queries.', res.responses.length)
    }
})

var transaction = function(txn, commit, abort) {
    txn = txn.prepare()

    for(var i = 0; i < 100; i++) {
        var key = i.toString()

        txn.put(key, "hello")
    }

    // Commit automatically flushes
    // the prepared transaction.
    commit()
}