var http = require('http')
 
var server = new http.Server(function(req, res){
    var body = []
    req.on('data', function(data){
        body.push(data)
    })
    req.on('end', function(){
        res.writeHead(200, {
          'x-any-header': 'x-any-value',
          'content-type': 'text/plain'
        })
        res.end('hello, Cocaine!')
    })
})
 
server.listen(8080)

#!/path/to/node
var cocaine = require('cocaine')
var http = cocaine.http // monkey-patches node's original http server
 
var argv = require('optimist').argv //which is actually a hash
// looking like { opt: 'value'}
 
var worker = new cocaine.Worker(argv)
 
var handle = worker.getListenHandle("http") // the handle implements a
// low-level nodejs' listening tcp socket, and it makes nodejs
// understand cocaine streams.
 
var server = new http.Server(...) // the same thing as above
 
server.listen(handle) // as per [1], start listening on cocaine handle

{ "slave":"app.js" }

 
var cocaine = require("cocaine")
 
var cli = new cocaine.Client(["localhost", 10053])
 
var log = new cli.Logger("myprefix") // logs lines like "myprefix/..."
 
cli.on('error', function(err){
    console.log('client error', err)
})
 
log.on('error', function(err){
    console.log('logger error', err)
})
 
 
log.connect()
 
log.on("connect", function() {
 
    cli.getServices(['geobase'], function(err, geo, ua){
        var names
        
        log.info("looking up regionId for ip 1.2.3.4")
        
        geo.region_id("1.2.3.4", function(err, regionId) {
            if(err) return _handleError(err)
 
            log.debug("found region %d for %s", regionId, "1.2.3.4")
 
            geo.names(regionId, function(err, names){
                if(err) return _handleError(err)
 
                log.debug("names for region %d are %s", regionId, names.join())
 
                geo.coordinates(regionId, function(coords){
                    if(err) return _handleError(err)
 
                    log.debug('coordinates for region %d are %s', regionId, coords.join())
 
                })
            })
        })
    })
})
 
function _handleError(err){
    console.log('service error', err)
}

var cli = new require('cocaine').Client()
 
var storage = cli.Service('storage')
 
storage.on('error', function(err){
    // reconnect on network error
})
 
storage.connect()
 
storage.on('connect', function(){
    storage0.write('collection','key','value', function(err){
        if(err){
            console.log('error writing to storage', err)
            return
        }
        
        console.log(done 'writing to storage')
    })
})

var cli = new require('cocaine').Client()
var app = cli.Service('the_app')
 
app.connect()
 
app.on('connect', function(){
    app.enqueue('handle','anydata', function(err, result){
        if(err) {
           console.log('app error', err)
        } else {
          console.log('app response is', result)
        }
    })
})