File Coverage

lib/Mediafire/Api/UploadFile.pm

Criterion	Covered	Total	%
statement	44	65	67.6
branch	0	6	0.0
condition	0	14	0.0
subroutine	15	17	88.2
pod	0	2	0.0
total	59	104	56.7

package Mediafire::Api::UploadFile;

use 5.008001;
use utf8;
use strict;
use warnings;
use open qw(:std :utf8);
use Carp qw/croak carp/;
use URI::Escape;
use LWP::UserAgent;
use File::Basename;
use HTTP::Request;
use JSON::XS;
use MIME::Detect;
use Crypt::Digest::SHA256 qw/sha256_hex/;
use Time::HiRes qw/gettimeofday/;

use Mediafire::Api::File;

our $VERSION = '0.01';

my $DEFAULT_BUFF_SIZE           = 1048576;

############################ PRIVATE METHODS ############################################
my ($getSha256Sum, $checkUploadFile, $getFileFromCache, $checkResumeUpload, $getMimeType, $uploadF);

$getSha256Sum = sub {
    my ($fname) = @_;
    my $sha = Crypt::Digest::SHA256->new();
    $sha->addfile($fname);
    return $sha->hexdigest;
};

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

    my $url = 'https://www.mediafire.com/api/1.5/upload/check.php';

    my @sec = gettimeofday();
    my $microseconds = substr(join('', @sec), 0, 13);

    my %param = (
        'hash'              => $self->{file}->hash,
        'size'              => $self->{file}->size,
        'filename'          => $self->{file}->name,
        'unit_size'         => $self->{buff_size},
        'resumable'         => 'yes',
        'preemptive'        => 'yes',
        'folder_key'        => $self->{path},
        'session_token'     => $self->{session_token},
        'response_format'   => 'json',
        $microseconds       => '',
    );

    my $param_str = join('&', map {"$_=" . uri_escape($param{$_})} keys %param);
    my $full_url = $url . '?' . $param_str;
    my $res = $self->{ua}->get($full_url);
    my $code = $res->code;
    if ($code ne '200') {
        croak "Wrong response code checkUploadFile(). Url: '$full_url'. Code: $code";
    }
    my $json_res = eval {
        decode_json($res->decoded_content);
    };
    if ($@) {
        croak "Can't parse respone '" . $res->decoded_content . "' to json";
    }

    # Get json response
    my $response = $json_res->{response};
    if ($response->{result} ne 'Success') {
        croak "checkUploadFile() not success";
    }

    # Limit exceeded
    if ($response->{storage_limit_exceeded} ne 'no') {
        croak "Can't checkUploadFile. Storage limit exceeded";
    }

    my $file_key = $response->{preemptive_quickkey} // $response->{duplicate_quickkey};
    $self->{file}->key($file_key);
    $self->{upload_url} = $response->{upload_url}->{resumable};
    return $response;
};

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

    my $url = 'https://www.mediafire.com/api/1.5/upload/instant.php';

    my @sec = gettimeofday();
    my $microseconds = substr(join('', @sec), 0, 13);

    my %param = (
        'hash'              => $self->{file}->hash,
        'size'              => $self->{file}->size,
        'filename'          => $self->{file}->name,
        'folder_key'        => $self->{path},
        'session_token'     => $self->{session_token},
        'response_format'   => 'json',
        $microseconds       => '',
    );

    my $param_str = join('&', map {"$_=" . uri_escape($param{$_})} keys %param);
    my $full_url = $url . '?' . $param_str;
    my $res = $self->{ua}->get($full_url);
    my $code = $res->code;
    if ($code ne '200') {
        croak "Wrong response code checkUploadFile(). Url: '$full_url'. Code: $code";
    }
    my $json_res = eval {
        decode_json($res->decoded_content);
    };
    if ($@) {
        croak "Can't parse respone '" . $res->decoded_content . "' to json";
    }

    # Get json response
    my $response = $json_res->{response};
    if ($response->{result} ne 'Success') {
        croak "getFileFromCache() not success";
    }
    my $file_key = $response->{quickkey};
    $self->{file}->key($file_key);

    return 1;
};

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

    my $ua = $self->{ua};
    my $url = 'https://ul.mediafireuserupload.com/api/1.5/upload/resumable.php';
    my %param = (
        'session_token'             => $self->{session_token},
        'uploadkey'                 => $self->{path},
        'response_format'           => 'json',
    );

    my $headers = [
        'Access-Control-Request-Method'         => 'POST',
        'Origin'                                => 'https://www.mediafire.com',
        'Access-Control-Request-Headers'        => 'content-type,x-filehash,x-filename,x-filesize,x-filetype,x-unit-hash,x-unit-id,x-unit-size',
        'Accept'                                => '*/*',
        'Accept-Encoding'                       => 'gzip, deflate, br',
        'Accept-Language'                       => 'ru-RU,ru;q=0.9,en-US;q=0.8,en;q=0.7',
    ];
    my $param_str = join('&', map {"$_=" . uri_escape($param{$_})} keys %param);
    my $full_url = $url . '?' . $param_str;
    my $request = HTTP::Request->new('OPTIONS', $full_url, $headers);
    my $res = $ua->request($request);
    my $code = $res->code;
    if ($code ne '200') {
        croak "Wrong response code on url: '$full_url'. Code: $code";
    }

    return 1;

};

# Upload file
$uploadF = sub {
    my ($self) = @_;

    my $upload_file     = $self->{upload_file};

    my %param = (
        'session_token'         => $self->{session_token},
        'uploadkey'             => $self->{path},
        'response_format'       => 'json',
    );
    my $param_str = join('&', map {"$_=" . uri_escape($param{$_})} keys %param);
    my $url = $self->{upload_url} . '?' . $param_str;

    my $unit_id = 0;
    my $filebuf;
    open my $FH, "<$upload_file" or croak "Can't open $upload_file $!";
    binmode $FH;

    my $json_res;
    while (my $bytes = read($FH, $filebuf, $self->{buff_size})) {
        my $unit_hash = sha256_hex($filebuf);
        my @headers = (
            "Accept"            => "*/*",
            "Accept-Language"   => "ru-RU,ru;q=0.9,en-US;q=0.8,en;q=0.7",
            "Accept-Encoding"   => "gzip, deflate, br",
            "Content-Type"      => "application/octet-stream",
            "Referer"           => "https://www.mediafire.com/uploads",
            "Origin"            => "https://www.mediafire.com",
            "X-Filesize"        => $self->{file}->size,
            "X-Filename"        => $self->{file}->name,
            "X-Filetype"        => $getMimeType->($self->{file}->name),
            "X-Filehash"        => $self->{file}->hash,
            "X-Unit-Hash"       => $unit_hash,
            "X-Unit-Size"       => $bytes,
            "X-Unit-Id"         => $unit_id,
            "Content"           => $filebuf,
                    );
        my $res = $self->{ua}->post($url, @headers);
        my $code = $res->code;
        if ($code ne '200') {
            croak "Wrong response code on request to url '$url'. Code: '$code'";
        }

        $json_res = eval {
            decode_json($res->decoded_content);
        };
        if ($@) {
            croak "Can't decode response to json. Response: '" . $res->decoded_content . "'";
        }

        if ($json_res->{response}->{result} ne 'Success') {
            croak "Response on url '$url' not success";
        }

        # Check all units ready
        if ($json_res->{response}->{resumable_upload}->{all_units_ready} eq 'yes') {
            last;
        }

        ++$unit_id;
    }
    close $FH;

    # Check all units ready
    if ($json_res->{response}->{resumable_upload}->{all_units_ready} ne 'yes') {
        croak "Not all parts of file '$upload_file' uploaded. Wrong answer from server";
    }

    return 1;
};

$getMimeType = sub {
    my ($fname) = @_;
    my $default_mime = 'application/zip';
    my $mime = MIME::Detect->new();
    my @types = $mime->mime_types_from_name($fname);
    if (@types) {
        return $types[0]->mime_type;
    }
    return $default_mime;
};

########################################################################################


sub new {
    my ($class, %opt) = @_;
    my $self = {};
    $self->{ua}             = $opt{-ua}                 // croak "You must specify param '-ua' for method new";
    $self->{session_token}  = $opt{-session_token}      // croak "You must specify '-session_token' param";
    $self->{buff_size}      = $opt{-buff_size}          // $DEFAULT_BUFF_SIZE;
    bless $self, $class;
    return $self;
}

sub uploadFile {
    my ($self, %opt)            = @_;

    $self->{upload_file}        = $opt{'-file'} || croak "You must specify -file param for method uploadFile";
    $self->{path}               = $opt{'-path'} || 'myfiles';


    if (not -f $self->{upload_file}) {
        croak "File '" . $self->{upload_file} . "' not exists";
    }

    $self->{file} = Mediafire::Api::File->new(
        -size               => -s $self->{upload_file},
        -name               => basename($self->{upload_file}),
        -hash               => $getSha256Sum->($self->{upload_file}),
    );


    # Get upload url
    my $response = $self->$checkUploadFile();
    if ($response->{hash_exists} eq 'yes') {
        # No need upload file. Get file from cache
        $self->$getFileFromCache();
    }
    else {
        # Upload file
        $self->$checkResumeUpload();
        $self->$uploadF();
    }

    # Check exists file key
    if (not defined($self->{file}->key)) {
        croak "Key of upload file '$self->{upload_file}' not exists. Error on upload file to server";
    }

    return $self->{file};
}




1;