var decryptedStream = decryptStream(socket)
decryptedStream.on('data', function(d) {
})
function decryptStream(socket) {
var s = createStream()
Lazy(socket)
.lines
.map(String)
.forEach(function(d) {
// d is one line of data
s.emit('data', decrypt(d))
})
return s
}
On Tue, May 1, 2012 at 12:43 AM, Tim Dickinson <price.ti...@gmail.com> wrote:
> Oh i like that idea. If i did it like you had said then i would maybe pipe
> to a xml praser or pipe even to a logger.
>
>
> On Monday, April 30, 2012 6:36:22 PM UTC-4, Marco Rogers wrote:
>>
>> There are several potential issues I'm seeing here. But it looks like you
>> have an incoming stream of json messages that are encrypted and separated by
>> newlines. You want parse the stream, decrypt each message and then pass the
>> message to a data handler that expect to each message one by one. Is that
>> accurate?
>>
>> This is a great use case for node streams. Read up on them and create a
>> stream (or multiple streams) that encapsulates this behavior. You might end
>> up with a an elegant solution that looks like multiple streams piped
>> together.
>>
>> decryptedStream.on('data', function(data) {
>> // do something with json object
>> });
>> socket.pipe(messageSplitter).pipe(decrytptedStream)
>>
>> Here are some good resources to check out.
>>
>> http://nodejs.org/api/stream.html
>> http://maxogden.com/node-streams
>> https://github.com/dominictarr/event-stream
>>
>> In short, try to separate concerns, splitting the message stream,
>> decrypting, json parsing, etc.
>>
>> :Marco
>>
>>
>> On Monday, April 30, 2012 3:24:37 PM UTC-7, Tim Dickinson wrote:
>>>
>>> Oh sorry and you would use it like so
>>>
>>>
>>> socket.on('data', bufferJson(key, function(data) {
>>> //do something with json object
>>> }))
>>>
>>> On Monday, April 30, 2012 6:23:11 PM UTC-4, Tim Dickinson wrote:
>>>>
>>>> Hey all.
>>>>
>>>> How can i better write this snippet of code?
>>>>
>>>> var bufferJson = function(key, requestEvent) {
>>>> var buffer = []
>>>> var cryptoFn = function(message) {
>>>> var decipher = crypto.createDecipher('aes-256-cbc', key)
>>>> return decipher.update(message, 'hex', 'utf8') +
>>>> decipher['final']('utf8')
>>>> }
>>>> function onData(data) {
>>>> if(data.indexOf('\n') > -1) {
>>>>
>>>> var message = buffer.join('');
>>>> data = data.split('\n');
>>>> message += data.shift();
>>>> buffer = [];
>>>>
>>>> try {
>>>> console.log(cryptoFn(message))
>>>> var json = JSON.parse(cryptoFn(message));
>>>> } catch(e) {
>>>> return util.error('Could not parse message: ' + e.message);
>>>> }
>>>>
>>>> requestEvent(json)
>>>> data = data.join('\n');
>>>>
>>>> if(data.length) {
>>>> onData(data);
>>>> }
>>>>
>>>> } else {
>>>> buffer.push(data);
>>>> }
>>>> }
>>>>
>>>> return onData
>>>> }
>
> --
> Job Board: http://jobs.nodejs.org/
> Posting guidelines:
> https://github.com/joyent/node/wiki/Mailing-List-Posting-Guidelines
> You received this message because you are subscribed to the Google
> Groups "nodejs" group.
> To post to this group, send email to nodejs@googlegroups.com
> To unsubscribe from this group, send email to
> nodejs+unsubscr...@googlegroups.com
> For more options, visit this group at
> http://groups.google.com/group/nodejs?hl=en?hl=en
--
Oliver Leics @ G+
https://plus.google.com/112912441146721682527
--
Job Board: http://jobs.nodejs.org/
Posting guidelines:
https://github.com/joyent/node/wiki/Mailing-List-Posting-Guidelines
You received this message because you are subscribed to the Google
Groups "nodejs" group.
To post to this group, send email to nodejs@googlegroups.com
To unsubscribe from this group, send email to
nodejs+unsubscr...@googlegroups.com
For more options, visit this group at
http://groups.google.com/group/nodejs?hl=en?hl=en
