114 lines
3.3 KiB
PHP
114 lines
3.3 KiB
PHP
<?php
|
|
|
|
namespace Zoomyboy\Social\Classes;
|
|
|
|
use Carbon\Carbon;
|
|
use Generator;
|
|
use GuzzleHttp\Client;
|
|
use Zoomyboy\Social\Models\Page;
|
|
use Zoomyboy\Social\Models\Setting;
|
|
|
|
class InstagramService extends SocialService {
|
|
|
|
public function getType(): string
|
|
{
|
|
return 'instagram';
|
|
}
|
|
|
|
public function refresh(Page $page): void
|
|
{
|
|
$response = $this->client()->get('/refresh_access_token', ['query' => [
|
|
'grant_type' => 'ig_refresh_token',
|
|
'access_token' => $page->access_token,
|
|
]]);
|
|
|
|
$page->update([
|
|
'access_token' => json_decode((string) $response->getBody())->access_token
|
|
]);
|
|
}
|
|
|
|
public function client()
|
|
{
|
|
return new Client([
|
|
'base_uri' => 'https://graph.instagram.com',
|
|
]);
|
|
}
|
|
|
|
public function authClient()
|
|
{
|
|
return new Client([
|
|
'base_uri' => 'https://api.instagram.com',
|
|
]);
|
|
}
|
|
|
|
public function authenticate(): string
|
|
{
|
|
$response = $this->authClient()->post('/oauth/access_token', [
|
|
'headers' => ['Content-Type' => 'application/x-www-form-urlencoded'],
|
|
'form_params' => [
|
|
'client_id' => Setting::get('instagram_client_id'),
|
|
'redirect_uri' => $this->redirectUri(),
|
|
'client_secret' => Setting::get('instagram_client_secret'),
|
|
'grant_type' => 'authorization_code',
|
|
'code' => request()->query('code')
|
|
]
|
|
]);
|
|
$accessToken = json_decode((string) $response->getBody())->access_token;
|
|
|
|
$response = $this->client()->get('/access_token', ['query' => [
|
|
'grant_type' => 'ig_exchange_token',
|
|
'client_secret' => Setting::get('instagram_client_secret'),
|
|
'access_token' => $accessToken,
|
|
]]);
|
|
return json_decode((string) $response->getBody())->access_token;
|
|
}
|
|
|
|
public function redirectUri(): string
|
|
{
|
|
return env('INSTAGRAM_REDIRECT_URI', url()->current());
|
|
}
|
|
|
|
public function me(string $accessToken): array
|
|
{
|
|
$response = $this->client()->get('/me', ['query' => [
|
|
'access_token' => $accessToken,
|
|
'fields' => 'id,username',
|
|
]]);
|
|
|
|
return json_decode((string) $response->getBody(), true);
|
|
}
|
|
|
|
public function clientId(): ?string
|
|
{
|
|
return Setting::get('instagram_client_id');
|
|
}
|
|
|
|
public function posts(): Generator
|
|
{
|
|
$response = $this->client()->get('/me/media', ['query' => ['access_token' => $this->page->access_token, 'fields' => 'caption,id,media_url,permalink,timestamp']]);
|
|
|
|
$posts = json_decode((string) $response->getBody(), true)['data'];
|
|
|
|
foreach ($posts as $post) {
|
|
if (!data_get($post, 'caption')) {
|
|
continue;
|
|
}
|
|
|
|
yield [
|
|
'message' => data_get($post, 'caption', ''),
|
|
'remote_id' => $post['id'],
|
|
'href' => $post['permalink'],
|
|
'created_at' => Carbon::parse($post['timestamp']),
|
|
'attachments' => [
|
|
[
|
|
'type' => 'image',
|
|
'href' => $this->saveUrl($post['media_url']),
|
|
'remote_id' => $post['id'],
|
|
]
|
|
],
|
|
];
|
|
}
|
|
}
|
|
|
|
}
|