<!doctype html>
<html>
    <head>
        <meta charset="utf-8">
        <script src="/resources/testharness.js"></script>
        <script src="/resources/testharnessreport.js"></script>
    </head>
    <body>
        <script>

promise_test(async (test) => {
    const pc = new RTCPeerConnection();
    const senderTransform = new SFrameTransform();
    const receiverTransform = new SFrameTransform();
    const sender1 = pc.addTransceiver('audio').sender;
    const sender2 = pc.addTransceiver('video').sender;
    const receiver1 = pc.getReceivers()[0];
    const receiver2 = pc.getReceivers()[1];

    sender1.transform = senderTransform;
    receiver1.transform = receiverTransform;
    assert_throws_dom("InvalidStateError", () => sender2.transform = senderTransform);
    assert_throws_dom("InvalidStateError", () => receiver2.transform = receiverTransform);

    sender1.transform = senderTransform;
    receiver1.transform = receiverTransform;

    sender1.transform = null;
    receiver1.transform = null;
}, "Cannot reuse attached transforms");

test(() => {
    const senderTransform = new SFrameTransform();

    assert_true(senderTransform.readable instanceof ReadableStream);
    assert_true(senderTransform.writable instanceof WritableStream);
}, "SFrameTransform exposes readable and writable");

promise_test(async (test) => {
    const pc = new RTCPeerConnection();
    const senderTransform = new SFrameTransform();
    const receiverTransform = new SFrameTransform();
    const sender1 = pc.addTransceiver('audio').sender;
    const sender2 = pc.addTransceiver('video').sender;
    const receiver1 = pc.getReceivers()[0];
    const receiver2 = pc.getReceivers()[1];

    assert_false(senderTransform.readable.locked, "sender readable before");
    assert_false(senderTransform.writable.locked, "sender writable before");
    assert_false(receiverTransform.readable.locked, "receiver readable before");
    assert_false(receiverTransform.writable.locked, "receiver writable before");

    sender1.transform = senderTransform;
    receiver1.transform = receiverTransform;

    assert_true(senderTransform.readable.locked, "sender readable during");
    assert_true(senderTransform.writable.locked, "sender writable during");
    assert_true(receiverTransform.readable.locked, "receiver readable during");
    assert_true(receiverTransform.writable.locked, "receiver writable during");

    sender1.transform = null;
    receiver1.transform = null;

    assert_true(senderTransform.readable.locked, "sender readable after");
    assert_true(senderTransform.writable.locked, "sender writable after");
    assert_true(receiverTransform.readable.locked, "receiver readable after");
    assert_true(receiverTransform.writable.locked, "receiver writable after");
}, "readable/writable are locked when attached and after being attached");

promise_test(async (test) => {
    const key = await crypto.subtle.importKey("raw", new Uint8Array([143, 77, 43, 10, 72, 19, 37, 67, 236, 219, 24, 93, 26, 165, 91, 178]), "HKDF", false, ["deriveBits", "deriveKey"]);

    const senderTransform = new SFrameTransform({ role : 'encrypt', authenticationSize: 10 });
    senderTransform.setEncryptionKey(key);

    const receiverTransform = new SFrameTransform({ role : 'decrypt', authenticationSize: 10 });
    receiverTransform.setEncryptionKey(key);

    const writer = senderTransform.writable.getWriter();
    const reader = receiverTransform.readable.getReader();

    senderTransform.readable.pipeTo(receiverTransform.writable);

    const sent = new ArrayBuffer(8);
    const view = new Int8Array(sent);
    for (let cptr = 0; cptr < sent.byteLength; ++cptr)
        view[cptr] = cptr;

    writer.write(sent);
    const received = await reader.read();

    assert_equals(received.value.byteLength, 8);
    const view2 = new Int8Array(received.value);
    for (let cptr = 0; cptr < sent.byteLength; ++cptr)
        assert_equals(view2[cptr], view[cptr]);
}, "SFrame with array buffer - authentication size 10");

promise_test(async (test) => {
    const key = await crypto.subtle.importKey("raw", new Uint8Array([143, 77, 43, 10, 72, 19, 37, 67, 236, 219, 24, 93, 26, 165, 91, 178]), "HKDF", false, ["deriveBits", "deriveKey"]);

    const senderTransform = new SFrameTransform({ role : 'encrypt', authenticationSize: 10 });
    const senderWriter = senderTransform.writable.getWriter();
    const senderReader = senderTransform.readable.getReader();

    const receiverTransform = new SFrameTransform({ role : 'decrypt', authenticationSize: 10 });
    const receiverWriter = receiverTransform.writable.getWriter();
    const receiverReader = receiverTransform.readable.getReader();

    senderTransform.setEncryptionKey(key);
    receiverTransform.setEncryptionKey(key);

    const chunk = new ArrayBuffer(8);

    // decryption should fail, leading to an empty array buffer.
    await receiverWriter.write(chunk);
    let received = await receiverReader.read();
    assert_equals(received.value.byteLength, 0);

    // We write again but this time with a chunk we can decrypt.
    await senderWriter.write(chunk);
    const encrypted = await senderReader.read();
    await receiverWriter.write(encrypted.value);
    received = await receiverReader.read();
    assert_equals(received.value.byteLength, 8);
}, "SFrame decryption with array buffer that is too small");

promise_test(async (test) => {
    const key = await crypto.subtle.importKey("raw", new Uint8Array([143, 77, 43, 10, 72, 19, 37, 67, 236, 219, 24, 93, 26, 165, 91, 178]), "HKDF", false, ["deriveBits", "deriveKey"]);

    const receiverTransform = new SFrameTransform({ role : 'decrypt', authenticationSize: 10 });
    const receiverWriter = receiverTransform.writable.getWriter();
    receiverTransform.setEncryptionKey(key);

    // decryption should fail, leading to erroring the transform.
    await promise_rejects_js(test, TypeError, receiverWriter.write({ }));
    await promise_rejects_js(test, TypeError, receiverWriter.closed);
}, "SFrame transform gets errored if trying to process unexpected value types");

        </script>
    </body>
</html>