UNIT3D-Community-Edition/app/Console/Commands/AutoWarning.php

<?php

declare(strict_types=1);

/**
 * 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\Console\Commands;

use App\Models\History;
use App\Models\User;
use App\Models\Warning;
use App\Notifications\UserWarning;
use App\Services\Unit3dAnnounce;
use Illuminate\Support\Carbon;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;
use Exception;
use Throwable;

class AutoWarning extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'auto:warning';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Automatically Post Warnings To Users Accounts and Warnings Table';

    /**
     * Execute the console command.
     *
     * @throws Exception|Throwable If there is an error during the execution of the command.
     */
    final public function handle(): void
    {
        if (config('hitrun.enabled') !== true) {
            return;
        }

        $carbon = new Carbon();
        $hitrun = History::with(['user', 'torrent'])
            ->where('actual_downloaded', '>', 0)
            ->where('prewarned_at', '<=', now()->subDays(config('hitrun.prewarn')))
            ->where('hitrun', '=', 0)
            ->where('immune', '=', 0)
            ->where('active', '=', 0)
            ->where('seedtime', '<', config('hitrun.seedtime'))
            ->where('updated_at', '<', $carbon->copy()->subDays(config('hitrun.grace')))
            ->get();

        $usersWithWarnings = [];

        foreach ($hitrun as $hr) {
            if (!$hr->user->group->is_immune && $hr->actual_downloaded > ($hr->torrent->size * (config('hitrun.buffer') / 100))) {
                $exsist = Warning::withTrashed()
                    ->where('torrent', '=', $hr->torrent->id)
                    ->where('user_id', '=', $hr->user->id)
                    ->first();

                // Insert Warning Into Warnings Table if doesnt already exsist
                if ($exsist === null) {
                    $warning = Warning::create([
                        'user_id'    => $hr->user->id,
                        'warned_by'  => User::SYSTEM_USER_ID,
                        'torrent'    => $hr->torrent->id,
                        'reason'     => \sprintf('Hit and Run Warning For Torrent %s', $hr->torrent->name),
                        'expires_on' => $carbon->copy()->addDays(config('hitrun.expire')),
                        'active'     => true,
                    ]);

                    History::query()
                        ->where('torrent_id', '=', $hr->torrent_id)
                        ->where('user_id', '=', $hr->user_id)
                        ->update([
                            'hitrun'     => true,
                            'updated_at' => DB::raw('updated_at'),
                        ]);

                    // Add +1 To Users Warnings Count In Users Table
                    $hr->user->increment('hitandruns');

                    // Add user to usersWithWarnings array
                    $usersWithWarnings[$hr->user->id] = $hr->user;
                }
            }
        }

        // Send a single notification for each user with warnings
        foreach ($usersWithWarnings as $user) {
            $user->notify(new UserWarning($user));
        }

        // Calculate User Warning Count and Disable DL Priv If Required.
        $warnings = Warning::with('warneduser')->select(DB::raw('user_id, count(*) as value'))->where('active', '=', 1)->groupBy('user_id')->having('value', '>=', config('hitrun.max_warnings'))->get();

        foreach ($warnings as $warning) {
            if ($warning->warneduser->can_download) {
                $warning->warneduser->update(['can_download' => 0]);

                cache()->forget('user:'.$warning->warneduser->passkey);
                Unit3dAnnounce::addUser($warning->warneduser);
            }
        }

        $this->comment('Automated User Warning Command Complete');
    }
}