@@ -15,6 +15,7 @@ namespace vonRotenberg\ShopwareApiBundle\API;

 use Contao\System;

 use Symfony\Component\Serializer\SerializerInterface;

 use Symfony\Contracts\HttpClient\HttpClientInterface;

+use Symfony\Contracts\HttpClient\ResponseInterface;

 class Shopware

 {

@@ -61,7 +62,14 @@ class Shopware

         $relEndpoint = '/' . ltrim($relEndpoint,'/');

-        return $this->httpClient->request($method,$this->getApiEndpoint().$relEndpoint,$options);

+        $request = $this->httpClient->request($method,$this->getApiEndpoint().$relEndpoint,$options);

+

+        if ($request->getStatusCode() == 401)

+        {

+            throw new \RuntimeException('Unauthorized');

+        }

+

+        return $request;

     }

     protected function getAccessToken()

@@ -84,20 +92,16 @@ class Shopware

             return json_decode($content);

         }

-        return null;

+        throw new \RuntimeException('Can\'t retrieve access token. Check credentials.');

     }

     protected function getAuthentication()

     {

-        if (($Token = $this->getAccessToken()) !== null)

-        {

-            return 'Authorization: ' . $Token->token_type . ' ' . $Token->access_token;

-        }

-

-        return null;

+        $Token = $this->getAccessToken();

+        return 'Authorization: ' . $Token->token_type . ' ' . $Token->access_token;

     }

-    public function isShopwareRunning()

+    public function isShopwareRunning(): bool

     {

         $options = [

             'headers' => [

@@ -117,10 +121,8 @@ class Shopware

         return false;

     }

-    public function getProductsForSku(string $strSku, bool $blnWildcardSearch=false, bool $blnShort=false)

+    public function getProductsForSku(string $strSku, bool $blnWildcardSearch=false, bool $blnShort=false): ResponseInterface

     {

-

-

         $options = [

             'headers' => [

                 $this->getAuthentication(),

@@ -159,13 +161,28 @@ class Shopware

             );

         }

-        $response = $this->sendRequest('search/product',$options,'POST');

+        return $this->sendRequest('search/product',$options,'POST');

+    }

-        if ($response->getStatusCode() == 200)

+    public function queryAPI(string $strUrlFragment, ?string $strBody, string $strMethod = 'GET', bool $blnAuthenticate=true): ResponseInterface

+    {

+        $options = [

+            'headers' => [

+                'Content-Type: application/json',

+                'Accept: application/json'

+            ]

+        ];

+

+        if ($blnAuthenticate)

         {

-            return json_decode($response->getContent());

+            $options['headers'][] = $this->getAuthentication();

         }

-        return false;

+        if ($strBody !== null)

+        {

+            $options['body'] = $strBody;

+        }

+

+        return $this->sendRequest($strUrlFragment,$options,$strMethod);

     }

 }

new file mode 100644

@@ -0,0 +1,84 @@

+<?php

+

+declare(strict_types=1);

+

+/*

+ * This file is part of vonRotenberg Shopware API Bundle.

+ *

+ * (c) vonRotenberg

+ *

+ * @license proprietary

+ */

+

+namespace vonRotenberg\ShopwareApiBundle\Command;

+

+use Contao\CoreBundle\Framework\ContaoFramework;

+use Contao\System;

+use Symfony\Component\Console\Command\Command;

+use Symfony\Component\Console\Input\InputArgument;

+use Symfony\Component\Console\Input\InputInterface;

+use Symfony\Component\Console\Input\InputOption;

+use Symfony\Component\Console\Output\OutputInterface;

+use Symfony\Component\Console\Style\SymfonyStyle;

+use Symfony\Component\VarDumper\Cloner\VarCloner;

+use Symfony\Component\VarDumper\Dumper\CliDumper;

+use vonRotenberg\ShopwareApiBundle\API\Shopware;

+

+class ShopwareApiTester extends Command

+{

+    protected static $defaultName = 'shopware:api-test';

+

+    protected $framework;

+

+    public function __construct(ContaoFramework $framework)

+    {

+        $this->framework = $framework;

+

+        parent::__construct();

+    }

+

+    protected function configure(): void

+    {

+        $this

+            ->setName(self::$defaultName)

+            ->setDescription('Query the Shopware API')

+            ->addOption('authenticate','a',InputOption::VALUE_NONE, 'Use Token authentication with request')

+        ;

+    }

+    protected function execute(InputInterface $input, OutputInterface $output): int

+    {

+        $this->framework->initialize();

+        $cloner = new VarCloner();

+        $dumper = new CliDumper();

+

+        $io = new SymfonyStyle($input, $output);

+        $io->title('Shopware API Tester');

+        $strUrlFragment = $io->ask('Enter URL fragment');

+        $strMethod = $io->choice('Request type',['GET','POST','PUT','DELETE','PATCH'], 'GET');

+        $strBody = $io->ask('Enter request body (JSON)', null, function ($strBody) {

+            if ($strBody !== null && !json_validate($strBody)) {

+                throw new \RuntimeException('Invalid JSON body');

+            }

+

+            return $strBody;

+        });

+

+        /** @var Shopware $Shopware */

+        $Shopware = System::getContainer()->get(Shopware::class);

+

+        $Result = $Shopware->queryAPI($strUrlFragment,$strBody, $strMethod, (bool)$input->getOption('authenticate'));

+

+        if ($Result->getStatusCode() === 200)

+        {

+            $dumper->dump(($cloner->cloneVar(json_validate($Result->getContent()) ? json_decode($Result->getContent(), true) : $Result)));

+

+            $io->success('Successful response');

+

+            return self::SUCCESS;

+        }

+

+        $io->error(sprintf('Error when querying the Shopware API. HTTP Status returned: %s',$Result->getStatusCode()));

+

+        return self::FAILURE;

+    }

+}

@@ -48,6 +48,8 @@ class ShopwareGetProductsBySku extends Command

     protected function execute(InputInterface $input, OutputInterface $output): int

     {

         $this->framework->initialize();

+        $cloner = new VarCloner();

+        $dumper = new CliDumper();

         $io = new SymfonyStyle($input, $output);

         $io->title('Shopware products search by SKU');

@@ -56,21 +58,22 @@ class ShopwareGetProductsBySku extends Command

         /** @var Shopware $Shopware */

         $Shopware = System::getContainer()->get(Shopware::class);

-        if (($Products = $Shopware->getProductsForSku($strSku,true, $input->getOption('short') ? true : false)) !== false)

+        $Result = $Shopware->getProductsForSku($strSku,true, $input->getOption('short') ? true : false);

+

+        if ($Result->getStatusCode() === 200)

         {

-            $cloner = new VarCloner();

-            $dumper = new CliDumper();

+            $Content = json_validate($Result->getContent()) ? json_decode($Result->getContent(), true) : $Result;

-            if ($Products->total)

+            if ($Content['total'])

             {

-                $dumper->dump(($cloner->cloneVar($Products->data)));

+                $dumper->dump(($cloner->cloneVar($Content['data'])));

             }

-            $io->success(sprintf('Found %s product(s)',$Products->total));

+            $io->success(sprintf('Found %s product(s)',$Content['total']));

             return self::SUCCESS;

         }

+        $io->error(sprintf('Could not retrieve products by SKU. HTTP Status returned: %s',$Result->getStatusCode()));

-        $io->error('Could not retrieve products by SKU');

         return self::FAILURE;

     }

 }