115 lines
2.4 KiB
PHP
115 lines
2.4 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
namespace App\Classes\External;
|
||
|
|
|
||
|
|
use GuzzleHttp\Client;
|
||
|
|
use Illuminate\Database\Eloquent\Model;
|
||
|
|
use Illuminate\Support\Arr;
|
||
|
|
use Illuminate\Support\Collection;
|
||
|
|
use Illuminate\Support\Facades\Cache;
|
||
|
|
use Illuminate\Support\Facades\Log;
|
||
|
|
|
||
|
|
abstract class Supplier
|
||
|
|
{
|
||
|
|
protected $o = NULL;
|
||
|
|
protected $_columns = [];
|
||
|
|
|
||
|
|
public function __construct(Model $o)
|
||
|
|
{
|
||
|
|
$this->o = $o;
|
||
|
|
$this->_columns = collect();
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Connect and pull down traffic data
|
||
|
|
*
|
||
|
|
* @param array $args
|
||
|
|
* @return mixed
|
||
|
|
*/
|
||
|
|
protected function connect(array $args=[])
|
||
|
|
{
|
||
|
|
if ($x=$this->mustPause()) {
|
||
|
|
Log::error('API Throttle, waiting .',['m'=>__METHOD__]);
|
||
|
|
sleep($x);
|
||
|
|
}
|
||
|
|
|
||
|
|
$result = Cache::remember('Supplier:'.$this->o->id,86400,function() {
|
||
|
|
$client = $this->getClient();
|
||
|
|
|
||
|
|
$result = $client->request('POST',null,[
|
||
|
|
'query'=>[
|
||
|
|
$this->login_user_field=>$this->o->stats_username,
|
||
|
|
$this->login_pass_field=>$this->o->stats_password,
|
||
|
|
$this->date_field=>$this->o->stats_lastupdate,
|
||
|
|
],
|
||
|
|
/*
|
||
|
|
'headers' => [
|
||
|
|
'Accept'=>'application/json',
|
||
|
|
],
|
||
|
|
*/
|
||
|
|
]);
|
||
|
|
|
||
|
|
$api_remain = Arr::get($result->getHeader('X-RateLimit-Remaining'),0);
|
||
|
|
$api_reset = Arr::get($result->getHeader('X-RateLimit-Reset'),0);
|
||
|
|
|
||
|
|
if ($api_remain == 0) {
|
||
|
|
Log::error('API Throttle.',['m'=>__METHOD__]);
|
||
|
|
Cache::put('api_throttle',$api_reset,now()->addSeconds($api_reset));
|
||
|
|
}
|
||
|
|
|
||
|
|
return $result->getBody()->getContents();
|
||
|
|
|
||
|
|
});
|
||
|
|
|
||
|
|
return $result;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Return the API HTTP client
|
||
|
|
* @return Client
|
||
|
|
*/
|
||
|
|
protected function getClient(): Client
|
||
|
|
{
|
||
|
|
return new Client(['base_uri'=>$this->o->stats_url]);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Return the expected columns from a supplier traffic import
|
||
|
|
*
|
||
|
|
* @param string $line
|
||
|
|
* @param Collection $expect
|
||
|
|
* @return Collection
|
||
|
|
*/
|
||
|
|
protected function getColumns(string $line,Collection $expect): Collection
|
||
|
|
{
|
||
|
|
$fields = collect(explode(',',$line))->filter();
|
||
|
|
$this->_columns = $expect;
|
||
|
|
|
||
|
|
if ($this->_columns->diff($fields)->count()) {
|
||
|
|
abort('500','Missing columns in data: '.join('|',$this->_columns->diff($fields)->toArray()));
|
||
|
|
}
|
||
|
|
|
||
|
|
return $fields->intersect($this->_columns);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Return the key ID for a column
|
||
|
|
*
|
||
|
|
* @param string $key
|
||
|
|
* @return mixed
|
||
|
|
*/
|
||
|
|
protected function getColumnKey(string $key)
|
||
|
|
{
|
||
|
|
return $this->_columns->search($key);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* If the supplier has API throttling...
|
||
|
|
*
|
||
|
|
* @return mixed
|
||
|
|
*/
|
||
|
|
protected function mustPause()
|
||
|
|
{
|
||
|
|
return Cache::get('api_throttle');
|
||
|
|
}
|
||
|
|
}
|