#!/usr/bin/perl

BEGIN {
    push @INC, split(":", $ENV{PERL5LIB});
}

$|++;

use strict;
use CGI;
use DBI;
use File::stat;
use File::Path;
use FileManager;
use JSON::XS;
use Data::Dumper;
use POSIX qw(ceil floor);
use GetDBHandle qw(:DEFAULT);
use ParseBrixConfig;

my $q = new CGI(\&hook);
my $filename  = $q->param('file');
my $upload_fh = $q->upload('file');

my $MY_HOME   = $ENV{MY_HOME};
my $log_path  = $MY_HOME . "/log";
my $state_dir = $MY_HOME . "/apache/htdocs/state";

open LOG, ">> $log_path/fileUpload.log";
print LOG "server process id = " . $$ . "\n";
print LOG "temp filename = " . $q->tmpFileName($filename) . "\n";
print LOG "apache file info = " . Dumper($q->uploadInfo($filename)) . "\n";
print LOG "upload fh = " . ref($upload_fh) . "\n";
print LOG "upload fh size = " . Dumper(stat($upload_fh)->size) . "\n";


my $config    = parse_brix_config($ENV{MY_HOME}."/conf/system.conf");
my $db_name   = $config->{global}{db_name};
my $db_string = 'dbi:Oracle:' . $db_name;

my ($cust_db_user, $cust_db_pass) = get_db_handle( r => $q,
                                                            config => $config,
                                                            req_type => 'cgi' );

# open the customer dbh handle
my $dbh = db_connect( credentials     =>
                      { db_user     => $cust_db_user,
                        db_password => $cust_db_pass,
                        db_string   => $db_string
                      }
                    );
die "Could not get the dbh handle. Something is wrong .... cust_db_user = [$cust_db_user], cust_db_pass = [$cust_db_pass], db_string = [$db_string]\n"
    if not defined $dbh;

# start file processing
my ($progressTempFile, $savedFileName) = $ENV{QUERY_STRING} =~ /fileProgressTemp=(.*?)&savedFileName=(.*)/;
print LOG "progressTempFile = $progressTempFile\n";
print LOG "savedFileName = $savedFileName\n";

# get the uploaded file handle
my $file_saved_location = get_saved_file_location(dbh => $dbh);

# If directory not exists then create it and give permission
if (!-d $file_saved_location) {
    `mkdir $file_saved_location`;
    `chmod 777 $file_saved_location`;
}

my $file_size = stat($upload_fh)->size;
my $file_path = "$file_saved_location$savedFileName"; # create actual file path
print LOG "file_path = $file_path\n";

my %final_data = ();
my $buffer = 0;
eval {
    # read the actual temp file and store the data in the real location
    open (FH, ">$file_path");
    while (my $length = sysread($upload_fh, $buffer, 262144)) { #256KB chunk at a time
        syswrite(FH, $buffer, $length);
    }
    close FH;

    # mark 100% in the progress temp file so that it shows 100% on the progress bar
    if (-e "$state_dir/$progressTempFile") {
        open (COUNTER, ">> $state_dir/$progressTempFile");
        print COUNTER "100";
        close COUNTER;
    }
};
if($@) {
    print STDERR "LOG: The EXFOConnect system encountered an error. Please Contact System Administrator: $@";
}
if(-e $file_path) {
    %final_data = (
        success => JSON::XS::true,
        success_status => 1,
        file_size => $file_size,
        saved_file_path => $file_path,
    );
}else {
    %final_data = (
        success => JSON::XS::false,
        message => "The EXFOConnect system encountered an error. Please Contact System Administrator.",
        success_status => 0
    );
}

$dbh->commit;
$dbh->disconnect;

print LOG "---------------------------------------------------\n";
close LOG;

print "Content-Type: text/html\n\n";
print encode_json(\%final_data);

#################################
## This is the handler to read the bytes of file uploaded
#################################
sub hook {
    my ($filename, $buffer, $bytes_read, $data) = @_;
    $bytes_read ||= 0;

    my $MY_HOME   = $ENV{MY_HOME};
    my $log_path  = $MY_HOME . "/log";
    my $state_dir = $MY_HOME . "/apache/htdocs/state";

    my ($fileProgressTemp) = $ENV{QUERY_STRING} =~ /fileProgressTemp=(.*?)&savedFileName=(.*)/;

    # calculate percentage of uploaded file and save it.
    # this will be read by a ajax request to show the percentage complete.
    open(COUNTER, ">> $state_dir/$fileProgressTemp");

    my $per = 0;
    if ($ENV{CONTENT_LENGTH} >  0) { 
        $per = ($bytes_read * 100) / $ENV{CONTENT_LENGTH};
    }

    print COUNTER ceil($per) . "\n";
    close(COUNTER);
}

exit;