*[_type == "blogPost"]{
  _id,
  title,
  slug,
  publishedAt,
  "imageUrl": image.asset->url,
  "imageFileName": image.asset->originalFilename,
  body
}

import json

# 1. Parse the entire JSON string response body from the Zapier input
data = json.loads(input_data['response']) 

documents = data.get('result', []) 
output = []

for doc in documents:
    # 2. Extract core fields from the Sanity document
    doc_id = doc.get('_id')
    title = doc.get('title', 'Untitled Entry')
    
    # Sanity returns slug as an object with a 'current' property
    slug = doc.get('slug', 'untitled-entry').get('current')

    image_url = doc.get('imageUrl', 'https://placehold.co/500') # Directly available from GROQ query
    
    # 3. Concatenate the Portable Text Body (Sanity's Rich Text)
    # The body is an array of 'block' objects.
    portable_text_blocks = doc.get('body', [])
    concatenated_body = ""
    
    # Iterate through each 'block' in the body array
    for block in portable_text_blocks:
        # We only want to process standard text blocks ('style': 'normal' or default '_type': 'block')
        # This skips images, lists, and other complex blocks for simple text extraction
        if block.get('_type') == 'block' and block.get('style') == 'normal':
            
            # A block contains an array of 'children' (span, strong, italic, etc.)
            text_parts = []
            for child in block.get('children', []):
                # We extract the 'text' value from each child span
                if child.get('_type') == 'span' and 'text' in child:
                    text_parts.append(child['text'])
            
            # Join the spans within the block
            if text_parts:
                concatenated_body += "".join(text_parts) + " "
    
    final_body = concatenated_body.strip()

    # 4. Create the new structured item
    processed_item = {
        "id": doc_id,
        "title": title,
        "slug": slug,
        "image_url": image_url,
        "concatenated_body": final_body, # The fully stitched text body
    }
    output.append(processed_item)

# 5. # Zapier expects a list of dictionaries for the output and will process each item in a single run
return output

mutation {
  updateProducts(products: [
    {
      productId: ""
      url: ""
      imageUrl: ""
      priceCurrencyCode: "USD"
      name: ""
      attributes: [
        {
          key: "contentType"
          value: "article"
        },
        {
          key: "body"
          value: ""
        }
      ]
      price: 1
      listPrice: 1
      inventoryLevel:1
      availability:"InStock"
    }
  ]) {
    result {
      errors {
        field
        message
      }
      data {
        productId
      }
    }
  }
}

mutation {
  updateProducts(products: [
    {
      productId: ""
      """
            Other fields from the mutation above
      """
      priceCurrencyCode: "USD"
      price: 1
      listPrice: 1
      inventoryLevel: 1
      availability: "InStock"
      variation_id: "GENERAL"
      variations: [
            {
                  variant_id: "LOYAL" 
            },
            {
                  variant_id: "WHOLESALE" 
            }
      ]
    }
  ]) {
    result {
      errors {
        field
        message
      }
      data {
        productId
      }
    }
  }
}