Added personalization monitors

sandbox/public/index.html

@@ -16,13 +16,21 @@
     <script>
       window.__alloyMonitors = window.__alloyMonitors || [];
       window.__alloyMonitors.push({
+        onContentRendering(data) {
+          console.log("Alloy Content Rendering");
+          console.log("data", data.status, data);
+        },
+        onContentHiding(data) {
+          console.log("Alloy Content Hiding");
+          console.log("data", data.status);
+        },
         onInstanceCreated(data) {
           console.log("Alloy Instance Created");
           console.log(data.instanceName);
           console.log(data.instance);
         },
         onInstanceConfigured(data) {
-          console.log("Alloy Instance Configured");
+         /* console.log("Alloy Instance Configured");
           console.log(JSON.stringify(data.config, null, 2));
           const { getLinkDetails } = data;
 
@@ -31,7 +39,7 @@
           for (var i = 0; i < listOfLinks.length; i++) {
             const linkDetails = getLinkDetails(listOfLinks[i]);
             console.log("link details", linkDetails);
-          }
+          }*/
         },
       });
     </script>
@@ -109,7 +117,7 @@
           getUrlParameter("edgeConfigId") ||
           "bc1a10e0-aee4-4e0e-ac5b-cdbb9abbec83",
         orgId: "5BFE274A5F6980A50A495C08@AdobeOrg", // UnifiedJS QE Only
-        debugEnabled: true,
+        debugEnabled: false,
         idMigrationEnabled: !(
           getUrlParameter("idMigrationEnabled") === "false"
         ),
@@ -164,7 +172,7 @@
 
       // For Testing multiple instances.
       // We use a different orgId and datastreamId.
-      organizationTwo("configure", {
+     organizationTwo("configure", {
         datastreamId: "7984963a-6609-4e84-98d5-4e2ff8c0dd5e:prod",
         orgId: "97D1F3F459CE0AD80A495CBE@AdobeOrg",
         debugEnabled: true,

src/components/Personalization/createFetchDataHandler.js

@@ -9,11 +9,13 @@ the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR REPRESENTA
 OF ANY KIND, either express or implied. See the License for the specific language
 governing permissions and limitations under the License.
 */
-import { groupBy } from "../../utils/index.js";
+import {groupBy, isNonEmptyArray} from "../../utils/index.js";
+import PAGE_WIDE_SCOPE from "../../constants/pageWideScope.js";
 
 const DECISIONS_HANDLE = "personalization:decisions";
 
 export default ({
+  logger,
   prehidingStyle,
   showContainers,
   hideContainers,
@@ -44,6 +46,16 @@ export default ({
 
     onResponse(({ response }) => {
       const handles = response.getPayloadsByType(DECISIONS_HANDLE);
+      if(!isNonEmptyArray(handles)){
+        logger.logOnContentRendering({
+          status: "no-offers",
+          message: "No offers were returned.",
+          logLevel: "info",
+          detail: {
+            query: personalizationDetails.createQueryDetails()
+          }
+        });
+      }
       const propositions = handles.map((handle) => createProposition(handle));
       const {
         page: pagePropositions = [],
@@ -63,6 +75,30 @@ export default ({
             [...pagePropositions, ...currentViewPropositions],
             nonRenderedPropositions,
           ));
+        if (isNonEmptyArray(pagePropositions)) {
+          logger.logOnContentRendering({
+            status: "rendering-started",
+            message: "Started rendering propositions for page-wide scope.",
+            logLevel: "info",
+            detail: {
+              scope: PAGE_WIDE_SCOPE,
+              propositions: pagePropositions.map(proposition => proposition.toJSON())
+            },
+          });
+        }
+
+        if (isNonEmptyArray(currentViewPropositions)) {
+          logger.logOnContentRendering({
+            status: "rendering-started",
+            message: `Rendering propositions started for view scope - ${personalizationDetails.getViewName()}.`,
+            logLevel: "info",
+            detail: {
+              scope: personalizationDetails.getViewName(),
+              propositions: currentViewPropositions.map(proposition => proposition.toJSON())
+            },
+          });
+        }
+
         render().then(handleNotifications);
 
         // Render could take a long time especially if one of the renders

src/components/Personalization/createPersonalizationDetails.js

@@ -134,6 +134,6 @@ export default ({
         (!this.isCacheInitialized() &&
           personalization.defaultPersonalizationEnabled !== false)
       );
-    },
+    }
   };
 };

src/components/Personalization/createViewChangeHandler.js

@@ -10,7 +10,7 @@ OF ANY KIND, either express or implied. See the License for the specific languag
 governing permissions and limitations under the License.
 */
 
-export default ({ processPropositions, viewCache }) => {
+export default ({ processPropositions, viewCache, logger }) => {
   return ({ personalizationDetails, onResponse }) => {
     let returnedPropositions;
     let returnedDecisions;
@@ -28,6 +28,17 @@ export default ({ processPropositions, viewCache }) => {
       if (personalizationDetails.isRenderDecisions()) {
         ({ render, returnedPropositions, returnedDecisions } =
           processPropositions(propositions));
+
+        logger.logOnContentRendering({
+          status: "rendering-started",
+          message: `Started rendering propositions for view scope - ${viewName}.`,
+          logLevel: "info",
+          detail: {
+            scope: viewName,
+            propositions: propositions.map(proposition => proposition.toJSON())
+          },
+        });
+
         return render();
       }
       ({ returnedPropositions, returnedDecisions } = processPropositions(

src/components/Personalization/flicker/index.js

@@ -56,36 +56,51 @@ export const showElements = (prehidingSelector) => {
   }
 };
 
-export const hideContainers = (prehidingStyle) => {
-  if (!prehidingStyle) {
-    return;
-  }
-
-  // If containers prehiding style has been added
-  // by customer's prehiding snippet we don't
-  // want to add the same node
-  const node = getElementById(PREHIDING_ID);
-
-  if (node) {
-    return;
-  }
-
-  const nonce = getNonce();
-  const attrs = { id: PREHIDING_ID, ...(nonce && { nonce }) };
-  const props = { textContent: prehidingStyle };
-  const styleNode = createNode(STYLE, attrs, props);
-
-  appendNode(document.head, styleNode);
-};
-
-export const showContainers = () => {
-  // If containers prehiding style exists
-  // we will remove it
-  const node = getElementById(PREHIDING_ID);
-
-  if (!node) {
-    return;
+export const createHideContainers = ( logger ) => {
+  return ( prehidingStyle ) => {
+    if (!prehidingStyle) {
+      return;
+    }
+
+    // If containers prehiding style has been added
+    // by customer's prehiding snippet we don't
+    // want to add the same node
+    const node = getElementById(PREHIDING_ID);
+
+    if (node) {
+      return;
+    }
+
+    const nonce = getNonce();
+    const attrs = { id: PREHIDING_ID, ...(nonce && { nonce }) };
+    const props = { textContent: prehidingStyle };
+    const styleNode = createNode(STYLE, attrs, props);
+
+    logger.logOnContentHiding({
+      status: "hide-containers",
+      message: "Prehiding style applied to hide containers.",
+      logLevel: "info",
+    });
+
+    appendNode(document.head, styleNode);
+  };
+}
+
+export const createShowContainers = ( logger ) => {
+  return () => {
+    // If containers prehiding style exists
+    // we will remove it
+    const node = getElementById(PREHIDING_ID);
+
+    if (!node) {
+      return;
+    }
+
+    logger.logOnContentHiding({
+      status: "show-containers",
+      message: "Prehiding style removed to show containers.",
+      logLevel: "info",
+    });
+    removeNode(node);
   }
-
-  removeNode(node);
 };

src/components/Personalization/handlers/createProcessPropositions.js

@@ -10,6 +10,8 @@ OF ANY KIND, either express or implied. See the License for the specific languag
 governing permissions and limitations under the License.
 */
 
+import {groupBy} from "../../../utils/index.js";
+
 export default ({ schemaProcessors, logger }) => {
   const wrapRenderWithLogging = (render, item) => () => {
     return Promise.resolve()
@@ -21,11 +23,19 @@ export default ({ schemaProcessors, logger }) => {
         return true;
       })
       .catch((error) => {
-        if (logger.enabled) {
-          const { message, stack } = error;
-          const warning = `Failed to execute action ${item.toString()}. ${message} ${stack}`;
-          logger.warn(warning);
-        }
+        const { message, stack } = error;
+        const warning = `Failed to execute action ${item.toString()}. ${message} ${stack}`;
+        logger.logOnContentRendering({
+          status: "rendering-failed",
+          detail: {
+            propositionDetails: item.getProposition().getNotification(),
+            item: item.toJSON()
+          },
+          error,
+          message: warning,
+          logLevel: "warn",
+        });
+
         return false;
       });
   };
@@ -186,7 +196,18 @@ export default ({ schemaProcessors, logger }) => {
     });
     const render = () => {
       return Promise.all(renderers.map((renderer) => renderer())).then(
-        (metas) => metas.filter((meta) => meta),
+        (metas) => {
+          const renderedPropositions = metas.filter((meta) => meta);
+          const propsByScope = groupBy(renderedPropositions, (p) => p.scope);
+          logger.logOnContentRendering({
+            status: "rendering-succeeded",
+            detail: {...propsByScope},
+            message: `Scopes: ${propsByScope} successfully executed.`,
+            logLevel: "info",
+          });
+
+          return renderedPropositions;
+        },
       );
     };
     return { returnedPropositions, returnedDecisions, render };

src/components/Personalization/handlers/createProcessRedirect.js

@@ -23,6 +23,15 @@ export default ({ logger, executeRedirect, collect }) =>
         decisionsMeta: [item.getProposition().getNotification()],
         documentMayUnload: true,
       }).then(() => {
+        logger.logOnContentRendering({
+          status: "rendering-redirect",
+          detail: {
+            propositionDetails: item.getProposition().getNotification(),
+            item: item.toJSON()
+          },
+          message: `Redirect action ${item.toString()} executed.`,
+          logLevel: "info",
+        });
         return executeRedirect(content);
         // Execute redirect will never resolve. If there are bottom of page events that are waiting
         // for display notifications from this request, they will never run because this promise will

src/components/Personalization/handlers/injectCreateProposition.js

@@ -62,9 +62,6 @@ export default ({ preprocess, isPageWideSurface }) => {
 
     return {
       getScope() {
-        if (!scope) {
-          return scope;
-        }
         return scope;
       },
       getScopeType() {

src/components/Personalization/index.js

@@ -20,7 +20,7 @@ import {
 import createComponent from "./createComponent.js";
 import { initDomActionsModules } from "./dom-actions/index.js";
 import createCollect from "./createCollect.js";
-import { hideContainers, showContainers } from "./flicker/index.js";
+import { createHideContainers, createShowContainers } from "./flicker/index.js";
 import createFetchDataHandler from "./createFetchDataHandler.js";
 import collectClicks from "./dom-actions/clicks/collectClicks.js";
 import isAuthoringModeEnabled from "./utils/isAuthoringModeEnabled.js";
@@ -70,6 +70,9 @@ const createPersonalization = ({ config, logger, eventManager, consent }) => {
   } = config;
   const collect = createCollect({ eventManager, mergeDecisionsMeta });
 
+  const showContainers = createShowContainers(logger);
+  const hideContainers = createHideContainers(logger);
+
   const { storeInteractionMeta, getInteractionMetas } =
     createInteractionStorage();
 
@@ -133,6 +136,7 @@ const createPersonalization = ({ config, logger, eventManager, consent }) => {
     createProposition,
     notificationHandler,
     consent,
+    logger,
   });
 
   const onClickHandler = createOnClickHandler({
@@ -148,6 +152,7 @@ const createPersonalization = ({ config, logger, eventManager, consent }) => {
   const viewChangeHandler = createViewChangeHandler({
     processPropositions,
     viewCache,
+    logger,
   });
   const applyPropositions = createApplyPropositions({
     processPropositions,

src/core/createLogger.js

@@ -91,6 +91,19 @@ export default ({ getDebugEnabled, console, getMonitors, context }) => {
         data.error,
       );
     },
+    logOnContentHiding(data) {
+      notifyMonitors("onContentHiding", {
+        status: data.status,
+      });
+      log(data.logLevel, data.message);
+    },
+    logOnContentRendering(data) {
+      notifyMonitors("onContentRendering", {
+        status: data.status,
+        payload: data.detail
+      });
+      log(data.logLevel, data.message);
+    },
     /**
      * Outputs informational message to the web console. In some
      * browsers a small "i" icon is displayed next to these items

test/unit/specs/components/Personalization/createFetchDataHandler.spec.js

@@ -27,7 +27,7 @@ describe("Personalization::createFetchDataHandler", () => {
   let renderedPropositions;
   let notificationHandler;
   let consent;
-
+  let logger;
   let cacheUpdate;
   let personalizationDetails;
   let event;
@@ -36,6 +36,7 @@ describe("Personalization::createFetchDataHandler", () => {
   let response;
 
   beforeEach(() => {
+    logger = jasmine.createSpyObj("logger", ["logOnContentRendering"]);
     prehidingStyle = "myprehidingstyle";
     showContainers = jasmine.createSpy("showContainers");
     hideContainers = jasmine.createSpy("hideContainers");
@@ -80,6 +81,7 @@ describe("Personalization::createFetchDataHandler", () => {
       createProposition,
       notificationHandler,
       consent,
+      logger,
     });
     fetchDataHandler({
       cacheUpdate,

test/unit/specs/components/Personalization/handlers/createProcessRedirect.spec.js

@@ -26,7 +26,7 @@ describe("createProcessRedirect", () => {
   let processRedirect;
 
   beforeEach(() => {
-    logger = jasmine.createSpyObj("logger", ["warn"]);
+    logger = jasmine.createSpyObj("logger", ["warn", "logOnContentRendering"]);
     executeRedirect = jasmine.createSpy("executeRedirect");
     collectDefer = defer();
     collect = jasmine