Comparing version 0.0.11 to 0.0.12
@@ -146,8 +146,7 @@ var stream = require('stream') | ||
Facebook.prototype.pipeSubscription = function(){ | ||
var _this = this; | ||
var fb = this; | ||
return function(req, res, next){ | ||
console.log(req.get('X-Hub-Signature')); | ||
console.log(req.body); | ||
_this.write(req.body); | ||
//req.pipe( _this); | ||
fb.write(req.body); | ||
next(); | ||
@@ -175,11 +174,28 @@ }; | ||
console.log('_transforming'); | ||
var expected = 0; | ||
for( var i in chunk.entry){ | ||
for( var i in chunk.entry){ | ||
console.log(chunk.entry[i].changes); | ||
//console.log(chunk.entry[i].changes); | ||
for( var j in chunk.entry[i].changes){ | ||
//console.log(chunk.entry[i].changes[j]); | ||
expected++; | ||
this._graphRequest( chunk.entry[i].changes[j].value.post_id, 'GET', { | ||
}, function(res){ | ||
expected--; | ||
this.push(chunk); | ||
if( !expected){ | ||
done(); | ||
} | ||
}) | ||
} | ||
} | ||
this.push(chunk); | ||
done(); | ||
}; | ||
@@ -186,0 +202,0 @@ |
{ | ||
"name": "socializr", | ||
"version": "0.0.11", | ||
"version": "0.0.12", | ||
"description": "Read data streams from several social networks.", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
27516
1123