|
|
import Memory = require("dojo/store/Memory");
|
|
|
import Observable = require("dojo/store/Observable");
|
|
|
import { Appointment, Member } from "./Appointment";
|
|
|
import { Contact } from "./Contact";
|
|
|
import { Uuid } from "@implab/core-amd/Uuid";
|
|
|
import { Observable as RxjsObservable } from "rxjs";
|
|
|
import { QueryResultUpdate } from "@implab/djx/tsx";
|
|
|
|
|
|
type AppointmentRecord = Omit<Appointment, "getMembers"> & {id: string};
|
|
|
|
|
|
type ContactRecord = Contact;
|
|
|
|
|
|
type MemberRecord = Member & { appointmentId: string; };
|
|
|
|
|
|
export interface ObservableResults<T> {
|
|
|
/**
|
|
|
* Allows observation of results
|
|
|
*/
|
|
|
observe(listener: (object: T, previousIndex: number, newIndex: number) => void, includeUpdates?: boolean): {
|
|
|
remove(): void;
|
|
|
};
|
|
|
}
|
|
|
|
|
|
|
|
|
export function isObservable<T>(v: PromiseLike<ArrayLike<T>> | ArrayLike<T>): v is ArrayLike<T> & ObservableResults<T> {
|
|
|
return v && (typeof (v as any).observe === "function");
|
|
|
}
|
|
|
|
|
|
export function observe<T>(results: T[], includeObjectUpdates?: boolean): RxjsObservable<QueryResultUpdate<T>>;
|
|
|
export function observe<T>(results: PromiseLike<T[]>, includeObjectUpdates?: boolean): PromiseLike<RxjsObservable<QueryResultUpdate<T>>>;
|
|
|
export function observe(results: any, includeObjectUpdates = true) {
|
|
|
// results может быть асинхронным, т.е. до завершения
|
|
|
// получения результатов store может быть обновлен. В любом
|
|
|
// случае, если между подключением хотя бы одного наблюдателя
|
|
|
// была выполнена команда обновления, results считается устаревшим
|
|
|
// и не может быть использован для отслеживания обновлений.
|
|
|
// Конкретно с dojo/store/Observable тут вообще возникает проблема:
|
|
|
// 1. Синхронные store типа Memory будут давать ошибку на методах
|
|
|
// обновления (add,put,remove)
|
|
|
// 2. Асинхронные store типа JsonRest будут выдавать предупреждения
|
|
|
// о необработанной ошибке в Promise при обращении к методам
|
|
|
// обновления (add,put,remove)
|
|
|
|
|
|
const _subscribe = (items: any[]) => new RxjsObservable<QueryResultUpdate<any>>(subscriber => {
|
|
|
items
|
|
|
.forEach((value, newIndex) => subscriber.next({ item: value, newIndex, prevIndex: -1}));
|
|
|
|
|
|
try {
|
|
|
if (isObservable(results)) {
|
|
|
const h = results.observe(
|
|
|
(value, prevIndex, newIndex) => subscriber.next({
|
|
|
item: value,
|
|
|
prevIndex,
|
|
|
newIndex
|
|
|
}),
|
|
|
includeObjectUpdates
|
|
|
);
|
|
|
|
|
|
return () => { h.remove(); };
|
|
|
}
|
|
|
} catch (err) {
|
|
|
subscriber.error(err);
|
|
|
}
|
|
|
});
|
|
|
|
|
|
return isPromise(results) ?
|
|
|
results.then(_subscribe) :
|
|
|
_subscribe(results || []);
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
export class MainContext {
|
|
|
private _appointments = new Observable(new Memory<AppointmentRecord>());
|
|
|
|
|
|
private _contacts = new Observable(new Memory<ContactRecord>());
|
|
|
|
|
|
private _members = new Observable(new Memory<MemberRecord>());
|
|
|
|
|
|
createAppointment(title: string, startAt: Date, duration: number, members: Member[]) {
|
|
|
const id = Uuid();
|
|
|
this._appointments.add({
|
|
|
id: Uuid(),
|
|
|
startAt,
|
|
|
duration,
|
|
|
title
|
|
|
});
|
|
|
|
|
|
members.forEach(member =>
|
|
|
this._members.add({
|
|
|
appointmentId: id,
|
|
|
...member
|
|
|
}, {id: Uuid()})
|
|
|
);
|
|
|
}
|
|
|
|
|
|
queryAppointments(dateFrom: Date, dateTo: Date) {
|
|
|
this._appointments.query().map()
|
|
|
}
|
|
|
|
|
|
private _mapAppointment = ({startAt, title, duration, id}: AppointmentRecord) => ({
|
|
|
|
|
|
})
|
|
|
|
|
|
}
|
|
|
|
