How to create a Custom Web hook in Shopify

<?php

// Configuration

$shop = 'your-store-name.myshopify.com';

$accessToken = 'your-access-token';

$webhookUrl = 'your-webhook-url';

// Function to create the webhook

function createWebhook($shop, $accessToken, $webhookUrl) {

   $data = [

       'webhook' => [

           'topic' => 'customers/create',

           'address' => $webhookUrl,

           'format' => 'json'

       ]

   ];

   $ch = curl_init("https://$shop/admin/api/2024-01/webhooks.json");

   curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

   curl_setopt($ch, CURLOPT_POST, true);

   curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));

   curl_setopt($ch, CURLOPT_HTTPHEADER, [

       'Content-Type: application/json',

       "X-Shopify-Access-Token: $accessToken"

   ]);

   $response = curl_exec($ch);

   if (curl_errno($ch)) {

       echo 'Error:' . curl_error($ch);

   }

   curl_close($ch);

   echo "Webhook creation response: " . $response;

}

// Function to handle the webhook and update customer tags

function handleWebhook($shop, $accessToken) {

   $webhookPayload = file_get_contents('php://input');

   $customerData = json_decode($webhookPayload, true);

   if (isset($customerData['id'])) {

       $customerId = $customerData['id'];

       $currentTags = $customerData['tags'];

       // Define the new tags you want to add

       $newTags = ['Tag1', 'Tag2'];

       $existingTagsArray = explode(', ', $currentTags);

       $updatedTagsArray = array_unique(array_merge($existingTagsArray, $newTags));

       $updatedTags = implode(', ', $updatedTagsArray);

       $updateData = [

           'customer' => [

               'id' => $customerId,

               'tags' => $updatedTags

           ]

       ];

       $ch = curl_init("https://$shop/admin/api/2024-01/customers/$customerId.json");

       curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

       curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'PUT');

       curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($updateData));

       curl_setopt($ch, CURLOPT_HTTPHEADER, [

           'Content-Type: application/json',

           "X-Shopify-Access-Token: $accessToken"

       ]);

       $response = curl_exec($ch);

       if (curl_errno($ch)) {

           echo 'Error:' . curl_error($ch);

       }

       curl_close($ch);

       // Log the response or handle errors as needed

       error_log("Update response: " . $response);

   }

}

// Create webhook

if ($_SERVER['REQUEST_METHOD'] === 'POST' && isset($_POST['action']) && $_POST['action'] === 'create_webhook') {

   createWebhook($shop, $accessToken, $webhookUrl);

}

// Handle webhook request

if ($_SERVER['REQUEST_METHOD'] === 'POST' && !isset($_POST['action'])) {

   handleWebhook($shop, $accessToken);

}

?>