Instagram Test

Login.php

<?php

namespace Instagram\Auth;

use GuzzleHttp\Client;
use GuzzleHttp\Cookie\CookieJar;
use GuzzleHttp\Exception\ClientException;
use Instagram\Exception\InstagramAuthException;
use Instagram\Exception\InstagramException;
use Instagram\Transport\TransportFeed;

class Login
{
    /**
     * @var Client
     */
    private $client;

    /**
     * @param Client|null $client
     */
    public function __construct(Client $client = null)
    {
        $this->client = $client ?: new Client();
    }

    /**
     * @param $username
     * @param $password
     *
     * @return CookieJar
     *
     * @throws InstagramAuthException
     * @throws InstagramException
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function execute($username, $password)
    {
        $query = $this->client->request('GET', TransportFeed::BASE_URL, [
            'headers' => [
                'user-agent' => TransportFeed::USER_AGENT
            ]
        ]);

        $html = (string)$query->getBody();

        preg_match('/<script type="text\/javascript">window\._sharedData\s?=(.+);<\/script>/', $html, $matches);

        if (!isset($matches[1])) {
            throw new InstagramException('Unable to extract JSON data');
        }

        $data = json_decode($matches[1]);

        $cookieJar = new CookieJar();

        try {
            $query = $this->client->request('POST', TransportFeed::AUTH_URL, [
                'form_params' => [
                    'username' => $username,
                    'password' => $password,
                ],
                'headers'     => [
                    'cookie'      => 'ig_cb=1; csrftoken=' . $data->config->csrf_token,
                    'referer'     => TransportFeed::BASE_URL,
                    'x-csrftoken' => $data->config->csrf_token,
                    'user-agent'  => TransportFeed::USER_AGENT,
                ],
                'cookies' => $cookieJar
            ]);
        } catch (ClientException $e) {
            $response = $e->getResponse();
            if ($response->getStatusCode() == 400) {
                $body = json_decode((string) $response->getBody());
                if ($body->message == 'checkpoint_required') {
                    $query = $this->client->request('POST', TransportFeed::BASE_URL . ltrim($body->checkpoint_url, '/'), [
                        'form_params' => [
                            'username' => $username,
                            'password' => $password,
                        ],
                        'headers'     => [
                            'cookie'      => 'ig_cb=1; csrftoken=' . $data->config->csrf_token,
                            'referer'     => TransportFeed::BASE_URL,
                            'x-csrftoken' => $data->config->csrf_token,
                            'user-agent'  => TransportFeed::USER_AGENT,
                        ],
                        'cookies' => $cookieJar
                    ]);
                }
            } else {
                throw new InstagramAuthException('Unknown error', 1, $e);
            }
        }


        if ($query->getStatusCode() !== 200) {
            throw new InstagramAuthException('Unknown error');
        } else {
            $response = json_decode((string)$query->getBody());
            if ($response->authenticated == true) {
                return $cookieJar;
            } else {
                throw new InstagramAuthException('Wrong login / password');
            }
        }
    }
}