client.js

module.exports = function (
	logger,
	inherits,
	EventEmitter,
	net,
	ReadableStream,
	Receiver
) {

	function Client() {
		net.Socket.call(this)

		this.input = this;
		if (!this.input.read) {
			this.input = new ReadableStream()
			this.input.wrap(this)
		}
		
		this.receiver = new Receiver(this.input)

		this.onPing = receiverPing.bind(this)
		this.onZxid = receiverZxid.bind(this)
		this.onWatch = receiverWatch.bind(this)
		this.onReceiverEnd = receiverEnd.bind(this)

		this.receiver.on('ping', this.onPing)
		this.receiver.on('zxid', this.onZxid)
		this.receiver.on('watch', this.onWatch)
		this.receiver.on('end', this.onReceiverEnd)
	}
	inherits(Client, net.Socket)

	Client.prototype.send = function (message) {
		var data = message.toBuffer()
		var head = Buffer(12)
		var extra = 0
		if (message.xid) {
			extra += 4
			head.writeInt32BE(message.xid, 4)
		}
		if (message.type) {
			extra += 4
			head.writeInt32BE(message.type, 8)
		}
		head.writeInt32BE(data.length + extra, 0)
		this.write(head.slice(0, extra + 4))
		this.write(data)
		this.receiver.push(message)
	}

	function receiverPing() {
		//logger.info('ping')
	}

	function receiverZxid(zxid) {
		this.emit('zxid', zxid)
	}

	function receiverWatch(watch) {
		this.emit('watch', watch)
	}

	function receiverEnd() {
		this.emit('receiverEnd')
	}

	return Client
}