penthouse/lib/core.js

"use strict";

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.default = exports.PAGE_UNLOADED_DURING_EXECUTION_ERROR_MESSAGE = void 0;

var _cssTree = _interopRequireDefault(require("css-tree"));

var _debug = _interopRequireDefault(require("debug"));

var _pruneNonCriticalSelectors = _interopRequireDefault(require("./browser-sandbox/pruneNonCriticalSelectors"));

var _replacePageCss = _interopRequireDefault(require("./browser-sandbox/replacePageCss"));

var _postformatting = _interopRequireDefault(require("./postformatting"));

var _selectorsProfile = _interopRequireDefault(require("./selectors-profile"));

var _nonMatchingMediaQueryRemover = _interopRequireDefault(require("./non-matching-media-query-remover"));

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

function _objectSpread(target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i] != null ? arguments[i] : {}; var ownKeys = Object.keys(source); if (typeof Object.getOwnPropertySymbols === 'function') { ownKeys = ownKeys.concat(Object.getOwnPropertySymbols(source).filter(function (sym) { return Object.getOwnPropertyDescriptor(source, sym).enumerable; })); } ownKeys.forEach(function (key) { _defineProperty(target, key, source[key]); }); } return target; }

function _defineProperty(obj, key, value) { if (key in obj) { Object.defineProperty(obj, key, { value: value, enumerable: true, configurable: true, writable: true }); } else { obj[key] = value; } return obj; }

function _toConsumableArray(arr) { return _arrayWithoutHoles(arr) || _iterableToArray(arr) || _nonIterableSpread(); }

function _nonIterableSpread() { throw new TypeError("Invalid attempt to spread non-iterable instance"); }

function _iterableToArray(iter) { if (Symbol.iterator in Object(iter) || Object.prototype.toString.call(iter) === "[object Arguments]") return Array.from(iter); }

function _arrayWithoutHoles(arr) { if (Array.isArray(arr)) { for (var i = 0, arr2 = new Array(arr.length); i < arr.length; i++) arr2[i] = arr[i]; return arr2; } }

const debuglog = (0, _debug.default)('penthouse:core');
const PUPPETEER_PAGE_UNLOADED_DURING_EXECUTION_ERROR_REGEX = /(Cannot find context with specified id|Execution context was destroyed)/;
const PAGE_UNLOADED_DURING_EXECUTION_ERROR_MESSAGE = 'PAGE_UNLOADED_DURING_EXECUTION: Critical css generation script could not be executed.\n\nThis can happen if Penthouse was killed during execution, OR otherwise most commonly if the page navigates away after load, via setting window.location, meta tag refresh directive or similar. For the critical css generation to work the loaded page must stay: remove any redirects or move them to the server. You can also disable them on your end just for the critical css generation, for example via a query parameter.';
exports.PAGE_UNLOADED_DURING_EXECUTION_ERROR_MESSAGE = PAGE_UNLOADED_DURING_EXECUTION_ERROR_MESSAGE;

function blockinterceptedRequests(interceptedRequest) {
  const isJsRequest = /\.js(\?.*)?$/.test(interceptedRequest.url);

  if (isJsRequest) {
    interceptedRequest.abort();
  } else {
    interceptedRequest.continue();
  }
}

function loadPage(page, url, timeout, pageLoadSkipTimeout, allowedResponseCode) {
  debuglog('page load start');
  let waitingForPageLoad = true;
  let loadPagePromise = page.goto(url);

  if (pageLoadSkipTimeout) {
    loadPagePromise = Promise.race([loadPagePromise, new Promise(resolve => {
      // _abort_ page load after X time,
      // in order to deal with spammy pages that keep sending non-critical requests
      // (tracking etc), which would otherwise never load.
      // With JS disabled it just shouldn't take that many seconds to load what's needed
      // for critical viewport.
      setTimeout(() => {
        if (waitingForPageLoad) {
          debuglog('page load waiting ABORTED after ' + pageLoadSkipTimeout / 1000 + 's. ');
          resolve();
        }
      }, pageLoadSkipTimeout);
    })]);
  }

  return loadPagePromise.then(response => {
    if (typeof allowedResponseCode !== 'undefined') {
      checkResponseStatus(allowedResponseCode, response);
    }

    waitingForPageLoad = false;
    debuglog('page load DONE');
  });
}

function checkResponseStatus(allowedResponseCode, response) {
  var errorMessage;

  if (typeof allowedResponseCode === 'number' && response.status() !== allowedResponseCode) {
    errorMessage = `Server response status ${response.status()} isn't matching allowedResponseCode: ${allowedResponseCode}.`;
  } else if (typeof allowedResponseCode === 'object' && allowedResponseCode.constructor.name === 'RegExp' && !response.status().toString().match(allowedResponseCode)) {
    errorMessage = `Server response status ${response.status()} isn't matching allowedResponseCode: ${allowedResponseCode.toString()}.`;
  } else if (typeof allowedResponseCode === 'function' && !allowedResponseCode.call(this, response)) {
    errorMessage = `Server response status ${response.status()} isn't matching allowedResponseCode.`;
  }

  if (errorMessage) {
    throw new Error(errorMessage);
  }
}

function setupBlockJsRequests(page) {
  page.on('request', blockinterceptedRequests);
  return page.setRequestInterception(true);
}

async function astFromCss({
  cssString,
  strict
}) {
  // breaks puppeteer
  const css = cssString.replace(/￿/g, '\f042');
  let parsingErrors = [];
  debuglog('parse ast START');

  let ast = _cssTree.default.parse(css, {
    onParseError: error => parsingErrors.push(error.formattedMessage)
  });

  debuglog(`parse ast DONE (with ${parsingErrors.length} errors)`);

  if (parsingErrors.length && strict === true) {
    // NOTE: only informing about first error, even if there were more than one.
    const parsingErrorMessage = parsingErrors[0];
    throw new Error(`AST parser (css-tree) found ${parsingErrors.length} errors in CSS.
      Breaking because in strict mode.
      The first error was:
      ` + parsingErrorMessage);
  }

  return ast;
}

async function preparePage({
  page,
  pagePromise,
  width,
  height,
  cookies,
  userAgent,
  customPageHeaders,
  blockJSRequests,
  cleanupAndExit,
  getHasExited
}) {
  let reusedPage;

  try {
    const pagePromiseResult = await pagePromise;
    page = pagePromiseResult.page;
    reusedPage = pagePromiseResult.reused;
  } catch (e) {
    debuglog('unexpected: could not get an open browser page' + e);
    return;
  } // we already exited while page was opening, stop execution
  // (strict mode ast css parsing erros)


  if (getHasExited()) {
    return;
  }

  debuglog('open page ready in browser'); // We set the viewport size in the browser when it launches,
  // and then re-use it for each page (to avoid extra work).
  // Only if later pages use a different viewport size do we need to
  // update it here.

  let setViewportPromise = Promise.resolve();
  const currentViewport = page.viewport();

  if (currentViewport.width !== width || currentViewport.height !== height) {
    setViewportPromise = page.setViewport({
      width,
      height
    }).then(() => debuglog('viewport size updated'));
  }

  const setUserAgentPromise = page.setUserAgent(userAgent).then(() => debuglog('userAgent set'));
  let setCustomPageHeadersPromise = Promise.resolve();

  if (customPageHeaders && Object.keys(customPageHeaders).length) {
    try {
      setCustomPageHeadersPromise = page.setExtraHTTPHeaders(customPageHeaders).then(() => debuglog('customPageHeaders set:' + JSON.stringify(customPageHeaders)));
    } catch (e) {
      debuglog('failed setting extra http headers: ' + e);
    }
  }

  let setCookiesPromise = Promise.resolve();

  if (cookies) {
    try {
      var _page;

      setCookiesPromise = (_page = page).setCookie.apply(_page, _toConsumableArray(cookies)).then(() => debuglog('cookie(s) set: ' + JSON.stringify(cookies)));
    } catch (e) {
      debuglog('failed to set cookies: ' + e);
    }
  } // assumes the page was already configured from previous call!


  if (reusedPage) {
    return Promise.all([setViewportPromise, setUserAgentPromise, setCustomPageHeadersPromise, setCookiesPromise]).then(() => {
      debuglog('preparePage DONE');
      return page;
    });
  } // disable Puppeteer navigation timeouts;
  // Penthouse tracks these internally instead.


  page.setDefaultNavigationTimeout(0);
  let blockJSRequestsPromise;

  if (blockJSRequests) {
    // NOTE: with JS disabled we cannot use JS timers inside page.evaluate
    // (setTimeout, setInterval), however requestAnimationFrame works.
    blockJSRequestsPromise = Promise.all([page.setJavaScriptEnabled(false), setupBlockJsRequests(page)]).then(() => {
      debuglog('blocking js requests DONE');
    });
  }

  page.on('error', error => {
    debuglog('page error: ' + error);
    cleanupAndExit({
      error
    });
  });
  page.on('console', msg => {
    const text = msg.text ? typeof msg.text === 'function' ? msg.text() : msg.text : msg; // pass through log messages
    // - the ones sent by penthouse for debugging has 'debug: ' prefix.

    if (/^debug: /.test(text)) {
      debuglog(text.replace(/^debug: /, ''));
    }
  });
  debuglog('page event listeners set');
  return Promise.all([setViewportPromise, setUserAgentPromise, setCustomPageHeadersPromise, setCookiesPromise, blockJSRequestsPromise]).then(() => {
    debuglog('preparePage DONE');
    return page;
  });
}

async function grabPageScreenshot({
  type,
  page,
  screenshots,
  screenshotExtension,
  debuglog
}) {
  const path = screenshots.basePath + `-${type}` + screenshotExtension;
  debuglog(`take ${type} screenshot, START`);
  return page.screenshot(_objectSpread({}, screenshots, {
    path
  })).then(() => debuglog(`take ${type} screenshot DONE, path: ${path}`));
}

async function pruneNonCriticalCssLauncher({
  pagePromise,
  url,
  cssString,
  width,
  height,
  forceInclude,
  forceExclude,
  strict,
  userAgent,
  renderWaitTime,
  timeout,
  pageLoadSkipTimeout,
  blockJSRequests,
  customPageHeaders,
  cookies,
  screenshots,
  propertiesToRemove,
  maxEmbeddedBase64Length,
  keepLargerMediaQueries,
  maxElementsToCheckPerSelector,
  unstableKeepBrowserAlive,
  allowedResponseCode
}) {
  let _hasExited = false; // hacky to get around _hasExited only available in the scope of this function

  const getHasExited = () => _hasExited;

  const takeScreenshots = screenshots && screenshots.basePath;
  const screenshotExtension = takeScreenshots && screenshots.type === 'jpeg' ? '.jpg' : '.png';
  return new Promise(async (resolve, reject) => {
    debuglog('Penthouse core start');
    let page;
    let killTimeout;

    async function cleanupAndExit({
      error,
      returnValue
    }) {
      if (_hasExited) {
        return;
      }

      debuglog('cleanupAndExit');
      _hasExited = true;
      clearTimeout(killTimeout);

      if (error) {
        return reject(error);
      }

      if (page) {
        let resetPromises = []; // reset page headers and cookies,
        // since we re-use the page

        if (customPageHeaders && Object.keys(customPageHeaders).length) {
          try {
            resetPromises.push(page.setExtraHTTPHeaders({}).then(() => debuglog('customPageHeaders reset')));
          } catch (e) {
            debuglog('failed resetting extra http headers: ' + e);
          }
        } // reset cookies


        if (cookies && cookies.length) {
          try {
            var _page2;

            resetPromises.push((_page2 = page).deleteCookie.apply(_page2, _toConsumableArray(cookies)).then(() => debuglog('cookie(s) reset: ')));
          } catch (e) {
            debuglog('failed to reset cookies: ' + e);
          }
        }

        await Promise.all(resetPromises);
      }

      return resolve(returnValue);
    }

    killTimeout = setTimeout(() => {
      cleanupAndExit({
        error: new Error('Penthouse timed out after ' + timeout / 1000 + 's. ')
      });
    }, timeout); // 1. start preparing a browser page (tab) [NOT BLOCKING]

    const updatedPagePromise = preparePage({
      page,
      pagePromise,
      width,
      height,
      userAgent,
      cookies,
      customPageHeaders,
      blockJSRequests,
      cleanupAndExit,
      getHasExited
    }); // 2. parse ast
    // -> [BLOCK FOR] AST parsing

    let ast;

    try {
      ast = await astFromCss({
        cssString,
        strict
      });
    } catch (e) {
      cleanupAndExit({
        error: e
      });
      return;
    } // 3. Further process the ast [BLOCKING]
    // Strip out non matching media queries.
    // Need to be done before buildSelectorProfile;
    // (very fast but could be done together/in parallel in future)


    (0, _nonMatchingMediaQueryRemover.default)(ast, width, height, keepLargerMediaQueries);
    debuglog('stripped out non matching media queries'); // -> [BLOCK FOR] page preparation

    page = await updatedPagePromise;

    if (!page) {
      cleanupAndExit({
        error: 'Could not open page in browser'
      });
      return;
    } // load the page (slow) [NOT BLOCKING]


    const loadPagePromise = loadPage(page, url, timeout, pageLoadSkipTimeout, allowedResponseCode); // turn css to formatted selectorlist [NOT BLOCKING]

    debuglog('turn css to formatted selectorlist START');
    const buildSelectorProfilePromise = (0, _selectorsProfile.default)(ast, forceInclude && forceInclude.length ? forceInclude : null, forceExclude && forceExclude.length ? forceExclude : null).then(res => {
      debuglog('turn css to formatted selectorlist DONE');
      return res;
    }); // -> [BLOCK FOR] page load

    try {
      await loadPagePromise;
    } catch (e) {
      cleanupAndExit({
        error: e
      });
      return;
    }

    if (!page) {
      // in case we timed out
      debuglog('page load TIMED OUT');
      cleanupAndExit({
        error: new Error('Page load timed out')
      });
      return;
    }

    if (_hasExited) return; // Penthouse waits for the `load` event to fire
    // (before loadPagePromise resolves; except for very slow loading pages)
    // (via default puppeteer page.goto options.waitUntil setting,
    //  https://github.com/GoogleChrome/puppeteer/blob/v1.8.0/docs/api.md#pagegotourl-options)
    // This means "all of the objects in the document are in the DOM, and all the images...
    // have finished loading".
    // This is necessary for Penthouse to know the correct layout of the critical viewport
    // (well really, we would only need to load the critical viewport.. not possible?)
    // However, @font-face's can be available later,
    // and for this reason it can be useful to delay further - if screenshots are used.
    // For this `renderWaitTime` can be used.
    // Note: `renderWaitTime` is not a very good name,
    // and just setting a time is also not the most effective solution to f.e. wait for fonts.
    // In future probably deprecate and allow for a custom function instead (returning a promise).
    // -> [BLOCK FOR] renderWaitTime - needs to be done before we take any screenshots

    await new Promise(resolve => {
      setTimeout(() => {
        debuglog('waited for renderWaitTime: ' + renderWaitTime);
        resolve();
      }, renderWaitTime);
    }); // take before screenshot (optional) [NOT BLOCKING]

    const beforeScreenshotPromise = takeScreenshots ? grabPageScreenshot({
      type: 'before',
      page,
      screenshots,
      screenshotExtension,
      debuglog
    }) : Promise.resolve(); // -> [BLOCK FOR] css into formatted selectors list with "sourcemap"
    // latter used to map back to full css rule

    const {
      selectors,
      selectorNodeMap
    } = await buildSelectorProfilePromise;

    if (getHasExited()) {
      return;
    } // -> [BLOCK FOR] critical css selector pruning (in browser)


    let criticalSelectors;

    try {
      criticalSelectors = await page.evaluate(_pruneNonCriticalSelectors.default, {
        selectors,
        renderWaitTime,
        maxElementsToCheckPerSelector
      }).then(criticalSelectors => {
        debuglog('pruneNonCriticalSelectors done');
        return criticalSelectors;
      });
    } catch (err) {
      debuglog('pruneNonCriticalSelector threw an error: ' + err);
      const errorDueToPageUnloaded = PUPPETEER_PAGE_UNLOADED_DURING_EXECUTION_ERROR_REGEX.test(err);
      cleanupAndExit({
        error: errorDueToPageUnloaded ? new Error(PAGE_UNLOADED_DURING_EXECUTION_ERROR_MESSAGE) : err
      });
      return;
    }

    if (getHasExited()) {
      return;
    } // -> [BLOCK FOR] clean up final ast for critical css


    debuglog('AST cleanup START'); // NOTE: this function mutates the AST

    (0, _postformatting.default)({
      ast,
      selectorNodeMap,
      criticalSelectors,
      propertiesToRemove,
      maxEmbeddedBase64Length
    });
    debuglog('AST cleanup DONE'); // -> [BLOCK FOR] generate final critical css from critical ast

    const css = _cssTree.default.generate(ast);

    debuglog('generated CSS from AST'); // take after screenshot (optional) [BLOCKING]

    if (takeScreenshots) {
      // wait for the before screenshot, before start modifying the page
      await beforeScreenshotPromise;
      debuglog('inline critical styles for after screenshot');
      await page.evaluate(_replacePageCss.default, {
        css
      }).then(() => {
        return grabPageScreenshot({
          type: 'after',
          page,
          screenshots,
          screenshotExtension,
          debuglog
        });
      });
    }

    debuglog('generateCriticalCss DONE');
    cleanupAndExit({
      returnValue: css
    });
  });
}

var _default = pruneNonCriticalCssLauncher;
exports.default = _default;