2020-05-12 15:57:23 +02:00
|
|
|
<?php
|
|
|
|
|
|
|
|
namespace Bluesquare\Connect\Commands;
|
|
|
|
|
|
|
|
use Bluesquare\Connect\Connect;
|
2022-05-18 17:40:18 +02:00
|
|
|
use Bluesquare\Connect\ConnectException;
|
2024-04-17 13:06:48 +02:00
|
|
|
use Bluesquare\Connect\Traits\HasConnectData;
|
2022-05-18 17:40:18 +02:00
|
|
|
use Bluesquare\Connect\Traits\HasConnectTokens;
|
2020-05-12 15:57:23 +02:00
|
|
|
use Illuminate\Console\Command;
|
|
|
|
|
|
|
|
class Sync extends Command
|
|
|
|
{
|
|
|
|
protected $signature = 'connect:sync';
|
|
|
|
|
2022-05-18 17:40:18 +02:00
|
|
|
protected $description = 'Sync Bluesquare Connect users';
|
2020-05-12 15:57:23 +02:00
|
|
|
|
|
|
|
public function handle(Connect $connect)
|
|
|
|
{
|
2022-05-18 17:40:18 +02:00
|
|
|
$this->call('connect:refresh');
|
|
|
|
|
|
|
|
$class = config('bconnect.model');
|
|
|
|
|
|
|
|
$has_fields = in_array(HasConnectTokens::class, class_uses($class));
|
|
|
|
|
2022-05-19 13:24:54 +02:00
|
|
|
if (! $has_fields) {
|
2022-05-18 17:40:18 +02:00
|
|
|
throw new ConnectException("$class does not implement HasConnectTokens");
|
|
|
|
}
|
|
|
|
|
|
|
|
$class::query()->chunks(10, function ($models) use ($connect) {
|
|
|
|
$models->each(function ($model) use ($connect) {
|
|
|
|
try {
|
2022-05-19 13:24:54 +02:00
|
|
|
if (! empty($model->connect_access_token)) {
|
2022-05-18 17:40:18 +02:00
|
|
|
$data = $connect->getUserData($model->connect_access_token);
|
|
|
|
$connect->updateUserData($model, $data);
|
|
|
|
$model->save();
|
2024-04-17 13:06:48 +02:00
|
|
|
|
|
|
|
if (in_array(HasConnectData::class, class_uses($model))) {
|
|
|
|
$model->postFillConnectData($data);
|
|
|
|
}
|
2022-05-18 17:40:18 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (\Exception $exception) {
|
|
|
|
$this->warn("Failed to sync model data", $model->toArray());
|
|
|
|
}
|
|
|
|
});
|
|
|
|
});
|
|
|
|
|
|
|
|
$this->info("Models synced");
|
|
|
|
|
|
|
|
return 0;
|
2020-05-12 15:57:23 +02:00
|
|
|
}
|
|
|
|
}
|