Add rewards to Jamstack Explorers

.prettierignore

@@ -8,3 +8,4 @@ backend/dist/
 backend/plugins/
 out_functions
 out_publish
+README.md

README.md

@@ -96,3 +96,5 @@ See our [contributing guidelines](./CONTRIBUTING.md) for more info about getting
 ## How to contribute mission!
 
 Thinking about a technology or best practice that you would like to share with the community? Check out our [Content Contribution Guide](https://www.notion.so/netlify/Content-Contribution-Guide-7e8c17246a524dec85ffe9525084403c) to learn how ✲ ﾟ｡.(✿╹◡╹)ﾉ ☆.｡₀:_ﾟ ✲ ﾟ_:₀｡
+
+

functions/check-achievement.js

@@ -77,56 +77,80 @@ exports.handler = async (event) => {
   const { new: newActivity } = payload.event.data;
 
   if (newActivity.type !== 'mission-complete') {
-    console.log('!mission-complete');
     return {
       statusCode: 200,
       body: 'ok',
     };
   }
 
-  const achievements = await postToHasura({
-    query: `mutation MyMutation(
+  const currentAchievements = await postToHasura({
+    query: `
+      query GetUserAchievements($user_id: String!) {
+        achievements(where: {user_id: {_eq: $user_id}}) {
+          id
+          type
+        }
+      }
+    `,
+    variables: {
+      user_id: newActivity.user_id,
+    },
+  });
+
+  if (
+    !currentAchievements.achievements.find(
+      (ach) => ach.type === 'mission-complete'
+    )
+  ) {
+    const newAchievement = await postToHasura({
+      query: `mutation AddAchievement(
           $app: String!,
           $event_data: jsonb!,
           $type: String!,
           $user_id: String!,
+          $description: String!,
         )
        {
           insert_achievements_one(object: {
             app: $app,
             event_data: $event_data,
             type: $type,
-            user_id: $user_id
+            user_id: $user_id,
+            description: $description
           }) {
             app
             event_data
             timestamp
             type
-            user_id
+            user_id,
+            description
           }
         }`,
-    variables: {
-      app: newActivity.app,
-      event_data: {},
-      type: 'mission-complete',
-      user_id: newActivity.user_id,
-    },
-  });
+      variables: {
+        app: newActivity.app,
+        event_data: newActivity.event_data,
+        type: 'mission-complete',
+        user_id: newActivity.user_id,
+        description:
+          'Work through every stage in a mission to earn credits in the Netlify Swag Store',
+      },
+    });
 
-  if (!achievements) {
+    if (!newAchievement) {
+      return {
+        statusCode: 200,
+        body: 'New achievement created!',
+      };
+    }
+  } else {
     return {
-      statusCode: 500,
-      body: 'Oh no!',
+      statusCode: 200,
+      headers: {
+        'Access-Control-Allow-Origin': '*',
+        'Access-Control-Allow-Headers':
+          'Origin, X-Requested-With, Content-Type, Accept',
+      },
+      body: 'Achievement already exists.',
     };
   }
-
-  return {
-    statusCode: 200,
-    headers: {
-      'Access-Control-Allow-Origin': '*',
-      'Access-Control-Allow-Headers':
-        'Origin, X-Requested-With, Content-Type, Accept',
-    },
-    body: 'Totally Ok',
-  };
 };

functions/check-reward-status.js

@@ -1,12 +1,82 @@
-/*
+/**
+ * This function is called by the Shopify webhook
+ * whenever an order is created.
+ */
 
-*/
+const { postToHasura } = require('./util/postToHasura');
 
-exports.handler = async (...args) => {
-  console.log(args);
+exports.handler = async (event) => {
+  const payload = JSON.parse(event.body);
+  const { discount_codes: discountCodes } = payload;
+
+  const allRewards = await postToHasura({
+    query: `
+      query RewardsList {
+        rewards {
+          reward_data
+          id
+        }
+      }
+    `,
+  });
+
+  if (!discountCodes.length > 0) {
+    console.error('Failed to retrieve discount codes from Shopify');
+    return {
+      statusCode: 200,
+      body: 'Failed to retrieve discount codes from Shopify',
+    };
+  }
+
+  if (!allRewards.rewards.length > 0) {
+    console.error('Failed to retrieve rewards from Hasura');
+    return {
+      statusCode: 500,
+      body: 'Failed to retrieve rewards from Hasura',
+    };
+  }
+
+  const discountPromises = discountCodes.map(async (discountCode) => {
+    try {
+      const discountCodeMatch = allRewards.rewards.find(
+        (item) => item.reward_data.code === discountCode.code
+      );
+
+      if (discountCodeMatch) {
+        await postToHasura({
+          query: `
+            mutation UpdateRewardStatus($reward_id: Int!) {
+              update_rewards(
+                where: {id: {_eq: $reward_id}},
+                _set: {is_claimed: true}
+              ) {
+                returning {
+                  id
+                  is_claimed
+                  reward_data
+                }
+              }
+            }
+          `,
+          variables: {
+            reward_id: discountCodeMatch.id,
+          },
+        });
+      }
+    } catch (err) {
+      console.error('Failure to update rewards: ', err);
+
+      return {
+        statusCode: 500,
+        body: 'Reward check failed.',
+      };
+    }
+  });
+
+  await Promise.all(discountPromises);
 
   return {
     statusCode: 200,
-    body: 'ok',
+    body: 'Checked reward',
   };
 };

functions/check-reward.js

@@ -1,50 +1,81 @@
-/*
+const { postToHasura } = require('./util/postToHasura');
+const {
+  createShopifyDiscountCode,
+} = require('./util/createShopifyDiscountCode');
 
-HOW THIS WORKS
+exports.handler = async (event) => {
+  const payload = JSON.parse(event.body);
+  const { new: newAchievement } = payload.event.data;
+  const { discountCodeBasicCreate } = await createShopifyDiscountCode(
+    newAchievement.id
+  );
+  const { codeDiscountNode: shopifyDiscountCode } = discountCodeBasicCreate;
 
-whenever a new entry in the achievement table is created, this
-function will be called with a payload:
-
-// TODO get a copy of Hasura's event payload
-// this will look very similar to the check-achievement.js payload
-
-if the achievement doesn't match Jamstack Explorers reward conditions,
-return 200 OK
-
-if it _might_ match JE reward conditions, check to see if it does,
-then generate appropriate rewards:
-
-- hit the Shopify API to generate a discount code
-
-update the achievements table to include the reward:
-
-{
-  ...originalEvent,
-  data: {
-    ...originalEvent.data,
-    rewards: [
-      ...originalEvent.data.rewards,
-      {
-        type: 'swag_discount_code',
-        discount_code: <whatever Shopify generates>,
-        description: 'Free Sticker Pack for Completing a Mission',
-        // this is optional. if there's a next action for the reward, this URL takes them there
-        actionUrl: 'https://swag.netlify.com?code=<shopify_coupon_code>',
-        callToAction: 'Claim Your Sticker Pack',
-      }
-    ]
+  /**
+   * Step 1: Check whether achievement meets criteria
+   * for generating a reward. If not, stop function
+   * and move on.
+   */
+  if (newAchievement.type !== 'mission-complete') {
+    return {
+      statusCode: 200,
+      body: 'OK! No reward needed!',
+    };
   }
-}
 
-OPEN QUESTION: can we extend JSONB with Hasura actions?
+  if (!shopifyDiscountCode) {
+    return {
+      statusCode: 500,
+      body: 'Unable to create Shopify reward.',
+    };
+  }
 
-*/
+  /**
+   * Step 2: Send request to generate reward.
+   */
+  const newReward = await postToHasura({
+    query: `
+      mutation AddReward(
+        $achievement_id: Int!,
+        $reward_type: String!,
+        $reward_data: jsonb!
+      ) {
+        insert_rewards_one(object: {
+          achievement_id: $achievement_id,
+          reward_data: $reward_data,
+          type: $reward_type
+        }) {
+          achievement_id
+          id
+          reward_data
+          timestamp
+          type
+        }
+      }
+    `,
+    variables: {
+      achievement_id: newAchievement.id,
+      reward_type: 'sticker pack',
+      reward_data: {
+        ...shopifyDiscountCode,
+      },
+    },
+  });
 
-exports.handler = async (...args) => {
-  console.log(args);
+  if (!newReward) {
+    return {
+      statusCode: 500,
+      body: 'Oh no! Check reward ran into an error!',
+    };
+  }
 
   return {
     statusCode: 200,
-    body: 'ok',
+    headers: {
+      'Access-Control-Allow-Origin': '*',
+      'Access-Control-Allow-Headers':
+        'Origin, X-Requested-With, Content-Type, Accept',
+    },
+    body: 'Success! Reward was created successfully!',
   };
 };

functions/get-user-achievement.js

@@ -0,0 +1,37 @@
+const { postToHasura } = require('./util/postToHasura');
+
+exports.handler = async (event) => {
+  const params = JSON.parse(event.body);
+  const achievements = await postToHasura({
+    query: `query GetUserAchievement($user_id: String) {
+  achievements(where: {user_id: {_eq: $user_id}, }) {
+    event_data
+    type
+    description
+    rewards{is_claimed id reward_data type }
+  }
+}
+`,
+
+    variables: {
+      user_id: `${params.user_id}`,
+    },
+  });
+
+  if (!achievements) {
+    return {
+      statusCode: 200,
+      body: "You don't have any achievements yet",
+    };
+  }
+
+  return {
+    statusCode: 200,
+    headers: {
+      'Access-Control-Allow-Origin': '*',
+      'Access-Control-Allow-Headers':
+        'Origin, X-Requested-With, Content-Type, Accept',
+    },
+    body: JSON.stringify(achievements),
+  };
+};