Implement ability to get a bulk operation by id

Author: xHeaven

src/GraphQLClientMethods.php

@@ -83,6 +83,18 @@ public function mutate(string $query, array $variables, bool $withExtensions = f
         );
     }
 
+    public function getBulkOperation(int $id): GraphQLClientTransformer
+    {
+        $response = $this->makeGetBulkOperationRequest($id);
+
+        /** @var ?array $response */
+        $response = data_get($response, 'data.node', []);
+
+        return new GraphQLClientTransformer(
+            data: $response ?? []
+        );
+    }
+
     public function getCurrentBulkOperation(): GraphQLClientTransformer
     {
         $response = $this->makeGetCurrentBulkOperationRequest();
@@ -203,6 +215,17 @@ private function makeMutationRequest(string $query, array $variables, bool $with
         return $response;
     }
 
+    private function makeGetBulkOperationRequest(int $id): array
+    {
+        throw_if($this->connector === null, ClientNotInitializedException::class);
+
+        $response = $this->connector->create()->getBulkOperation($id);
+
+        throw_if($response->failed(), ClientRequestFailedException::class, $response);
+
+        return Arr::wrap($response->json());
+    }
+
     /**
      * @throws ClientNotInitializedException
      * @throws ClientRequestFailedException
@@ -237,12 +260,17 @@ private function makeCreateBulkOperationRequest(string $query): array
      * @throws ClientNotInitializedException
      * @throws ClientRequestFailedException
      */
-    private function makeCancelBulkOperationRequest(): array
+    private function makeCancelBulkOperationRequest(?int $id = null): array
     {
         throw_if($this->connector === null, ClientNotInitializedException::class);
 
         /** @var array $currentBulkOperation */
-        $currentBulkOperation = data_get($this->makeGetCurrentBulkOperationRequest(), 'data.currentBulkOperation');
+        $currentBulkOperation = when(
+            condition: $id !== null,
+            // @phpstan-ignore argument.type
+            value: data_get($this->makeGetBulkOperationRequest($id), 'data.node'),
+            default: data_get($this->makeGetCurrentBulkOperationRequest(), 'data.currentBulkOperation'),
+        );
         /** @var ?string $currentBulkOperationId */
         $currentBulkOperationId = data_get($currentBulkOperation, 'id');
         /** @var ?string $currentBulkOperationStatus */

src/Integrations/Requests/BulkOperation.php

@@ -0,0 +1,39 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Luminarix\Shopify\GraphQLClient\Integrations\Requests;
+
+class BulkOperation extends BaseRequest
+{
+    public function __construct(
+        public int $id,
+    ) {}
+
+    protected function defaultBody(): array
+    {
+        $currentBulkOperationQuery = <<<GRAPHQL
+query {
+    node(id: "gid://shopify/BulkOperation/{$this->id}") {
+        ... on BulkOperation {
+            completedAt
+            createdAt
+            errorCode
+            fileSize
+            objectCount
+            partialDataUrl
+            query
+            rootObjectCount
+            status
+            type
+            url
+        }
+    }
+}
+GRAPHQL;
+
+        return [
+            'query' => $currentBulkOperationQuery,
+        ];
+    }
+}

src/Integrations/ShopifyResource.php

@@ -4,6 +4,7 @@
 
 namespace Luminarix\Shopify\GraphQLClient\Integrations;
 
+use Luminarix\Shopify\GraphQLClient\Integrations\Requests\BulkOperation;
 use Luminarix\Shopify\GraphQLClient\Integrations\Requests\CancelBulkOperation;
 use Luminarix\Shopify\GraphQLClient\Integrations\Requests\CreateBulkOperation;
 use Luminarix\Shopify\GraphQLClient\Integrations\Requests\CurrentBulkOperation;
@@ -35,6 +36,13 @@ public function mutation(string $graphqlQuery, array $variables, bool $detailedC
         );
     }
 
+    public function getBulkOperation(int $id): Response
+    {
+        return $this->connector->send(
+            new BulkOperation($id)
+        );
+    }
+
     public function currentBulkOperation(): Response
     {
         return $this->connector->send(