Shopify: Find Product by Title

 
export default async function main(args) {
  const { shopifyStoreName, shopifyApiVersion, shopifyAdminApiKey, productTitle } = args.inputVars;

  // Validate input variables
  if (!shopifyStoreName || !shopifyApiVersion || !shopifyAdminApiKey || !productTitle) {
    return {
      next: { path: 'error' },
      trace: [{ type: "debug", payload: { message: "Missing required input variables" } }]
    };
  }

  const url = `https://${shopifyStoreName}.myshopify.com/admin/api/${shopifyApiVersion}/products.json?limit=250`;
  const headers = {
    'X-Shopify-Access-Token': shopifyAdminApiKey,
    'Content-Type': 'application/json'
  };

  try {
    // Fetch the list of products
    const response = await fetch(url, { method: 'GET', headers: headers });
    if (!response.ok) {
      throw new Error(`HTTP error! status: ${response.status}`);
    }
    
    const responseBody = await response.json;

    // Check if the response contains products
    if (!responseBody.products || !Array.isArray(responseBody.products)) {
      throw new Error("Invalid or missing response body from Shopify API");
    }

    // Find the product by title
    const product = responseBody.products.find(p => p.title.toLowerCase() === productTitle.toLowerCase());

    if (!product) {
      return {
        next: { path: 'no_match' },
        trace: [{ type: "debug", payload: { message: "No matching product found" } }]
      };
    }

    // Extract the required values
    const productId = product.id;
    const productType = product.product_type;
    const bodyHtml = product.body_html;
    const adminGraphqlApiId = product.admin_graphql_api_id;
    const firstVariant = product.variants[0];
    const firstVariantPrice = firstVariant.price;
    const inventoryQuantity = firstVariant.inventory_quantity;
    const option1 = firstVariant.option1;
    const option2 = firstVariant.option2;

    return {
      outputVars: {
        productId,
        productType,
        firstVariantPrice,
        bodyHtml,
        adminGraphqlApiId,
        inventoryQuantity,
        option1,
        option2
      },
      next: { path: 'success' },
      trace: [{ type: "debug", payload: { message: "Product found and values extracted" } }]
    };

  } catch (error) {
    return {
      next: { path: 'error' },
      trace: [{ type: "debug", payload: { message: `Error: ${error.message}` } }]
    };
  }
}