File Coverage

blib/lib/Stream/Reader.pm

Criterion	Covered	Total	%
statement	12	163	7.3
branch	1	124	0.8
condition	1	69	1.4
subroutine	3	12	25.0
pod	3	3	100.0
total	20	371	5.3

package Stream::Reader;

use 5.005;
use strict;

our $VERSION = '0.09';

# Global/system variables

our $CODE;
our $AUTOLOAD;
our $Shift;

# Autoloaded code
$CODE ||= {

# Constructor
new => <<'ENDC',
  my $class = shift;
  my $input = shift;
  my $attr  = ( ref($Shift = shift) eq 'HASH' )? $Shift : {};
  my $self  = {
      # System parameters
    input    => $input,
    inpos    => 0,
    inlimit  => ( defined($attr->{Limit}) and $attr->{Limit} >= 0 )? $attr->{Limit} : 1e10,
    buffsize => ( defined($attr->{BuffSize}) and $attr->{BuffSize} >= 0 )? $attr->{BuffSize} : 32_768,
    bufferA  => '',
    bufferB  => '',
    status   => 1,
      # System flags
    mode_B  => ( $attr->{Mode} and index(uc($attr->{Mode}),'B') != -1 ),
    mode_U  => ( $attr->{Mode} and index(uc($attr->{Mode}),'U') != -1 ),
      # Statistic parameters
    Match  => '',
    Readed => 0,
    Stored => 0,
    Total  => 0,
    Error  => 0
  };
  return bless( $self => $class );
ENDC

# Destructor
DESTROY => <<'ENDC',
  return 1;
ENDC

# Public method
readto => <<'ENDC',
  my $self  = shift;
  my $delim = ( ref($Shift = shift) eq 'ARRAY' )? $Shift : [$Shift];
  my $attr  = ( ref($Shift = shift) eq 'HASH' )? $Shift : {};
  my $limit = ( defined($attr->{Limit}) and $attr->{Limit} >= 0 )? $attr->{Limit} : 1e10;
  my $wcase = ( $attr->{Mode} and index(uc($attr->{Mode}),'I') != -1 );
  my $max_d = 0;
  my $min_d = 1e10;
  my $error;
  my $rsize;

  # Preparing:
  #  - reseting some statistic variables
  @$self{ qw(Readed Stored Match) } = ( (0)x2, '' );
  #  - initialize output stream, if this is SCALAR and initialization required
  if( UNIVERSAL::isa($attr->{Out},'SCALAR')
    and !( defined(${$attr->{Out}}) and $attr->{Mode} and index(uc($attr->{Mode}),'A') != -1 )
  ) {
    ${$attr->{Out}} = '';
  }
  #  - maximal and minimal delimiter length detection
  foreach( @$delim ) {
    $max_d = length if $max_d < length;
    $min_d = length if $min_d > length;
  }
  #  - checking status and delimiter(s) presents
  unless( $self->{status} and $max_d ) {
    return $self->{status};
  } else {
    # Processing:
    while(1) {
      #  - searching
      if( length($self->{bufferA}) >= $min_d ) {
        my $found = 1e10;
        my $buffer;
        if( $wcase ) {
          $buffer = \( $self->{mode_B}? $self->{bufferB} : lc($self->{bufferA}) );
        }
        foreach( @$delim ) {
          my $pos = $wcase? index($$buffer,lc) : index($self->{bufferA},$_);
          if( $pos != -1 and $pos < $found ) {
            $found = $pos;
            $self->{Match} = $_;
          }
        }
        if( $found < 1e10 ) {
          if( !$error and $self->{Stored} < $limit ) {
            $rsize = $found;
            $rsize = $limit - $self->{Stored} if( $rsize > $limit - $self->{Stored} );
            $error = !$self->_write( $attr->{Out}, \(substr( $self->{bufferA}, 0, $rsize )) );
            $self->{Stored} += $rsize unless $error;
          }
          $self->{Readed} += $found;
          $self->{Total}  += $found;
          my $psize = $found + length($self->{Match});
          substr( $self->{bufferA}, 0, $psize, '' );
          substr( $self->{bufferB}, 0, $psize, '' ) if $self->{mode_B};
          return 1;
        }
      }
      #  - move part data to output stream
      if( length($self->{bufferA}) >= $max_d ) {
        my $psize = length($self->{bufferA}) - ($max_d - 1);
        if( !$error and $self->{Stored} < $limit ) {
          $rsize = $psize;
          $rsize = $limit - $self->{Stored} if( $rsize > $limit - $self->{Stored} );
          $error = !$self->_write( $attr->{Out}, \(substr( $self->{bufferA}, 0, $rsize )) );
          $self->{Stored} += $rsize unless $error;
        }
        $self->{Readed} += $psize;
        $self->{Total}  += $psize;
        substr( $self->{bufferA}, 0, $psize, '' );
        substr( $self->{bufferB}, 0, $psize, '' ) if $self->{mode_B};
      }
      #  - if limit not ended yet then trying to fill buffer
      #  - else move last data to output stream and finish
      if( $self->{inlimit} ) {
        return 0 unless $self->_fill_buffer();
      } else {
        if( length $self->{bufferA} ) {
          $rsize = length $self->{bufferA};
          $self->{Readed} += $rsize;
          $self->{Total}  += $rsize;
          if( !$error and $self->{Stored} < $limit ) {
            $rsize = $limit - $self->{Stored} if( $rsize > $limit - $self->{Stored} );
            $error = !$self->_write( $attr->{Out}, \(substr( $self->{bufferA}, 0, $rsize )) );
            $self->{Stored} += $rsize unless $error;
          }
          $self->{bufferA} = '';
          $self->{bufferB} = '' if $self->{mode_B};
        }
        $self->{status} = 0;
        return( ( $attr->{Mode} and index(uc($attr->{Mode}),'E') != -1 )? 0 : 1 );
      }
    }
  }
ENDC

# Public method
readsome => <<'ENDC',
  my $self  = shift;
  my $limit = ( defined($Shift = shift) and $Shift >= 0 )? $Shift : 1e10;
  my $attr  = ( ref($Shift = shift) eq 'HASH' )? $Shift : {};
  my $rsize;
  my $error;

  # Preparing:
  #  - reseting some statistic variables
  @$self{ qw(Readed Stored Match) } = ( (0)x2, '' );
  #  - initialize output stream, if this is SCALAR and initialization required
  if( UNIVERSAL::isa($attr->{Out},'SCALAR')
    and !( defined(${$attr->{Out}}) and $attr->{Mode} and index(uc($attr->{Mode}),'A') != -1 )
  ) {
    ${$attr->{Out}} = '';
  }
  #  - checking status
  unless( $self->{status} ) {
    return 0;
  } else {
    # Processing:
    while( $self->{Readed} < $limit ) {
      #  - trying to fill buffer
      unless( length $self->{bufferA} ) {
        return 0 unless $self->_fill_buffer();
      }
      #  - if buffer still empty then break cycle
      unless( length $self->{bufferA} ) {
        $self->{status} = 0;
        return( $self->{Readed} ? 1 : 0 );
      #  - else if not enouth data in buffer, then move all data from buffer to output stream
      } elsif( length($self->{bufferA}) <= $limit - $self->{Readed} ) {
        unless( $error ) {
          $error = !$self->_write( $attr->{Out}, \($self->{bufferA}) );
        }
        $rsize = length $self->{bufferA};
        $self->{Stored} += $rsize unless $error;
        $self->{Readed} += $rsize;
        $self->{Total}  += $rsize;
        $self->{bufferA} = '';
        $self->{bufferB} = '' if $self->{mode_B};
      #  - else move necessary of characters to output stream  and break cycle
      } else {
        $rsize = $limit - $self->{Readed};
        unless( $error ) {
          $error = !$self->_write( $attr->{Out}, \(substr( $self->{bufferA}, 0, $rsize )) );
        }
        $self->{Stored} += $rsize unless $error;
        $self->{Readed} += $rsize;
        $self->{Total}  += $rsize;
        substr( $self->{bufferA}, 0, $rsize, '' );
        substr( $self->{bufferB}, 0, $rsize, '' ) if $self->{mode_B};
        last;
      }
    }
  }
  return 1;
ENDC

# Private method: BOOL = _fill_buffer()
# Trying to filling buffer with new portion of data. Returns false on errors
_fill_buffer => <<'ENDC',
  my $self = shift;

  if( $self->{inlimit} ) { # checking stream limit
    my $buffer;
    my $result;
    # Getting new portion of data
    if( $self->{buffsize} > $self->{inlimit} ) {
      $result = $self->_read( \$buffer, $self->{inlimit} );
    } else {
      $result = $self->_read( \$buffer, $self->{buffsize} );
    }
    # Checking data
    if( !defined($result) or ($] >= 5.008001
      and !$self->{mode_U} and $result and utf8::is_utf8($buffer) and !utf8::valid($buffer)
    )) {
      # Error reading or malformed data
      @$self{ qw(Error status inlimit bufferA bufferB) } = ( qw(1 0 0), ('')x2 );
      return undef;
    } else {
      # Fixing stream limit and appending data to buffers
      $self->{inlimit}  = $result? ( $self->{inlimit} - $result ) : 0;
      $self->{bufferA} .= $buffer;
      $self->{bufferB} .= lc($buffer) if $self->{mode_B};
    }
  }
  return 1;
ENDC

# Private method: LENGTH = SELF->_read(STRREF,LENGTH)
# Trying to reading data from input stream into STRREF
_read => <<'ENDC',
  my $self   = shift;
  my $strref = shift;
  my $length = shift;
  my $result;

  # Checking type of stream:
  #  - if SCALAR, then copy part of data from SCALAR variable
  if( UNIVERSAL::isa($self->{input},'SCALAR') ) {
    $result = length(${$self->{input}}) - $self->{inpos};
    $result = $length if $result > $length;
    $result = 0 if $result < 0;
    $$strref = substr( ${$self->{input}}, $self->{inpos}, $result );
    $self->{inpos} += $result;
  #  - if TYPEGLOB, then reading next part of data from file stream
  } elsif( UNIVERSAL::isa($self->{input},'GLOB') ) {
    $result = read( $self->{input}, $$strref, $length );
  }
  return $result;
ENDC

# Private method: BOOL = SELF->_write(OUTPUT,STRREF)
# Storing data in output stream
_write => <<'ENDC',
  my $self   = shift;
  my $output = shift;
  my $strref = shift;
  my $result;

  # Checking type of reference:
  #  - if SCALAR, then appending data to SCALAR variable
  #  - if TYPEGLOB, then writing data to file stream
  if( UNIVERSAL::isa($output,'SCALAR') ) {
    $$output .= $$strref;
    $result = 1; # alltimes true result
  } elsif ( UNIVERSAL::isa($output,'GLOB') ) {
    $result = print( {$output} $$strref );
  }
  return $result;
ENDC

};

# Compiling all under mod_perl
if( exists $ENV{MOD_PERL} ) {
  _compile($_) foreach( keys %{$CODE} );
}

# Standard function
sub AUTOLOAD {
  my $name = substr(
    $AUTOLOAD, rindex( $AUTOLOAD, ':' ) + 1
  );
  unless( _compile($name) ) {
    _croak("Undefined subroutine &${AUTOLOAD} called");
  } else {
    goto &{$AUTOLOAD};
  }
}

# Private function: BOOL = _compile(NAME)
# Compiling, specified by NAME, subroutine from $CODE array
sub _compile {
  my $name = shift;

  unless( exists $CODE->{$name} ) {
    return undef;
  } else {
    eval "sub $name { $CODE->{$name} }";
    if( $@ ne '' and $^W ) {
      warn $@; # warnings enable
    }
    delete $CODE->{$name};
    return 1;
  }
}

# Handling fatals
sub _croak {
  require Carp; Carp::croak(shift);
}

1;

__END__