SyncWithGeneanum::handle() - Code Metrics - familytree365/backend - Measure and Improve Code Quality continuously with Scrutinizer

SyncWithGeneanum::handle() B
last analyzed 2021-05-16 05:53 UTC

↳ Parent: SyncWithGeneanum

Complexity

Conditions	5
Paths	9

Size

Total Lines	65
Code Lines	50

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
eloc	50
c	1
b	0
f	0
dl	0
loc	65
rs	8.7797
cc	5
nc	9
nop	0

How to fix Long Method

<?php

namespace App\Jobs;

use App\Models\Geneanum;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldBeUnique;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Http;
use Spatie\Multitenancy\Jobs\NotTenantAware;

class SyncWithGeneanum implements ShouldQueue, NotTenantAware
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;


    private const URL = 'http://static.geneanum.com/libs/grid/malte_bapteme.php?annee_limite=75&_search=false&nd=%s&rows=100&page=%s&sidx=Nom_Baptise&sord=asc';
    private const MAX_RETRY = 3;

    private $current_page;
    private $retry;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct(int $page = 1, int $retry = 0)
    {
        $this->current_page = $page;
        $this->retry        = $retry;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        $url = sprintf(self::URL, time() - mt_rand(1, 30), $this->current_page);

        $response = Http::get($url);

        if ($response->failed()) {
            if (++$this->retry > self::MAX_RETRY) {
                return;
            }

            dispatch(new SyncWithGeneanum($this->current_page, $this->retry));
        }

        $result = $response->json();

        $has_more_result = $result['total'] > $result['page'];
        if ($has_more_result) {
            dispatch(new SyncWithGeneanum(++$this->current_page))
                ->delay(now()->addSeconds(mt_rand(10, 60)));
        }

        $rows = $result['rows'];

        foreach ($rows as $row) {
            $remote_id = $row['id'];
            [
                $date,
                $name,
                $first_name,
                $sex,
                $father_first_name,
                $father_is_dead,
                $mother_name,
                $mother_first_name,
                $mother_is_dead,
                $observation1,
                $observation2,
                $observation3,
                $observation4,
                $officer,
                $parish,
                $source,
                $update,
            ] = $row['cell'];

            Geneanum::updateOrCreate(['remote_id' => $remote_id],
                [
                    'date'              => $date,
                    'name'              => $name,
                    'first_name'        => $first_name,
                    'sex'               => $sex,
                    'father_first_name' => $father_first_name,
                    'father_is_dead'    => $father_is_dead,
                    'mother_name'       => $mother_name,
                    'mother_first_name' => $mother_first_name,
                    'mother_is_dead'    => $mother_is_dead,
                    'observation1'      => $observation1,
                    'observation2'      => $observation2,
                    'observation3'      => $observation3,
                    'observation4'      => $observation4,
                    'officer'           => $officer,
                    'parish'            => $parish,
                    'source'            => $source,
                    'update'            => $update,
                ]);
        }

    }
}


1			<?php
2
3			namespace App\Jobs;
4
5			use App\Models\Geneanum;
6			use Illuminate\Bus\Queueable;
7			use Illuminate\Contracts\Queue\ShouldBeUnique;
8			use Illuminate\Contracts\Queue\ShouldQueue;
9			use Illuminate\Foundation\Bus\Dispatchable;
10			use Illuminate\Queue\InteractsWithQueue;
11			use Illuminate\Queue\SerializesModels;
12			use Illuminate\Support\Facades\Http;
13			use Spatie\Multitenancy\Jobs\NotTenantAware;
14
15			class SyncWithGeneanum implements ShouldQueue, NotTenantAware
16			{
17			use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
			0 ignored issues – show introduced 2021-05-14 15:28 UTC by Report Bug Copy Issue Report The trait `Illuminate\Queue\SerializesModels` requires some properties which are not provided by `App\Jobs\SyncWithGeneanum`: `$id`, `$relations`, `$class`, `$keyBy` Loading history...
18
19			private const URL = 'http://static.geneanum.com/libs/grid/malte_bapteme.php?annee_limite=75&_search=false&nd=%s&rows=100&page=%s&sidx=Nom_Baptise&sord=asc';
20			private const MAX_RETRY = 3;
21
22			private $current_page;
23			private $retry;
24
25			/**
26			* Create a new job instance.
27			*
28			* @return void
29			*/
30			public function __construct(int $page = 1, int $retry = 0)
31			{
32			$this->current_page = $page;
33			$this->retry = $retry;
34			}
35
36			/**
37			* Execute the job.
38			*
39			* @return void
40			*/
41			public function handle()
42			{
43			$url = sprintf(self::URL, time() - mt_rand(1, 30), $this->current_page);
44
45			$response = Http::get($url);
46
47			if ($response->failed()) {
48			if (++$this->retry > self::MAX_RETRY) {
49			return;
50			}
51
52			dispatch(new SyncWithGeneanum($this->current_page, $this->retry));
53			}
54
55			$result = $response->json();
56
57			$has_more_result = $result['total'] > $result['page'];
58			if ($has_more_result) {
59			dispatch(new SyncWithGeneanum(++$this->current_page))
60			->delay(now()->addSeconds(mt_rand(10, 60)));
61			}
62
63			$rows = $result['rows'];
64
65			foreach ($rows as $row) {
66			$remote_id = $row['id'];
67			[
68			$date,
69			$name,
70			$first_name,
71			$sex,
72			$father_first_name,
73			$father_is_dead,
74			$mother_name,
75			$mother_first_name,
76			$mother_is_dead,
77			$observation1,
78			$observation2,
79			$observation3,
80			$observation4,
81			$officer,
82			$parish,
83			$source,
84			$update,
85			] = $row['cell'];
86
87			Geneanum::updateOrCreate(['remote_id' => $remote_id],
88			[
89			'date' => $date,
90			'name' => $name,
91			'first_name' => $first_name,
92			'sex' => $sex,
93			'father_first_name' => $father_first_name,
94			'father_is_dead' => $father_is_dead,
95			'mother_name' => $mother_name,
96			'mother_first_name' => $mother_first_name,
97			'mother_is_dead' => $mother_is_dead,
98			'observation1' => $observation1,
99			'observation2' => $observation2,
100			'observation3' => $observation3,
101			'observation4' => $observation4,
102			'officer' => $officer,
103			'parish' => $parish,
104			'source' => $source,
105			'update' => $update,
106			]);
107			}
108
109			}
110			}
111

familytree365 / backend

SyncWithGeneanum::handle() B last analyzed 2021-05-16 05:53 UTC

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like

SyncWithGeneanum::handle() B
last analyzed 2021-05-16 05:53 UTC