Comparing version 0.4.1-1 to 0.4.1-2
@@ -17,4 +17,5 @@ | ||
var trace = 0 | ||
var debug = require('../util').debug('co:channel') | ||
function notImplemented(){ | ||
@@ -25,3 +26,3 @@ throw new Error('method not implemented') | ||
function Channel(host, port){ | ||
trace && console.log('creating channel') | ||
debug('creating channel') | ||
this.owner = null | ||
@@ -46,3 +47,3 @@ this._socket = null | ||
connect: function(){ | ||
trace && console.log('connecting channel') | ||
debug('connecting channel') | ||
__assert(!this._socket, '!this._socket') | ||
@@ -53,6 +54,6 @@ this._makeSocket() | ||
if(this._socketPath){ | ||
trace && console.log('connecting channel, path:', this._socketPath) | ||
debug('connecting channel, path:', this._socketPath) | ||
this._socket.connect(this._socketPath) | ||
} else if(this._host){ | ||
trace && console.log('connecting channel, [host,port]:', [this._host, this._port]) | ||
debug('connecting channel, [host,port]:', [this._host, this._port]) | ||
this._socket.connect(this._port, this._host) | ||
@@ -153,3 +154,3 @@ } | ||
"typeof sid === 'number' && typeof event === 'string'")){ | ||
trace && console.log('bad RPC.invoke message') | ||
debug('bad RPC.invoke message') | ||
} else { | ||
@@ -165,3 +166,3 @@ this.on_invoke(sid, event) | ||
"typeof sid === 'number', Buffer.isBuffer(buf)")){ | ||
trace && console.log('bad RPC.chunk message') | ||
debug('bad RPC.chunk message') | ||
} else { | ||
@@ -177,3 +178,3 @@ this.on_chunk(sid, buf) | ||
"typeof sid === 'number'")){ | ||
trace && console.log('bad RPC.choke message') | ||
debug('bad RPC.choke message') | ||
} else { | ||
@@ -189,3 +190,3 @@ this.on_choke(sid) | ||
"typeof errno === 'number', typeof message === 'string'")){ | ||
trace && console.log('bad RPC.error message', m) | ||
debug('bad RPC.error message', m) | ||
} else { | ||
@@ -201,3 +202,3 @@ this.on_error(errno, message) | ||
"typeof code === 'number', typeof message === 'string'")){ | ||
trace && console.log('bad RPC.terminate message', m) | ||
debug('bad RPC.terminate message', m) | ||
} else { | ||
@@ -210,3 +211,3 @@ this.on_terminate(code, reason) | ||
default: { | ||
trace && console.log('discarding unknown message type', m) | ||
debug('discarding unknown message type', m) | ||
} | ||
@@ -218,3 +219,3 @@ } | ||
__assert(Buffer.isBuffer(buf), 'Buffer.isBuffer(buf)') | ||
trace && console.log('channel got data', buf) | ||
debug('channel got data', buf) | ||
@@ -230,12 +231,12 @@ if(this._inBuffer){ | ||
if(m === _mpFail){ | ||
trace && console.log('bad message framing') | ||
debug('bad message framing') | ||
this.close() | ||
} | ||
trace && console.log('worker got message', m) | ||
trace && console.log('unpackMessage.bytesParsed', remaining) | ||
debug('worker got message', m) | ||
debug('unpackMessage.bytesParsed', remaining) | ||
var remaining = this._inBuffer.length - unpackMessage.bytesParsed | ||
trace && console.log('remaining', remaining) | ||
debug('remaining', remaining) | ||
@@ -245,3 +246,3 @@ this._hdl.message(m) | ||
if(0 < remaining){ | ||
trace && console.log('remaining buffer', this._inBuffer.slice(unpackMessage.bytesParsed)) | ||
debug('remaining buffer', this._inBuffer.slice(unpackMessage.bytesParsed)) | ||
this._inBuffer = this._inBuffer.slice(this._inBuffer.length - remaining) | ||
@@ -248,0 +249,0 @@ } else { |
@@ -9,4 +9,5 @@ | ||
var trace = 0 | ||
var debug = require('../util').debug('co:mp') | ||
function unpackMessage(buf){ | ||
@@ -24,3 +25,3 @@ if(buf.length === 0){ | ||
trace && console.log('parser got method', method) | ||
debug('parser got method', method) | ||
@@ -39,6 +40,6 @@ if(method === null){ | ||
parsed += parseInt.bytesParsed | ||
trace && console.log('parsed sid,len', sid, parseInt.bytesParsed) | ||
debug('parsed sid,len', sid, parseInt.bytesParsed) | ||
if(!buf[parsed] === 0x91){ | ||
trace && console.log('buf[parsed] === 0x91 '+buf.slice(parsed).toString()) | ||
debug('buf[parsed] === 0x91 '+buf.slice(parsed).toString()) | ||
return fail | ||
@@ -54,6 +55,6 @@ } | ||
} | ||
trace && console.log('before parseBuffer, parsed', parsed) | ||
debug('before parseBuffer, parsed', parsed) | ||
parsed += parseBuffer.bytesParsed | ||
trace && console.log('parseBuffer.bytesParsed', parseBuffer.bytesParsed) | ||
debug('parseBuffer.bytesParsed', parseBuffer.bytesParsed) | ||
unpackMessage.bytesParsed = parsed | ||
@@ -65,4 +66,4 @@ | ||
var m = mp.unpack(buf) | ||
trace && console.log('mp.unpack.bytes_remaining', mp.unpack.bytes_remaining) | ||
trace && console.log('unpacked', m) | ||
debug('mp.unpack.bytes_remaining', mp.unpack.bytes_remaining) | ||
debug('unpacked', m) | ||
if(m === null){ | ||
@@ -217,3 +218,3 @@ return m | ||
default: | ||
trace && console.log('parse int failed: '+hexy.hexy(b.slice(i))) | ||
debug('parse int failed: '+hexy.hexy(b.slice(i))) | ||
return fail | ||
@@ -239,3 +240,3 @@ } | ||
} | ||
trace && console.log('parsed buffer len', len) | ||
debug('parsed buffer len', len) | ||
var val = b.slice(i+1,i+1+len) | ||
@@ -264,3 +265,3 @@ parseBuffer.bytesParsed = 1+len | ||
default: | ||
trace && console.log('parse binary buffer failed: '+hexy.hexy(b.slice(o))) | ||
debug('parse binary buffer failed: '+hexy.hexy(b.slice(o))) | ||
return fail | ||
@@ -267,0 +268,0 @@ } |
@@ -13,4 +13,5 @@ | ||
var trace = 0 | ||
var debug = require('../util').debug('co:base_service') | ||
var BaseService = FSM.define({ | ||
@@ -53,3 +54,3 @@ | ||
connect: function(endpoint){ | ||
trace && console.log('connecting to', endpoint) | ||
debug('connecting to', endpoint) | ||
if(Array.isArray(endpoint)){ | ||
@@ -128,3 +129,3 @@ __assert(typeof endpoint[0] === 'string' && typeof endpoint[1] === 'number', "endpoint is ['host|ip', port]") | ||
var _this = this.owner | ||
trace && console.log('socket error <%s>', _this._name, _ERRNO[errno]) | ||
debug('socket error <%s>', _this._name, _ERRNO[errno]) | ||
var e = makeError(errno) | ||
@@ -146,3 +147,3 @@ _this._closeHandle() | ||
on_choke: function(sid){ | ||
trace && console.log('choke',sid) | ||
debug('choke',sid) | ||
var _this = this.owner | ||
@@ -157,3 +158,3 @@ var s = _this._sessions[sid] | ||
on_error: function(sid, code, message){ | ||
trace && console.log('error',sid, code, message) | ||
debug('error',sid, code, message) | ||
var _this = this.owner | ||
@@ -160,0 +161,0 @@ var s = _this._sessions[sid] |
@@ -25,4 +25,5 @@ | ||
var trace = 0 | ||
var debug = require('../util').debug('co:client') | ||
function normalizeEndpoint(endpoint, defaultEndpoint){ | ||
@@ -96,3 +97,3 @@ if(!endpoint) return defaultEndpoint | ||
function _onConnect(){ | ||
trace && console.log('onConnect') | ||
debug('onConnect') | ||
clients[idx].removeListener('connect', _onConnect) | ||
@@ -108,3 +109,3 @@ clients[idx].removeListener('error', _onError) | ||
function _onError(err0){ | ||
trace && console.log('onError', err) | ||
debug('onError', err) | ||
if(err === null){ | ||
@@ -127,3 +128,3 @@ err = new Array(names.length) | ||
resolve: function(name, cb){ | ||
trace && console.log('>>>> enter resolve') | ||
debug('>>>> enter resolve') | ||
if(this._state === 'closed'){ | ||
@@ -142,11 +143,11 @@ this.connect() | ||
} | ||
trace && console.log('this._requests', this._requests) | ||
debug('this._requests', this._requests) | ||
}, | ||
_resolve: function(name){ | ||
trace && console.log('>>> enter _resolve', new Error('trace:').stack) | ||
debug('>>> enter _resolve', new Error('trace:').stack) | ||
__assert(this._state === 'connected', "this._state === 'connected'") | ||
var _this = this | ||
this._locator.resolve(name, function(err, result){ | ||
trace && console.log('arguments, name, _this._requests', arguments, name, _this._requests) | ||
debug('arguments, name, _this._requests', arguments, name, _this._requests) | ||
var rr = _this._requests[name] | ||
@@ -239,3 +240,3 @@ delete _this._requests[name] | ||
_resetRequests: function(err){ | ||
trace && console.log('resetRequests', arguments) | ||
debug('resetRequests', arguments) | ||
var rr = this._requests | ||
@@ -242,0 +243,0 @@ this._requests = {} |
var trace = 0 | ||
var debug = require('../util').debug('co:logger') | ||
@@ -27,5 +27,2 @@ var __assert = require('assert') | ||
} | ||
if(VL.debug <= level){ | ||
console.log(message) | ||
} | ||
} | ||
@@ -55,3 +52,3 @@ } | ||
this._logging.connect() | ||
trace && console.log('Logger: connecting to service logging') | ||
debug('Logger: connecting to service logging') | ||
this._logging.once('connect', _getVerbosity) | ||
@@ -74,3 +71,3 @@ this._logging.once('error', _handleConnectError) | ||
__assert(_this._state === 'connecting', format("_this._state === 'connecting'; state %s",_this._state)) | ||
trace && console.log('Logger: connected to service logging') | ||
debug('Logger: connected to service logging') | ||
_this._logging.removeListener('error', _handleConnectError) | ||
@@ -96,3 +93,3 @@ _this._logging.on('error', _handleSocketError) | ||
function _handleSocketError(err){ | ||
trace && console.log('handleSocketError') | ||
debug('handleSocketError') | ||
__assert(_this._state === 'connecting' || _this._state === 'connected') | ||
@@ -99,0 +96,0 @@ _this.close() |
@@ -13,4 +13,5 @@ | ||
var trace = 0 | ||
var debug = require('../../util').debug('co:methods:callback') | ||
function Session(id, cb){ | ||
@@ -48,3 +49,3 @@ var _this = this | ||
pushChunk: function(chunk){ | ||
trace && console.log('chunk for', this._id, chunk) | ||
debug('chunk for', this._id, chunk) | ||
__assert(this._chunk === undefined) | ||
@@ -56,3 +57,3 @@ this._chunk = chunk | ||
pushChoke: function(){ | ||
trace && console.log('choke for', this._id) | ||
debug('choke for', this._id) | ||
__assert(!this._done) | ||
@@ -86,3 +87,3 @@ this._done = true | ||
return function(){ | ||
trace && console.log('================ unpackWith, calling method %s', mid) | ||
debug('================ unpackWith, calling method %s', mid) | ||
__assert(this._state === 'connected') | ||
@@ -110,3 +111,3 @@ var args = slice.call(arguments) | ||
return function(){ | ||
trace && console.log('================ unpacking, calling method %s', mid) | ||
debug('================ unpacking, calling method %s', mid) | ||
__assert(this._state === 'connected') | ||
@@ -113,0 +114,0 @@ var args = slice.call(arguments) |
@@ -13,4 +13,5 @@ | ||
var trace = 0 | ||
var debug = require('../../util').debug('co:methods:fibers') | ||
module.exports = function(Fiber){ | ||
@@ -17,0 +18,0 @@ |
@@ -13,4 +13,5 @@ | ||
var trace = 0 | ||
var debug = require('../../util').debug('co:methods:promises') | ||
module.exports = function(Promise) { | ||
@@ -79,3 +80,3 @@ | ||
return function(){ | ||
trace && console.log('================ unpackWith, calling method %s of service %s', mid, this._name) | ||
debug('================ unpackWith, calling method %s of service %s', mid, this._name) | ||
var args = slice.call(arguments) | ||
@@ -97,3 +98,3 @@ var d = Promise.defer() | ||
return function(){ | ||
trace && console.log('================ unpackWith, calling method %s of service %s', mid, this._name) | ||
debug('================ unpackWith, calling method %s of service %s', mid, this._name) | ||
var args = slice.call(arguments) | ||
@@ -100,0 +101,0 @@ var d = Promise.defer() |
@@ -11,4 +11,5 @@ | ||
var trace = 0 | ||
var debug = require('../../util').debug('co:method:streaming') | ||
var Session = require('../../session').Session | ||
@@ -50,3 +51,3 @@ | ||
return function(){ | ||
trace && console.log('================ calling method %s', mid) | ||
debug('================ calling method %s', mid) | ||
__assert(this._state === 'connected') | ||
@@ -53,0 +54,0 @@ var args = slice.call(arguments) |
@@ -23,5 +23,6 @@ | ||
var trace = 0 | ||
var debug = require('../util').debug('co:service') | ||
var slice = Array.prototype.slice | ||
@@ -46,3 +47,3 @@ | ||
function loadServiceDefinition(name, methods){ | ||
trace && console.log('loadServiceDefinition', slice.call(arguments)) | ||
debug('loadServiceDefinition', slice.call(arguments)) | ||
__assert(typeof name === 'string', "typeof name === 'string'") | ||
@@ -52,3 +53,3 @@ var modName = './services/'+name | ||
var def = require(modName) | ||
trace && console.log('loaded service definition', name, def) | ||
debug('loaded service definition', name, def) | ||
if(typeof def === 'function'){ | ||
@@ -61,3 +62,3 @@ return def(methods) | ||
if(e.code === 'MODULE_NOT_FOUND'){ | ||
trace && console.log('module '+modName+' not found') | ||
debug('module '+modName+' not found') | ||
return {defaultMethod: methods.unpacking} | ||
@@ -72,3 +73,3 @@ } else { | ||
trace && console.log('>>> bakeServiceProto:', arguments) | ||
debug('>>> bakeServiceProto:', arguments) | ||
@@ -101,12 +102,12 @@ var endpoint = result[0] | ||
function Service(name, def, methods0){ | ||
trace && console.log('Service', slice.call(arguments)) | ||
debug('Service', slice.call(arguments)) | ||
if(typeof def === 'string'){ | ||
trace && console.log('definition: string', def) | ||
debug('definition: string', def) | ||
def = loadServiceDefinition(def, methods0 || methods) | ||
} else if(typeof def === 'undefined'){ | ||
trace && console.log('definition: undefined') | ||
debug('definition: undefined') | ||
def = loadServiceDefinition(name, methods0 || methods) | ||
} else { | ||
trace && console.log('definition: object', def) | ||
debug('definition: object', def) | ||
__assert(typeof def === 'object', "typeof def === 'object'") | ||
@@ -153,3 +154,3 @@ //def = loadServiceDefinition(name, methods0 || methods) | ||
function _resolve(){ | ||
trace && console.log('_resolve', _this._name, _this._endpoint) | ||
debug('_resolve', _this._name, _this._endpoint) | ||
if(!_this._client && client === undefined){ | ||
@@ -162,4 +163,4 @@ client = new Client() | ||
function _resolveDone(err, result){ | ||
trace && console.log('_resolveDone', arguments) | ||
trace && console.log('svcproto',_this.__svcproto) | ||
debug('_resolveDone', arguments) | ||
debug('svcproto',_this.__svcproto) | ||
if(err) return _handleError(err) | ||
@@ -169,3 +170,3 @@ var p = bakeServiceProto(_this._name, result, | ||
_this.__svcproto || _this.__proto__) | ||
trace && console.log('baked proto', p) | ||
debug('baked proto', p) | ||
_checkIP() | ||
@@ -175,5 +176,5 @@ } | ||
function _checkIP(){ | ||
trace && console.log('_checkIP', _this._endpoint) | ||
debug('_checkIP', _this._endpoint) | ||
if(Array.isArray(_this._endpoint) && !isIP(_this._endpoint[0])){ | ||
trace && console.log('not ip:', _this._endpoint[0]) | ||
debug('not ip:', _this._endpoint[0]) | ||
dns.lookup(_this._endpoint[0], _lookupDone) | ||
@@ -186,3 +187,3 @@ } else { | ||
function _lookupDone(err, address, family){ | ||
trace && console.log('_lookupDone', arguments) | ||
debug('_lookupDone', arguments) | ||
if(err) return _handleError(err) | ||
@@ -194,3 +195,3 @@ _this._endpoint[0] = address | ||
function _handleError(err){ | ||
trace && console.log('_handleError', arguments) | ||
debug('_handleError', arguments) | ||
if(!done){ | ||
@@ -201,3 +202,3 @@ done = true | ||
} else { | ||
trace && console.log('_handleError called after done', arguments) | ||
debug('_handleError called after done', arguments) | ||
} | ||
@@ -207,3 +208,3 @@ } | ||
function _connect(){ | ||
trace && console.log('_connect') | ||
debug('_connect') | ||
if(!done){ | ||
@@ -214,3 +215,3 @@ done = true | ||
} else { | ||
trace && console.log('_connect called after done') | ||
debug('_connect called after done') | ||
} | ||
@@ -217,0 +218,0 @@ } |
@@ -9,3 +9,5 @@ | ||
var trace = 0 | ||
var debug = require('./util').debug('co:fsm') | ||
function define(def){ | ||
@@ -48,3 +50,3 @@ function FSM(){ | ||
return function method(){ | ||
trace && console.log('<state %s>: calling method %s', this._state, name) | ||
debug('<state %s>: calling method %s', this._state, name) | ||
var stateDef = this.__fsmdef[this._state] | ||
@@ -76,3 +78,3 @@ if(trace){ | ||
_setState: function(state){ | ||
trace && console.log('state: %s->%s', this._state, state) | ||
debug('state: %s->%s', this._state, state) | ||
if(this._state === state) return | ||
@@ -84,3 +86,3 @@ var stateDef0 = this.__fsmdef[this._state] | ||
if(!this._handle){ | ||
trace && console.log('this._handle false-ish') | ||
debug('this._handle false-ish') | ||
__assert(!stateDef1.handlers, | ||
@@ -90,7 +92,7 @@ format('<state %s> -> <state %s>: handlers defined for null handle',this._state, state)) | ||
} else { | ||
trace && console.log('this._handle true-ish') | ||
debug('this._handle true-ish') | ||
this._state = state | ||
trace && console.log('unsetting handlers', stateDef0.handlers) | ||
debug('unsetting handlers', stateDef0.handlers) | ||
util.unsetHandlers(this._handle, stateDef0.handlers) | ||
trace && console.log('setting handlers', stateDef1.handlers) | ||
debug('setting handlers', stateDef1.handlers) | ||
util.setHandlers(this._handle, stateDef1.handlers) | ||
@@ -97,0 +99,0 @@ } |
var _ERRNO = require('./errno').code | ||
var debug = require('debug') | ||
module.exports = { | ||
debug: debug, | ||
makeError: function(errno, message){ | ||
@@ -7,0 +9,0 @@ var e = new Error(message || '') |
@@ -14,4 +14,5 @@ | ||
var trace = 0 | ||
var debug = require('../util').debug('co:handles') | ||
function Req(handle,cb){ | ||
@@ -92,4 +93,4 @@ this._handle = handle | ||
} | ||
trace && console.log('baked request: ================================================================') | ||
trace && console.log(requestBuf.toString('ascii')) | ||
debug('baked request: ================================================================') | ||
debug(requestBuf.toString('ascii')) | ||
return requestBuf | ||
@@ -96,0 +97,0 @@ } |
@@ -17,4 +17,5 @@ | ||
var trace = 0 | ||
var debug = require('../util').debug('co:worker') | ||
var Worker = FSM.define({ | ||
@@ -134,3 +135,3 @@ | ||
connect: function(endpoint){ | ||
trace && console.log('connect', arguments) | ||
debug('connect', arguments) | ||
endpoint = endpoint || this._endpoint | ||
@@ -208,3 +209,3 @@ if(Array.isArray(endpoint)){ | ||
var _this = this.owner | ||
trace && console.log('socket error <%s>', _this._name, _ERRNO[errno]) | ||
debug('socket error <%s>', _this._name, _ERRNO[errno]) | ||
_this._closeHandle() | ||
@@ -231,7 +232,7 @@ _this._setState('closed') | ||
on_invoke: function(sid, event){ | ||
trace && console.log('on_invoke sss', sid, event) | ||
debug('on_invoke sss', sid, event) | ||
var _this = this.owner | ||
var lh = _this._listenHandles[event] | ||
if(lh){ | ||
trace && console.log('got listen handle') | ||
debug('got listen handle') | ||
var s = lh.createStreamHandle(sid, event) | ||
@@ -249,3 +250,3 @@ _this._sessions[s._id] = s | ||
on_chunk: function(sid, data){ | ||
trace && console.log('on_chunk', sid, data) | ||
debug('on_chunk', sid, data) | ||
var _this = this.owner | ||
@@ -260,3 +261,3 @@ var s = _this._sessions[sid] | ||
on_choke: function(sid){ | ||
trace && console.log('on_choke', sid) | ||
debug('on_choke', sid) | ||
var _this = this.owner | ||
@@ -272,3 +273,3 @@ var s = _this._sessions[sid] | ||
on_error: function(sid, code, message){ | ||
trace && console.log('on_error', sid, code, message) | ||
debug('on_error', sid, code, message) | ||
var _this = this.owner | ||
@@ -275,0 +276,0 @@ var s = _this._sessions[sid] |
{ | ||
"name": "cocaine", | ||
"version": "0.4.0-alpha0", | ||
"version": "0.4.1-1", | ||
"dependencies": { | ||
@@ -10,5 +10,17 @@ "bindings": { | ||
}, | ||
"debug": { | ||
"version": "1.0.4", | ||
"from": "debug@", | ||
"resolved": "https://registry.npmjs.org/debug/-/debug-1.0.4.tgz", | ||
"dependencies": { | ||
"ms": { | ||
"version": "0.6.2", | ||
"from": "ms@0.6.2", | ||
"resolved": "https://registry.npmjs.org/ms/-/ms-0.6.2.tgz" | ||
} | ||
} | ||
}, | ||
"hexy": { | ||
"version": "0.2.6", | ||
"from": "hexy@", | ||
"from": "https://registry.npmjs.org/hexy/-/hexy-0.2.6.tgz", | ||
"resolved": "https://registry.npmjs.org/hexy/-/hexy-0.2.6.tgz" | ||
@@ -18,3 +30,3 @@ }, | ||
"version": "0.0.7", | ||
"from": "jampack@0.0.7", | ||
"from": "https://registry.npmjs.org/jampack/-/jampack-0.0.7.tgz", | ||
"resolved": "https://registry.npmjs.org/jampack/-/jampack-0.0.7.tgz" | ||
@@ -49,3 +61,3 @@ }, | ||
"version": "1.1.5", | ||
"from": "slide@1.1.5", | ||
"from": "https://registry.npmjs.org/slide/-/slide-1.1.5.tgz", | ||
"resolved": "https://registry.npmjs.org/slide/-/slide-1.1.5.tgz" | ||
@@ -55,3 +67,3 @@ }, | ||
"version": "0.0.2", | ||
"from": "runforcover@0.0.2", | ||
"from": "https://registry.npmjs.org/runforcover/-/runforcover-0.0.2.tgz", | ||
"resolved": "https://registry.npmjs.org/runforcover/-/runforcover-0.0.2.tgz", | ||
@@ -61,3 +73,3 @@ "dependencies": { | ||
"version": "0.1.2", | ||
"from": "bunker@0.1.2", | ||
"from": "https://registry.npmjs.org/bunker/-/bunker-0.1.2.tgz", | ||
"resolved": "https://registry.npmjs.org/bunker/-/bunker-0.1.2.tgz", | ||
@@ -67,3 +79,3 @@ "dependencies": { | ||
"version": "0.2.12", | ||
"from": "burrito@0.2.12", | ||
"from": "https://registry.npmjs.org/burrito/-/burrito-0.2.12.tgz", | ||
"resolved": "https://registry.npmjs.org/burrito/-/burrito-0.2.12.tgz", | ||
@@ -78,3 +90,3 @@ "dependencies": { | ||
"version": "1.1.1", | ||
"from": "uglify-js@1.1.1", | ||
"from": "https://registry.npmjs.org/uglify-js/-/uglify-js-1.1.1.tgz", | ||
"resolved": "https://registry.npmjs.org/uglify-js/-/uglify-js-1.1.1.tgz" | ||
@@ -90,3 +102,3 @@ } | ||
"version": "2.1.2", | ||
"from": "nopt@2.1.2", | ||
"from": "https://registry.npmjs.org/nopt/-/nopt-2.1.2.tgz", | ||
"resolved": "https://registry.npmjs.org/nopt/-/nopt-2.1.2.tgz", | ||
@@ -96,3 +108,3 @@ "dependencies": { | ||
"version": "1.0.4", | ||
"from": "abbrev@1.0.4", | ||
"from": "https://registry.npmjs.org/abbrev/-/abbrev-1.0.4.tgz", | ||
"resolved": "https://registry.npmjs.org/abbrev/-/abbrev-1.0.4.tgz" | ||
@@ -104,3 +116,3 @@ } | ||
"version": "0.3.5", | ||
"from": "mkdirp@0.3.5", | ||
"from": "https://registry.npmjs.org/mkdirp/-/mkdirp-0.3.5.tgz", | ||
"resolved": "https://registry.npmjs.org/mkdirp/-/mkdirp-0.3.5.tgz" | ||
@@ -110,3 +122,3 @@ }, | ||
"version": "0.2.6", | ||
"from": "difflet@0.2.6", | ||
"from": "https://registry.npmjs.org/difflet/-/difflet-0.2.6.tgz", | ||
"resolved": "https://registry.npmjs.org/difflet/-/difflet-0.2.6.tgz", | ||
@@ -121,3 +133,3 @@ "dependencies": { | ||
"version": "0.1.2", | ||
"from": "charm@0.1.2", | ||
"from": "https://registry.npmjs.org/charm/-/charm-0.1.2.tgz", | ||
"resolved": "https://registry.npmjs.org/charm/-/charm-0.1.2.tgz" | ||
@@ -127,3 +139,3 @@ }, | ||
"version": "0.1.2", | ||
"from": "deep-is@0.1.2", | ||
"from": "https://registry.npmjs.org/deep-is/-/deep-is-0.1.2.tgz", | ||
"resolved": "https://registry.npmjs.org/deep-is/-/deep-is-0.1.2.tgz" | ||
@@ -135,3 +147,3 @@ } | ||
"version": "0.0.0", | ||
"from": "deep-equal@0.0.0", | ||
"from": "https://registry.npmjs.org/deep-equal/-/deep-equal-0.0.0.tgz", | ||
"resolved": "https://registry.npmjs.org/deep-equal/-/deep-equal-0.0.0.tgz" | ||
@@ -141,3 +153,3 @@ }, | ||
"version": "0.0.0", | ||
"from": "buffer-equal@0.0.0", | ||
"from": "https://registry.npmjs.org/buffer-equal/-/buffer-equal-0.0.0.tgz", | ||
"resolved": "https://registry.npmjs.org/buffer-equal/-/buffer-equal-0.0.0.tgz" | ||
@@ -152,3 +164,3 @@ }, | ||
"version": "0.2.12", | ||
"from": "minimatch@0.2.12", | ||
"from": "https://registry.npmjs.org/minimatch/-/minimatch-0.2.12.tgz", | ||
"resolved": "https://registry.npmjs.org/minimatch/-/minimatch-0.2.12.tgz", | ||
@@ -158,3 +170,3 @@ "dependencies": { | ||
"version": "2.3.1", | ||
"from": "lru-cache@2.3.1", | ||
"from": "https://registry.npmjs.org/lru-cache/-/lru-cache-2.3.1.tgz", | ||
"resolved": "https://registry.npmjs.org/lru-cache/-/lru-cache-2.3.1.tgz" | ||
@@ -164,3 +176,3 @@ }, | ||
"version": "1.0.0", | ||
"from": "sigmund@1.0.0", | ||
"from": "https://registry.npmjs.org/sigmund/-/sigmund-1.0.0.tgz", | ||
"resolved": "https://registry.npmjs.org/sigmund/-/sigmund-1.0.0.tgz" | ||
@@ -172,3 +184,3 @@ } | ||
"version": "2.0.1", | ||
"from": "inherits@2.0.1", | ||
"from": "https://registry.npmjs.org/inherits/-/inherits-2.0.1.tgz", | ||
"resolved": "https://registry.npmjs.org/inherits/-/inherits-2.0.1.tgz" | ||
@@ -217,3 +229,3 @@ } | ||
"version": "0.0.2", | ||
"from": "wordwrap@0.0.2", | ||
"from": "https://registry.npmjs.org/wordwrap/-/wordwrap-0.0.2.tgz", | ||
"resolved": "https://registry.npmjs.org/wordwrap/-/wordwrap-0.0.2.tgz" | ||
@@ -220,0 +232,0 @@ } |
{ | ||
"name": "cocaine", | ||
"version": "0.4.1-1", | ||
"version": "0.4.1-2", | ||
"description": "Node.js framework for Cocaine platform", | ||
@@ -17,2 +17,3 @@ "author": "Cocaine Project <cocaine@yandex-team.ru>", | ||
"bindings": "~1.0.0", | ||
"debug": "^1.0.4", | ||
"hexy": "^0.2.6", | ||
@@ -19,0 +20,0 @@ "jampack": "0.0.7", |
var hostname = require('os').hostname() | ||
var format = require('util').format | ||
var cli = new (require('../lib/client/client').Client)(['localhost', 10053]) | ||
var cli = new (require('../lib/client/client').Client)(['apefront.tst.ape.yandex.net', 10053]) | ||
@@ -6,0 +6,0 @@ |
113439
40
3220
7
+ Addeddebug@^1.0.4
+ Addeddebug@1.0.5(transitive)
+ Addedms@2.0.0(transitive)