implab/implabjs-djx Files · djx/src/main/ts/tsx/WatchForRendition.ts

Added priorities to render tasks, revisited rendering scheduler...

Added priorities to render tasks, revisited rendering scheduler nested `watch` and `watchFor` has a lower priority then they enclosing renditions

cin - - Load All Authors

File last commit:

r146:af4f8424e83d v1.9.0 default


                r146:af4f8424e83d

v1.9.0 default

Download file

             WatchForRendition.ts
        
                    207 lines
            
             | 6.6 KiB
            
                | video/mp2t
            
             |
                TypeScriptLexer
            
             / djx / src / main / ts / tsx / WatchForRendition.ts
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        cin
    
Working on WatchForRendition

              r107
            
      import { id as mid } from "module";

      import { TraceSource } from "@implab/core-amd/log/TraceSource";

      import { argumentNotNull } from "@implab/core-amd/safe";

        cin
    
Added priorities to render tasks, revisited rendering scheduler...

              r146
            
      import { queueRenderTask, getPriority, getScope, render } from "./render";

        cin
    
Working on WatchForRendition

              r107
            
      import { RenditionBase } from "./RenditionBase";

      import { Scope } from "./Scope";

      import { Cancellation } from "@implab/core-amd/Cancellation";

      import { collectNodes, destroy as safeDestroy, isDocumentFragmentNode, isElementNode, isMounted, placeAt, startupWidgets } from "./traits";

      import { IDestroyable } from "@implab/core-amd/interfaces";

      import { play } from "../play";

      import * as fx from "dojo/fx";

        cin
    
added whenRendered() method to wait for pending oprations to complete

              r118
            
      import { isSubscribable, Subscribable } from "../observable";

      import { isDjObservableResults, OrderedUpdate } from "../store";

        cin
    
Working on WatchForRendition

              r107
            
      const trace = TraceSource.get(mid);

      interface ItemRendition {

          nodes: Node[];

          scope: IDestroyable;

          destroy(): void;

      }

        cin
    
added reduce() and next() methods to observable...

              r116
            
      interface RenderTask<T> extends OrderedUpdate<T> {

        cin
    
Working on WatchForRendition

              r107
            
          animate: boolean;

      }

      export interface AnimationAttrs {

          animate?: boolean;

          animateIn?: (nodes: Node[]) => Promise<void>;

          animateOut?: (nodes: Node[]) => Promise<void>;

      }

      export interface WatchForRenditionAttrs<T> extends AnimationAttrs {

        cin
    
added whenRendered() method to wait for pending oprations to complete

              r118
            
          subject: T[] | Subscribable<OrderedUpdate<T>> | undefined | null;

        cin
    
Working on WatchForRendition

              r107
            
          component: (arg: T, index: number) => unknown;

      }

        cin
    
linting

              r109
            
      const noop = () => { };

        cin
    
Working on WatchForRendition

              r107
            
      const fadeIn = (nodes: Node[]) => Promise.all(nodes

          .filter(isElementNode)

          .map(el => play(fx.fadeIn({ node: el as HTMLElement })))

      ).then(noop);

      const fadeOut = (nodes: Node[]) => Promise.all(nodes

          .filter(isElementNode)

          .map(el => play(fx.fadeOut({ node: el as HTMLElement })))

      ).then(noop);

      export class WatchForRendition<T> extends RenditionBase<Node> {

          private readonly _component: (arg: T, index: number) => unknown;

          private readonly _node: Node;

          private readonly _itemRenditions: ItemRendition[] = [];

        cin
    
added reduce() and next() methods to observable...

              r116
            
          private readonly _subject: T[] | Subscribable<OrderedUpdate<T>>;

        cin
    
Working on WatchForRendition

              r107
            
          private readonly _renderTasks: RenderTask<T>[] = [];

          private readonly _animate: boolean;

          private readonly _animateIn: (nodes: Node[]) => Promise<void>;

          private readonly _animateOut: (nodes: Node[]) => Promise<void>;

          private _ct = Cancellation.none;

        cin
    
Added priorities to render tasks, revisited rendering scheduler...

              r146
            
          private _priority = 0;

        cin
    
Working on WatchForRendition

              r107
            
          constructor({ subject, component, animate, animateIn, animateOut }: WatchForRenditionAttrs<T>) {

              super();

              argumentNotNull(component, "component");

              this._component = component;

        cin
    
added whenRendered() method to wait for pending oprations to complete

              r118
            
              this._subject = subject ?? [];

        cin
    
Working on WatchForRendition

              r107
            
              this._node = document.createComment("[WatchFor]");

              this._animate = !!animate;

              this._animateIn = animateIn ?? fadeIn;

              this._animateOut = animateOut ?? fadeOut;

          }

          protected _create() {

        cin
    
Added priorities to render tasks, revisited rendering scheduler...

              r146
            
              this._priority = getPriority() + 1;

        cin
    
Working on WatchForRendition

              r107
            
              const scope = getScope();

              scope.own(() => {

                  this._itemRenditions.forEach(safeDestroy);

                  safeDestroy(this._node);

              });

              const result = this._subject;

              if (result) {

        cin
    
added whenRendered() method to wait for pending oprations to complete

              r118
            
                  if (isSubscribable<OrderedUpdate<T>>(result)) {

        cin
    
Working on WatchForRendition

              r107
            
                      let animate = false;

                      const subscription = result.subscribe({

        cin
    
linting

              r109
            
                          next: ({ item, prevIndex, newIndex }) => this._onItemUpdated({ item, prevIndex, newIndex, animate })

        cin
    
Working on WatchForRendition

              r107
            
                      });

                      scope.own(subscription);

                      animate = this._animate;

                  } else {

        cin
    
added whenRendered() method to wait for pending oprations to complete

              r118
            
                      if (isDjObservableResults<T>(result))

        cin
    
Working on WatchForRendition

              r107
            
                          scope.own(result.observe((item, prevIndex, newIndex) => this._onItemUpdated({ item, prevIndex, newIndex, animate: false }), true));

                      for (let i = 0, n = result.length; i < n; i++)

                          this._onItemUpdated({ item: result[i], prevIndex: -1, newIndex: i, animate: this._animate });

                  }

              }

              this._ct = new Cancellation(cancel => scope.own(cancel));

          }

        cin
    
linting

              r109
            
          private readonly _onItemUpdated = (item: RenderTask<T>) => {

        cin
    
Working on WatchForRendition

              r107
            
              if (!this._renderTasks.length) {

                  // schedule a new job

                  this._renderTasks.push(item);

        cin
    
Added priorities to render tasks, revisited rendering scheduler...

              r146
            
                  // fork

                  // use dummy scope, because every item will have it's own scope

                  queueRenderTask(this._render, Scope.dummy, this._priority);

        cin
    
Working on WatchForRendition

              r107
            
              } else {

                  // update existing job

                  this._renderTasks.push(item);

              }

        cin
    
linting

              r109
            
          };

        cin
    
Working on WatchForRendition

              r107
            
        cin
    
Added priorities to render tasks, revisited rendering scheduler...

              r146
            
          private readonly _render = () => {

              // don't render destroyed rendition

              if (this._ct.isRequested())

                  return;

        cin
    
Working on WatchForRendition

              r107
            
        cin
    
Added priorities to render tasks, revisited rendering scheduler...

              r146
            
              this._renderTasks.forEach(this._onRenderItem);

              this._renderTasks.length = 0;

          };

        cin
    
Working on WatchForRendition

              r107
            
        cin
    
linting

              r109
            
          private readonly _onRenderItem = ({ item, newIndex, prevIndex, animate: _animate }: RenderTask<T>) => {

        cin
    
Working on WatchForRendition

              r107
            
              const animate = _animate && prevIndex !== newIndex;

              if (prevIndex > -1) {

                  // if we need to delete previous rendition

                  const [{ nodes, destroy }] = this._itemRenditions.splice(prevIndex, 1);

                  if (animate) {

                      this._animateOut(nodes)

                          .then(destroy)

                          .catch(e => trace.error(e));

                  } else {

                      destroy();

                  }

              }

              if (newIndex > -1) {

                  // if we need to create the new rendition

                  // 1. create a new scope for rendering a content

                  const scope = new Scope();

                  // 2. render the content

                  const itemNode = render(this._component(item, newIndex), scope);

                  // 3. track nodes 

                  const nodes = isDocumentFragmentNode(itemNode) ?

                      collectNodes(itemNode.childNodes) :

                      [itemNode];

                  // 5. insert node at the correct position

                  const { nodes: [beforeNode] } = this._itemRenditions[newIndex] ?? { nodes: [] };

                  if (beforeNode)

                      placeAt(itemNode, beforeNode, "before");

                  else

                      placeAt(itemNode, this._node, "before");

                  // 6. store information about rendition

                  this._itemRenditions.splice(newIndex, 0, {

                      scope,

                      nodes,

                      destroy: () => {

                          scope.destroy();

                          nodes.forEach(safeDestroy);

                      }

                  });

                  // 7. startup widgets if needed

                  if (isMounted(this._node))

                      nodes.forEach(n => startupWidgets(n));

                  // 8. optionally play the animation

                  if (animate)

                      this._animateIn(nodes).catch(e => trace.error(e));

              }

        cin
    
linting

              r109
            
          };

        cin
    
Working on WatchForRendition

              r107
            
          protected _getDomNode() {

              if (!this._node)

        cin
    
added whenRendered() method to wait for pending oprations to complete

              r118
            
                  throw new Error("The instance of the rendition isn't created");

        cin
    
Working on WatchForRendition

              r107
            
              return this._node;

          }

      }

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

cin Working on WatchForRendition	r107	import { id as mid } from "module";
		import { TraceSource } from "@implab/core-amd/log/TraceSource";
		import { argumentNotNull } from "@implab/core-amd/safe";
cin Added priorities to render tasks, revisited rendering scheduler...	r146	import { queueRenderTask, getPriority, getScope, render } from "./render";
cin Working on WatchForRendition	r107	import { RenditionBase } from "./RenditionBase";
		import { Scope } from "./Scope";
		import { Cancellation } from "@implab/core-amd/Cancellation";
		import { collectNodes, destroy as safeDestroy, isDocumentFragmentNode, isElementNode, isMounted, placeAt, startupWidgets } from "./traits";
		import { IDestroyable } from "@implab/core-amd/interfaces";
		import { play } from "../play";
		import * as fx from "dojo/fx";
cin added whenRendered() method to wait for pending oprations to complete	r118	import { isSubscribable, Subscribable } from "../observable";
		import { isDjObservableResults, OrderedUpdate } from "../store";
cin Working on WatchForRendition	r107
		const trace = TraceSource.get(mid);

		interface ItemRendition {
		nodes: Node[];

		scope: IDestroyable;

		destroy(): void;
		}

cin added reduce() and next() methods to observable...	r116	interface RenderTask<T> extends OrderedUpdate<T> {
cin Working on WatchForRendition	r107	animate: boolean;
		}

		export interface AnimationAttrs {
		animate?: boolean;

		animateIn?: (nodes: Node[]) => Promise<void>;

		animateOut?: (nodes: Node[]) => Promise<void>;
		}

		export interface WatchForRenditionAttrs<T> extends AnimationAttrs {
cin added whenRendered() method to wait for pending oprations to complete	r118	subject: T[] \| Subscribable<OrderedUpdate<T>> \| undefined \| null;
cin Working on WatchForRendition	r107
		component: (arg: T, index: number) => unknown;
		}


cin linting	r109	const noop = () => { };
cin Working on WatchForRendition	r107
		const fadeIn = (nodes: Node[]) => Promise.all(nodes
		.filter(isElementNode)
		.map(el => play(fx.fadeIn({ node: el as HTMLElement })))
		).then(noop);

		const fadeOut = (nodes: Node[]) => Promise.all(nodes
		.filter(isElementNode)
		.map(el => play(fx.fadeOut({ node: el as HTMLElement })))
		).then(noop);


		export class WatchForRendition<T> extends RenditionBase<Node> {
		private readonly _component: (arg: T, index: number) => unknown;

		private readonly _node: Node;

		private readonly _itemRenditions: ItemRendition[] = [];

cin added reduce() and next() methods to observable...	r116	private readonly _subject: T[] \| Subscribable<OrderedUpdate<T>>;
cin Working on WatchForRendition	r107
		private readonly _renderTasks: RenderTask<T>[] = [];

		private readonly _animate: boolean;

		private readonly _animateIn: (nodes: Node[]) => Promise<void>;

		private readonly _animateOut: (nodes: Node[]) => Promise<void>;

		private _ct = Cancellation.none;

cin Added priorities to render tasks, revisited rendering scheduler...	r146	private _priority = 0;

cin Working on WatchForRendition	r107	constructor({ subject, component, animate, animateIn, animateOut }: WatchForRenditionAttrs<T>) {
		super();
		argumentNotNull(component, "component");

		this._component = component;

cin added whenRendered() method to wait for pending oprations to complete	r118	this._subject = subject ?? [];
cin Working on WatchForRendition	r107
		this._node = document.createComment("[WatchFor]");
		this._animate = !!animate;
		this._animateIn = animateIn ?? fadeIn;
		this._animateOut = animateOut ?? fadeOut;
		}

		protected _create() {
cin Added priorities to render tasks, revisited rendering scheduler...	r146	this._priority = getPriority() + 1;
cin Working on WatchForRendition	r107	const scope = getScope();
		scope.own(() => {
		this._itemRenditions.forEach(safeDestroy);
		safeDestroy(this._node);
		});

		const result = this._subject;

		if (result) {
cin added whenRendered() method to wait for pending oprations to complete	r118	if (isSubscribable<OrderedUpdate<T>>(result)) {
cin Working on WatchForRendition	r107	let animate = false;
		const subscription = result.subscribe({
cin linting	r109	next: ({ item, prevIndex, newIndex }) => this._onItemUpdated({ item, prevIndex, newIndex, animate })
cin Working on WatchForRendition	r107	});
		scope.own(subscription);
		animate = this._animate;
		} else {
cin added whenRendered() method to wait for pending oprations to complete	r118	if (isDjObservableResults<T>(result))
cin Working on WatchForRendition	r107	scope.own(result.observe((item, prevIndex, newIndex) => this._onItemUpdated({ item, prevIndex, newIndex, animate: false }), true));

		for (let i = 0, n = result.length; i < n; i++)
		this._onItemUpdated({ item: result[i], prevIndex: -1, newIndex: i, animate: this._animate });
		}
		}
		this._ct = new Cancellation(cancel => scope.own(cancel));
		}

cin linting	r109	private readonly _onItemUpdated = (item: RenderTask<T>) => {
cin Working on WatchForRendition	r107	if (!this._renderTasks.length) {
		// schedule a new job
		this._renderTasks.push(item);
cin Added priorities to render tasks, revisited rendering scheduler...	r146
		// fork
		// use dummy scope, because every item will have it's own scope
		queueRenderTask(this._render, Scope.dummy, this._priority);
cin Working on WatchForRendition	r107	} else {
		// update existing job
		this._renderTasks.push(item);
		}
cin linting	r109	};
cin Working on WatchForRendition	r107
cin Added priorities to render tasks, revisited rendering scheduler...	r146	private readonly _render = () => {
		// don't render destroyed rendition
		if (this._ct.isRequested())
		return;
cin Working on WatchForRendition	r107
cin Added priorities to render tasks, revisited rendering scheduler...	r146	this._renderTasks.forEach(this._onRenderItem);
		this._renderTasks.length = 0;
		};
cin Working on WatchForRendition	r107
cin linting	r109	private readonly _onRenderItem = ({ item, newIndex, prevIndex, animate: _animate }: RenderTask<T>) => {
cin Working on WatchForRendition	r107	const animate = _animate && prevIndex !== newIndex;

		if (prevIndex > -1) {
		// if we need to delete previous rendition
		const [{ nodes, destroy }] = this._itemRenditions.splice(prevIndex, 1);
		if (animate) {
		this._animateOut(nodes)
		.then(destroy)
		.catch(e => trace.error(e));
		} else {
		destroy();
		}
		}

		if (newIndex > -1) {
		// if we need to create the new rendition

		// 1. create a new scope for rendering a content
		const scope = new Scope();

		// 2. render the content
		const itemNode = render(this._component(item, newIndex), scope);

		// 3. track nodes
		const nodes = isDocumentFragmentNode(itemNode) ?
		collectNodes(itemNode.childNodes) :
		[itemNode];

		// 5. insert node at the correct position

		const { nodes: [beforeNode] } = this._itemRenditions[newIndex] ?? { nodes: [] };

		if (beforeNode)
		placeAt(itemNode, beforeNode, "before");
		else
		placeAt(itemNode, this._node, "before");

		// 6. store information about rendition
		this._itemRenditions.splice(newIndex, 0, {
		scope,
		nodes,
		destroy: () => {
		scope.destroy();
		nodes.forEach(safeDestroy);
		}
		});

		// 7. startup widgets if needed
		if (isMounted(this._node))
		nodes.forEach(n => startupWidgets(n));

		// 8. optionally play the animation
		if (animate)
		this._animateIn(nodes).catch(e => trace.error(e));
		}
cin linting	r109	};
cin Working on WatchForRendition	r107
		protected _getDomNode() {
		if (!this._node)
cin added whenRendered() method to wait for pending oprations to complete	r118	throw new Error("The instance of the rendition isn't created");
cin Working on WatchForRendition	r107	return this._node;
		}
		}