README

This package designed to help developers migrate from Shopify's REST API to the more modern and efficient GraphQL API. The package provides a set of utility functions and endpoints that map REST API functionality to GraphQL queries and mutations, making it easier to transition your Laravel application to use Shopify's GraphQL API. NOTE : This is experimental package

Features

Easy Integration: Simplifies the integration of Shopify's GraphQL API into your Laravel application.
Minimal Changes: Converts Shopify REST API payloads to GraphQL with minimal modifications, reducing development time and effort.

Overview
Installation
Usage
GraphqlService Class
Endpoints
- Products
- Variants
- Collections
- Orders
- Inventory
- ApplicationCharges
- Metafields
- Fulfillments
- Webhooks
- Themes
- Other Endpoints
Contributing

Overview

Shopify's GraphQL API offers several advantages over the REST API, including more efficient data fetching, fewer requests, and more flexible queries. This Laravel package provides a seamless way to transition from the REST API to GraphQL by offering utility functions and endpoints that mimic REST API behavior but use GraphQL under the hood.

Installation

To install the package in your Laravel application, follow these steps:

composer require thalia/shopify-rest-to-graphql

Publish the configuration file:

php artisan vendor:publish --provider="Thalia\ShopifyRestToGraphql\ShopifyRestToGraphqlServiceProvider"

Usage

The package provides a GraphqlService class with methods to handle various Shopify GraphQL operations.

use Thalia\ShopifyRestToGraphql\GraphqlService;

$shopifyGraphql = new GraphqlService($shop, $accessToken);
$product = $shopifyGraphql->graphqlPostProduct($params);
print_r($product);

Example Usage for calling graphql query

Basic Query Without Variables

$query = 'query { shop { name email } }';
$variables = [];

$response = $shopifyGraphql->graphqlQueryThalia($query, $variables);

if (isset($response['errors'])) {
    echo "Error: " . $response['errors']['message'];
} else {
    print_r($response);
}

Query With Variables

$query = 'mutation createProduct($title: String!) { productCreate(input: { title: $title }) { product { id      title } } }';

$variables = [
    'title' => 'New Product'
];

$response = $shopifyGraphql->graphqlQueryThalia($query, $variables);

if (isset($response['errors'])) {
    echo "Error: " . $response['errors']['message'];
} else {
    print_r($response);
}

Authentication & Expiring Offline Access Tokens

Shopify is replacing non-expiring offline access tokens with expiring ones. Public apps created before 2026-04-01 must migrate by 2027-01-01, after which requests for non-expiring tokens will error. Custom and merchant-created apps are exempt. See the Shopify docs.

This package is stateless — it acquires/refreshes tokens but never stores them. Your app owns persistence. To support expiring tokens, add these columns to your per-shop token storage: expires_at, refresh_token, refresh_token_expires_at (alongside access_token).

use Thalia\ShopifyRestToGraphql\Endpoints\OauthEndpoints;

$oauth = new OauthEndpoints($shop, $appApiKey, $appSecret);

// 1) Redirect the merchant to install (unchanged):
$url = $oauth->getAuthorizeUrl($appScope, $redirectUrl);

New installs — acquire an expiring token on the OAuth callback:

$tokens  = $oauth->getExpiringAccessToken($_GET['code']);
// $tokens = [access_token, expires_in, refresh_token, refresh_token_expires_in, scope]

$storage = OauthEndpoints::toStorage($tokens);
// $storage = [access_token, refresh_token, scope, expires_at, refresh_token_expires_at]
// → persist $storage keyed by the shop domain

The legacy getAccessToken($code) (non-expiring, returns a bare token string) is unchanged and still works, but new installs should use getExpiringAccessToken().

Before each use — refresh proactively if near expiry:

if (time() >= $storage['expires_at'] - 300) {                 // 5-minute skew
    $rotated = $oauth->refreshOfflineAccessToken($storage['refresh_token']);
    $storage = OauthEndpoints::toStorage($rotated);           // persist BEFORE using
}
$service = new \Thalia\ShopifyRestToGraphql\GraphqlService($shop, $storage['access_token']);

refreshOfflineAccessToken() returns a new access token and a new refresh token — the old refresh token is invalidated immediately, so persist the new values before using them. On an HTTP 401 (caught as a GraphqlException with getCode() === 401), refresh once and retry. If the refresh itself returns 401, or refresh_token_expires_at (90 days) has passed, the merchant must relaunch/reinstall the app. Transient 429/5xx failures are safe to retry with backoff.

Existing merchants — migrate a non-expiring token once (irreversible):

$tokens  = $oauth->migrateToExpiringToken($existingNonExpiringToken);
$storage = OauthEndpoints::toStorage($tokens);                // persist immediately
// The original non-expiring token is REVOKED on success.

Run the migration once per shop — from a background/batch job or lazily on the next app launch.

GraphqlService Class

The GraphqlService class is the core of this package and provides direct interaction with Shopify's GraphQL API.

Available Methods

General GraphQL

graphqlQueryThalia(string $query, array $variables = []): Execute any GraphQL query with optional variables
graphQLQuery($query, $shop, $accessToken): Alternative method to execute GraphQL queries with different credentials

Products

graphqlPostProduct($params): Create a new product
graphqlPostProductWithVariants($params): Create a product with multiple variants
graphqlUpdateProduct($params): Update an existing product
graphqlGetProducts($params): Get a list of products with filtering options
graphqlGetProductsCount(): Get the total count of products
graphqlGetProduct($shopifyid): Get a single product by ID
graphqlGetProductWithoutInventory($shopifyid): Get a product without inventory information
graphqlDeleteProduct($shopifyid): Delete a product
graphqlCheckProductOnShopify($shopifyid): Check if a product exists on Shopify
reOrderProductImages($params): Reorder product images
graphqlCreateProductImage($images, $productShopifyId): Add Product Image
graphqlDeleteProductImage(imageIds, $productShopifyId): Delete Product Image

Variants

graphqlDeleteVariant($shopifyid, $variantid): Delete a variant
graphqlGetProductVariants($shopifyid): Get all variants for a product
graphqlGetVariant($variantid): Get a single variant by ID
getProductIdFromVairant($variantid): Get product ID that a variant belongs to
graphqlUpdateVariant($shopifyId, $variantId, $params): Update a variant

Other

getCollectionHandle($collection_id): Get a collection's handle by ID

Example: Creating a Product

$productData = [
    'product' => [
        'title' => 'New Product',
        'body_html' => '<p>Product description</p>',
        'vendor' => 'My Vendor',
        'product_type' => 'Clothing',
        'tags' => 'tag1,tag2',
        'variants' => [
            [
                'price' => '19.99',
                'sku' => 'SKU123',
                'inventory_management' => 'shopify'
            ]
        ],
        'images' => [
            [
                'src' => 'https://example.com/image.jpg',
                'alt' => 'Product Image'
            ]
        ]
    ]
];

$response = $shopifyGraphql->graphqlPostProduct($productData);

Example: Updating a Product

$updateData = [
    'product' => [
        'id' => '1234567890',
        'title' => 'Updated Product Title',
        'tags' => 'updated,tags',
        'variants' => [
            [
                'id' => '9876543210',
                'price' => '29.99'
            ]
        ]
    ]
];

$response = $shopifyGraphql->graphqlUpdateProduct($updateData);

Example: Getting Products

$params = [
    'limit' => 10,
    'vendor' => 'Example Vendor',
    'published_status' => 'published',
    'fields' => 'id,title,variants,tags'
];

$products = $shopifyGraphql->graphqlGetProducts($params);

Example: Add Product Image

        $images = [
            [
                'url' => 'https://fastly.picsum.photos/id/365/200/300.jpg?hmac=n_4DxqK0o938eabBZRnEywWtPwgF2MKoTfnRmJ7vlKQ',
                'alt' => 'lorem ipsum',
            ]
        ];

$response = $shopifyGraphql->graphqlCreateProductImage($images, $productShopifyId);

Example: Delete Product Image

        $imageIds = [
            "4145546145154","5456564465234",
        ];


$response = $shopifyGraphql->graphqlDeleteProductImage($imageIds, $productShopifyId);

Endpoints

The package provides endpoint classes that map to different Shopify resources. Each endpoint class offers methods that correspond to REST API operations but utilize GraphQL under the hood.

Products

use Thalia\ShopifyRestToGraphql\Endpoints\ProductsEndpoints;

$productsEndpoint = new ProductsEndpoints($shop, $accessToken);

getProducts($params): Get a list of products with filtering options
getProduct($productId): Get a single product by ID
productVariantsCount(): Get the total count of product variants
deleteAllProductImages($productId): Delete all images for a product

Variants

use Thalia\ShopifyRestToGraphql\Endpoints\VariantsEndpoints;

$variantsEndpoint = new VariantsEndpoints($shop, $accessToken);

productVariantsBulkUpdate($shopifyId, $variantId, $params): Update a variant
productVariantsBulkDelete($shopifyId, $variantId): Delete a variant

Collections

use Thalia\ShopifyRestToGraphql\Endpoints\CollectionsEndpoints;

$collectionsEndpoint = new CollectionsEndpoints($shop, $accessToken);

getSmartCollections(): Get a list of smart collections
getCollection($collectionId): Get a single collection by ID
getCustomCollections(): Get a list of custom collections

Orders

use Thalia\ShopifyRestToGraphql\Endpoints\OrdersEndpoints;

$ordersEndpoint = new OrdersEndpoints($shop, $accessToken);

getOrders($params): Get a list of orders with filtering options
getOrder($orderId): Get a single order by ID
createOrder($params): Create a new order
updateOrder($orderId, $params): Update an existing order
cancelOrder($orderId, $params): Cancel an order
closeOrder($orderId): Close an order
reopenOrder($orderId): Reopen a closed order

Inventory

use Thalia\ShopifyRestToGraphql\Endpoints\InventoryEndpoints;

$inventoryEndpoint = new InventoryEndpoints($shop, $accessToken);

getInventoryLevels($params): Get inventory levels
adjustInventoryLevel($params): Adjust inventory level
getInventoryItem($inventoryItemId): Get inventory item by ID
updateInventoryItem($inventoryItemId, $params): Update inventory item

ApplicationCharges

use Thalia\ShopifyRestToGraphql\Endpoints\ApplicationChargesEndpoints;

$chargesEndpoint = new ApplicationChargesEndpoints($shop, $accessToken);

appPurchaseOneTimeCreate($params): Create a one-time application charge
currentAppInstallationForOneTime($chargeId): Get details of a one-time charge

Metafields

use Thalia\ShopifyRestToGraphql\Endpoints\MetafieldsEndpoints;

$metafieldsEndpoint = new MetafieldsEndpoints($shop, $accessToken);

getMetafields($params): Get metafields
getMetafield($metafieldId): Get a single metafield
createMetafield($params): Create a metafield
updateMetafield($metafieldId, $params): Update a metafield
deleteMetafield($metafieldId): Delete a metafield

Fulfillments

use Thalia\ShopifyRestToGraphql\Endpoints\FulfillmentsEndpoints;

$fulfillmentsEndpoint = new FulfillmentsEndpoints($shop, $accessToken);

createFulfillment($params): Create a fulfillment
updateFulfillment($fulfillmentId, $params): Update a fulfillment
getFulfillment($fulfillmentId): Get a single fulfillment
cancelFulfillment($fulfillmentId): Cancel a fulfillment

Webhooks

use Thalia\ShopifyRestToGraphql\Endpoints\WebhooksEndpoints;

$webhooksEndpoint = new WebhooksEndpoints($shop, $accessToken);

createWebhook($params): Create a webhook
getWebhooks($params): Get webhooks
getWebhook($webhookId): Get a single webhook
updateWebhook($webhookId, $params): Update a webhook
deleteWebhook($webhookId): Delete a webhook

Themes

use Thalia\ShopifyRestToGraphql\Endpoints\ThemesEndpoints;

$themesEndpoint = new ThemesEndpoints($shop, $accessToken);

getThemes(): Get all themes
getTheme($themeId): Get a single theme
createTheme($params): Create a new theme
updateTheme($themeId, $params): Update a theme
deleteTheme($themeId): Delete a theme

Other Endpoints

Additional endpoint classes include:

ShopEndpoints: Shop-related operations
LocationsEndpoints: Location management
DiscountsEndpoints: Discount operations
ScriptTagsEndPoints: Script tag operations
RecurringApplicationChargesEndpoints: Recurring charge operations
OauthEndpoints: OAuth operations
OauthScopeEndpoints: OAuth scope operations
ShippingEndpoints: Shipping operations

Contributing

We welcome contributions! To contribute:

Fork the repository.
Create a feature branch (git checkout -b feature-branch).
Commit your changes (git commit -m 'Add new feature').
Push to your branch (git push origin feature-branch).
Open a Pull Request.

thalia / shopify-rest-to-graphql

Maintainers

Package info

Statistics

Security

README

Features

Table of Contents

Overview

Installation

Usage

Authentication & Expiring Offline Access Tokens

GraphqlService Class

Available Methods

General GraphQL

Products

Variants

Other

Example: Creating a Product

Example: Updating a Product

Example: Getting Products

Example: Add Product Image

Example: Delete Product Image

Endpoints

Products

Variants

Collections

Orders

Inventory

ApplicationCharges

Metafields

Fulfillments

Webhooks

Themes

Other Endpoints

Contributing