sending lists of minichunks but it's not great

Author: elsehow

contributing.md

@@ -11,5 +11,6 @@ now you can edit js files in src/ and test/ - tests will automatically re-run
 
 ## TODO 
 
+- [ ] what/why is the limit on size of plaintext? is it my format?
 - [ ] why do i keep getting new remote ephemeral keys?
 - [ ] pad / unpad plaintext / ciphertext?

src/index.js

@@ -1,27 +1,31 @@
 let signal = require('signal-protocol')
 let through = require('through2')
-let l = require('./helpers')
+// let l = require('./helpers')
 // var textsecure = require('signal-protocol/test/temp_helpers')
 const PREKEY_BUNDLE_CODE = 3 //textsecure.protobuf.IncomingPushMessageSignal.Type.PREKEY_BUNDLE
-
 let pushPromise = (p, next) => p.then(x => next(null, x), next)
-let streamF = f => through.obj(function (buf, enc, next) { pushPromise(f(buf), next) })
-let duplexify = require('duplexify')
+let streamF = f => through.obj((buf, enc, next) => pushPromise(f(buf), next))
 
 function encryptor (cipher) {
     return function (plaintext) {
-        return cipher.encrypt(plaintext)
+        return Promise.all([
+            cipher.encrypt(plaintext.slice(0, 200)),
+            cipher.encrypt(plaintext.slice(201, 400)),
+        ])
     }
 }
 
 function decryptor (cipher) {
     // returns a promise of plaintext
-    return function (ciphertext) {
+    function dec (ciphertext) {
         // console.log('ciphertext to decrypt is', ciphertext)
         if (ciphertext.type == PREKEY_BUNDLE_CODE)
             return cipher.decryptPreKeyWhisperMessage(ciphertext.body, 'binary')
         return cipher.decryptWhisperMessage(ciphertext.body, 'binary')
     }
+    return function (ctxts) {
+        return Promise.all(ctxts.map(dec))
+    }
 }
 
 module.exports = function (cipher) {

test/index.js

@@ -49,11 +49,11 @@ function echo ([aliceCipher, bobCipher]) {
     read(__dirname + '/story.txt', 'utf-8')
         .pipe(alice.encrypt)
         .pipe(bob.decrypt)
-        .pipe(bob.encrypt)
-        .pipe(alice.decrypt)
-        .on('data', d => {
+        // .pipe(bob.encrypt)
+        // .pipe(alice.decrypt)
+        .on('data', ds => ds.map(d => {
             let pt = new Buffer.from(d).toString('utf-8')
-            console.log(pt)
-        })
+            console.log('SEE', d, pt)
+        }))
         .on('error', err => console.log('err', err))
 }