Compare commits

..

No commits in common. "master" and "0.1.4" have entirely different histories.

19 changed files with 89 additions and 521 deletions

View File

@ -1,23 +1,23 @@
{
"name": "leenooks/intuit",
"description": "Intuit API",
"keywords": ["laravel","leenooks","intuit"],
"authors": [
{
"name": "Deon George",
"email": "deon@dege.au"
}
],
"require": {
"jenssegers/model": "^1.5"
},
"require-dev": {
},
"autoload": {
"psr-4": {
"Intuit\\": "src"
}
},
"name": "leenooks/intuit",
"description": "Intuit API",
"keywords": ["laravel","leenooks","intuit"],
"authors": [
{
"name": "Deon George",
"email": "deon@leenooks.net"
}
],
"require": {
"jenssegers/model": "^1.5"
},
"require-dev": {
},
"autoload": {
"psr-4": {
"Intuit\\": "src"
}
},
"extra": {
"laravel": {
"providers": [
@ -25,5 +25,5 @@
]
}
},
"minimum-stability": "dev"
}
"minimum-stability": "dev"
}

View File

@ -7,9 +7,9 @@ use Illuminate\Support\Arr;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\Log;
use Intuit\Exceptions\{ConnectionIssueException,InvalidQueryResultException,NotFoundException};
use Intuit\Models\{ProviderToken,Payment};
use Intuit\Response\{Customer,Invoice,ListList,Taxcode};
use Intuit\Exceptions\{ConnectionIssueException,InvalidQueryResultException};
use Intuit\Models\{ProviderToken};
use Intuit\Response\{Customer,Invoice,ListList};
final class API
{
@ -25,14 +25,10 @@ final class API
private const CURLOPT_HEADER = FALSE;
private ProviderToken $token;
private string $url;
public function __construct(ProviderToken $token,bool $tryprod=FALSE)
{
$this->url = ((config('app.env') === 'local') && (! $tryprod))
? 'https://sandbox-quickbooks.api.intuit.com'
: 'https://quickbooks.api.intuit.com';
$this->url = (config('app.env') == 'local' && ! $tryprod) ? 'https://sandbox-quickbooks.api.intuit.com' : 'https://quickbooks.api.intuit.com';
$this->token = $token;
Log::debug(sprintf('%s:Intuit API for id [%s]',static::LOGKEY,$token->realm_id));
@ -40,17 +36,9 @@ final class API
/* STATIC */
/**
* URL to get log into Quickbooks
*
* @param bool $tryprod
* @return string
*/
public static function url(bool $tryprod=FALSE): string
{
return ((config('app.env') === 'local') && (! $tryprod))
? 'https://app.sandbox.qbo.intuit.com/app'
: 'https://app.qbo.intuit.com/app';
return (config('app.env') == 'local' && ! $tryprod) ? 'https://app.sandbox.qbo.intuit.com/app' : 'https://app.qbo.intuit.com/app';
}
/**
@ -62,7 +50,7 @@ final class API
private function convertHeaders(array $header): array
{
return collect($header)
->map(fn($value,$key)=>sprintf('%s:%s',$key,$value))
->map(function($value,$key) { return sprintf('%s:%s',$key,$value); })
->values()
->toArray();
}
@ -75,7 +63,7 @@ final class API
* @return object|array
* @throws \Exception
*/
private function execute(string $path,array $parameters=[],string $query=NULL): mixed
private function execute(string $path,array $parameters=[])
{
$url = sprintf('%s/%s/company/%s/%s',$this->url,self::VERSION,$this->token->realm_id,$path);
@ -175,41 +163,9 @@ final class API
}
});
switch ($path) {
case 'query':
if (! $result->QueryResponse) {
Log::debug(sprintf('%s:Query response malformed',self::LOGKEY),['parameters'=>$parameters,'x'=>$x]);
throw new InvalidQueryResultException(sprintf('%s:Query response malformed',self::LOGKEY));
}
if (! object_get($result->QueryResponse,$query))
throw new NotFoundException(sprintf('%s:Query returned no results',self::LOGKEY));
return $result->QueryResponse;
}
return $result;
}
/**
* Find a customer by their email address
*
* @param string $id
* @param array $parameters
* @return Customer
* @throws InvalidQueryResultException
*/
public function getAccountQuery(string $id,array $parameters=[]): Customer
{
Log::debug(sprintf('%s:Get a specific account [%s]',static::LOGKEY,$id));
$table = 'Customer';
$parameters['query'] = sprintf("select * from %s where Id='%s'",$table,$id);
$result = object_get($this->execute('query',$parameters,$table),$table);
return new Customer(array_pop($result));
}
/**
* Get a list of our classes
*
@ -226,6 +182,28 @@ final class API
return new ListList($this->execute('query',$parameters),$key);
}
/**
* Find a customer by their email address
*
* @param string $id
* @param array $parameters
* @return Customer
* @throws InvalidQueryResultException
*/
public function getAccountQuery(string $id,array $parameters=[]): Customer
{
Log::debug(sprintf('%s:Get a specific account [%s]',static::LOGKEY,$id));
$parameters['query'] = sprintf("select * from Customer where PrimaryEmailAddr='%s'",$id);
$x = $this->execute('query',$parameters);
if ((! $x->QueryResponse) || (! $x->QueryResponse->Customer) || (count($x->QueryResponse->Customer) !== 1))
throw new InvalidQueryResultException(sprintf('%s:Query response malformed',self::LOGKEY));
return new Customer($x->QueryResponse);
}
/**
* Get a specific customer record
*
@ -269,11 +247,14 @@ final class API
{
Log::debug(sprintf('%s:Get a specific invoice [%s]',static::LOGKEY,$id));
$table = 'Invoice';
$parameters['query'] = sprintf("select * from %s where DocNumber='%s'",$table,$id);
$result = object_get($this->execute('query',$parameters,$table),$table);
$parameters['query'] = sprintf("select * from Invoice where DocNumber='%s'",$id);
return new Invoice(array_pop($result));
$x = $this->execute('query',$parameters);
if ((! $x->QueryResponse) || (! $x->QueryResponse->Invoice) || (count($x->QueryResponse->Invoice) !== 1))
throw new InvalidQueryResultException(sprintf('%s:Query response malformed',self::LOGKEY));
return new Invoice($x->QueryResponse);
}
/**
@ -305,27 +286,7 @@ final class API
$key = 'Item';
$parameters['query'] = 'select * from Item';
return new ListList($this->execute('query',$parameters,$key),$key);
}
/**
* Get a specific payment record
*
* @param int $id
* @param array $parameters
* @return Payment
* @throws \Exception
*/
public function getPayment(int $id,array $parameters=[]): Payment
{
Log::debug(sprintf('%s:Get a specific payment [%d]',static::LOGKEY,$id));
$x = $this->execute('payment/'.$id,$parameters);
if (! $x->Payment)
throw new InvalidQueryResultException(sprintf('%s:Query response malformed',self::LOGKEY));
return new Payment((array)$x->Payment);
return new ListList($this->execute('query',$parameters),$key);
}
/**
@ -345,26 +306,7 @@ final class API
}
/**
* Find an taxcode by its ID
*
* @param string $id
* @param array $parameters
* @return Taxcode
* @throws InvalidQueryResultException
*/
public function getTaxCodeQuery(string $id,array $parameters=[]): Taxcode
{
Log::debug(sprintf('%s:Get a specific invoice [%s]',static::LOGKEY,$id));
$table = 'TaxCode';
$parameters['query'] = sprintf("select * from %s where Id='%s'",$table,$id);
$result = object_get($this->execute('query',$parameters,$table),$table);
return new Taxcode(array_pop($result));
}
/**
* Get a list of our tax codes
* Get a list of our invoices
*
* @param array $parameters
* @return ListList
@ -374,9 +316,9 @@ final class API
{
Log::debug(sprintf('%s:Get a list of taxes',static::LOGKEY));
$key = 'TaxCode';
$parameters['query'] = 'select * from TaxCode';
$parameters['query'] = 'select * from Taxcode';
return new ListList($this->execute('query',$parameters,$key),$key);
return new ListList($this->execute('query',$parameters),$key);
}
/**
@ -428,9 +370,7 @@ final class API
{
Log::debug(sprintf('%s:Update invoice',static::LOGKEY),['params'=>$parameters]);
$result = $this->execute('invoice',array_merge($parameters,['method'=>'POST']));
return new Invoice($result->Invoice);
return new Invoice($this->execute('invoice',array_merge($parameters,['method'=>'POST'])));
}
/**
@ -444,8 +384,6 @@ final class API
{
Log::debug(sprintf('%s:Update customer',static::LOGKEY),['params'=>$parameters]);
$result = $this->execute('customer',array_merge($parameters,['method'=>'POST']));
return new Customer($result->Customer);
return new Customer($this->execute('customer',array_merge($parameters,['method'=>'POST'])));
}
}

View File

@ -1,56 +0,0 @@
<?php
namespace Intuit\Commands;
use GuzzleHttp\Exception\ConnectException;
use Illuminate\Console\Command;
use Intuit\Exceptions\ConnectionIssueException;
use Intuit\Exceptions\NotFoundException;
use Intuit\Traits\ProviderTokenTrait;
class AccountGet extends Command
{
use ProviderTokenTrait;
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'intuit:account:get'
.' {id : Account ID}'
.' {user? : User Email}';
/**
* The console command description.
*
* @var string
*/
protected $description = 'Get an account from quickbooks';
/**
* Execute the console command.
*
* @return int
*/
public function handle()
{
$to = $this->providerToken($this->argument('user'));
try {
dump($to->API()->getAccountQuery($this->argument('id')));
} catch (ConnectException|ConnectionIssueException $e) {
$this->error($e->getMessage());
return self::FAILURE;
} catch (NotFoundException $e) {
$this->error('Nothing found');
return self::FAILURE;
}
return self::SUCCESS;
}
}

View File

@ -1,56 +0,0 @@
<?php
namespace Intuit\Commands;
use GuzzleHttp\Exception\ConnectException;
use Illuminate\Console\Command;
use Intuit\Exceptions\ConnectionIssueException;
use Intuit\Exceptions\NotFoundException;
use Intuit\Traits\ProviderTokenTrait;
class InvoiceGet extends Command
{
use ProviderTokenTrait;
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'intuit:invoice:get'
.' {id : Invoice ID}'
.' {user? : User Email}';
/**
* The console command description.
*
* @var string
*/
protected $description = 'Get an invoice from the quickbooks';
/**
* Execute the console command.
*
* @return int
*/
public function handle()
{
$to = $this->providerToken($this->argument('user'));
try {
dump($to->API()->getInvoiceQuery($this->argument('id')));
} catch (ConnectException|ConnectionIssueException $e) {
$this->error($e->getMessage());
return self::FAILURE;
} catch (NotFoundException $e) {
$this->error('Nothing found');
return self::FAILURE;
}
return self::SUCCESS;
}
}

View File

@ -1,61 +0,0 @@
<?php
namespace Intuit\Commands;
use GuzzleHttp\Exception\ConnectException;
use Illuminate\Console\Command;
use Intuit\Exceptions\ConnectionIssueException;
use Intuit\Exceptions\NotFoundException;
use Intuit\Traits\ProviderTokenTrait;
use App\Jobs\AccountingPaymentSync as Job;
class PaymentGet extends Command
{
use ProviderTokenTrait;
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'intuit:payment:get'
.' {id : Payment ID}'
.' {user? : User Email}';
/**
* The console command description.
*
* @var string
*/
protected $description = 'Get a payment from the accounting provider';
/**
* Execute the console command.
*
* @return int
*/
public function handle()
{
$to = $this->providerToken($this->argument('user'));
try {
dd($to->API()->getPayment($this->argument('id')));
} catch (ConnectException|ConnectionIssueException $e) {
$this->error($e->getMessage());
return self::FAILURE;
} catch (NotFoundException $e) {
$this->error('Nothing found');
return self::FAILURE;
}
if ($acc)
Job::dispatchSync($to,$acc);
return self::SUCCESS;
}
}

View File

@ -1,57 +0,0 @@
<?php
namespace Intuit\Commands;
use GuzzleHttp\Exception\ConnectException;
use Illuminate\Console\Command;
use Intuit\Exceptions\ConnectionIssueException;
use Intuit\Exceptions\NotFoundException;
use Intuit\Traits\ProviderTokenTrait;
class TaxCodeGet extends Command
{
use ProviderTokenTrait;
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'intuit:taxcode:get'
.' {id : Taxcode ID}'
.' {user? : User Email}';
/**
* The console command description.
*
* @var string
*/
protected $description = 'Get the defined tax codes from the accounting provider';
/**
* Execute the console command.
*
* @return int
*/
public function handle()
{
$to = $this->providerToken($this->argument('user'));
try {
$result = $to->API()->getTaxCodeQuery($this->argument('id'));
dd($result,$result->getTaxRateRef());
} catch (ConnectException|ConnectionIssueException $e) {
$this->error($e->getMessage());
return self::FAILURE;
} catch (NotFoundException $e) {
$this->error('Nothing found');
return self::FAILURE;
}
return self::SUCCESS;
}
}

View File

@ -1,54 +0,0 @@
<?php
namespace Intuit\Commands;
use Illuminate\Console\Command;
use Intuit\Traits\ProviderTokenTrait;
/**
* Refresh the Intuit tokens
*/
class TokenRefresh extends Command
{
use ProviderTokenTrait;
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'intuit:token:refresh'
.' {user? : User Email}';
/**
* The console command description.
*
* @var string
*/
protected $description = 'Refresh an access token';
/**
* Execute the console command.
*
* @return int
* @throws \Intuit\Exceptions\NotTokenException
*/
public function handle()
{
$to = $this->providerToken($this->argument('user'));
$old = $to->refresh_token;
$x = $to->refreshToken();
dump([
'access'=>$to->access_token,
'old'=>$old,
'refresh'=>$to->refresh_token,
'expires'=>(string)$to->refresh_token_expires_at,
'x'=>$x,
]);
return self::SUCCESS;
}
}

View File

@ -2,7 +2,6 @@
namespace Intuit\Controllers;
use App\Events\ProviderPaymentCreated;
use Illuminate\Foundation\Bus\DispatchesJobs;
use Illuminate\Http\Request;
use Illuminate\Routing\Controller as BaseController;
@ -48,11 +47,6 @@ class Webhook extends BaseController
case 'entities':
foreach ($data as $eventData) {
switch ($x=$eventData['name']) {
case 'Payment':
Log::alert(sprintf('We got a payment event [%s:%s]',$object,$x),['data'=>$eventData]);
event(new ProviderPaymentCreated('intuit',$eventData));
break;
default:
Log::alert(sprintf('We dont know how to handle [%s:%s] yet',$object,$x),['data'=>$eventData]);
}

View File

@ -1,9 +0,0 @@
<?php
namespace Intuit\Exceptions;
use Exception;
class NotFoundException extends Exception
{
}

View File

@ -1,9 +0,0 @@
<?php
namespace Intuit\Exceptions;
use Exception;
class NotTokenException extends Exception
{
}

View File

@ -3,21 +3,18 @@
namespace Intuit\Models;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Support\Facades\Log;
use Laravel\Socialite\Facades\Socialite;
class ProviderToken extends Model
{
private const LOGKEY = 'IPT';
protected $casts = [
'access_token_expires_at' => 'datetime:Y-m-d H:i:s',
'refresh_token_expires_at' => 'datetime:Y-m-d H:i:s',
protected $dates = [
'access_token_expires_at',
'refresh_token_expires_at',
];
/* ATTRIBUTES */
public function getAccessTokenAttribute(string $value): ?string
public function getAccessTokenAttribute($value): ?string
{
if (! $this->hasAccessTokenExpired())
return $value;
@ -32,16 +29,11 @@ class ProviderToken extends Model
public function hasAccessTokenExpired(): bool
{
return $this
->access_token_expires_at
->isPast();
return $this->access_token_expires_at->isPast();
}
public function refreshToken(): bool
{
Log::debug(sprintf('%s:= Refreshing token for [%s]',self::LOGKEY,$this->provider->name));
return Socialite::with($this->provider->name)
->refreshToken($this);
return Socialite::with($this->provider->name)->refreshtoken($this);
}
}

View File

@ -4,7 +4,6 @@ namespace Intuit\Providers;
use Illuminate\Routing\Router;
use Illuminate\Support\ServiceProvider;
use Intuit\Commands\{AccountGet,InvoiceGet,PaymentGet,TaxCodeGet,TokenRefresh};
/**
* Class IntuitServiceProvider.
@ -21,14 +20,6 @@ class IntuitServiceProvider extends ServiceProvider
public function boot(Router $router)
{
$this->mergeConfigFrom($this->_path.'/config/intuit.php','intuit');
$this->commands([
AccountGet::class,
InvoiceGet::class,
PaymentGet::class,
TaxCodeGet::class,
TokenRefresh::class,
]);
}
/**
@ -38,7 +29,8 @@ class IntuitServiceProvider extends ServiceProvider
*/
public function register()
{
if (! $this->_path)
if (! $this->_path) {
$this->_path = realpath(__DIR__.'/../../src');
}
}
}

View File

@ -6,7 +6,6 @@ use Carbon\Carbon;
use GuzzleHttp\RequestOptions;
use Illuminate\Support\Arr;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\Log;
use Laravel\Passport\Exceptions\InvalidAuthTokenException;
use Laravel\Socialite\Two\InvalidStateException;
use Laravel\Socialite\Two\ProviderInterface;
@ -17,8 +16,6 @@ use App\Models\{ProviderOauth,ProviderToken};
class IntuitProvider extends AbstractProvider implements ProviderInterface
{
private const LOGKEY = 'SIP';
private const hosts = [
'authorise' => 'https://appcenter.intuit.com/connect/oauth2',
'tokenendpoint' => 'https://oauth.platform.intuit.com/oauth2/v1/tokens/bearer',
@ -107,16 +104,12 @@ class IntuitProvider extends AbstractProvider implements ProviderInterface
];
}
public function refreshToken($to)
public function refreshtoken(ProviderToken $to): bool
{
Log::debug(sprintf('%s:= Refreshing token for [%d]',self::LOGKEY,$to->id));
$response = $this
->getHttpClient()
->post($this->getTokenUrl(),[
RequestOptions::HEADERS => $this->getAuthorisationHeader($to->provider),
RequestOptions::FORM_PARAMS => $this->getRefreshTokenFields($to->refresh_token),
]);
$response = $this->getHttpClient()->post($this->getTokenUrl(), [
RequestOptions::HEADERS => $this->getAuthorisationHeader($to->provider),
RequestOptions::FORM_PARAMS => $this->getRefreshTokenFields($to->refresh_token),
]);
switch ($response->getStatusCode()) {
case '200':
@ -132,11 +125,10 @@ class IntuitProvider extends AbstractProvider implements ProviderInterface
if (($x=Arr::get($body,'refresh_token')) !== $to->refresh_token) {
$to->refresh_token = $x;
$to->refresh_token_expires_at = Carbon::now()->addSeconds(Arr::get($body,'x_refresh_token_expires_in'));
Log::debug(sprintf('%s:= Refresh token updated.',self::LOGKEY));
}
$to->save();
return $to->save();
return TRUE;
default:
throw new InvalidAuthTokenException(sprintf('Invalid response [%d] refreshing token for [%s] (%s)',$response->getStatusCode(),$to->user->email,$response->getBody()));

View File

@ -55,8 +55,8 @@ abstract class Base implements \JsonSerializable
* @param mixed $value
* @return mixed
*/
public function search(string $key,mixed $value): mixed
public function search(string $key, mixed $value): mixed
{
return $this->_data->search(fn($item)=>$item->{$key}===$value);
return $this->_data->search(function($item) use ($key,$value) { return $item->{$key} == $value; });
}
}

View File

@ -18,6 +18,6 @@ class Customer extends Base
if (object_get($response,'time'))
unset($response->time);
$this->_model = new CustomerModel((array)$response);
$this->_model = new CustomerModel((array)$response->Customer);
}
}

View File

@ -18,6 +18,6 @@ class Invoice extends Base
if (object_get($response,'time'))
unset($response->time);
$this->_model = new InvoiceModel((array)$response);
$this->_model = new InvoiceModel((array)$response->Invoice);
}
}

View File

@ -144,7 +144,9 @@ class ListList extends Base implements \Countable, \ArrayAccess, \Iterator
*/
private function data(object $response,string $type): Collection
{
$x = $response->{$type};
if (! ($x=object_get($response->QueryResponse,$type)))
return collect();
switch (Arr::get(self::TYPES,$type)) {
case Category::class:
$data = collect(Category::hydrate($x));
@ -175,8 +177,8 @@ class ListList extends Base implements \Countable, \ArrayAccess, \Iterator
throw new \Exception(sprintf('%s:Unknown object type: %s',self::LOGKEY,$type));
}
$this->startPosition = $response->startPosition;
$this->maxResults = $response->maxResults;
$this->startPosition = $response->QueryResponse->startPosition;
$this->maxResults = $response->QueryResponse->maxResults;
return $data;
}

View File

@ -2,8 +2,7 @@
namespace Intuit\Response;
use Illuminate\Support\Collection;
use Intuit\Models\Taxcode as TaxcodeModel;
use Intuit\Models\Tax as TaxModel;
/**
* This is an Invoice Intuit Response to API calls
@ -19,12 +18,6 @@ class Taxcode extends Base
if (object_get($response,'time'))
unset($response->time);
$this->_model = new TaxcodeModel((array)$response);
}
public function getTaxRateRef(): Collection
{
return collect($this->SalesTaxRateList->TaxRateDetail)
->pluck('TaxRateRef.value');
$this->_model = new TaxModel((array)$response->Tax);
}
}

View File

@ -1,33 +0,0 @@
<?php
namespace Intuit\Traits;
use App\Models\{ProviderOauth,ProviderToken,User};
use Intuit\Exceptions\NotTokenException;
/**
* Return a provider token for API calls
*/
trait ProviderTokenTrait
{
private const provider = 'intuit';
/**
* Return a provider token to use for an API call
*
* @return ProviderToken
*/
protected function providerToken(string $user=NULL): ProviderToken
{
$uo = User::where('email',$user ?: config('osb.admin'))
->sole();
$so = ProviderOauth::where('name',self::provider)
->sole();
if (! ($to=$so->token($uo)))
throw new NotTokenException(sprintf('Unknown Tokens for [%s]',$uo->email));
return $to;
}
}