(Unicode C++) Streaming Encryption

Encrypt and decrypt using a stream.

Chilkat C/C++ Library Downloads
MS Visual C/C++ C++ Builder Linux C/C++ Alpine Linux C/C++	MacOS C/C++ iOS C/C++ Android C/C++ MinGW C/C++

#include <CkCrypt2W.h>
#include <CkStreamW.h>
#include <CkStringArrayW.h>
#include <CkTaskW.h>

void ChilkatSample(void)
    {
    // This example assumes the Chilkat API to have been previously unlocked.
    // See Global Unlock Sample for sample code.

    CkCrypt2W crypt;

    // Setup encryption using the chacha20 algorithm...
    crypt.put_CryptAlgorithm(L"chacha20");
    crypt.put_KeyLength(256);
    crypt.put_EncodingMode(L"hex");
    const wchar_t *ivHex = L"000000000000000000000002";
    crypt.SetEncodedIV(ivHex,L"hex");
    crypt.put_InitialCount(42);
    const wchar_t *keyHex = L"1c9240a5eb55d38af333888604f6b5f0473917c1402b80099dca5cbc207075c0";
    crypt.SetEncodedKey(keyHex,L"hex");

    const wchar_t *plainText = L"The quick brown fox jumped over the lazy dog.\r\n";

    CkStreamW stream;

    // We'll save the encrypted output in eStrings to demonstrate streaming decryption next.
    CkStringArrayW eStrings;

    // Start a background task that will encrypt a stream.
    CkTaskW *task = crypt.EncryptStreamAsync(stream);
    bool success = task->Run();

    // Write plainText to the stream, and read chacha20 encrypted text..
    const wchar_t *cipherText = 0;
    int i;
    for (i = 1; i <= 10; i++) {
        // Note: An encryption algorithm's block size will cause buffering,
        // and therefore not every loop iteration will produce output.
        success = stream.WriteString(plainText);
        if (stream.get_DataAvailable() == true) {
            cipherText = stream.readBytesENC(L"hex");
            wprintf(L"%s\n",cipherText);
            success = eStrings.Append(cipherText);
        }

    }

    // Tell the background task that the stream has ended.
    success = stream.WriteClose();

    // Let's make sure the background task finished.
    // It should already be the case that the task is finished.
    while ((task->get_Finished() != true)) {
        task->SleepMs(20);
    }

    // Get any remaining data available from the stream.
    if (stream.get_DataAvailable() == true) {
        cipherText = stream.readBytesENC(L"hex");
        wprintf(L"%s\n",cipherText);
        success = eStrings.Append(cipherText);
    }

    if (task->get_TaskSuccess() != true) {
        wprintf(L"async encryption failed:\n");
        wprintf(L"%s\n",task->resultErrorText());
        success = false;
    }

    delete task;

    wprintf(L"-- encrypt finished --\n");

    // Now decrypt to return the original.

    // Reset the stream object so it can be used again.
    stream.Reset();

    // Start a background task that will decrypt a stream.
    task = crypt.DecryptStreamAsync(stream);
    success = task->Run();

    int n = eStrings.get_Count();
    for (i = 0; i <= n - 1; i++) {
        success = stream.WriteBytesENC(eStrings.getString(i),L"hex");
        if (stream.get_DataAvailable() == true) {
            plainText = stream.readString();
            wprintf(L"%s\n",plainText);
        }

    }

    // Tell the background task that the stream has ended.
    success = stream.WriteClose();

    // Let's make sure the background task finished.
    // It should already be the case that the task is finished.
    while ((task->get_Finished() != true)) {
        task->SleepMs(20);
    }

    // Get any remaining data available from the stream.
    if (stream.get_DataAvailable() == true) {
        plainText = stream.readString();
        wprintf(L"%s\n",plainText);
    }

    if (task->get_TaskSuccess() != true) {
        wprintf(L"async decryption failed:\n");
        wprintf(L"%s\n",task->resultErrorText());
        success = false;
    }

    delete task;

    wprintf(L"-- decrypt finished --\n");
    }