App\Services\CollectionCleanupService

Complexity

Total Complexity

12

Size/Duplication

Total Lines	102
Duplicated Lines	0 %

Importance

Changes	2
Bugs	1	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
C	deleteFinishedAndOrphans()	0	90	11
A	__construct()	0	3	1

<?php

namespace App\Services;

use App\Models\Collection;
use App\Models\Settings;
use Blacklight\ColorCLI;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Str;

class CollectionCleanupService
{
    public function __construct(
        private readonly ColorCLI $colorCLI
    ) {}

    /**
     * Deletes finished/old collections, cleans orphans, and removes collections missed after NZB creation.
     * Mirrors the previous ProcessReleases::deleteCollections logic.
     *
     * @return int total deleted rows across operations (approximate)
     */
    public function deleteFinishedAndOrphans(bool $echoCLI): int
    {
        $startTime = now()->toImmutable();
        $deletedCount = 0;

        if ($echoCLI) {
            echo $this->colorCLI->header('Process Releases -> Delete finished collections.'.PHP_EOL).

Are you sure the usage of $this->colorCLI->header('Process Releases -> Delete finished collections.' . App\Services\PHP_EOL) targeting Blacklight\ColorCLI::header() seems to always return null.

Are you sure $this->colorCLI->header('Process Releases -> Delete finished collections.' . App\Services\PHP_EOL) of type void can be used in concatenation?

                $this->colorCLI->primary(sprintf(

Are you sure the usage of $this->colorCLI->primary(sprintf('Deleting collections/binaries/parts older than %d hours.', App\Models\Settings::settingValue('partretentionhours')), true) targeting Blacklight\ColorCLI::primary() seems to always return null.

                    'Deleting collections/binaries/parts older than %d hours.',
                    Settings::settingValue('partretentionhours')
                ), true);
        }

        DB::transaction(function () use (&$deletedCount, $startTime, $echoCLI) {
            $deleted = 0;
            $deleteQuery = Collection::query()
                ->where('dateadded', '<', now()->subHours(Settings::settingValue('partretentionhours')))
                ->delete();
            if ($deleteQuery > 0) {
                $deleted = $deleteQuery;
                $deletedCount += $deleted;
            }
            $firstQuery = $fourthQuery = now();

            $totalTime = $firstQuery->diffInSeconds($startTime, true);

            if ($echoCLI) {
                $this->colorCLI->primary(
                    'Finished deleting '.$deleted.' old collections/binaries/parts in '.
                    $totalTime.Str::plural(' second', $totalTime),
                    true
                );
            }

            if (random_int(0, 200) <= 1) {
                if ($echoCLI) {
                    echo $this->colorCLI->header('Process Releases -> Remove CBP orphans.'.PHP_EOL).

Are you sure $this->colorCLI->header('Process Releases -> Remove CBP orphans.' . App\Services\PHP_EOL) of type void can be used in concatenation?

Are you sure the usage of $this->colorCLI->header('Process Releases -> Remove CBP orphans.' . App\Services\PHP_EOL) targeting Blacklight\ColorCLI::header() seems to always return null.

                        $this->colorCLI->primary('Deleting orphaned collections.');

Are you sure the usage of $this->colorCLI->primary('Deleting orphaned collections.') targeting Blacklight\ColorCLI::primary() seems to always return null.

                }

                $deleted = 0;
                $deleteQuery = Collection::query()
                    ->whereNull('binaries.id')
                    ->orWhereNull('parts.binaries_id')
                    ->leftJoin('binaries', 'collections.id', '=', 'binaries.collections_id')
                    ->leftJoin('parts', 'binaries.id', '=', 'parts.binaries_id')
                    ->delete();

                if ($deleteQuery > 0) {
                    $deleted = $deleteQuery;
                    $deletedCount += $deleted;
                }

                $totalTime = now()->diffInSeconds($firstQuery);

                if ($echoCLI) {
                    $this->colorCLI->primary('Finished deleting '.$deleted.' orphaned collections in '.$totalTime.Str::plural(' second', $totalTime), true);
                }
            }

            if ($echoCLI) {
                $this->colorCLI->primary('Deleting collections that were missed after NZB creation.', true);
            }

            $deleted = 0;
            $collections = Collection::query()
                ->where('releases.nzbstatus', '=', 1)
                ->leftJoin('releases', 'releases.id', '=', 'collections.releases_id')
                ->select('collections.id')
                ->get();

            foreach ($collections as $collection) {
                $deleted++;
                Collection::query()->where('id', $collection->id)->delete();
            }
            $deletedCount += $deleted;

            $colDelTime = now()->diffInSeconds($fourthQuery, true);
            $totalTime = $fourthQuery->diffInSeconds($startTime, true);

            if ($echoCLI) {
                $this->colorCLI->primary(
                    'Finished deleting '.$deleted.' collections missed after NZB creation in '.$colDelTime.Str::plural(' second', $colDelTime).
                    PHP_EOL.'Removed '.number_format($deletedCount).' parts/binaries/collection rows in '.$totalTime.Str::plural(' second', $totalTime),
                    true
                );
            }
        }, 10);

        return $deletedCount;
    }
}