Syncer::incrementStats() - Code Metrics - 24Slides/auth-connector - Measure and Improve Code Quality continuously with Scrutinizer

Syncer::incrementStats() A
last analyzed 2020-10-26 19:06 UTC

↳ Parent: Syncer
Complexity

Conditions	1
Paths	1
Size

Total Lines	5
Code Lines	2
Duplication

Lines	0
Ratio	0 %
Code Coverage

Tests	0
CRAP Score	2
Importance

Changes	1
Bugs	0	Features	0
Metric	Value
cc	1
eloc	2
c	1
b	0
f	0
nc	1
nop	1
dl	0
loc	5
rs	10
ccs	0
cts	3
cp	0
crap	2
<?php

namespace Slides\Connector\Auth\Sync;

use Illuminate\Support\Arr;
use Illuminate\Support\Collection;
use Slides\Connector\Auth\Sync\Syncable as LocalUser;
use Slides\Connector\Auth\Sync\User as RemoteUser;
use Slides\Connector\Auth\Client;
use Slides\Connector\Auth\AuthService;

/**
 * Class Syncer
 *
 * @package Slides\Connector\Auth\Sync
 */
class Syncer
{
    use HandlesActions,
        ExportsUsers,
        ImportsUsers;

    /**
     * Number of users which can be sent per request
     */
    const USERS_PER_REQUEST = 5000;

    /**
     * Synchronization modes.
     *
     * `passwords` — allows updating passwords locally and remotely.
     * `users` — allows syncing specific users only.
     */
    const MODE_PASSWORDS = 'passwords';
    const MODE_USERS = 'users';

    /**
     * The authentication service.
     *
     * @var AuthService
     */
    protected $authService;

    /**
     * Authentication Service client.
     *
     * @var Client
     */
    protected $client;

    /**
     * The local users for syncing remotely.
     *
     * @var LocalUser[]|Collection
     */
    protected $locals;

    /**
     * The remote users fetched.
     *
     * @var RemoteUser[]|Collection
     */
    protected $foreigners;

    /**
     * The sync modes.
     *
     * @var array
     */
    protected $modes;

    /**
     * The remote statistics.
     *
     * @var array
     */
    protected $remoteStats = [
        'created' => 0,
        'updated' => 0,
        'deleted' => 0
    ];

    /**
     * The local statistics.
     *
     * @var array
     */
    protected $localStats = [
        'created' => 0,
        'updated' => 0,
        'deleted' => 0
    ];

    /**
     * Output messages.
     *
     * @var array
     */
    protected $output = [];

    /**
     * The callback called on adding a message to the output.
     *
     * @var \Closure
     */
    protected $outputCallback;

    /**
     * Syncer constructor.
     *
     * @param LocalUser[]|Collection|null $locals
     * @param array $modes
     * @param Client|null $client
     */
    public function __construct(Collection $locals = null, array $modes = [], Client $client = null)
    {
        $this->locals = $locals ?? collect();
        $this->foreigners = collect();
        $this->modes = $modes;
        $this->client = $client ?? new Client();
        $this->authService = app('authService');
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}
    }

    /**
     * Synchronize local users remotely and apply changes.
     *
     * @return void
     */
    public function sync()
    {
        $iterator = new UserGroupsIterator($this->locals, static::USERS_PER_REQUEST);

        $this->outputMessage('Total requests: ' . $iterator->requestsCount());

        /** @var LocalUser[]|Collection $users */
        foreach ($iterator as $users) {
            $this->outputMessage('Sending a request with bunch of ' . $users->count() . ' users');

            $response = $this->client->request('sync', [
                'users' => $this->formatLocals($users),
                'modes' => $this->modes
            ]);

            $this->outputMessage('Parsing a response...');

            $this->parseResponse($response);
        }

        $this->outputMessage("Applying {$this->foreigners->count()} remote changes locally");

        $this->apply();
    }

    /**
     * Parse a response.
     *
     * @param array $response
     */
    protected function parseResponse(array $response)
    {
        $foreigners = array_map(function (array $user) {
            return $this->createRemoteUserFromResponse($user);
        }, Arr::get($response, 'difference'));
        }, /** @scrutinizer ignore-type */ Arr::get($response, 'difference'));

        $this->mergeRemoteStats($remoteStats = Arr::get($response, 'stats'));
        $this->mergeRemoteStats(/** @scrutinizer ignore-type */ $remoteStats = Arr::get($response, 'stats'));

        $this->outputMessage(
            'Remote affection:'
            . ' created ' . $remoteStats['created']
            . ', updated ' . $remoteStats['updated']
            . ', deleted ' . $remoteStats['deleted']
        );

        $this->foreigners = $this->foreigners->merge($foreigners);
    }

    /**
     * Apply changes locally from the given response.
     *
     * @return void
     */
    public function apply()
    {
        $count = $this->getForeignersCount();

        foreach ($this->foreigners as $index => $foreigner) {
            $index++;

            $this->outputMessage(
                "[$index of $count] Handling the action \"" . $foreigner->getRemoteAction() . '"'
                    . ' of ' . $foreigner->getName()
                    . ' (' . $foreigner->getEmail() . ')'
            );

            try {
                $this->handleAction(
                    $foreigner,
                    $action = $foreigner->getRemoteAction()
                );
            }
            catch(\Slides\Connector\Auth\Exceptions\SyncException $e) {
                \Illuminate\Support\Facades\Log::error(
                    "Cannot $action the user {$foreigner->getEmail()}: " . $e->getMessage()
                );
            }
        }
    }

    /**
     * Format local users for a request payload.
     *
     * @param Collection $locals
     *
     * @return array
     */
    private function formatLocals(Collection $locals)
    {
        return $locals
            ->map(function(Syncable $user) {
                return [
                    'id' => $user->retrieveId(),
                    'remoteId' => $user->retrieveRemoteId(),
                    'name' => $user->retrieveName(),
                    'email' => $user->retrieveEmail(),
                    'password' => $user->retrievePassword(),
                    'country' => $user->retrieveCountry(),
                    'created_at' => $user->retrieveCreatedAt()->toDateTimeString(),
                    'updated_at' => $user->retrieveUpdatedAt()->toDateTimeString(),
                    'deleted_at' => $user->retrieveDeletedAt()
                        ? $user->retrieveDeletedAt()->toDateTimeString()
                        : null
                ];
            })
            ->toArray();
    }

    /**
     * Create a remote user from the response.
     *
     * @param array $user
     *
     * @return User
     */
    public function createRemoteUserFromResponse(array $user)
    {
        return new RemoteUser(
            Arr::get($user, 'id'),
            /** @scrutinizer ignore-type */ Arr::get($user, 'id'),
            Arr::get($user, 'name'),
            Arr::get($user, 'email'),
            /** @scrutinizer ignore-type */ Arr::get($user, 'email'),
            Arr::get($user, 'password'),
            Arr::get($user, 'updated_at'),
            Arr::get($user, 'created_at'),
            /** @scrutinizer ignore-type */ Arr::get($user, 'created_at'),
            Arr::get($user, 'deleted_at'),
            Arr::get($user, 'country'),
            Arr::get($user, 'action')
        );
    }

    /**
     * Check whether a mode is passed.
     *
     * @param string $mode
     *
     * @return bool
     */
    public function hasMode(string $mode): bool
    {
        return array_key_exists($mode, $this->modes);
    }

    /**
     * Get passed modes.
     *
     * @return array
     */
    public function getModes(): array
    {
        return $this->modes;
    }

    /**
     * Check if there are difference detected by remote service.
     *
     * @return bool
     */
    public function hasDifference(): bool
    {
        return $this->foreigners->isNotEmpty();
    }

    /**
     * Get the local stats.
     *
     * @return array
     */
    public function getLocalStats(): array
    {
        return $this->localStats;
    }

    /**
     * Get the remote stats.
     *
     * @return array
     */
    public function getRemoteStats(): array
    {
        return $this->remoteStats;
    }

    /**
     * Set remote users.
     *
     * @param Collection|RemoteUser[] $foreigners
     */
    public function setForeigners(Collection $foreigners): void
    {
        $this->foreigners = $foreigners;
    }

    /**
     * Get number of foreign users.
     *
     * @return int
     */
    public function getForeignersCount(): int
    {
        return $this->foreigners->count();
    }

    /**
     * Retrieve all local users.
     *
     * @return Collection
     */
    public static function retrieveLocals(): Collection
    {
        return \Illuminate\Support\Facades\Auth::getProvider()->createModel()
            ->newQuery()
            ->get();
    }

    /**
     * Merge the remote stats.
     *
     * @param array $stats
     */
    private function mergeRemoteStats(array $stats)
    {
        $this->remoteStats['created'] += $stats['created'];
        $this->remoteStats['updated'] += $stats['updated'];
        $this->remoteStats['deleted'] += $stats['deleted'];
    }

    /**
     * Add a message to the output
     *
     * @param string $message
     *
     * @return void
     */
    private function outputMessage(string $message)
    {
        $output[] = $message;


        if($this->outputCallback instanceof \Closure) {

            call_user_func($this->outputCallback, $message);
        }
    }

    /**
     * Set a callback which should be called on adding output message.
     *
     * @param \Closure $outputCallback
     *
     * @return void
     */
    public function setOutputCallback(\Closure $outputCallback): void
    {
        $this->outputCallback = $outputCallback;
    }

    /**
     * Increment a local stats value.
     *
     * @param string $key
     */
    protected function incrementStats(string $key)
    {
        $value = Arr::get($this->localStats, $key, 0);

        $this->localStats[$key] = ++$value;
    }
}
24Slides / auth-connector

Syncer::incrementStats() A last analyzed 2020-10-26 19:06 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

Syncer::incrementStats() A
last analyzed 2020-10-26 19:06 UTC
