From 8755fda1e3ecdeb7a060fe41c195ab0fe37c1193 Mon Sep 17 00:00:00 2001 From: C-3PO Date: Thu, 5 Jul 2018 11:37:23 +0200 Subject: [PATCH] =?UTF-8?q?=F0=9F=90=9B=20Fix=20decrypt=20transform?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/ssn/streams/decryptStream.ts | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/src/ssn/streams/decryptStream.ts b/src/ssn/streams/decryptStream.ts index 26ed865..3e9169d 100644 --- a/src/ssn/streams/decryptStream.ts +++ b/src/ssn/streams/decryptStream.ts @@ -4,8 +4,13 @@ import getDecryptor from '../decryption/decryptChunk'; export default function decryptTransform(decryptionKeys: [number, number, number]): stream.Transform { const decryptor = getDecryptor(decryptionKeys); const transform = new stream.Transform(); + //TODO: we need to set transform._transform = (chunk) => { return chunk; } + transform._transform = (chunk, encoding, callback) => { + const decryptedChunk = decryptor(chunk); + callback(undefined, decryptedChunk); + }; - transform.on('readable', () => { + /*transform.on('readable', () => { const encryptedChunk = transform.read(); if (encryptedChunk === null) { @@ -16,7 +21,7 @@ export default function decryptTransform(decryptionKeys: [number, number, number const decryptedChunk = decryptor(encryptedChunk); transform.write(decryptedChunk); - }); + });*/ return transform; }