//
// Copyright (c) James Jackson-South and contributors.
// Licensed under the Apache License, Version 2.0.
//
namespace ImageSharp.Formats
{
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
///
/// Performs the png decoding operation.
///
internal class PngDecoderCore
{
///
/// The dictionary of available color types.
///
private static readonly Dictionary ColorTypes = new Dictionary();
///
/// Reusable buffer for reading chunk types.
///
private readonly byte[] chunkTypeBuffer = new byte[4];
///
/// Reusable buffer for reading chunk lengths.
///
private readonly byte[] chunkLengthBuffer = new byte[4];
///
/// Reusable buffer for reading crc values.
///
private readonly byte[] crcBuffer = new byte[4];
///
/// Reusable buffer for reading char arrays.
///
private readonly char[] chars = new char[4];
///
/// The stream to decode from.
///
private Stream currentStream;
///
/// The png header.
///
private PngHeader header;
///
/// The number of bytes per pixel.
///
private int bytesPerPixel;
///
/// The number of bytes per sample
///
private int bytesPerSample;
///
/// The number of bytes per scanline
///
private int bytesPerScanline;
///
/// The palette containing color information for indexed png's
///
private byte[] palette;
///
/// The palette containing alpha channel color information for indexed png's
///
private byte[] paletteAlpha;
///
/// Initializes static members of the class.
///
static PngDecoderCore()
{
ColorTypes.Add((int)PngColorType.Grayscale, new byte[] { 1, 2, 4, 8 });
ColorTypes.Add((int)PngColorType.Rgb, new byte[] { 8 });
ColorTypes.Add((int)PngColorType.Palette, new byte[] { 1, 2, 4, 8 });
ColorTypes.Add((int)PngColorType.GrayscaleWithAlpha, new byte[] { 8 });
ColorTypes.Add((int)PngColorType.RgbWithAlpha, new byte[] { 8 });
}
///
/// Gets or sets the png color type
///
public PngColorType PngColorType { get; set; }
///
/// Decodes the stream to the image.
///
/// The pixel format.
/// The packed format. uint, long, float.
/// The image to decode to.
/// The stream containing image data.
///
/// Thrown if the stream does not contain and end chunk.
///
///
/// Thrown if the image is larger than the maximum allowable size.
///
public void Decode(Image image, Stream stream)
where TColor : struct, IPackedPixel
where TPacked : struct
{
Image currentImage = image;
this.currentStream = stream;
this.currentStream.Skip(8);
bool isEndChunkReached = false;
using (MemoryStream dataStream = new MemoryStream())
{
PngChunk currentChunk;
while ((currentChunk = this.ReadChunk()) != null)
{
if (isEndChunkReached)
{
throw new ImageFormatException("Image does not end with end chunk.");
}
switch (currentChunk.Type)
{
case PngChunkTypes.Header:
this.ReadHeaderChunk(currentChunk.Data);
this.ValidateHeader();
break;
case PngChunkTypes.Physical:
this.ReadPhysicalChunk(currentImage, currentChunk.Data);
break;
case PngChunkTypes.Data:
dataStream.Write(currentChunk.Data, 0, currentChunk.Data.Length);
break;
case PngChunkTypes.Palette:
this.palette = currentChunk.Data;
image.Quality = this.palette.Length / 3;
break;
case PngChunkTypes.PaletteAlpha:
this.paletteAlpha = currentChunk.Data;
break;
case PngChunkTypes.Text:
this.ReadTextChunk(currentImage, currentChunk.Data);
break;
case PngChunkTypes.End:
isEndChunkReached = true;
break;
}
}
if (this.header.Width > image.MaxWidth || this.header.Height > image.MaxHeight)
{
throw new ArgumentOutOfRangeException(
$"The input png '{this.header.Width}x{this.header.Height}' is bigger than the "
+ $"max allowed size '{image.MaxWidth}x{image.MaxHeight}'");
}
image.InitPixels(this.header.Width, this.header.Height);
using (PixelAccessor pixels = image.Lock())
{
this.ReadScanlines(dataStream, pixels);
}
}
}
///
/// Reads the data chunk containing physical dimension data.
///
/// The pixel format.
/// The packed format. uint, long, float.
/// The image to read to.
/// The data containing physical data.
private void ReadPhysicalChunk(Image image, byte[] data)
where TColor : struct, IPackedPixel
where TPacked : struct
{
data.ReverseBytes(0, 4);
data.ReverseBytes(4, 4);
// 39.3700787 = inches in a meter.
image.HorizontalResolution = BitConverter.ToInt32(data, 0) / 39.3700787d;
image.VerticalResolution = BitConverter.ToInt32(data, 4) / 39.3700787d;
}
///
/// Calculates the correct number of bytes per pixel for the given color type.
///
/// The
private int CalculateBytesPerPixel()
{
switch (this.PngColorType)
{
case PngColorType.Grayscale:
return 1;
case PngColorType.GrayscaleWithAlpha:
return 2;
case PngColorType.Palette:
return 1;
case PngColorType.Rgb:
return 3;
// PngColorType.RgbWithAlpha:
default:
return 4;
}
}
///
/// Calculates the scanline length.
///
/// The representing the length.
private int CalculateScanlineLength()
{
int scanlineLength = this.header.Width * this.header.BitDepth * this.bytesPerPixel;
int amount = scanlineLength % 8;
if (amount != 0)
{
scanlineLength += 8 - amount;
}
return scanlineLength / 8;
}
///
/// Reads the scanlines within the image.
///
/// The pixel format.
/// The packed format. uint, long, float.
/// The containing data.
/// The pixel data.
private void ReadScanlines(MemoryStream dataStream, PixelAccessor pixels)
where TColor : struct, IPackedPixel
where TPacked : struct
{
this.bytesPerPixel = this.CalculateBytesPerPixel();
this.bytesPerScanline = this.CalculateScanlineLength() + 1;
this.bytesPerSample = 1;
if (this.header.BitDepth >= 8)
{
this.bytesPerSample = this.header.BitDepth / 8;
}
dataStream.Position = 0;
using (ZlibInflateStream compressedStream = new ZlibInflateStream(dataStream))
{
this.DecodePixelData(compressedStream, pixels);
}
}
///
/// Decodes the raw pixel data row by row
///
/// The pixel format.
/// The packed format. uint, long, float.
/// The compressed pixel data stream.
/// The image pixel accessor.
private void DecodePixelData(Stream compressedStream, PixelAccessor pixels)
where TColor : struct, IPackedPixel
where TPacked : struct
{
// TODO: ArrayPool.Shared.Rent(this.bytesPerScanline)
byte[] previousScanline = new byte[this.bytesPerScanline];
byte[] scanline = new byte[this.bytesPerScanline];
for (int y = 0; y < this.header.Height; y++)
{
compressedStream.Read(scanline, 0, this.bytesPerScanline);
FilterType filterType = (FilterType)scanline[0];
byte[] defilteredScanline;
// TODO: It would be good if we can reduce the memory usage here. Each filter is creating a new row.
switch (filterType)
{
case FilterType.None:
defilteredScanline = NoneFilter.Decode(scanline);
break;
case FilterType.Sub:
defilteredScanline = SubFilter.Decode(scanline, this.bytesPerPixel);
break;
case FilterType.Up:
defilteredScanline = UpFilter.Decode(scanline, previousScanline);
break;
case FilterType.Average:
defilteredScanline = AverageFilter.Decode(scanline, previousScanline, this.bytesPerPixel);
break;
case FilterType.Paeth:
defilteredScanline = PaethFilter.Decode(scanline, previousScanline, this.bytesPerPixel);
break;
default:
throw new ImageFormatException("Unknown filter type.");
}
previousScanline = defilteredScanline;
this.ProcessDefilteredScanline(defilteredScanline, y, pixels);
}
}
///
/// Processes the de-filtered scanline filling the image pixel data
///
/// The pixel format.
/// The packed format. uint, long, float.
/// The de-filtered scanline
/// The current image row.
/// The image pixels
private void ProcessDefilteredScanline(byte[] defilteredScanline, int row, PixelAccessor pixels)
where TColor : struct, IPackedPixel
where TPacked : struct
{
TColor color = default(TColor);
switch (this.PngColorType)
{
case PngColorType.Grayscale:
for (int x = 0; x < this.header.Width; x++)
{
int offset = 1 + (x * this.bytesPerPixel);
byte intensity = defilteredScanline[offset];
color.PackFromBytes(intensity, intensity, intensity, 255);
pixels[x, row] = color;
}
break;
case PngColorType.GrayscaleWithAlpha:
for (int x = 0; x < this.header.Width; x++)
{
int offset = 1 + (x * this.bytesPerPixel);
byte intensity = defilteredScanline[offset];
byte alpha = defilteredScanline[offset + this.bytesPerSample];
color.PackFromBytes(intensity, intensity, intensity, alpha);
pixels[x, row] = color;
}
break;
case PngColorType.Palette:
byte[] newScanline = defilteredScanline.ToArrayByBitsLength(this.header.BitDepth);
if (this.paletteAlpha != null && this.paletteAlpha.Length > 0)
{
// If the alpha palette is not null and has one or more entries, this means, that the image contains an alpha
// channel and we should try to read it.
for (int x = 0; x < this.header.Width; x++)
{
int index = newScanline[x];
int pixelOffset = index * 3;
byte a = this.paletteAlpha.Length > index ? this.paletteAlpha[index] : (byte)255;
if (a > 0)
{
byte r = this.palette[pixelOffset];
byte g = this.palette[pixelOffset + 1];
byte b = this.palette[pixelOffset + 2];
color.PackFromBytes(r, g, b, a);
}
pixels[x, row] = color;
}
}
else
{
for (int x = 0; x < this.header.Width; x++)
{
int index = newScanline[x];
int pixelOffset = index * 3;
byte r = this.palette[pixelOffset];
byte g = this.palette[pixelOffset + 1];
byte b = this.palette[pixelOffset + 2];
color.PackFromBytes(r, g, b, 255);
pixels[x, row] = color;
}
}
break;
case PngColorType.Rgb:
for (int x = 0; x < this.header.Width; x++)
{
int offset = 1 + (x * this.bytesPerPixel);
byte r = defilteredScanline[offset];
byte g = defilteredScanline[offset + this.bytesPerSample];
byte b = defilteredScanline[offset + (2 * this.bytesPerSample)];
color.PackFromBytes(r, g, b, 255);
pixels[x, row] = color;
}
break;
case PngColorType.RgbWithAlpha:
for (int x = 0; x < this.header.Width; x++)
{
int offset = 1 + (x * this.bytesPerPixel);
byte r = defilteredScanline[offset];
byte g = defilteredScanline[offset + this.bytesPerSample];
byte b = defilteredScanline[offset + (2 * this.bytesPerSample)];
byte a = defilteredScanline[offset + (3 * this.bytesPerSample)];
color.PackFromBytes(r, g, b, a);
pixels[x, row] = color;
}
break;
}
}
///
/// Reads a text chunk containing image properties from the data.
///
/// The pixel format.
/// The packed format. uint, long, float.
/// The image to decode to.
/// The containing data.
private void ReadTextChunk(Image image, byte[] data)
where TColor : struct, IPackedPixel
where TPacked : struct
{
int zeroIndex = 0;
for (int i = 0; i < data.Length; i++)
{
if (data[i] == 0)
{
zeroIndex = i;
break;
}
}
string name = Encoding.Unicode.GetString(data, 0, zeroIndex);
string value = Encoding.Unicode.GetString(data, zeroIndex + 1, data.Length - zeroIndex - 1);
image.Properties.Add(new ImageProperty(name, value));
}
///
/// Reads a header chunk from the data.
///
/// The containing data.
private void ReadHeaderChunk(byte[] data)
{
this.header = new PngHeader();
data.ReverseBytes(0, 4);
data.ReverseBytes(4, 4);
this.header.Width = BitConverter.ToInt32(data, 0);
this.header.Height = BitConverter.ToInt32(data, 4);
this.header.BitDepth = data[8];
this.header.ColorType = data[9];
this.header.CompressionMethod = data[10];
this.header.FilterMethod = data[11];
this.header.InterlaceMethod = data[12];
}
///
/// Validates the png header.
///
///
/// Thrown if the image does pass validation.
///
private void ValidateHeader()
{
if (!ColorTypes.ContainsKey(this.header.ColorType))
{
throw new NotSupportedException("Color type is not supported or not valid.");
}
if (!ColorTypes[this.header.ColorType].Contains(this.header.BitDepth))
{
throw new NotSupportedException("Bit depth is not supported or not valid.");
}
if (this.header.FilterMethod != 0)
{
throw new NotSupportedException("The png specification only defines 0 as filter method.");
}
if (this.header.InterlaceMethod != 0)
{
// TODO: Support interlacing
throw new NotSupportedException("Interlacing is not supported.");
}
this.PngColorType = (PngColorType)this.header.ColorType;
}
///
/// Reads a chunk from the stream.
///
///
/// The .
///
private PngChunk ReadChunk()
{
PngChunk chunk = new PngChunk();
if (this.ReadChunkLength(chunk) == 0)
{
return null;
}
if (chunk.Length <= 0)
{
return null;
}
this.ReadChunkType(chunk);
this.ReadChunkData(chunk);
this.ReadChunkCrc(chunk);
return chunk;
}
///
/// Reads the cycle redundancy chunk from the data.
///
/// The chunk.
///
/// Thrown if the input stream is not valid or corrupt.
///
private void ReadChunkCrc(PngChunk chunk)
{
int numBytes = this.currentStream.Read(this.crcBuffer, 0, 4);
if (numBytes >= 1 && numBytes <= 3)
{
throw new ImageFormatException("Image stream is not valid!");
}
this.crcBuffer.ReverseBytes();
chunk.Crc = BitConverter.ToUInt32(this.crcBuffer, 0);
Crc32 crc = new Crc32();
crc.Update(this.chunkTypeBuffer);
crc.Update(chunk.Data);
if (crc.Value != chunk.Crc)
{
throw new ImageFormatException("CRC Error. PNG Image chunk is corrupt!");
}
}
///
/// Reads the chunk data from the stream.
///
/// The chunk.
private void ReadChunkData(PngChunk chunk)
{
chunk.Data = new byte[chunk.Length];
this.currentStream.Read(chunk.Data, 0, chunk.Length);
}
///
/// Identifies the chunk type from the chunk.
///
/// The chunk.
///
/// Thrown if the input stream is not valid.
///
private void ReadChunkType(PngChunk chunk)
{
int numBytes = this.currentStream.Read(this.chunkTypeBuffer, 0, 4);
if (numBytes >= 1 && numBytes <= 3)
{
throw new ImageFormatException("Image stream is not valid!");
}
this.chars[0] = (char)this.chunkTypeBuffer[0];
this.chars[1] = (char)this.chunkTypeBuffer[1];
this.chars[2] = (char)this.chunkTypeBuffer[2];
this.chars[3] = (char)this.chunkTypeBuffer[3];
chunk.Type = new string(this.chars);
}
///
/// Calculates the length of the given chunk.
///
/// he chunk.
///
/// The representing the chunk length.
///
///
/// Thrown if the input stream is not valid.
///
private int ReadChunkLength(PngChunk chunk)
{
int numBytes = this.currentStream.Read(this.chunkLengthBuffer, 0, 4);
if (numBytes >= 1 && numBytes <= 3)
{
throw new ImageFormatException("Image stream is not valid!");
}
this.chunkLengthBuffer.ReverseBytes();
chunk.Length = BitConverter.ToInt32(this.chunkLengthBuffer, 0);
return numBytes;
}
}
}