BrotliEncoder.cs

using System;
using System.IO;
using System.IO.Compression;
using System.Threading.Tasks;
using Waher.Content;
 
namespace Waher.Networking.HTTP.Brotli
{
    public class BrotliEncoder : TransferEncoding
    {
        private readonly string? compressedFileName;
        private TransferEncoding? uncompressedStream;
        private MemoryStream? ms = null;
        private BrotliStream? brEncoder = null;
        private BrotliStream? brDecoder = null;
        private long? bytesLeft;
        private int pos = 0;
        private bool dataWritten = false;
        private bool finished = false;
 
        public BrotliEncoder(string? CompressedFileName, TransferEncoding UncompressedStream, long? ExpectedContentLength)
            : base(null, UncompressedStream)
        {
            this.compressedFileName = CompressedFileName;
            this.uncompressedStream = UncompressedStream;
            this.bytesLeft = ExpectedContentLength;
        }
 
        public void PrepareForCompression()
        {
            this.ms = new MemoryStream();
            this.brEncoder = new BrotliStream(this.ms, CompressionMode.Compress, true);
        }
 
        public override Task BeforeContentAsync(HttpResponse Response, bool ExpectContent)
        {
            return this.uncompressedStream!.BeforeContentAsync(Response, ExpectContent);
        }
 
        public override Task<ulong> DecodeAsync(byte[] Data, int Offset, int NrRead)
        {
            return Task.FromResult(0x100000000UL);  // TODO: Support Content-Encoding in POST, PUT and PATCH, etc.
        }
 
        public override async Task<bool> EncodeAsync(byte[] Data, int Offset, int NrBytes)
        {
            if (NrBytes > 0)
            {
                if (this.finished)
                    return false;
 
                this.dataWritten = true;
 
                if (this.bytesLeft.HasValue)
                {
                    if (NrBytes > this.bytesLeft.Value)
                        NrBytes = (int)this.bytesLeft.Value;
 
                    await this.brEncoder!.WriteAsync(Data, Offset, NrBytes);
 
                    this.bytesLeft -= NrBytes;
                    if (this.bytesLeft <= 0)
                    {
                        this.finished = true;
                        await this.FlushAsync();
                    }
                }
                else
                    await this.brEncoder!.WriteAsync(Data, Offset, NrBytes);
            }
 
            return true;
        }
 
        public override async Task<bool> FlushAsync()
        {
            if (this.dataWritten)
            {
                await this.brEncoder!.FlushAsync();
                this.dataWritten = false;
 
                byte[] Data = this.ms!.ToArray();
                int c = Data.Length;
                if (this.pos < c)
                {
                    c -= this.pos;
                    if (!await this.uncompressedStream!.EncodeAsync(Data, this.pos, c))
                        return false;
 
                    if (!string.IsNullOrEmpty(this.compressedFileName))
                    {
                        if (this.pos == 0)
                            await Resources.WriteAllBytesAsync(this.compressedFileName, Data, this.pos, c);
                        else
                            await Resources.AppendAllBytesAsync(this.compressedFileName, Data, this.pos, c);
                    }
 
                    this.pos += c;
                }
 
                return await this.uncompressedStream!.FlushAsync();
            }
 
            return true;
        }
 
        public override async Task<bool> ContentSentAsync()
        {
            await this.FlushAsync();
            return await this.uncompressedStream!.ContentSentAsync();
        }
 
        public override void Dispose()
        {
            this.uncompressedStream?.Dispose();
            this.uncompressedStream = null;
 
            this.brEncoder?.Dispose();
            this.brEncoder = null;
 
            this.brDecoder?.Dispose();
            this.brDecoder = null;
 
            this.ms?.Dispose();
            this.ms = null;
 
            base.Dispose();
        }
 
        public override bool InvalidEncoding => this.uncompressedStream!.InvalidEncoding;
 
        public override bool TransferError => this.uncompressedStream!.TransferError;
    }
}