pg-copy-streams-binary
Advanced tools
Comparing version 1.0.0 to 1.0.1
@@ -13,5 +13,3 @@ /** | ||
var util = require('util') | ||
var bufferEqual = require('buffer-equal'); | ||
var BP = require('bufferput'); | ||
var b = require('binary'); | ||
var parse = require('./pg_types').parse; | ||
@@ -48,3 +46,3 @@ | ||
if (!this._headerReceived && chunk.length >= this.COPYHeaderFull.length) { | ||
if (bufferEqual(this.COPYHeaderFull, chunk.slice(0, this.COPYHeaderFull.length))) { | ||
if (this.COPYHeaderFull.equals(chunk.slice(0, this.COPYHeaderFull.length))) { | ||
this._headerReceived = true; | ||
@@ -51,0 +49,0 @@ offset += this.COPYHeaderFull.length; |
{ | ||
"name": "pg-copy-streams-binary", | ||
"version": "1.0.0", | ||
"version": "1.0.1", | ||
"description": "Streams for parsing and deparsing the COPY binary format", | ||
@@ -19,3 +19,2 @@ "main": "index.js", | ||
"dependencies": { | ||
"buffer-equal": "^1.0.0", | ||
"bufferput": "^0.1.2", | ||
@@ -22,0 +21,0 @@ "flatten": "^1.0.2", |
var assert = require('assert'); | ||
var gonna = require('gonna'); | ||
var bufferEqual = require('buffer-equal'); | ||
@@ -16,3 +15,3 @@ var pgtypes = require('../lib/pg_types'); | ||
var buf = deparse(new BP(), s.t, s.v).buffer(); | ||
var eq = bufferEqual(buf, s.r); | ||
var eq = buf.equals(s.r); | ||
assert(eq, 'Unparse ' + s.t + ' not matching: ' + ((s.v !== null) ? s.v.toString() : 'null') + ' => ' + buf.toString('hex') + ' / ' + s.r.toString('hex')); | ||
@@ -19,0 +18,0 @@ }) |
var assert = require('assert'); | ||
var gonna = require('gonna'); | ||
var bufferEqual = require('buffer-equal'); | ||
@@ -5,0 +4,0 @@ var pgtypes = require('../lib/pg_types'); |
Sorry, the diff of this file is not supported yet
4
40486
747
- Removedbuffer-equal@^1.0.0
- Removedbuffer-equal@1.0.1(transitive)