Merge pull request #125 from BuildFire/ai-seeder

AI seeder init commit

Author: mas-iota

control/content/app.services.js

@@ -164,5 +164,291 @@
           return deferred.promise;
         }
       };
-    }])
+    }]).factory('StateSeeder', ['Context', 'LoyaltyAPI', '$rootScope', 'Buildfire', '$timeout' ,function(Context, LoyaltyAPI, $rootScope, Buildfire, $timeout) {
+      let itemsList;
+      let orderedItems = [];
+      let currentUser;
+      let currentContext;
+      let stateSeederInstance;
+      let generateJSONTemplate = {
+          items: [
+            {
+              title: "",
+              pointsToRedeem: 0,
+              description: "",
+              listImage: "",
+            },
+          ],
+        };
+        let importJSONTemplate = {
+          items: [
+            {
+              title: "",
+              pointsToRedeem: 0,
+              pointsPerItem: 0,
+              description: "",
+              listImage: "",
+            },
+          ],
+        };
+      let handleAIReq = function(isImport, err, data) {
+        if (
+          err ||
+          !data ||
+          typeof data !== "object" ||
+          !Object.keys(data).length || !data.data || !data.data.items || !data.data.items.length
+        ) {
+          return buildfire.dialog.toast({
+            message: "Bad AI request, please try changing your request.",
+            type: "danger",
+          });
+        }
+        let initPromises = [
+          new Promise((resolve, reject) => {
+            getCurrentUser().then((user) => {
+              currentUser = user;
+              resolve();
+          }).catch(err => reject(err))
+          }), 
+          new Promise((resolve, reject) => {
+            Context.getContext().then(context => {
+              currentContext = context;
+              resolve();
+            }).catch(err => reject(err))
+          })
+        ]
+        Promise.all(initPromises).then(() => {
+          itemsList = data.data.items;
+          //Check image URLs
+          let items = itemsList.map((item, i) => {
+            return new Promise((resolve, reject) => {
+              elimanateNotFoundImages(item.listImage).then(res => {
+                if (res.isValid) {
+                  item.listImage = res.newURL;
+                  item.order = i;
+                  orderedItems.push(item);
+                  resolve(item);
+                } else {
+                  reject('image URL not valid');
+                }
+              })
+            })
+          })
+    
+          Promise.allSettled(items).then(results => {
+            itemsList = [];
+            results.forEach(res => {
+              if(res.status == 'fulfilled') {
+                const item = res.value;
+                if (item) {
+                  itemsList.push(item);
+                }
+              }
+            })
+            if (!itemsList.length) {
+              stateSeederInstance?.requestResult?.complete();
+              return buildfire.dialog.toast({
+                message: isImport ? "Each row must have a valid image URL." : "Bad AI request, please try changing your request.",
+                type: "danger",
+              });
+            }
+            
+            // reset old data
+            deleteAll().then(() => {
+              // save new data
+              let promises = itemsList.map((item, i) => {
+                return new Promise((resolve, reject) => {
+                  itemsList[i] = _applyDefaults(item);
+                  LoyaltyAPI.addReward(itemsList[i]).then(result => {
+                    console.info('Saved data result: ', result);
+                    itemsList[i].deepLinkUrl = Buildfire.deeplink.createLink({id: result._id});
+                    itemsList[i] = Object.assign(itemsList[i], result);
+                    resolve();
+                  })
+                  .catch(err => {
+                    console.error('Error while saving data : ', err);
+                    resolve('Error while saving data : ', err);
+                  })
+                })
+              }) 
+              Promise.allSettled(promises).then(res => {
+                if (isImport) {
+                  let sortedItems = orderedItems.sort((a,b) => a.order - b.order);
+                  let sortedIds =[];
+                  LoyaltyAPI.getRewards(currentContext.instanceId).then(results => {
+                    sortedItems.forEach(item => {
+                      if (results) {
+                        results.forEach(result => {
+                          if (item.title == result.title && item.listImage == result.listImage ) {
+                           sortedIds.push(result._id);
+                          }
+                        })
+                     }
+                    })
+                    results.forEach(result => {
+                      if (!sortedIds.includes(result._id))
+                      sortedIds.push(result._id);
+                    })
+                    const data = {
+                      appId: currentContext.appId,
+                      loyaltyUnqiueId: currentContext.instanceId,
+                      userToken: currentUser && currentUser.userToken,
+                      auth: currentUser && currentUser.auth,
+                      loyaltyRewardIds: sortedIds
+                    } 
+                    LoyaltyAPI.sortRewards(data).finally(() => {
+                      $timeout(() => {
+                        sortedItems = [];
+                        orderedItems = [];
+                        $rootScope.reloadRewards = true;
+                        buildfire.messaging.sendMessageToWidget({
+                          type: 'refresh'
+                        });
+                        stateSeederInstance?.requestResult?.complete();
+                      })
+                    });
+                  });
+                } else {
+                  $timeout(() => {
+                  $rootScope.reloadRewards = true;
+                  orderedItems = [];
+                  buildfire.messaging.sendMessageToWidget({
+                    type: 'refresh'
+                  });
+                  stateSeederInstance?.requestResult?.complete();
+                })
+                }
+              })
+            }).catch(err => console.warn('old data delete error', err));
+          })
+        }).catch(err => {
+          console.error(err);
+          stateSeederInstance?.requestResult?.complete();
+        })
+      }
+    
+    // UTILITIES
+    let _applyDefaults = function(item) {
+        if (item.title) {
+          const points = checkPoints(item.pointsToRedeem, item.pointsPerItem);
+          return {
+            title: item.title,
+            pointsToRedeem: points.pointsToRedeem,
+            description: item.description || "",
+            listImage: item.listImage || "",
+            pointsPerItem: points.pointsPerItem,
+            appId: currentContext.appId,
+            loyaltyUnqiueId: currentContext.instanceId,
+            userToken: currentUser && currentUser.userToken,
+            auth: currentUser && currentUser.auth,
+          }
+        }
+        return null
+      }
+
+      let checkPoints = function(pointsToRedeem, pointsPerItem) {
+        let points = {
+          pointsToRedeem: 0,
+          pointsPerItem: 0,
+        };
+        if (pointsToRedeem && pointsToRedeem > 0) {
+          points.pointsToRedeem = pointsToRedeem;
+        } else {
+          points.pointsToRedeem = 100;
+        }
+
+        if (pointsPerItem && pointsPerItem > 0) {
+          points.pointsPerItem = pointsPerItem;
+        } else {
+          points.pointsPerItem = Math.ceil(points.pointsToRedeem * 0.1);
+        }
+        return points;
+      }
+
+      let elimanateNotFoundImages = function(url) {
+        const optimisedURL = url.replace('1080x720', '100x100'); 
+        return new Promise((resolve) => {
+          if (url.includes("http")){
+            const xhr = new XMLHttpRequest();
+            xhr.open("GET", optimisedURL);
+            xhr.onerror = (error) => {
+              console.warn('provided URL is not a valid image', error);
+              resolve({isValid: false, newURL: null});
+            }
+            xhr.onload = () => {
+              if (xhr.responseURL.includes('source-404') || xhr.status == 404) {
+                return resolve({isValid: false ,newURL: null});
+              } else {
+                return resolve({isValid: true, newURL: xhr.responseURL.replace('h=100', 'h=720').replace('w=100', 'w=1080') });
+              }
+            };
+            xhr.send();
+          } else resolve(false);
+        });
+      };
+          
+      let deleteAll = function() {
+        const data = {
+          userToken: currentUser.userToken,
+          auth: currentUser.auth,
+          appId: currentContext.appId
+        };
+        return new Promise(resolve => {
+          if (stateSeederInstance.requestResult.resetData){
+            LoyaltyAPI.getRewards(currentContext.instanceId).then(items => {
+              const promises = items.map((item) => deleteItem(item._id, data));
+              resolve(Promise.all(promises)); 
+            }).catch(err => console.warn('old data get error', err));
+          }
+          else {
+            resolve();
+          }
+        })
+      }
+
+      let deleteItem = function(itemId, data) {
+        return new Promise((resolve, reject) => {
+          LoyaltyAPI.removeReward(itemId, data).then(res => {
+          Deeplink.deleteById(itemId);
+          resolve(res);
+          }).catch(err => {
+            if (err) reject(err);
+          })
+        });
+      }
+
+      let getCurrentUser = function() {
+        return new Promise(resolve => {
+          buildfire.auth.getCurrentUser(function (err, user) {
+            if (user && user._cpUser) {
+              resolve(user._cpUser);
+            }
+          });
+        })
+      }
+
+      return {
+        initStateSeeder: function() {
+          stateSeederInstance = new buildfire.components.aiStateSeeder({
+            generateOptions: {
+              userMessage: `Generate a sample of redeemable items for a new [business-type].`,
+              maxRecords: 5, 
+              systemMessage:
+              'listImage URL related to title and the list type. use source.unsplash.com for image URL, URL should not have premium_photo or source.unsplash.com/random, cost to redeem which is a number greater than zero and less than 100, return description as HTML.',
+              jsonTemplate: generateJSONTemplate,
+              callback: handleAIReq.bind(this, false),
+              hintText: 'Replace values between brackets to match your requirements.',
+            },
+            importOptions: {
+              jsonTemplate: importJSONTemplate,
+              sampleCSV: "Hotel Voucher, 50, 10, Redeem this voucher for a one-night stay at a luxurious hotel of your choice, https://source.unsplash.com/featured/?hotel\nFlight Upgrade, 30, 15, Upgrade your economy class ticket to business class, https://source.unsplash.com/featured/?flight\nCity Tour, 20, 5, Explore the city with a guided tour that covers all the major attractions and landmarks, https://source.unsplash.com/featured/?city\nAdventure Activity, 80, 30, Embark on an adrenaline-pumping adventure activity such as bungee jumping or skydiving, https://source.unsplash.com/featured/?adventure",
+              maxRecords: 15,
+              hintText: 'Each row should start with a loyalty item title, cost to redeem, points earned, description, and image URL.',
+              systemMessage: ``,
+              callback: handleAIReq.bind(this, true),
+            },
+          }).smartShowEmptyState();
+        },
+      }
+  }])
 })(window.angular, window.buildfire);

control/content/assets/css/style.css

@@ -186,4 +186,4 @@ i {
 	background-color:white; 
 	bottom:0px; 
 	z-index:1;
- }
+ }