cerbero90 / command-validator Goto Github PK

<?php

namespace App\Console\Commands;

use App\Models\Toggl\TogglTimeEntry;
use App\Models\Toggl\TogglUser;
use App\Models\User\User;
use Carbon\Carbon;
use Cerbero\CommandValidator\ValidatesInput;
use Illuminate\Console\Command;

class TogglPullTimeEntries extends Command
{
    use ValidatesInput;

    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'toggl:pulltimeentries
        {users? : (optional) Comma-separated list of user IDs to be synced, default is all Toggl users.},
        {--S|since= : Start date for range to be synced, default is the most recent sync date in existing records for each user.},
        {--U|until= : End date for range to be synced, default is today.},
        {--P|page= : Toggl API data page number to start retrieval. If not defined, all pages within the scope will be retrieved starting with page 1.},
        {--Q|queued : Perform action asynchronously with use of Laravel\'s Jobs feature.},
        {--N|noNextPage : Do not pull the next page in the data set.}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Pull activity entries from Toggl to local via API.';

    protected function rules()
    {
        return [
            //users regex expression is for comma-separated list of numbers
            'users' => 'regex:/^\s*\d+(\s*,+\s*\d+)*\s*$/',
            'since' => 'date_format:Y-m-d',
            'until' => 'date_format:Y-m-d',
            'page' => 'integer',
            'queued' => 'boolean',
            'noNextPage' => 'boolean'
        ];
    }

    protected function messages()
    {
        return [
            'users.regex' => '\'Users\' argument must be an integer or comma-separated list of integers representing Users with related Toggl account.'
        ];
    }

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        if (!\Config::get('toggl.enabled')) {
            $this->error('Toggl API function is disabled');
            return;
        }

        $users = $this->argument('users');

        $query = User::query()->whereHas('toggl', function($q) {
            $q->where('membership_status', TogglUser::WORKSPACE_STATUS_MEMBER);
        });
        if($users !== null) {
            $query = $query->whereIn('id', explode(',', str_replace(' ', '', $users)));
        }

        $usersList = $query->get();

        $params = [];



        if($usersList->count() > 0) {
            if($this->option('queued')) {
                foreach ($usersList as $user) {
                    /** @var User $user */
                    $user->getTogglTimeEntriesJob(Carbon::parse($this->option('since')), Carbon::parse($this->option('until')), $this->option('page'), !is_null($this->option('noNextPage')));
                }

                $this->line('Toggl time entries retrieval queued for ' . $usersList->count() . ' users.');
            } else {
                if ($this->option('since') !== null)
                    $params['since'] = Carbon::parse($this->option('since'))->toDateString();
                if ($this->option('until') !== null)
                    $params['until'] = Carbon::parse($this->option('until'))->toDateString();
                if ($this->option('page') !== null)
                    $params['page'] = $this->option('page');
                $doNextPage = !is_null($this->option('noNextPage'));

                $this->line('Beginning Toggl API time entries fetch for ' . $usersList->count() . ' users...');
                $progressBar = $this->output->createProgressBar(count($usersList));

                foreach ($usersList as $user) {
                    /** @var User $user */
                    TogglTimeEntry::fetch($user, $params, $doNextPage);
                    $progressBar->advance();
                }

                $progressBar->finish();
                $this->line(PHP_EOL . '...Toggl time entries sync complete!');
            }
        } else {
            $this->error('No Toggl API users in set.');
        }
    }
}