mc/in-app-purchases-example

InAppPurchasesAtlasAppServices/App Services app/auth/custom_user_data.json

@@ -0,0 +1,3 @@
+{
+    "enabled": false
+}

InAppPurchasesAtlasAppServices/App Services app/auth/providers.json

@@ -0,0 +1,23 @@
+{
+    "anon-user": {
+        "name": "anon-user",
+        "type": "anon-user",
+        "disabled": false
+    },
+    "api-key": {
+        "name": "api-key",
+        "type": "api-key",
+        "disabled": true
+    },
+    "local-userpass": {
+        "name": "local-userpass",
+        "type": "local-userpass",
+        "config": {
+            "autoConfirm": true,
+            "resetFunctionName": "resetFunc",
+            "runConfirmationFunction": false,
+            "runResetFunction": true
+        },
+        "disabled": false
+    }
+}

InAppPurchasesAtlasAppServices/App Services app/data_sources/mongodb-atlas/config.json

@@ -0,0 +1,10 @@
+{
+    "name": "mongodb-atlas",
+    "type": "mongodb-atlas",
+    "config": {
+        "clusterName": "YOUR_CLUSTER_NAME",
+        "readPreference": "primary",
+        "wireProtocolEnabled": false
+    },
+    "version": 1
+}

InAppPurchasesAtlasAppServices/App Services app/data_sources/mongodb-atlas/default_rule.json

@@ -0,0 +1,17 @@
+{
+    "roles": [
+        {
+            "name": "read-not-write",
+            "apply_when": {},
+            "document_filters": {
+                "write": false,
+                "read": true
+            },
+            "read": true,
+            "write": false,
+            "insert": true,
+            "delete": true,
+            "search": true
+        }
+    ]
+}

InAppPurchasesAtlasAppServices/App Services app/environments/development.json

@@ -0,0 +1,3 @@
+{
+    "values": {}
+}

InAppPurchasesAtlasAppServices/App Services app/environments/no-environment.json

@@ -0,0 +1,3 @@
+{
+    "values": {}
+}

InAppPurchasesAtlasAppServices/App Services app/environments/production.json

@@ -0,0 +1,3 @@
+{
+    "values": {}
+}

InAppPurchasesAtlasAppServices/App Services app/environments/qa.json

@@ -0,0 +1,3 @@
+{
+    "values": {}
+}

InAppPurchasesAtlasAppServices/App Services app/environments/testing.json

@@ -0,0 +1,3 @@
+{
+    "values": {}
+}

InAppPurchasesAtlasAppServices/App Services app/functions/addPurchaseReceipt.js

@@ -0,0 +1,14 @@
+exports = async function(userId, transactionResult){
+  var serviceName = "mongodb-atlas";
+  var dbName = "foodie-folio";
+  var collName = "Purchase";
+
+  var purchasesCollection = context.services.get(serviceName).db(dbName).collection(collName);
+
+  var receipt = JSON.parse(transactionResult);
+
+    return purchasesCollection.insertOne({
+    userId: userId,
+    receipt: receipt
+  });
+};

InAppPurchasesAtlasAppServices/App Services app/functions/config.json

@@ -0,0 +1,20 @@
+[
+    {
+        "name": "resetFunc",
+        "private": true
+    },
+    {
+        "name": "fetchRecipes",
+        "private": false,
+        "disable_arg_logs": true
+    },
+    {
+        "name": "fetchPremiumRecipes",
+        "private": false,
+        "disable_arg_logs": true
+    },
+    {
+        "name": "addPurchaseReceipt",
+        "private": false
+    }
+]

InAppPurchasesAtlasAppServices/App Services app/functions/fetchPremiumRecipes.js

@@ -0,0 +1,80 @@
+exports = async function(arg){
+  const axios = require('axios');
+
+  var serviceName = "mongodb-atlas";
+  var dbName = "foodie-folio";
+  var collName = "Recipe";
+
+  var edamamAppID = context.values.get('edamam-app-id-link-to-secret');
+  var edamamAPIKey = context.values.get('edamam-api-key-link-to-secret');
+
+  // Change this and add it as url query parameters instead
+  const diet = "low-carb";
+  const premiumRecipes = "Japanese"
+  var queryString = `?type=any&app_id=${edamamAppID}&app_key=${edamamAPIKey}&cuisineType=${premiumRecipes}&diet=${diet}`;
+  var baseURL = "https://api.edamam.com/api/recipes/v2";
+
+  const endpoint = baseURL + queryString;
+
+  console.log(endpoint);
+
+  // Get a collection from the context
+  var collection = context.services.get(serviceName).db(dbName).collection(collName);
+
+  try {
+    const response = await axios.get(endpoint);
+    const recipes = response.data.hits;
+
+    for (const recipe of recipes) {
+      const recipeObject = recipe.recipe // Avoid duplication of field and improve readability
+      const recipeURI = recipeObject.uri; // Assuming the URI is accessible this way
+
+      // Use the recipe URI as the unique identifier
+      const filter = { uri: recipeURI };
+
+      // SELECTION OF DATA I WANT TO insert
+      const dataToUpsert = {
+        category: "purchased",
+        uri: recipeObject.uri,
+        calories: recipeObject.calories,
+        cautions: recipeObject.cautions,
+        cuisineType: recipeObject.cuisineType[0],
+        dietLabels: recipeObject.dietLabels,
+        dishType: recipeObject.dishType,
+        healthLabels: recipeObject.healthLabels,
+        image: recipeObject.image,
+        ingredientLines: recipeObject.ingredientLines,
+        ingredients: recipeObject.ingredients,
+        label: recipeObject.label,
+        mealType: recipeObject.mealType,
+        shareAs: recipeObject.shareAs,
+        source: recipeObject.source,
+        totalCO2Emissions: recipeObject.totalCO2Emissions,
+        totalTime: recipeObject.totalTime,
+        totalWeight: recipeObject.totalWeight,
+        url: recipeObject.url,
+        yield: recipeObject.yield
+      };
+
+      // Update document with the new data, or insert if it doesn't exist
+      const updateData = {
+        $set: dataToUpsert
+      };
+
+      const updateResult = await collection.updateOne(
+        filter,
+        updateData,
+        { upsert: true } // Enable upsert option
+      );
+
+      console.log("Upsert result:", updateResult);
+    }
+
+    return "Upsert operation completed";
+
+  } catch(err) {
+    console.log("Error occurred while executing findOne:", err.message);
+
+    return { error: err.message };
+  }
+};

InAppPurchasesAtlasAppServices/App Services app/functions/fetchRecipes.js

@@ -0,0 +1,79 @@
+exports = async function(arg){
+  const axios = require('axios');
+
+  var serviceName = "mongodb-atlas";
+  var dbName = "foodie-folio";
+  var collName = "Recipe";
+
+  var edamamAppID = context.values.get('edamam-app-id-link-to-secret');
+  var edamamAPIKey = context.values.get('edamam-api-key-link-to-secret');
+
+  // Change this and add it as url query parameters instead
+  const diet = "balanced";
+  var queryString = `?type=any&app_id=${edamamAppID}&app_key=${edamamAPIKey}&diet=${diet}`;
+  var baseURL = "https://api.edamam.com/api/recipes/v2";
+
+  const endpoint = baseURL + queryString;
+
+  console.log(endpoint);
+
+  // Get a collection from the context
+  var collection = context.services.get(serviceName).db(dbName).collection(collName);
+
+  try {
+    const response = await axios.get(endpoint);
+    const recipes = response.data.hits;
+
+    for (const recipe of recipes) {
+      const recipeObject = recipe.recipe // Avoid duplication of field and improve readability
+      const recipeURI = recipeObject.uri; // Assuming the URI is accessible this way
+
+      // Use the recipe URI as the unique identifier
+      const filter = { uri: recipeURI };
+
+      // SELECTION OF DATA I WANT TO insert
+      const dataToUpsert = {
+        category: "free",
+        uri: recipeObject.uri,
+        calories: recipeObject.calories,
+        cautions: recipeObject.cautions,
+        cuisineType: recipeObject.cuisineType[0],
+        dietLabels: recipeObject.dietLabels,
+        dishType: recipeObject.dishType,
+        healthLabels: recipeObject.healthLabels,
+        image: recipeObject.image,
+        ingredientLines: recipeObject.ingredientLines,
+        ingredients: recipeObject.ingredients,
+        label: recipeObject.label,
+        mealType: recipeObject.mealType,
+        shareAs: recipeObject.shareAs,
+        source: recipeObject.source,
+        totalCO2Emissions: recipeObject.totalCO2Emissions,
+        totalTime: recipeObject.totalTime,
+        totalWeight: recipeObject.totalWeight,
+        url: recipeObject.url,
+        yield: recipeObject.yield
+      };
+
+      // Update document with the new data, or insert if it doesn't exist
+      const updateData = {
+        $set: dataToUpsert
+      };
+
+      const updateResult = await collection.updateOne(
+        filter,
+        updateData,
+        { upsert: true } // Enable upsert option
+      );
+
+      console.log("Upsert result:", updateResult);
+    }
+
+    return "Upsert operation completed";
+
+  } catch(err) {
+    console.log("Error occurred while executing findOne:", err.message);
+
+    return { error: err.message };
+  }
+};

InAppPurchasesAtlasAppServices/App Services app/functions/resetFunc.js

@@ -0,0 +1,55 @@
+
+  /*
+    This function will be run when the client SDK 'callResetPasswordFunction' and is called with an object parameter
+    which contains four keys: 'token', 'tokenId', 'username', and 'password', and additional parameters
+    for each parameter passed in as part of the argument list from the SDK.
+
+    The return object must contain a 'status' key which can be empty or one of three string values:
+      'success', 'pending', or 'fail'
+
+    'success': the user's password is set to the passed in 'password' parameter.
+
+    'pending': the user's password is not reset and the UserPasswordAuthProviderClient 'resetPassword' function would
+      need to be called with the token, tokenId, and new password via an SDK. (see below)
+
+      const Realm = require("realm");
+      const appConfig = {
+          id: "my-app-id",
+          timeout: 1000,
+          app: {
+              name: "my-app-name",
+              version: "1"
+          }
+        };
+      let app = new Realm.App(appConfig);
+      let client = app.auth.emailPassword;
+      await client.resetPassword(token, tokenId, newPassword);
+
+    'fail': the user's password is not reset and will not be able to log in with that password.
+
+    If an error is thrown within the function the result is the same as 'fail'.
+
+    Example below:
+
+    exports = ({ token, tokenId, username, password }, sendEmail, securityQuestionAnswer) => {
+      // process the reset token, tokenId, username and password
+      if (sendEmail) {
+        context.functions.execute('sendResetPasswordEmail', username, token, tokenId);
+        // will wait for SDK resetPassword to be called with the token and tokenId
+        return { status: 'pending' };
+      } else if (context.functions.execute('validateSecurityQuestionAnswer', username, securityQuestionAnswer)) {
+        // will set the users password to the password parameter
+        return { status: 'success' };
+      }
+
+      // will not reset the password
+      return { status: 'fail' };
+    };
+
+    The uncommented function below is just a placeholder and will result in failure.
+  */
+
+  exports = ({ token, tokenId, username, password }) => {
+    // will not reset the password
+    return { status: 'fail' };
+  };

InAppPurchasesAtlasAppServices/App Services app/graphql/config.json

@@ -0,0 +1,4 @@
+{
+    "use_natural_pluralization": true,
+    "disable_schema_introspection": false
+}

InAppPurchasesAtlasAppServices/App Services app/http_endpoints/config.json

@@ -0,0 +1 @@
+[]

InAppPurchasesAtlasAppServices/App Services app/realm_config.json

@@ -0,0 +1,8 @@
+{
+    "app_id": "YOUR_APP_ID",
+    "config_version": 20210101,
+    "name": "YOUR_APP_NAME",
+    "location": "IE",
+    "provider_region": "aws-eu-west-1",
+    "deployment_model": "LOCAL"
+}

InAppPurchasesAtlasAppServices/App Services app/sync/config.json

@@ -0,0 +1,16 @@
+{
+    "type": "flexible",
+    "state": "enabled",
+    "development_mode_enabled": false,
+    "service_name": "mongodb-atlas",
+    "database_name": "foodie-folio",
+    "client_max_offline_days": 30,
+    "is_recovery_mode_disabled": false,
+    "permissions": {
+        "rules": {},
+        "defaultRoles": []
+    },
+    "queryable_fields_names": [
+        "label"
+    ]
+}

InAppPurchasesAtlasAppServices/App Services app/triggers/fetchPremiumRecipes.json

@@ -0,0 +1,16 @@
+{
+    "name": "fetchPremiumRecipes",
+    "type": "SCHEDULED",
+    "config": {
+        "schedule": "*/30 * * * *",
+        "skip_catchup_events": false
+    },
+    "disabled": false,
+    "event_processors": {
+        "FUNCTION": {
+            "config": {
+                "function_name": "fetchPremiumRecipes"
+            }
+        }
+    }
+}

InAppPurchasesAtlasAppServices/App Services app/triggers/fetchRecipes.json

@@ -0,0 +1,16 @@
+{
+    "name": "fetchRecipes",
+    "type": "SCHEDULED",
+    "config": {
+        "schedule": "*/30 * * * *",
+        "skip_catchup_events": false
+    },
+    "disabled": false,
+    "event_processors": {
+        "FUNCTION": {
+            "config": {
+                "function_name": "fetchRecipes"
+            }
+        }
+    }
+}