Shopify MCP Server

Implementation Reference

• src/tools/updateProduct.ts:168-261 (handler)

  The `execute` method of the `updateProduct` tool object, which contains the core logic for updating Shopify product details and variants using GraphQL mutations.
  execute: async (input: UpdateProductInput) => { if (!updateProduct.client) { throw new Error('GraphQL client not initialized. Call initialize() first.'); } try { const { productId, variants, ...productInput } = input; let response: ProductUpdateResponse; // If we're only updating variants, fetch the initial product data if (Object.keys(productInput).length === 0) { response = await updateProduct.client.request<ProductUpdateResponse>(updateProductMutation, { input: { id: productId } }); } else { // Update product details response = await updateProduct.client.request<ProductUpdateResponse>(updateProductMutation, { input: { id: productId, ...productInput } }); if (response.productUpdate.userErrors.length > 0) { throw new Error( `Failed to update product: ${response.productUpdate.userErrors .map((error) => error.message) .join(", ")}` ); } } // Update variants if provided if (variants && variants.length > 0) { const variantResponse = await updateProduct.client.request<VariantsBulkUpdateResponse>(updateVariantsMutation, { productId, variants: variants.map(variant => ({ id: variant.id, price: variant.price, compareAtPrice: variant.compareAtPrice, sku: variant.sku, barcode: variant.barcode, inventoryPolicy: variant.inventoryPolicy })) }); if (variantResponse.productVariantsBulkUpdate.userErrors.length > 0) { throw new Error( `Failed to update variants: ${variantResponse.productVariantsBulkUpdate.userErrors .map((error) => error.message) .join(", ")}` ); } // Fetch the latest product data after variant update response = await updateProduct.client.request<ProductUpdateResponse>(updateProductMutation, { input: { id: productId } }); } // Format variants for response const formattedVariants = response.productUpdate.product.variants.edges.map((edge) => ({ id: edge.node.id, title: edge.node.title, price: edge.node.price, compareAtPrice: edge.node.compareAtPrice, sku: edge.node.sku, barcode: edge.node.barcode, inventoryQuantity: edge.node.inventoryQuantity, inventoryPolicy: edge.node.inventoryPolicy })); return { product: { id: response.productUpdate.product.id, title: response.productUpdate.product.title, descriptionHtml: response.productUpdate.product.descriptionHtml, handle: response.productUpdate.product.handle, status: response.productUpdate.product.status, vendor: response.productUpdate.product.vendor, productType: response.productUpdate.product.productType, tags: response.productUpdate.product.tags, seo: response.productUpdate.product.seo, variants: formattedVariants, updatedAt: response.productUpdate.product.updatedAt } }; } catch (error: unknown) { if (error instanceof Error) { throw new Error(`Failed to update product: ${error.message}`); } throw new Error('Failed to update product: Unknown error'); } },
• src/tools/updateProduct.ts:5-29 (schema)

  Zod input schema defining all parameters for the update-product tool, used in the tool definition.
  const UpdateProductInputSchema = z.object({ productId: z.string().min(1).describe("The GID of the product to update (e.g., \"gid://shopify/Product/1234567890\")"), title: z.string().optional().describe("The new title for the product"), descriptionHtml: z.string().optional().describe("The new HTML description for the product"), seo: z.object({ title: z.string().optional().describe("SEO-optimized title for the product"), description: z.string().optional().describe("SEO meta description for the product") }).optional().describe("SEO information for the product"), status: z.enum(["ACTIVE", "ARCHIVED", "DRAFT"]).optional().describe("Product status (ACTIVE, ARCHIVED, or DRAFT)"), vendor: z.string().optional().describe("The vendor or manufacturer of the product"), productType: z.string().optional().describe("The type or category of the product"), tags: z.array(z.string()).optional().describe("Array of tags to categorize the product"), variants: z.array(z.object({ id: z.string().optional().describe("The GID of the variant to update"), price: z.string().optional().describe("The price of the variant"), compareAtPrice: z.string().optional().describe("Compare at price for showing a markdown"), sku: z.string().optional().describe("Stock keeping unit (SKU)"), barcode: z.string().optional().describe("Barcode (ISBN, UPC, GTIN, etc.)"), inventoryQuantity: z.number().optional().describe("Available inventory quantity"), inventoryPolicy: z.enum(["DENY", "CONTINUE"]).optional().describe("What happens when a variant is out of stock"), fulfillmentService: z.string().optional().describe("Service responsible for fulfilling the variant"), weight: z.number().optional().describe("Weight of the variant"), weightUnit: z.enum(["KILOGRAMS", "GRAMS", "POUNDS", "OUNCES"]).optional().describe("Unit of weight measurement") })).optional().describe("Product variants to update") });
• src/index.ts:309-342 (registration)

  MCP server registration of the 'update-product' tool, including duplicated inline schema and wrapper that calls the tool's execute method.
  server.tool( "update-product", { productId: z.string().min(1).describe("The GID of the product to update (e.g., \"gid://shopify/Product/1234567890\")"), title: z.string().optional().describe("The new title for the product"), descriptionHtml: z.string().optional().describe("The new HTML description for the product"), seo: z.object({ title: z.string().optional().describe("SEO-optimized title for the product"), description: z.string().optional().describe("SEO meta description for the product") }).optional().describe("SEO information for the product"), status: z.enum(["ACTIVE", "ARCHIVED", "DRAFT"]).optional().describe("Product status (ACTIVE, ARCHIVED, or DRAFT)"), vendor: z.string().optional().describe("The vendor or manufacturer of the product"), productType: z.string().optional().describe("The type or category of the product"), tags: z.array(z.string()).optional().describe("Array of tags to categorize the product"), variants: z.array(z.object({ id: z.string().optional().describe("The GID of the variant to update"), price: z.string().optional().describe("The price of the variant"), compareAtPrice: z.string().optional().describe("Compare at price for showing a markdown"), sku: z.string().optional().describe("Stock keeping unit (SKU)"), barcode: z.string().optional().describe("Barcode (ISBN, UPC, GTIN, etc.)"), inventoryQuantity: z.number().optional().describe("Available inventory quantity"), inventoryPolicy: z.enum(["DENY", "CONTINUE"]).optional().describe("What happens when a variant is out of stock"), fulfillmentService: z.string().optional().describe("Service responsible for fulfilling the variant"), weight: z.number().optional().describe("Weight of the variant"), weightUnit: z.enum(["KILOGRAMS", "GRAMS", "POUNDS", "OUNCES"]).optional().describe("Unit of weight measurement") })).optional().describe("Product variants to update") }, async (args) => { const result = await updateProduct.execute(args); return { content: [{ type: "text", text: JSON.stringify(result) }] }; } );
• src/tools/updateProduct.ts:93-131 (helper)

  GraphQL mutation for updating product details, used in the handler.
  const updateProductMutation = gql` mutation productUpdate($input: ProductInput!) { productUpdate(input: $input) { product { id title descriptionHtml handle status vendor productType tags seo { title description } variants(first: 50) { edges { node { id title price compareAtPrice sku barcode inventoryQuantity inventoryPolicy } } } updatedAt } userErrors { field message } } } `;
• src/index.ts:71-71 (helper)

  Initialization of the updateProduct tool with the Shopify GraphQL client.
  updateProduct.initialize(shopifyClient);