suzanne.soy/fork-openpgpjs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix armor checksum mismatch error message with allow_unauthenticated_stream

Browse Source
This commit is contained in:
Daniel Huigens 2019-07-19 17:24:28 +02:00
parent 9166d6737c
commit 562783df01
1 changed files with 4 additions and 2 deletions

6
src/packet/packet.js
View File

@ -140,6 +140,7 @@ export default {
read: async function(input, streaming, callback) { read: async function(input, streaming, callback) {
const reader = stream.getReader(input); const reader = stream.getReader(input);
let writer; let writer;
let callbackReturned;
try { try {
const peekedBytes = await reader.peekBytes(2); const peekedBytes = await reader.peekBytes(2);
// some sanity checks // some sanity checks
@ -168,7 +169,6 @@ export default {
const supportsStreaming = this.supportsStreaming(tag); const supportsStreaming = this.supportsStreaming(tag);
let packet = null; let packet = null;
let callbackReturned;
if (streaming && supportsStreaming) { if (streaming && supportsStreaming) {
const transform = new TransformStream(); const transform = new TransformStream();
writer = stream.getWriter(transform.writable); writer = stream.getWriter(transform.writable);
@ -295,7 +295,6 @@ export default {
if (writer) { if (writer) {
await writer.ready; await writer.ready;
await writer.close(); await writer.close();
await callbackReturned;
} else { } else {
packet = util.concatUint8Array(packet); packet = util.concatUint8Array(packet);
await callback({ tag, packet }); await callback({ tag, packet });
@ -309,6 +308,9 @@ export default {
throw e; throw e;
} }
} finally { } finally {
if (writer) {
await callbackReturned;
}
reader.releaseLock(); reader.releaseLock();
} }
} }