api session changes

Author: craghurampec

src/BwtApi.php

@@ -2,4 +2,6 @@
 
 namespace AlwaysOpen\BwtApi;
 
-class BwtApi {}
+class BwtApi {
+    public const BWT_AMAZON_ENGINE = 'bwt_amazon_product';
+}

src/BwtApiClient.php

@@ -4,6 +4,7 @@
 
 use AlwaysOpen\BwtApi\DTOs\Amazon\AmazonRequestCreationResponse;
 use AlwaysOpen\BwtApi\DTOs\Amazon\AmazonResults;
+use AlwaysOpen\BwtApi\DTOs\Amazon\AmazonSessionStatusResponse;
 use AlwaysOpen\BwtApi\DTOs\BatchRequest;
 use GuzzleHttp\Exception\GuzzleException;
 use GuzzleHttp\Promise\PromiseInterface;
@@ -24,14 +25,14 @@ public function __construct(
         ?string $apiKey = null,
     ) {
         $this->baseUrl = $baseUrl ?? config('bwt-api.base_url', 'https://bwt.com/api/');
-        $this->apiKey = $apiKey ?? config('bwt-api.username') ?? '';
+        $this->apiKey = $apiKey ?? config('bwt-api.api_key') ?? '';
     }
 
     protected function getAuthHeader(): array
     {
         return [
             'Authorization' => 'Bearer '.$this->apiKey,
-        ];
+        ];        
     }
 
     /**
@@ -61,6 +62,27 @@ protected function makeRequest(
         }, 2000);
     }
 
+    public function getAmazonSessionStatus(
+        string $id,
+    ): AmazonSessionStatusResponse {
+        try {
+            $response = $this->makeRequest(
+                'get',
+                $this->baseUrl .= "/$id",
+                null,
+                3,
+            );
+        } catch (Throwable $e) {
+            throw new RuntimeException('API request failed: '.$e->getMessage(), $e->getCode(), $e);
+        }
+
+        if (! $response->successful()) {
+            throw new RuntimeException('API request failed: '.$response->body(), $response->getStatusCode());
+        }
+
+        return AmazonSessionStatusResponse::from($response->json());
+    }
+
     public function getAmazonResults(
         string $id,
         int $limit = 1,
@@ -69,7 +91,7 @@ public function getAmazonResults(
         try {
             $response = $this->makeRequest(
                 'get',
-                $this->baseUrl .= "$id/results?limit=$limit&offset=$offset",
+                $this->baseUrl .= "/$id/results?limit=$limit&offset=$offset",
                 null,
                 3,
             );

src/DTOs/Amazon/AmazonSessionStatusResponse.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace AlwaysOpen\BwtApi\DTOs\Amazon;
+
+use Carbon\Carbon;
+use Spatie\LaravelData\Attributes\DataCollectionOf;
+use Spatie\LaravelData\Attributes\WithCast;
+use Spatie\LaravelData\Casts\DateTimeInterfaceCast;
+use Spatie\LaravelData\Data;
+
+class AmazonSessionStatusResponse extends Data
+{
+    public function __construct(
+        public readonly int $status,
+        public readonly string $message,
+        #[WithCast(DateTimeInterfaceCast::class, format: ['Y-m-d H:i:s', 'Y-m-d\TH:i:s\+H:i', 'Y-m-d H:i:s.u'])]
+        public readonly ?Carbon $created_at,
+        #[WithCast(DateTimeInterfaceCast::class, format: ['Y-m-d H:i:s', 'Y-m-d\TH:i:s\+H:i', 'Y-m-d H:i:s.u'])]
+        public readonly ?Carbon $finished_at,
+    ) {}
+}

src/DTOs/Amazon/ProductRequestItem.php

@@ -1,16 +1,17 @@
 <?php
 
-namespace AlwaysOpen\BwtApi\DTOs;
+namespace AlwaysOpen\BwtApi\DTOs\Amazon;
 
 use Spatie\LaravelData\Data;
+use AlwaysOpen\BwtApi\Enums\ScrapingModes;
 
 class ProductRequestItem extends Data
 {
     public function __construct(
         public readonly string $requested_asin,
         public readonly string $region,
-        public readonly string $postal_code,
-        public readonly int $scraping_mode,
+        public readonly string $postal_code = '00000',
+        public readonly int $scraping_mode = ScrapingModes::INVENTORY->value,
         public readonly ?int $max_offer_pages = null,
     ) {}
 }

src/DTOs/BatchRequest.php

@@ -2,6 +2,7 @@
 
 namespace AlwaysOpen\BwtApi\DTOs;
 
+use AlwaysOpen\BwtApi\DTOs\Amazon\ProductRequestItem;
 use Spatie\LaravelData\Data;
 
 class BatchRequest extends Data