Filtering by sku is working

examples/shopify/src/index.ts

@@ -17,9 +17,12 @@ const trigger = new Trigger({
 
     const response = await shopify.searchProductVariants(
       "get-shopify-variants",
-      {}
+      {
+        filter: {
+          sku: ["prod3", "prod6"],
+        },
+      }
     );
-    console.log(response);
 
     await ctx.logger.debug("Debug message");
 

packages/internal-integrations/src/shopify/index.ts

@@ -73,9 +73,11 @@ class ShopifyRequestIntegration implements RequestIntegration {
         ? buildFilter(parsedParams.filter)
         : undefined;
 
-      const query = gql`
+      const query = `
         query {
-          productVariants(${firstLast}${filters ? `, ${filters}` : ""}) {
+          productVariants(${firstLast}${
+        filters ? `, query: "${filters}"` : ""
+      }) {
             edges {
               node {
                 id
@@ -138,15 +140,13 @@ class ShopifyRequestIntegration implements RequestIntegration {
         };
       }
 
-      console.log("result.data", JSON.stringify(result.data));
-
       const parsed = VariantsSearchQueryResultSchema.parse(result.data);
 
       const response: SearchVariantsSuccessResponse = {
         count: parsed.productVariants.edges.length,
         productVariants: parsed.productVariants.edges.map((p) => ({
           id: p.node.id,
-          title: p.node.id,
+          title: p.node.title,
           createdAt: p.node.createdAt,
           updatedAt: p.node.updatedAt,
           price: p.node.price,
@@ -179,7 +179,6 @@ class ShopifyRequestIntegration implements RequestIntegration {
 
       return performedRequest;
     } catch (error) {
-      console.error("productVariants.search query error %O", error);
       log("productVariants.search query error %O", error);
       return {
         ok: false,

packages/internal-providers/src/providers/shopify/schemas.ts

@@ -3,7 +3,6 @@ import { z } from "zod";
 export const FirstOrLastSchema = z
   .object({
     first: z.number().optional(),
-    last: z.number().optional(),
   })
   .default({ first: 100 });
 
@@ -36,8 +35,8 @@ export const SearchVariantsBodySchema = FirstOrLastSchema.and(
   z.object({
     filter: z
       .object({
-        productIds: z.array(z.string()).optional(),
-        skus: z.array(z.string()).optional(),
+        productId: z.array(z.string()).optional(),
+        sku: z.array(z.string()).optional(),
       })
       .optional(),
   })