Make sure there is enought initialization vector (iv).

encrypt.js

@@ -81,6 +81,7 @@ export class Encryptor {
   decrypt(buf) {
     if (!this.decipher) {
       const decipher_iv_len = this.get_cipher_len(this.method)[1];
+      if (buf.length < decipher_iv_len) throw new Error('insufficient iv');
       const decipher_iv = buf.subarray(0, decipher_iv_len);
       this.decipher = this.get_cipher(this.key, this.method, 0, decipher_iv);
       return this.decipher.update(buf.subarray(decipher_iv_len));

server.js

@@ -70,6 +70,7 @@ wsserver.on('connection', async (ws) => {
   const readable = conn.pipe(
     createTransform(encryptor.decrypt.bind(encryptor)),
   );
+  readable.on('error', (e) => console.error(`server: ${e}`));
 
   let data = await readable.read();
   while (!data) {

utils.js

@@ -28,7 +28,11 @@ export function memoize(func) {
 export function createTransform(withFn) {
   return new Transform({
     transform(chunk, encoding, callback) {
-      callback(null, withFn(chunk));
+      try {
+        callback(null, withFn(chunk));
+      } catch (err) {
+        callback(err);
+      }
     },
   });
 }