Comparing version 0.2.0 to 0.3.0
@@ -26,12 +26,7 @@ /* | ||
var helpers = require('./message/helpers'); | ||
var toArrayBuffer = helpers.toArrayBuffer; | ||
var Field = message.Field; | ||
var os = require('os'); | ||
var ByteBuffer = require('bytebuffer'); | ||
var uuid = require('./uuid'); | ||
var compute_oid_uuid = uuid.compute_oid_uuid; | ||
var helpers = require('./message/helpers'); | ||
var dict_to_fields = helpers.dict_to_fields; | ||
@@ -74,3 +69,3 @@ | ||
var HekaClient = function(sender, logger, severity, disabledTimers, filters) | ||
var HekaClient = function(sender, logger, severity, disabledTimers, filters) | ||
{ | ||
@@ -136,4 +131,4 @@ this.setup(sender, logger, severity, disabledTimers, filters); | ||
var msg_encoded = msg.encode(); | ||
var raw_uuid = new Buffer(compute_oid_uuid(msg_encoded.toBuffer()), "hex"); | ||
msg.uuid = ByteBuffer.wrap(toArrayBuffer(raw_uuid)); | ||
msg.uuid = compute_oid_uuid(msg_encoded.toBuffer()); | ||
this._sendMessage(msg); | ||
@@ -140,0 +135,0 @@ }; |
@@ -5,3 +5,3 @@ { | ||
"description": "A node.js client for Mozilla's Heka logging server", | ||
"version": "0.2.0", | ||
"version": "0.3.0", | ||
"homepage": "https://github.com/mozilla-services/heka-node", | ||
@@ -21,2 +21,3 @@ "repository": { | ||
"dependencies": { | ||
"bytebuffer": "1.3.6", | ||
"protobufjs": ">=0.12.8", | ||
@@ -23,0 +24,0 @@ "underscore": ">=1.4.2", |
@@ -5,12 +5,16 @@ [![Build Status](https://secure.travis-ci.org/mozilla-services/heka-node.png)](http://travis-ci.org/mozilla-services/heka-node) | ||
Installing: | ||
To run the test suite use: | ||
Source Install: | ||
$ npm test | ||
git clone git://github.com/mozilla-services/heka-node.git | ||
cd heka-node | ||
make | ||
You should see all tests pass with something that looks like this :: | ||
You should see 33 tests run successfully | ||
> heka@0.2.0 test /Users/victorng/dev/heka-node | ||
> jasmine-node tests | ||
Full documentation is available at http://heka-node.rtfd.org | ||
.......................................... | ||
Finished in 0.713 seconds | ||
42 tests, 247 assertions, 0 failures | ||
@@ -49,3 +49,3 @@ /* | ||
this.hmc = null; | ||
} else { | ||
} else { | ||
this.hmc = hmc; | ||
@@ -55,3 +55,3 @@ } | ||
this.buildHeader = function(msg, msg_length) { | ||
this.buildHeader = function(msg, msg_length) { | ||
@@ -90,4 +90,4 @@ var header = new message.Header(); | ||
*/ | ||
msg_buff = this.encoder.encode(msg); | ||
header = this.buildHeader(msg, msg_buff.length); | ||
var msg_buff = this.encoder.encode(msg); | ||
var header = this.buildHeader(msg, msg_buff.length); | ||
@@ -94,0 +94,0 @@ var header_buff = header.encode().toBuffer(); |
@@ -17,4 +17,6 @@ /* | ||
*/ | ||
var ByteBuffer = require('bytebuffer'); | ||
var Header = require('../message').Header; | ||
var helpers = require('../message/helpers'); | ||
var toArrayBuffer = helpers.toArrayBuffer; | ||
@@ -28,3 +30,3 @@ /* | ||
* in Header.MessageEncoding | ||
* | ||
* | ||
*/ | ||
@@ -60,4 +62,4 @@ | ||
jdata = {} | ||
jdata['uuid'] = new Buffer(msg.uuid).toString('base64'); | ||
var jdata = {} | ||
jdata['uuid'] = new Buffer(msg.uuid, "hex").toString('base64'); | ||
jdata['timestamp'] = msg.timestamp; | ||
@@ -76,3 +78,3 @@ jdata['type'] = msg.type; | ||
var field_dict = {'value_type': f.value_type, 'value_format': 0}; | ||
var field_dict = {'name': f.name, 'value_type': f.value_type, 'value_format': 0}; | ||
if (f.value_string.length !== 0) { | ||
@@ -112,2 +114,4 @@ field_dict['value_string'] = [f.value_string[0]]; | ||
ProtoBufEncoder.prototype.encode = function(msg) { | ||
var raw_uuid = new Buffer(msg.uuid, "hex"); | ||
msg.uuid = ByteBuffer.wrap(toArrayBuffer(raw_uuid)); | ||
return msg.encode().toBuffer() | ||
@@ -114,0 +118,0 @@ } |
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
35322
910
20
1
4
+ Addedbytebuffer@1.3.6
+ Addedbytebuffer@1.3.6(transitive)