Shopify MCP Server

Implementation Reference

• src/tools/createProduct.ts:31-85 (handler)

  The execute method that handles the create-product tool logic. It constructs a GraphQL mutation, sends it to Shopify, handles errors, and returns the created product.

  execute: async (input: CreateProductInput) => {
    try {
      const query = gql`
        mutation productCreate($input: ProductInput!) {
          productCreate(input: $input) {
            product {
              id
              title
              descriptionHtml
              vendor
              productType
              status
              tags
            }
            userErrors {
              field
              message
            }
          }
        }
      `;
  
      const variables = {
        input,
      };
  
      const data = (await shopifyClient.request(query, variables)) as {
        productCreate: {
          product: any;
          userErrors: Array<{
            field: string;
            message: string;
          }>;
        };
      };
  
      // If there are user errors, throw an error
      if (data.productCreate.userErrors.length > 0) {
        throw new Error(
          `Failed to create product: ${data.productCreate.userErrors
            .map((e) => `${e.field}: ${e.message}`)
            .join(", ")}`
        );
      }
  
      return { product: data.productCreate.product };
    } catch (error) {
      console.error("Error creating product:", error);
      throw new Error(
        `Failed to create product: ${
          error instanceof Error ? error.message : String(error)
        }`
      );
    }
  },

• src/tools/createProduct.ts:7-14 (schema)

  Input validation schema using Zod for the create-product tool. Defines fields: title (required), descriptionHtml, vendor, productType, tags, and status (default DRAFT).

  const CreateProductInputSchema = z.object({
    title: z.string().min(1),
    descriptionHtml: z.string().optional(),
    vendor: z.string().optional(),
    productType: z.string().optional(),
    tags: z.array(z.string()).optional(),
    status: z.enum(["ACTIVE", "DRAFT", "ARCHIVED"]).default("DRAFT"),
  });

• src/index.ts:255-271 (registration)

  Registration of the create-product tool with the MCP server. Maps the schema and calls createProduct.execute with the validated arguments.

  server.tool(
    "create-product",
    {
      title: z.string().min(1),
      descriptionHtml: z.string().optional(),
      vendor: z.string().optional(),
      productType: z.string().optional(),
      tags: z.array(z.string()).optional(),
      status: z.enum(["ACTIVE", "DRAFT", "ARCHIVED"]).default("DRAFT"),
    },
    async (args) => {
      const result = await createProduct.execute(args);
      return {
        content: [{ type: "text", text: JSON.stringify(result) }]
      };
    }
  );

• src/index.ts:19-19 (registration)

  Import statement for the createProduct module.

  import { createProduct } from "./tools/createProduct.js";

• src/index.ts:71-71 (registration)

  Initialization of the createProduct tool with the Shopify GraphQL client.

  createProduct.initialize(shopifyClient);