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

Avoid using stream.clone over polyfilled steam in test

Browse Source 
Gives issues in Node and Safari < 14.1
This commit is contained in:
larabr 2024-06-18 16:36:31 +02:00
parent 6ace4a00f5
commit 1ce2df1119
1 changed files with 17 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
test/general/streaming.js
View File

@ -654,16 +654,28 @@ function tests() {
}); });
it('Detached sign/verify: support streamed input', async function() { it('Detached sign/verify: support streamed input', async function() {
dataArrived(); const getDataStream = () => (global.ReadableStream ? new global.ReadableStream({
start(controller) {
controller.enqueue(util.stringToUint8Array('hello '));
controller.enqueue(util.stringToUint8Array('world'));
controller.close();
}
}) : new NodeReadableStream({
read() {
this.push(util.stringToUint8Array('hello '));
this.push(util.stringToUint8Array('world'));
this.push(null);
}
}));
const signed = await openpgp.sign({ const signed = await openpgp.sign({
message: await openpgp.createMessage({ binary: stream.clone(data) }), message: await openpgp.createMessage({ binary: getDataStream() }),
signingKeys: privKey, signingKeys: privKey,
config: { minRSABits: 1024 }, config: { minRSABits: 1024 },
detached: true detached: true
}); });
const armoredSignature = await stream.readToEnd(signed); const armoredSignature = await stream.readToEnd(signed);
const message = await openpgp.createMessage({ binary: getDataStream() });
const message = await openpgp.createMessage({ binary: data });
const verified = await openpgp.verify({ const verified = await openpgp.verify({
message, message,
signature: await openpgp.readSignature({ armoredSignature }), signature: await openpgp.readSignature({ armoredSignature }),
@ -671,7 +683,7 @@ function tests() {
format: 'binary', format: 'binary',
config: { minRSABits: 1024 } config: { minRSABits: 1024 }
}); });
expect(await stream.readToEnd(verified.data)).to.deep.equal(util.concatUint8Array(plaintext)); expect(await stream.readToEnd(verified.data)).to.deep.equal(util.stringToUint8Array('hello world'));
expect(verified.signatures).to.exist.and.have.length(1); expect(verified.signatures).to.exist.and.have.length(1);
expect(await verified.signatures[0].verified).to.be.true; expect(await verified.signatures[0].verified).to.be.true;
}); });