backporting the root implementation with memoize feature

Author: lynchbomb

USAGE.md

@@ -111,7 +111,8 @@ The `Watcher` constructor can be passed 3 different options:
 
 * `time` - The time threshold
 * `ratio` - The ratio threshold
-* `rootMargin` - The [rootMargin](https://wicg.github.io/IntersectionObserver/#dom-intersectionobserverinit-rootmargin) in object form.
+* `rootMargin` - The [rootMargin](https://developer.mozilla.org/en-US/docs/Web/API/Intersection_Observer_API#Intersection_observer_options) in object form.
+* `root` - The [root](https://developer.mozilla.org/en-US/docs/Web/API/Intersection_Observer_API#Intersection_observer_options) element with respect to which we want to watch the target. By default it is window.
 
 ## Utility API
 

src/intersection-observer.ts

@@ -109,6 +109,9 @@ export class SpanielIntersectionObserver implements IntersectionObserver {
   takeRecords(): IntersectionObserverEntry[] {
     return [];
   }
+  forceStateValidation() {
+    this.scheduler.forceStateValidation();
+  }
   private generateEntryEvent(frame: Frame, clientRect: DOMRectReadOnly, el: Element): EntryEvent {
     let count: number = 0;
     let entry = generateEntry(frame, clientRect, el, this.rootMarginObj);
@@ -132,14 +135,14 @@ export class SpanielIntersectionObserver implements IntersectionObserver {
     this.id = generateToken();
     options.threshold = options.threshold || 0;
     this.rootMarginObj = rootMarginToDOMMargin(options.rootMargin || '0px');
-
+    this.root = options.root;
     if (Array.isArray(options.threshold)) {
       this.thresholds = <Array<number>>options.threshold;
     } else {
       this.thresholds = [<number>options.threshold];
     }
 
-    this.scheduler = new ElementScheduler();
+    this.scheduler = new ElementScheduler(null, this.root);
   }
 };
 
@@ -182,8 +185,8 @@ export class IntersectionObserverEntry implements IntersectionObserverEntryInit
 export function generateEntry(frame: Frame, clientRect: DOMRectReadOnly, el: Element, rootMargin: DOMMargin): IntersectionObserverEntry {
   let { top, bottom, left, right } = clientRect;
   let rootBounds: ClientRect = {
-    left: rootMargin.left,
-    top: rootMargin.top,
+    left: frame.left + rootMargin.left,
+    top: frame.top + rootMargin.top,
     bottom: rootMargin.bottom,
     right: rootMargin.right,
     width: frame.width - (rootMargin.right + rootMargin.left),

src/metal/interfaces.ts

@@ -52,17 +52,30 @@ export interface FrameInterface {
   scrollLeft: number;
   width: number;
   height: number;
+  x: number;
+  y: number;
+  top: number;
+  left: number;
 }
 
 export interface MetaInterface {
+  scrollTop: number;
+  scrollLeft: number;
   width: number;
   height: number;
-  scrollLeft: number;
-  scrollTop: number;
+  x: number;
+  y: number;
+  top: number;
+  left: number;
 }
 
-export interface OnWindowIsDirtyInterface {
-  fn: any;
-  scope: any;
-  id: string;
+export interface SpanielClientRectInterface {
+  width: number;
+  height: number;
+  x: number;
+  y: number;
+  bottom: number;
+  top: number;
+  left: number;
+  right: number;
 }

src/metal/scheduler.ts

@@ -14,7 +14,9 @@ import {
   SchedulerInterface,
   ElementSchedulerInterface,
   FrameInterface,
-  QueueInterface
+  QueueInterface,
+  MetaInterface,
+  SpanielClientRectInterface
 } from './interfaces';
 import W from './window-proxy';
 
@@ -29,45 +31,85 @@ const TOKEN_SEED = 'xxxx'.replace(/[xy]/g, function(c) {
 });
 let tokenCounter = 0;
 
-function generateRandomToken() {
-  return Math.floor(Math.random() * (9999999 - 0o0)).toString(16);
-}
-
 export class Frame implements FrameInterface {
   constructor(
     public timestamp: number,
     public scrollTop: number,
     public scrollLeft: number,
     public width: number,
-    public height: number
+    public height: number,
+    public x: number,
+    public y: number,
+    public top: number,
+    public left: number
   ) {}
-  static generate(): Frame {
+  static generate(root: Element | Window = window): Frame {
+    const rootMeta = this.revalidateRootMeta(root);
     return new Frame(
       Date.now(),
-      W.meta.scrollTop,
-      W.meta.scrollLeft,
-      W.meta.width,
-      W.meta.height
+      rootMeta.scrollTop,
+      rootMeta.scrollLeft,
+      rootMeta.width,
+      rootMeta.height,
+      rootMeta.x,
+      rootMeta.y,
+      rootMeta.top,
+      rootMeta.left
     );
   }
+  static revalidateRootMeta(root: any = window): MetaInterface {
+    let _rootMeta: MetaInterface = {
+      width: 0,
+      height: 0,
+      scrollTop: 0,
+      scrollLeft: 0,
+      x: 0,
+      y: 0,
+      top: 0,
+      left: 0
+    };
+
+    if (root === window) {
+      _rootMeta.scrollTop = W.getScrollTop();
+      _rootMeta.scrollLeft = W.getScrollLeft();
+      _rootMeta.width = W.getWidth();
+      _rootMeta.height = W.getHeight();
+    }else if (root) {
+      let _clientRect = getBoundingClientRect(root);
+      _rootMeta.scrollTop = root.scrollTop;
+      _rootMeta.scrollLeft = root.scrollLeft;
+      _rootMeta.width = _clientRect.width;
+      _rootMeta.height = _clientRect.height;
+      _rootMeta.x = _clientRect.x;
+      _rootMeta.y = _clientRect.y;
+      _rootMeta.top = _clientRect.top;
+      _rootMeta.left = _clientRect.left;
+    }
+
+    return _rootMeta;
+  }
 }
 
 export function generateToken() {
   return tokenCounter++ + TOKEN_SEED;
 }
 
 export abstract class BaseScheduler {
+  protected root: Element | Window;
   protected engine: EngineInterface;
   protected queue: QueueInterface;
   protected isTicking: Boolean = false;
   protected toRemove: Array<string| Element | Function> = [];
+  protected id?: string;
 
-  constructor(customEngine?: EngineInterface) {
+  constructor(customEngine?: EngineInterface, root: Element | Window = window) {
     if (customEngine) {
       this.engine = customEngine;
     } else {
       this.engine = getGlobalEngine();
     }
+
+    this.root = root;
   }
   protected abstract applyQueue(frame: Frame): void;
 
@@ -81,8 +123,7 @@ export abstract class BaseScheduler {
         }
         this.toRemove = [];
       }
-
-      this.applyQueue(Frame.generate());
+      this.applyQueue(Frame.generate(this.root));
       this.engine.scheduleRead(this.tick.bind(this));
     }
   }
@@ -97,7 +138,7 @@ export abstract class BaseScheduler {
     let frame: Frame = null;
     this.engine.scheduleRead(() => {
       clientRect = getBoundingClientRect(el);
-      frame = Frame.generate();
+      frame = Frame.generate(this.root);
     });
     this.engine.scheduleWork(() => {
       callback(clientRect, frame);
@@ -108,14 +149,20 @@ export abstract class BaseScheduler {
   }
   unwatchAll() {
     this.queue.clear();
-    W.__destroy__();
   }
   startTicking() {
     if (!this.isTicking) {
       this.isTicking = true;
       this.engine.scheduleRead(this.tick.bind(this));
     }
   }
+  forceStateValidation() {
+    ++W.version;
+    W.meta.height = W.getHeight();
+    W.meta.width = W.getWidth();
+    W.meta.scrollLeft = W.getScrollLeft();
+    W.meta.scrollTop = W.getScrollTop();
+  }
 }
 
 export class Scheduler extends BaseScheduler implements SchedulerInterface {
@@ -140,7 +187,7 @@ export class Scheduler extends BaseScheduler implements SchedulerInterface {
 export class PredicatedScheduler extends Scheduler implements SchedulerInterface {
   predicate: (frame: Frame) => Boolean;
   constructor(predicate: (frame: Frame) => Boolean) {
-    super(null);
+    super(null, window);
     this.predicate = predicate;
   }
   applyQueue(frame: Frame) {
@@ -152,13 +199,15 @@ export class PredicatedScheduler extends Scheduler implements SchedulerInterface
 
 export class ElementScheduler extends BaseScheduler implements ElementSchedulerInterface {
   protected queue: DOMQueue;
-  protected isDirty: boolean = false;
-  protected id: string = '';
+  protected lastVersion: number = W.version;
 
-  constructor(customEngine?: EngineInterface) {
-    super(customEngine);
+  constructor(customEngine?: EngineInterface, root?: Element | Window) {
+    super(customEngine, root);
     this.queue = new DOMQueue();
-    this.id = generateRandomToken();
+  }
+
+  get isDirty(): boolean {
+    return W.version !== this.lastVersion;
   }
 
   applyQueue(frame: Frame) {
@@ -172,11 +221,10 @@ export class ElementScheduler extends BaseScheduler implements ElementSchedulerI
       callback(frame, id, clientRect);
     }
 
-    this.isDirty = false;
+    this.lastVersion = W.version;
   }
 
   watch(el: Element, callback: (frame: FrameInterface, id: string, clientRect?: ClientRect | null) => void, id?: string): string {
-    this.initWindowIsDirtyListeners();
     this.startTicking();
     id = id || generateToken();
     let clientRect = null;
@@ -189,14 +237,6 @@ export class ElementScheduler extends BaseScheduler implements ElementSchedulerI
     });
     return id;
   }
-
-  initWindowIsDirtyListeners() {
-    W.onWindowIsDirtyListeners.push({ fn: this.windowIsDirtyHandler, scope: this, id: this.id });
-  }
-
-  windowIsDirtyHandler() {
-    this.isDirty = true;
-  }
 }
 
 let globalScheduler: Scheduler = null;