exceptionfactory / jagged Goto Github PK

    @Test
    void shouldEncrypt66000() throws Exception {
        String content = IntStream.range(0, 66000).boxed()
                .map(i -> "1")
                .collect(Collectors.joining());
        verify(content);
    }

    void verify(final String content) throws Exception {
        byte[] encrypted;
        String decrypted;
        System.out.printf("input content length: %s%n", content.length());
        final KeyPairGenerator keyPairGenerator = new X25519KeyPairGenerator();
        final KeyPair keyPair = keyPairGenerator.generateKeyPair();

        final RecipientStanzaWriter stanzaWriter = X25519RecipientStanzaWriterFactory.newRecipientStanzaWriter(keyPair.getPublic().toString());
        final EncryptingChannelFactory encryptingChannelFactory = new StandardEncryptingChannelFactory();

        try (
                final ByteArrayOutputStream out = new ByteArrayOutputStream();
                final ReadableByteChannel inputChannel =
                        Channels.newChannel(new ByteArrayInputStream(content.getBytes(StandardCharsets.UTF_8)));
                final WritableByteChannel encryptingChannel = encryptingChannelFactory.newEncryptingChannel(
                        Channels.newChannel(new BufferedOutputStream(out)),
                        Collections.singletonList(stanzaWriter))) {
            copy(inputChannel, encryptingChannel);
            out.flush();
            encrypted = out.toByteArray();
        }

        System.out.printf("encrypted length: %s%n", encrypted.length);
        assertThat(encrypted.length)
                .isGreaterThan(content.length());
    }

    // from README:
    void copy(
            final ReadableByteChannel inputChannel,
            final WritableByteChannel outputChannel) throws IOException {
        final ByteBuffer buffer = ByteBuffer.allocate(65536);
        int read = 0;
        int wrote = 0;
        while (inputChannel.read(buffer) > 0) {
            buffer.flip();
            read += buffer.limit();
            //System.out.printf("read: %s ", read);
            while (buffer.hasRemaining()) {
                wrote += outputChannel.write(buffer);
                //System.out.printf("wrote: %s%n", read);
            }
            buffer.clear();
        }
    }