Shopify MCP Server

Implementation Reference

• src/tools/getBlogById.ts:22-83 (handler)

  The `execute` function that runs the GraphQL query to retrieve a specific blog by its ID using the Shopify GraphQL client.

  async execute(input: GetBlogByIdInput) {
    try {
      const query = gql`
        query GetBlogById($id: ID!) {
          blog(id: $id) {
            id
            title
            handle
            templateSuffix
            commentPolicy
            createdAt
            updatedAt
            articles(first: 5) {
              nodes {
                id
                title
                handle
                publishedAt
                author {
                  name
                }
                tags
              }
            }
          }
        }
      `;
  
      const data = await shopifyClient.request(query, { id: input.blogId }) as {
        blog: {
          id: string;
          title: string;
          handle: string;
          templateSuffix: string | null;
          commentPolicy: string;
          createdAt: string;
          updatedAt: string;
          articles: {
            nodes: Array<{
              id: string;
              title: string;
              handle: string;
              publishedAt: string;
              author: {
                name: string;
              } | null;
              tags: string[];
            }>;
          };
        };
      };
  
      return {
        blog: data.blog
      };
    } catch (error) {
      console.error("Error fetching blog by ID:", error);
      throw new Error(
        `Failed to fetch blog: ${error instanceof Error ? error.message : String(error)}`
      );
    }
  }

• src/tools/getBlogById.ts:5-7 (schema)

  Zod schema defining the input: `blogId` as a required string.

  const GetBlogByIdInputSchema = z.object({
    blogId: z.string().min(1).describe("The GID of the blog to fetch (e.g., \"gid://shopify/Blog/1234567890\")")
  });

• src/index.ts:264-273 (registration)

  Registers the `get-blog-by-id` tool with the MCP server, using the schema from the tool module and delegating execution to the tool's `execute` method.

  server.tool(
    "get-blog-by-id",
    getBlogById.schema.shape,
    async (args: z.infer<typeof getBlogById.schema>) => {
      const result = await getBlogById.execute(args);
      return {
        content: [{ type: "text", text: JSON.stringify(result) }]
      };
    }
  );