implab/implabjs-djx Files · djx/src/main/ts/store.ts

Added tag v1.9.0 for changeset

cin - - Load All Authors

File last commit:

r144:63215d91ae4b v1.9.0-rc6 default


                r147:ae34865a484b

default

Download file

             store.ts
        
                    124 lines
            
             | 4.2 KiB
            
                | video/mp2t
            
             |
                TypeScriptLexer
            
             / djx / src / main / ts / store.ts
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

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

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

        cin
    
added store::get method to wrap up dojo/store/get

              r136
            
      import { isCancellable, isPromise } from "@implab/core-amd/safe";

      import { observe, Observable, empty } from "./observable";

      import { after } from "dojo/aspect";

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

              r116
            
      export interface OrderedUpdate<T> {

          /** The item is being updated */

          readonly item: T;

          /** The previous index of the item, -1 in case it is inserted */

          readonly prevIndex: number;

          /** The new index of the item, -1 in case it is deleted */

          readonly newIndex: number;

      }

      export type QueryResults<T> = Observable<OrderedUpdate<T>>;

      interface DjObservableResults<T> {

          /**

           * Allows observation of results

           */

          observe(listener: (object: T, previousIndex: number, newIndex: number) => void, includeUpdates?: boolean): {

              remove(): void;

          };

      }

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

              r118
            
      interface Queryable<T, Q, O> {

          query(query?: Q, options?: O): PromiseOrValue<T[]>;

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

              r116
            
      }

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

              r118
            
      export const isDjObservableResults = <T>(v: object): v is DjObservableResults<T> =>

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

              r116
            
          v && (typeof (v as { observe?: unknown; }).observe === "function");

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

              r118
            
      export const query = <T, Q, O>(store: Queryable<T, Q, O>, includeUpdates = true) =>

        cin
    
type fixes for i18n, store

              r120
            
          (query?: Q, options?: O & { observe?: boolean }) => {

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

              r116
            
              return observe<OrderedUpdate<T>>(({ next, complete, error, isClosed }) => {

        cin
    
added observable.collect() method to collect a sequnce to the array...

              r129
            
                  const processResults = (items: T[]) =>

                      items.forEach((item, newIndex) => next({ item, newIndex, prevIndex: -1 }));

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

              r116
            
                  try {

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

              r118
            
                      const results = store.query(query, options);

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

              r116
            
                      if (isPromise(results)) {

        cin
    
added observable.collect() method to collect a sequnce to the array...

              r129
            
                          results.then(processResults).then(undefined, error);

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

              r116
            
                      } else {

        cin
    
added observable.collect() method to collect a sequnce to the array...

              r129
            
                          processResults(results);

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

              r116
            
                      }

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

              r118
            
                      if (!isClosed() && (options?.observe !== false) && isDjObservableResults<T>(results)) {

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

              r116
            
                          const h = results.observe((item, prevIndex, newIndex) => next({ item, prevIndex, newIndex }), includeUpdates);

                          return () => h.remove();

                      } else {

                          complete();

                      }

                  } catch (err) {

                      error(err);

                  }

              });

          };

        cin
    
added store::get method to wrap up dojo/store/get

              r136
            
      interface IndexedStore<T> {

          get(id: string | number): PromiseLike<T> | T | null | undefined;

      }

      interface Notifications<T> {

          notify(item: T | undefined, id: string | number | undefined): void;

      }

      const hasNotifications = <T>(x: unknown): x is Notifications<T> =>

          typeof x === "object" && x !== null && (typeof (x as Notifications<T>).notify === "function");

      interface GetOpts {

          observe?: boolean;

      }

      type Change<T> = [item: NonNullable<T>, id: string | number | undefined] |

      [item: undefined | null, id: string | number];

      const filterItem = (itemId: string | number) =>

          <T>(source: Observable<Change<T>>) =>

              observe<T>(({ next, complete, error }) => {

                  const subscription = source

                      .filter(([, id]) => id === itemId)

                      .subscribe({

                          next: ([item]) => item !== null && item !== undefined ? next(item) : complete(),

                          complete,

                          error

                      });

                  return () => subscription.unsubscribe();

              });

      export const get = <T>(store: IndexedStore<T>) => {

          const changes = hasNotifications<T>(store) ?

              observe<Change<T>>(({ next }) => {

                  const handle = after(store, "notify", (...args: Change<T>) => next(args), true);

                  return () => handle.remove();

        cin
    
Added a fallback error handler to observables, it will report unhandled errors

              r138
            
              }) : empty;

        cin
    
added store::get method to wrap up dojo/store/get

              r136
            
          return (id: string | number, opts: GetOpts = {}) =>

              observe<T>(({ next, complete, error }) => {

        cin
    
Added a fallback error handler to observables, it will report unhandled errors

              r138
            
                  try {

                      const result = store.get(id);

        cin
    
added store::get method to wrap up dojo/store/get

              r136
            
        cin
    
Added a fallback error handler to observables, it will report unhandled errors

              r138
            
                      const handle = (x: T | null | undefined) => {

                          if (x !== null && x !== undefined)

                              next(x);

                          complete();

                      };

        cin
    
added store::get method to wrap up dojo/store/get

              r136
            
        cin
    
Added a fallback error handler to observables, it will report unhandled errors

              r138
            
                      if (isPromise(result)) {

                          result.then(handle).then(undefined, error);

        cin
    
added store::get method to wrap up dojo/store/get

              r136
            
        cin
    
Added a fallback error handler to observables, it will report unhandled errors

              r138
            
                          if (isCancellable(result))

                              return () => result.cancel();

                      } else {

                          handle(result);

                      }

                  } catch (e) {

                      error(e);

        cin
    
added store::get method to wrap up dojo/store/get

              r136
            
                  }

              }).cat(opts.observe !== false ? changes.pipe(filterItem(id)) : empty);

      };

	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 added reduce() and next() methods to observable...	r116	import { PromiseOrValue } from "@implab/core-amd/interfaces";
cin added store::get method to wrap up dojo/store/get	r136	import { isCancellable, isPromise } from "@implab/core-amd/safe";
		import { observe, Observable, empty } from "./observable";
		import { after } from "dojo/aspect";
cin added reduce() and next() methods to observable...	r116
		export interface OrderedUpdate<T> {
		/** The item is being updated */
		readonly item: T;

		/** The previous index of the item, -1 in case it is inserted */
		readonly prevIndex: number;

		/** The new index of the item, -1 in case it is deleted */
		readonly newIndex: number;

		}

		export type QueryResults<T> = Observable<OrderedUpdate<T>>;

		interface DjObservableResults<T> {
		/**
		* Allows observation of results
		*/
		observe(listener: (object: T, previousIndex: number, newIndex: number) => void, includeUpdates?: boolean): {
		remove(): void;
		};
		}

cin added whenRendered() method to wait for pending oprations to complete	r118	interface Queryable<T, Q, O> {
		query(query?: Q, options?: O): PromiseOrValue<T[]>;
cin added reduce() and next() methods to observable...	r116	}

cin added whenRendered() method to wait for pending oprations to complete	r118	export const isDjObservableResults = <T>(v: object): v is DjObservableResults<T> =>
cin added reduce() and next() methods to observable...	r116	v && (typeof (v as { observe?: unknown; }).observe === "function");

cin added whenRendered() method to wait for pending oprations to complete	r118	export const query = <T, Q, O>(store: Queryable<T, Q, O>, includeUpdates = true) =>
cin type fixes for i18n, store	r120	(query?: Q, options?: O & { observe?: boolean }) => {
cin added reduce() and next() methods to observable...	r116	return observe<OrderedUpdate<T>>(({ next, complete, error, isClosed }) => {
cin added observable.collect() method to collect a sequnce to the array...	r129
		const processResults = (items: T[]) =>
		items.forEach((item, newIndex) => next({ item, newIndex, prevIndex: -1 }));

cin added reduce() and next() methods to observable...	r116	try {
cin added whenRendered() method to wait for pending oprations to complete	r118	const results = store.query(query, options);
cin added reduce() and next() methods to observable...	r116	if (isPromise(results)) {
cin added observable.collect() method to collect a sequnce to the array...	r129	results.then(processResults).then(undefined, error);
cin added reduce() and next() methods to observable...	r116	} else {
cin added observable.collect() method to collect a sequnce to the array...	r129	processResults(results);
cin added reduce() and next() methods to observable...	r116	}

cin added whenRendered() method to wait for pending oprations to complete	r118	if (!isClosed() && (options?.observe !== false) && isDjObservableResults<T>(results)) {
cin added reduce() and next() methods to observable...	r116	const h = results.observe((item, prevIndex, newIndex) => next({ item, prevIndex, newIndex }), includeUpdates);
		return () => h.remove();
		} else {
		complete();
		}
		} catch (err) {
		error(err);
		}
		});

		};
cin added store::get method to wrap up dojo/store/get	r136
		interface IndexedStore<T> {
		get(id: string \| number): PromiseLike<T> \| T \| null \| undefined;
		}

		interface Notifications<T> {
		notify(item: T \| undefined, id: string \| number \| undefined): void;
		}

		const hasNotifications = <T>(x: unknown): x is Notifications<T> =>
		typeof x === "object" && x !== null && (typeof (x as Notifications<T>).notify === "function");

		interface GetOpts {
		observe?: boolean;
		}

		type Change<T> = [item: NonNullable<T>, id: string \| number \| undefined] \|
		[item: undefined \| null, id: string \| number];

		const filterItem = (itemId: string \| number) =>
		<T>(source: Observable<Change<T>>) =>
		observe<T>(({ next, complete, error }) => {
		const subscription = source
		.filter(([, id]) => id === itemId)
		.subscribe({
		next: ([item]) => item !== null && item !== undefined ? next(item) : complete(),
		complete,
		error
		});
		return () => subscription.unsubscribe();
		});

		export const get = <T>(store: IndexedStore<T>) => {
		const changes = hasNotifications<T>(store) ?
		observe<Change<T>>(({ next }) => {
		const handle = after(store, "notify", (...args: Change<T>) => next(args), true);
		return () => handle.remove();
cin Added a fallback error handler to observables, it will report unhandled errors	r138	}) : empty;
cin added store::get method to wrap up dojo/store/get	r136
		return (id: string \| number, opts: GetOpts = {}) =>
		observe<T>(({ next, complete, error }) => {
cin Added a fallback error handler to observables, it will report unhandled errors	r138	try {
		const result = store.get(id);
cin added store::get method to wrap up dojo/store/get	r136
cin Added a fallback error handler to observables, it will report unhandled errors	r138	const handle = (x: T \| null \| undefined) => {
		if (x !== null && x !== undefined)
		next(x);
		complete();
		};
cin added store::get method to wrap up dojo/store/get	r136
cin Added a fallback error handler to observables, it will report unhandled errors	r138	if (isPromise(result)) {
		result.then(handle).then(undefined, error);
cin added store::get method to wrap up dojo/store/get	r136
cin Added a fallback error handler to observables, it will report unhandled errors	r138	if (isCancellable(result))
		return () => result.cancel();
		} else {
		handle(result);
		}
		} catch (e) {
		error(e);
cin added store::get method to wrap up dojo/store/get	r136	}
		}).cat(opts.observe !== false ? changes.pipe(filterItem(id)) : empty);
		};