package RPS::Import::EMIMusic::Subscriptions::v2;

use strict;

use lib '/app/tools/data_classes/lib';
use lib '/app/tools/common/lib';
use lib '/app/tools/rps/lib';
use lib '/app/tools/raptor/lib';
use Common::Date;
use Common::Log;
use Common::RSMath;
use Client::Service;

use base 'RPS::Import::EMIMusic::Subscriptions::v1';

use Data::Dumper;

sub _importLines {
    my ( $self, %args ) = @_;

    # We're going to collect header statistics.
    # If the header doesn't match correctly, we croak.
    #

    my $rVal = $self->SUPER::_importLines(%args);

    # Sanity-check the last block.
    #
    $self->_checkStreamCount();

    if ( $self->{_badBlocks} > 0 ) {

        # JPK - We could just call die here, but that will tack on the file name/line num stuff that we frankly don't need to report.
        #
        $self->errstr( "Header unit totals do not match detail unit totals for "
              . $self->{_badBlocks}
              . " out of "
              . $self->{_totalBlocks}
              . " headers." );
        return undef;
    }

    return $rVal;
}

sub _checkStreamCount {
    my ($self) = @_;

    if ( $self->{_expectedStreamCount} ) {
        Common::Log::Print( "expected: " . $self->{_expectedStreamCount} . ", actual: " . $self->{_actualStreamCount} );
        if ( $self->{_actualStreamCount} != $self->{_expectedStreamCount} ) {
            $self->{_badBlocks}++;
        }
    }
}

sub _processNewHeader {
    my ($self) = @_;

    $self->_checkStreamCount();

    my $streams = $self->_getByFieldName('streamCount');
    $self->{_expectedStreamCount} = $streams;
    $self->{_actualStreamCount}   = 0;
    $self->{_totalBlocks}++;

    $self->SUPER::_processNewHeader();
}

# I'll override this to count the accumulated units.
#
sub _validateUnits {
    my ( $self, $saleRec ) = @_;
    $self->SUPER::_validateUnits($saleRec);

    my $units = $saleRec->units;
    $self->{_actualStreamCount} += $units;
}

###
1;    # Play nicely.
###