CharDecoder.avt

/*
    Исходный код среды исполнения ПВТ-ОО.

    Этот исходный код является частью проекта ПВТ-ОО.

    Copyright © 2021 Малик Разработчик

    Это свободная программа: вы можете перераспространять её и/или
    изменять её на условиях Меньшей Стандартной общественной лицензии GNU в том виде,
    в каком она была опубликована Фондом свободного программного обеспечения;
    либо версии 3 лицензии, либо (по вашему выбору) любой более поздней версии.

    Эта программа распространяется в надежде, что она может быть полезна,
    но БЕЗО ВСЯКИХ ГАРАНТИЙ; даже без неявной гарантии ТОВАРНОГО ВИДА
    или ПРИГОДНОСТИ ДЛЯ ОПРЕДЕЛЁННЫХ ЦЕЛЕЙ. Подробнее см. в Меньшей Стандартной
    общественной лицензии GNU.

    Вы должны были получить копию Меньшей Стандартной общественной лицензии GNU
    вместе с этой программой. Если это не так, см.
    <http://www.gnu.org/licenses/>.
*/

package avt.io.charset;

import avt.io.*;
import avt.io.extension.*;
import avt.lang.array.*;

public abstract class CharDecoder(Object)
{
    private static ByteArrayInputStream toStream(ByteArray src, int offset, int length) {
        byte[] array = new byte[length];
        for(int i = 0; i < length; offset++, i++) array[i] = src[offset];
        return new ByteArrayInputStream(array);
    }

    private static ByteArrayInputStream toStream(ByteReader src, int length) throws IOException {
        byte[] array = new byte[length];
        src.read(array, 0, length);
        return new ByteArrayInputStream(array);
    }


    private long fldGivedChars;
    private long fldAcceptedBytes;
    private DecodingErrorHandler fldHandler;
    private ErrorAction fldErrorAction;
    private final Charset fldCharset;
    private final Object fldMonitor;

    protected (Charset charset) {
        fldErrorAction = ErrorAction.replace;
        fldCharset = charset;
        fldMonitor = new Object();
    }

    public final void decodeToWriter(CharWriter dst, ByteArray src) throws CharacterDecodingException, IOException {
        if(dst == null)
        {
            throw new NullPointerException("аргумент dst равен нулевой ссылке");
        }
        dst.write(decode(src));
    }

    public final void decodeToWriter(CharWriter dst, ByteArray src, int offset, int length) throws CharacterDecodingException, IOException {
        if(dst == null)
        {
            throw new NullPointerException("аргумент dst равен нулевой ссылке");
        }
        dst.write(decode(src, offset, length));
    }

    public final void decodeToWriter(CharWriter dst, ByteReader src, int length) throws CharacterDecodingException, IOException {
        if(dst == null)
        {
            throw new NullPointerException("аргумент dst равен нулевой ссылке");
        }
        dst.write(decode(src, length));
    }

    public final void reset() { synchronized(fldMonitor) { fldGivedChars = fldAcceptedBytes = 0L; } }

    public final long givedChars() { return fldGivedChars; }

    public final long acceptedBytes() { return fldAcceptedBytes; }

    public final char[] decode(ByteArray src) throws CharacterDecodingException { return decode(src, 0, src == null ? 0 : src.length); }

    public final char[] decode(ByteArray src, int offset, int length) throws CharacterDecodingException {
        if(src == null)
        {
            throw new NullPointerException("аргумент src равен нулевой ссылке");
        }
        Array.checkBounds(src, offset, length);
        if(length <= 0) return new char[0];
        long deltaAcceptedBytes = 0L;
        CharDestination result = new CharDestination();
        try
        {
            if(src instanceof byte[])
            {
                ByteArrayInputStream buffer = new ByteArrayInputStream((byte[]) src, offset + length, offset);
                decode(buffer, length, result);
                deltaAcceptedBytes = buffer.position() - offset;
            } else
            {
                ByteArrayInputStream buffer = toStream(src, offset, length);
                decode(buffer, length, result);
                deltaAcceptedBytes = buffer.position();
            }
        }
        catch(IOException e) {  }
        long deltaGivedChars = result.position;
        synchronized(fldMonitor)
        {
            fldAcceptedBytes += deltaAcceptedBytes;
            fldGivedChars += deltaGivedChars;
        }
        return result.toCharArray();
    }

    public final char[] decode(ByteReader src, int length) throws CharacterDecodingException, IOException {
        if(src == null)
        {
            throw new NullPointerException("аргумент src равен нулевой ссылке");
        }
        if(length <= 0) return new char[0];
        long deltaAcceptedBytes = 0L;
        CharDestination result = new CharDestination();
        SeekExtension seekable = null;
        if(src instanceof ByteArrayInputStream)
        {
            ByteArrayInputStream buffer = (ByteArrayInputStream) src;
            long offset = buffer.position();
            decode(src, length, result);
            deltaAcceptedBytes = buffer.position() - offset;
        }
        else if((seekable = (SeekExtension) src.getExtension(SeekExtension.class)) != null)
        {
            long offset = seekable.position();
            decode(src, length, result);
            deltaAcceptedBytes = seekable.position() - offset;
        }
        else
        {
            ByteArrayInputStream buffer = toStream(src, length);
            decode(buffer, length, result);
            deltaAcceptedBytes = buffer.position();
        }
        long deltaGivedChars = result.position;
        synchronized(fldMonitor)
        {
            fldAcceptedBytes += deltaAcceptedBytes;
            fldGivedChars += deltaGivedChars;
        }
        return result.toCharArray();
    }

    public final Charset charset { read = fldCharset }

    public final ErrorAction errorAction { read = fldErrorAction, write = setErrorAction }

    public final DecodingErrorHandler decodingErrorHandler { read = fldHandler, write = fldHandler }

    protected abstract void decode(ByteReader src, int length, CharWriter dst) throws CharacterDecodingException, IOException;

    protected final void report() {
        DecodingErrorHandler handler = fldHandler;
        if(handler != null) handler.decodingError(this);
    }

    private void setErrorAction(ErrorAction errorAction) { fldErrorAction = errorAction == null ? ErrorAction.report : errorAction; }
}