mirror of
https://github.com/HDInnovations/UNIT3D-Community-Edition.git
synced 2026-02-13 23:19:55 -06:00
138 lines
4.0 KiB
PHP
138 lines
4.0 KiB
PHP
<?php
|
|
/**
|
|
* NOTICE OF LICENSE.
|
|
*
|
|
* UNIT3D Community Edition is open-sourced software licensed under the GNU Affero General Public License v3.0
|
|
* The details is bundled with this project in the file LICENSE.txt.
|
|
*
|
|
* @project UNIT3D Community Edition
|
|
*
|
|
* @author HDVinnie <hdinnovations@protonmail.com>
|
|
* @license https://www.gnu.org/licenses/agpl-3.0.en.html/ GNU Affero General Public License v3.0
|
|
*/
|
|
|
|
namespace App\Jobs;
|
|
|
|
use Carbon\Carbon;
|
|
use App\Models\Peer;
|
|
use App\Models\User;
|
|
use App\Models\Group;
|
|
use App\Models\History;
|
|
use App\Models\Torrent;
|
|
use App\Helpers\Bencode;
|
|
use Illuminate\Bus\Queueable;
|
|
use App\Models\FreeleechToken;
|
|
use App\Models\PersonalFreeleech;
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
|
use Illuminate\Foundation\Bus\Dispatchable;
|
|
use Illuminate\Queue\InteractsWithQueue;
|
|
use Illuminate\Queue\SerializesModels;
|
|
|
|
class ProcessStartedAnnounceRequest implements ShouldQueue
|
|
{
|
|
use Dispatchable;
|
|
use InteractsWithQueue;
|
|
use Queueable;
|
|
use SerializesModels;
|
|
|
|
protected $queries;
|
|
|
|
protected $user;
|
|
|
|
protected $torrent;
|
|
|
|
/**
|
|
* The number of times the job may be attempted.
|
|
*
|
|
* @var int
|
|
*/
|
|
public $tries = 3;
|
|
|
|
/**
|
|
* ProcessAnnounceRequest constructor.
|
|
*
|
|
* @param $queries
|
|
* @param \App\Models\User $user
|
|
* @param \App\Models\Torrent $torrent
|
|
*/
|
|
public function __construct($queries, User $user, Torrent $torrent)
|
|
{
|
|
$this->queries = $queries;
|
|
$this->user = $user;
|
|
$this->torrent = $torrent;
|
|
}
|
|
|
|
/**
|
|
* Execute the job.
|
|
*
|
|
* @return void
|
|
* @throws \Exception
|
|
*/
|
|
public function handle()
|
|
{
|
|
$bin2hex_hash = bin2hex($this->queries['info_hash']);
|
|
|
|
if ($this->attempts() > 2) {
|
|
$this->delay(min(30 * $this->attempts(), 300));
|
|
}
|
|
|
|
// Get The Current Peer
|
|
$peer = Peer::where('torrent_id', '=', $this->torrent->id)
|
|
->where('peer_id', $this->queries['peer_id'])
|
|
->where('user_id', '=', $this->user->id)
|
|
->first();
|
|
|
|
// Creates a new peer if not existing
|
|
if ($peer === null) {
|
|
if ($this->queries['uploaded'] > 0 || $this->queries['downloaded'] > 0) {
|
|
$ghost = true;
|
|
$this->queries['event'] = 'started';
|
|
}
|
|
$peer = new Peer();
|
|
}
|
|
|
|
// Get history information
|
|
$history = History::where('info_hash', '=', $bin2hex_hash)->where('user_id', '=', $this->user->id)->first();
|
|
|
|
// If no History record found then create one
|
|
if ($history === null) {
|
|
$history = new History();
|
|
$history->user_id = $this->user->id;
|
|
$history->info_hash = $bin2hex_hash;
|
|
}
|
|
|
|
$real_uploaded = $this->queries['uploaded'];
|
|
$real_downloaded = $this->queries['downloaded'];
|
|
|
|
// Peer Update
|
|
$peer->peer_id = $this->queries['peer_id'];
|
|
$peer->md5_peer_id = md5($this->queries['peer_id']);
|
|
$peer->info_hash = $bin2hex_hash;
|
|
$peer->ip = $this->queries['ip-address'];
|
|
$peer->port = $this->queries['port'];
|
|
$peer->agent = $this->queries['user-agent'];
|
|
$peer->uploaded = $real_uploaded;
|
|
$peer->downloaded = $real_downloaded;
|
|
$peer->seeder = $this->queries['left'] == 0;
|
|
$peer->left = $this->queries['left'];
|
|
$peer->torrent_id = $this->torrent->id;
|
|
$peer->user_id = $this->user->id;
|
|
$peer->save();
|
|
// End Peer Update
|
|
|
|
// History Update
|
|
$history->agent = $this->queries['user-agent'];
|
|
$history->active = 1;
|
|
$history->seeder = $this->queries['left'] == 0;
|
|
$history->immune = $this->user->group->is_immune == 1;
|
|
$history->uploaded += 0;
|
|
$history->actual_uploaded += 0;
|
|
$history->client_uploaded = $real_uploaded;
|
|
$history->downloaded += 0;
|
|
$history->actual_downloaded += 0;
|
|
$history->client_downloaded = $real_downloaded;
|
|
$history->save();
|
|
// End History Update
|
|
}
|
|
}
|