test/unit/test-chunk.js - main - githubmirror/amphtml

test/unit/test-chunk.js
664 строки19 KB
Daniel Rozenberg
❄️ Unskip some tests that no longer fail (#39329)
09 авг 2023, 22:33
09 авг 2023, 22:331986291
import {Services} from '#service';
import {installDocService} from '#service/ampdoc-impl';

import {
  activateChunkingForTesting,
  chunkInstanceForTesting,
  deactivateChunking,
  onIdle,
  startupChunk,
} from '../../src/chunk';

describes.sandboxed('chunk2', {}, () => {
  beforeEach(() => {
    activateChunkingForTesting();
  });

  const resolvingIdleCallbackWithTimeRemaining = (timeRemaining) => (fn) => {
    Promise.resolve({
      timeRemaining: () => timeRemaining,
    }).then(fn);
  };

  function basicTests(env) {
    let fakeWin;

    beforeEach(() => {
      fakeWin = env.win;

      // If there is a viewer, wait for it, so we run with it being
      // installed.
      if (env.win.__AMP_SERVICES.viewer) {
        return Services.viewerPromiseForDoc(env.win.document).then(() => {
          // Make sure we make a chunk instance, so all runs
          // have a viewer.
          chunkInstanceForTesting(env.win.document);
          return Promise.resolve();
        });
      }
    });

    it('should execute a chunk', (done) => {
      startupChunk(fakeWin.document, (unusedIdleDeadline) => {
        done();
      });
    });

    it('should execute chunks', () => {
      let count = 0;
      let progress = '';
      return new Promise((resolve) => {
        function complete(str) {
          return function (unusedIdleDeadline) {
            progress += str;
            if (++count == 6) {
              resolve();
            }
          };
        }
        startupChunk(fakeWin.document, complete('a'));
        startupChunk(fakeWin.document, complete('b'));
        startupChunk(fakeWin.document, function () {
          complete('c')();
          startupChunk(fakeWin.document, function () {
            complete('d')();
            startupChunk(fakeWin.document, complete('e'));
            startupChunk(fakeWin.document, complete('f'));
          });
        });
      }).then(() => {
        expect(progress).to.equal('abcdef');
      });
    });
  }

  describes.fakeWin(
    'visible no amp',
    {
      amp: false,
    },
    (env) => {
      beforeEach(() => {
        installDocService(env.win, /* isSingleDoc */ true);
        expect(env.win.__AMP_SERVICES.viewer).to.be.undefined;
        env.win.document.hidden = false;
      });

      basicTests(env);

      it('should support nested micro tasks in chunks', (done) => {
        let progress = '';
        startupChunk(env.win.document, () => {
          progress += '1';
          Promise.resolve()
            .then(() => (progress += 2))
            .then(() => (progress += 3))
            .then(() => (progress += 4))
            .then(() => (progress += 5));
        });
        startupChunk(env.win.document, () => {
          expect(progress).to.equal('12345');
          done();
        });
      });
    }
  );

  describes.fakeWin(
    'invisible no amp',
    {
      amp: false,
    },
    (env) => {
      beforeEach(() => {
        installDocService(env.win, /* isSingleDoc */ true);
        expect(env.win.__AMP_SERVICES.viewer).to.be.undefined;
        env.win.document.hidden = true;
        env.win.requestIdleCallback = function () {
          throw new Error('Should not be called');
        };
        env.win.postMessage = function (data, targetOrigin) {
          expect(targetOrigin).to.equal('*');
          Promise.resolve().then(() => {
            const event = {
              data,
              type: 'message',
            };
            env.win.eventListeners.fire(event);
          });
        };
      });

      basicTests(env);
    }
  );

  describes.fakeWin(
    'with viewer',
    {
      amp: true,
    },
    (env) => {
      beforeEach(() => {
        expect(env.win.__AMP_SERVICES.viewer).to.exist;
        env.win.document.hidden = false;
      });

      describe('visible', () => {
        beforeEach(() => {
          const {ampdoc} = env;
          env.sandbox.stub(ampdoc, 'isVisible').callsFake(() => {
            return true;
          });
        });

        it('should execute a chunk with an ampdoc', (done) => {
          startupChunk(env.ampdoc, (unusedIdleDeadline) => {
            done();
          });
        });

        basicTests(env);
      });

      describe('error handling', () => {
        let fakeWin;
        let done;

        function onReject(event) {
          expect(event.reason.message).to.match(/test async/);
          done();
        }

        beforeEach(() => {
          fakeWin = env.win;
          const {ampdoc} = env;
          env.sandbox.stub(ampdoc, 'isVisible').callsFake(() => {
            return true;
          });
          window.addEventListener('unhandledrejection', onReject);
        });

        afterEach(() => {
          window.removeEventListener('unhandledrejection', onReject);
        });

        it('should proceed on error and rethrowAsync', (d) => {
          startupChunk(fakeWin.document, () => {
            throw new Error('test async');
          });
          startupChunk(fakeWin.document, () => {
            done = d;
          });
        });
      });

      describe('invisible', () => {
        beforeEach(() => {
          const {ampdoc} = env;
          env.sandbox.stub(ampdoc, 'isVisible').callsFake(() => {
            return false;
          });
          env.win.requestIdleCallback =
            resolvingIdleCallbackWithTimeRemaining(15);
          const chunks = chunkInstanceForTesting(env.win.document);
          env.sandbox.stub(chunks, 'executeAsap_').callsFake(() => {
            throw new Error('No calls expected: executeAsap_');
          });
          env.win.location.resetHref('test#visibilityState=hidden');
        });

        basicTests(env);
      });

      describe('invisible but deactivated', () => {
        beforeEach(() => {
          deactivateChunking();
          const {ampdoc} = env;
          env.sandbox.stub(ampdoc, 'isVisible').callsFake(() => {
            return false;
          });
          env.win.requestIdleCallback = () => {
            throw new Error('No calls expected');
          };
          env.win.location.resetHref('test#visibilityState=hidden');
        });

        basicTests(env);
      });

      describe('invisible via document.hidden', () => {
        beforeEach(() => {
          const {ampdoc} = env;
          env.sandbox.stub(ampdoc, 'isVisible').callsFake(() => {
            return false;
          });
          env.win.requestIdleCallback =
            resolvingIdleCallbackWithTimeRemaining(15);
          const chunks = chunkInstanceForTesting(env.win.document);
          env.sandbox.stub(chunks, 'executeAsap_').callsFake(() => {
            throw new Error('No calls expected: executeAsap_');
          });
          env.win.document.hidden = true;
        });

        basicTests(env);
      });

      describe('invisible to visible', () => {
        beforeEach(() => {
          env.win.location.resetHref('test#visibilityState=hidden');
          const {ampdoc} = env;
          let visible = false;
          env.sandbox.stub(ampdoc, 'isVisible').callsFake(() => {
            return visible;
          });
          env.win.requestIdleCallback = () => {
            // Don't call the callback, but transition to visible
            visible = true;
            ampdoc.visibilityStateHandlers_.fire();
          };
        });

        basicTests(env);
      });

      describe('invisible to visible', () => {
        beforeEach(() => {
          env.win.location.resetHref('test#visibilityState=prerender');
          const {ampdoc} = env;
          let visible = false;
          env.sandbox.stub(ampdoc, 'isVisible').callsFake(() => {
            return visible;
          });
          env.win.requestIdleCallback = () => {
            // Don't call the callback, but transition to visible
            visible = true;
            ampdoc.visibilityStateHandlers_.fire();
          };
        });

        basicTests(env);
      });

      describe('invisible to visible after a while', () => {
        beforeEach(() => {
          env.win.location.resetHref('test#visibilityState=hidden');
          const {ampdoc} = env;
          let visible = false;
          env.sandbox.stub(ampdoc, 'isVisible').callsFake(() => {
            return visible;
          });
          env.win.requestIdleCallback = () => {
            // Don't call the callback, but transition to visible
            setTimeout(() => {
              visible = true;
              ampdoc.visibilityStateHandlers_.fire();
            }, 10);
          };
        });

        basicTests(env);
      });
    }
  );

  describes.realWin(
    'realWin',
    {
      amp: true,
    },
    (env) => {
      beforeEach(() => {
        env.sandbox.defineProperty(env.win.document, 'hidden', {
          get: () => false,
        });
      });
      basicTests(env);
    }
  );

  describes.realWin(
    'realWin noIdleCallback',
    {
      amp: true,
    },
    (env) => {
      beforeEach(() => {
        env.win.requestIdleCallback = null;
        expect(env.win.requestIdleCallback).to.be.null;
        const {ampdoc} = env;
        env.sandbox.stub(ampdoc, 'isVisible').callsFake(() => {
          return false;
        });
        env.sandbox.defineProperty(env.win.document, 'hidden', {
          get: () => false,
        });
      });
      basicTests(env);
    }
  );
});

describes.sandboxed('long tasks', {}, () => {
  describes.fakeWin(
    'long chunk tasks force a macro task between work',
    {
      amp: false,
    },
    (env) => {
      let subscriptions;
      let clock;
      let progress;
      let postMessageCalls;

      function complete(str, long) {
        return function (unusedIdleDeadline) {
          if (long) {
            // Ensure this task takes a long time beyond the 5ms buffer.
            clock.tick(100);
          }
          progress += str;
        };
      }

      function runSubs() {
        subscriptions['message']
          .slice()
          .forEach((method) => method({data: 'amp-macro-task'}));
      }

      beforeEach(() => {
        postMessageCalls = 0;
        subscriptions = {};
        clock = env.sandbox.useFakeTimers();
        installDocService(env.win, /* isSingleDoc */ true);

        env.win.addEventListener = function (type, handler) {
          if (subscriptions[type] && !subscriptions[type].includes(handler)) {
            subscriptions[type].push(handler);
          } else {
            subscriptions[type] = [handler];
          }
        };

        env.win.postMessage = function (key) {
          expect(key).to.equal('amp-macro-task');
          postMessageCalls++;
          runSubs();
        };

        progress = '';
        chunkInstanceForTesting(
          env.win.document.documentElement
        ).macroAfterLongTask_ = true;
      });

      it('should not break out of microtask loop when body is invisible', (done) => {
        startupChunk(env.win.document, complete('init', true));
        startupChunk(env.win.document, complete('a', true));
        startupChunk(env.win.document, complete('b', true));
        startupChunk(env.win.document, () => {
          expect(progress).to.equal('initab');
          done();
        });
      });

      it('should execute chunks after long task in a macro task', (done) => {
        startupChunk(env.win.document, complete('1', true));
        startupChunk(env.win.document, complete('2', false));
        startupChunk(
          env.win.document,
          function () {
            complete('3', false)();
            expect(progress).to.equal('123');
            expect(postMessageCalls).to.equal(0);
          },
          /* make body visible */ true
        );
        startupChunk(env.win.document, () => {
          expect(postMessageCalls).to.equal(1);
          expect(progress).to.equal('123');
          complete('4', false)();
        });
        startupChunk(env.win.document, () => {
          expect(postMessageCalls).to.equal(1);
          expect(progress).to.equal('1234');
        });
        startupChunk(env.win.document, complete('5', true));
        startupChunk(env.win.document, () => {
          expect(postMessageCalls).to.equal(2);
          expect(progress).to.equal('12345');
          done();
        });
      });

      it('should not issue a macro task after having been idle', (done) => {
        (async function () {
          startupChunk(
            env.win.document,
            complete('1', false),
            /* make body visible */ true
          );
          // Unwind the promise queue so that subsequent invocations
          // are scheduled into an empty task queue.
          for (let i = 0; i < 100; i++) {
            await Promise.resolve();
          }
          expect(progress).to.equal('1');
          complete('2', true)();
          startupChunk(env.win.document, () => {
            expect(postMessageCalls).to.equal(0);
            expect(progress).to.equal('12');
            done();
          });
        })();
      });
    }
  );
});

describes.sandboxed('isInputPending usage', {}, () => {
  describes.fakeWin(
    'pending input breaks microtask loop to subsequent macrotask',
    {
      amp: false,
    },
    (env) => {
      let subscriptions;
      let progress;
      let postMessageCalls;
      let pendingInput;

      function complete(str, simulatePendingInputAfter) {
        return function (unusedIdleDeadline) {
          if (simulatePendingInputAfter) {
            pendingInput = true;
          }
          progress += str;
        };
      }

      function runSubs() {
        subscriptions['message']
          .slice()
          .forEach((method) => method({data: 'amp-macro-task'}));
      }

      beforeEach(() => {
        postMessageCalls = 0;
        pendingInput = false;
        subscriptions = {};

        env.win.navigator.scheduling = {
          isInputPending: function () {
            if (pendingInput) {
              pendingInput = false;
              return true;
            }

            return false;
          },
        };

        installDocService(env.win, /* isSingleDoc */ true);

        env.win.addEventListener = function (type, handler) {
          if (subscriptions[type] && !subscriptions[type].includes(handler)) {
            subscriptions[type].push(handler);
          } else {
            subscriptions[type] = [handler];
          }
        };

        env.win.postMessage = function (key) {
          expect(key).to.equal('amp-macro-task');
          postMessageCalls++;
          runSubs();
        };

        progress = '';
        chunkInstanceForTesting(
          env.win.document.documentElement
        ).macroAfterLongTask_ = true;
      });

      it('should not break out of microtask loop when body is invisible', (done) => {
        startupChunk(env.win.document, complete('init', true));
        startupChunk(env.win.document, complete('a', true));
        startupChunk(env.win.document, complete('b', true));
        startupChunk(env.win.document, () => {
          expect(progress).to.equal('initab');
          done();
        });
      });

      it('should execute chunks after pending input in a macro task', (done) => {
        startupChunk(env.win.document, complete('1', true));
        startupChunk(env.win.document, complete('2', false));
        startupChunk(
          env.win.document,
          function () {
            complete('3', false)();
            expect(progress).to.equal('123');
            expect(postMessageCalls).to.equal(0);
          },
          /* make body visible */ true
        );
        startupChunk(env.win.document, () => {
          expect(postMessageCalls).to.equal(1);
          expect(progress).to.equal('123');
          complete('4', false)();
        });
        startupChunk(env.win.document, () => {
          expect(postMessageCalls).to.equal(1);
          expect(progress).to.equal('1234');
        });
        startupChunk(env.win.document, complete('5', true));
        startupChunk(env.win.document, () => {
          expect(postMessageCalls).to.equal(2);
          expect(progress).to.equal('12345');
          done();
        });
      });
    }
  );
});

describes.sandboxed('onIdle', {}, (env) => {
  let win;
  let calls;
  let callbackCalled;
  let clock;

  beforeEach(() => {
    clock = env.sandbox.useFakeTimers();
    calls = [];
    callbackCalled = false;
    win = {
      requestIdleCallback: (fn, options) => {
        calls.push({
          invoke: (timeRemaining, didTimeout) => {
            fn({
              timeRemaining: () => timeRemaining,
              didTimeout: !!didTimeout,
            });
          },
          options,
        });
      },
    };
  });

  function markCalled() {
    callbackCalled = true;
  }

  it('should fire for sufficient remaining time', () => {
    onIdle(win, 66, 1000, markCalled);
    expect(calls).to.have.length(1);
    expect(callbackCalled).to.be.false;
    expect(calls[0].options.timeout).to.equal(1000);
    calls[0].invoke(66);
    expect(callbackCalled).to.be.true;
    expect(calls).to.have.length(1);
  });

  it('should try again with not enough time', () => {
    onIdle(win, 66, 1000, markCalled);
    expect(calls).to.have.length(1);
    expect(callbackCalled).to.be.false;
    expect(calls[0].options.timeout).to.equal(1000);
    clock.tick(100);
    calls[0].invoke(65);
    expect(callbackCalled).to.be.false;
    expect(calls).to.have.length(2);
    expect(calls[1].options.timeout).to.equal(900);
    calls[1].invoke(66);
    expect(callbackCalled).to.be.true;
    expect(calls).to.have.length(2);
  });

  it('should try again with not enough time (2 recursions)', () => {
    onIdle(win, 66, 1000, markCalled);
    expect(calls).to.have.length(1);
    expect(callbackCalled).to.be.false;
    expect(calls[0].options.timeout).to.equal(1000);
    clock.tick(100);
    calls[0].invoke(65);
    expect(callbackCalled).to.be.false;
    expect(calls).to.have.length(2);
    expect(calls[1].options.timeout).to.equal(900);
    clock.tick(50);
    calls[1].invoke(0);
    expect(callbackCalled).to.be.false;
    expect(calls).to.have.length(3);
    expect(calls[2].options.timeout).to.equal(850);
    calls[2].invoke(66);
    expect(callbackCalled).to.be.true;
    expect(calls).to.have.length(3);
  });

  it('should timeout when callback is called after timeout', () => {
    onIdle(win, 66, 1000, markCalled);
    expect(calls).to.have.length(1);
    expect(callbackCalled).to.be.false;
    expect(calls[0].options.timeout).to.equal(1000);
    clock.tick(1000);
    // Not enough time remaining but timed out via time.
    calls[0].invoke(1);
    expect(callbackCalled).to.be.true;
    expect(calls).to.have.length(1);
  });

  it('should timeout when callback is called with didTimeout', () => {
    onIdle(win, 66, 1000, markCalled);
    expect(calls).to.have.length(1);
    expect(callbackCalled).to.be.false;
    expect(calls[0].options.timeout).to.equal(1000);
    // Not enough time remaining but timed out via didTimeout.
    calls[0].invoke(1, /* didTimeout */ true);
    expect(callbackCalled).to.be.true;
    expect(calls).to.have.length(1);
  });
});