selection.ts 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336
  1. /**
  2. * Copyright (c) 2018-2020 mol* contributors, licensed under MIT, See LICENSE file for more info.
  3. *
  4. * @author David Sehnal <david.sehnal@gmail.com>
  5. */
  6. import { StateObject, StateObjectCell } from '../object';
  7. import { State } from '../state';
  8. import { StateTree } from '../tree';
  9. import { StateTransform } from '../transform';
  10. import { StateTransformer } from '../transformer';
  11. namespace StateSelection {
  12. export type Selector<C extends StateObjectCell = StateObjectCell> = Query<C> | Builder<C> | string | C;
  13. export type CellSeq<C extends StateObjectCell = StateObjectCell> = C[]
  14. export type Query<C extends StateObjectCell = StateObjectCell> = (state: State) => CellSeq<C>;
  15. export function select<C extends StateObjectCell>(s: Selector<C>, state: State) {
  16. return compile(s)(state);
  17. }
  18. export function compile<C extends StateObjectCell>(s: Selector<C>): Query<C> {
  19. const selector = s ? s : Generators.root;
  20. let query: Query;
  21. if (isBuilder(selector)) query = (selector as any).compile();
  22. else if (isObj(selector)) query = (Generators.byValue(selector) as any).compile();
  23. else if (isQuery(selector)) query = selector;
  24. else query = (Generators.byRef(selector as string) as any).compile();
  25. return query as Query<C>;
  26. }
  27. function isObj(arg: any): arg is StateObjectCell {
  28. return (arg as StateObjectCell).transform !== void 0 && (arg as StateObjectCell).status !== void 0;
  29. }
  30. function isBuilder(arg: any): arg is Builder {
  31. return arg.compile !== void 0;
  32. }
  33. function isQuery(arg: any): arg is Query {
  34. return typeof arg === 'function';
  35. }
  36. export interface Builder<C extends StateObjectCell = StateObjectCell> {
  37. flatMap<D extends StateObjectCell>(f: (n: C) => D[]): Builder<D>;
  38. mapObject<D extends StateObjectCell>(f: (n: C) => D): Builder<D>;
  39. unique(): Builder<C>;
  40. parent(): Builder<C>;
  41. first(): Builder<C>;
  42. filter(p: (n: C) => boolean): Builder<C>;
  43. withTag<D extends StateObjectCell = C>(tag: string): Builder<D>;
  44. withTransformer<T extends StateTransformer<any, StateObjectCell.Obj<C>, any>>(t: T): Builder<StateObjectCell<StateObjectCell.Obj<C>, StateTransform<T>>>;
  45. withStatus(s: StateObjectCell.Status): Builder<C>;
  46. subtree(): Builder;
  47. children(): Builder;
  48. ofType<T extends StateObject.Ctor>(t: T): Builder<StateObjectCell<StateObject.From<T>>>;
  49. ancestorOfType<T extends StateObject.Ctor>(t: T[]): Builder<StateObjectCell<StateObject.From<T>>>;
  50. rootOfType(t: StateObject.Ctor[]): Builder;
  51. select(state: State): CellSeq<C>
  52. }
  53. const BuilderPrototype: any = {
  54. select(state?: State) {
  55. return select(this, state || this.state);
  56. }
  57. };
  58. function registerModifier(name: string, f: Function) {
  59. BuilderPrototype[name] = function (this: any, ...args: any[]) { return f.call(void 0, this, ...args) };
  60. }
  61. function build<C extends StateObjectCell>(compile: () => Query<C>): Builder<C> {
  62. return Object.create(BuilderPrototype, { compile: { writable: false, configurable: false, value: compile } });
  63. }
  64. export namespace Generators {
  65. export const root = build(() => (state: State) => [state.cells.get(state.tree.root.ref)!]);
  66. export function byRef<T extends StateObject.Ctor>(...refs: StateTransform.Ref[]) {
  67. return build(() => (state: State) => {
  68. const ret: StateObjectCell<StateObject.From<T>>[] = [];
  69. for (const ref of refs) {
  70. const n = state.cells.get(ref);
  71. if (!n) continue;
  72. ret.push(n as any);
  73. }
  74. return ret;
  75. });
  76. }
  77. export function byValue<T extends StateObjectCell>(...objects: T[]) { return build(() => (state: State) => objects); }
  78. export function rootsOfType<T extends StateObject.Ctor>(type: T, root: StateTransform.Ref = StateTransform.RootRef) {
  79. return build(() => state => {
  80. const ctx = { roots: [] as StateObjectCell<StateObject.From<T>>[], cells: state.cells, type: type.type };
  81. StateTree.doPreOrder(state.tree, state.tree.transforms.get(root), ctx, _findRootsOfType);
  82. return ctx.roots;
  83. });
  84. }
  85. export function ofType<T extends StateObject.Ctor>(type: T, root: StateTransform.Ref = StateTransform.RootRef) {
  86. return build(() => state => {
  87. const ctx = { ret: [] as StateObjectCell<StateObject.From<T>>[], cells: state.cells, type: type.type };
  88. StateTree.doPreOrder(state.tree, state.tree.transforms.get(root), ctx, _findOfType);
  89. return ctx.ret;
  90. });
  91. }
  92. export function ofTransformer<T extends StateTransformer<any, A, any>, A extends StateObject>(t: T, root: StateTransform.Ref = StateTransform.RootRef) {
  93. return build(() => state => {
  94. const ctx = { ret: [] as StateObjectCell<A, StateTransform<T>>[], cells: state.cells, t };
  95. StateTree.doPreOrder(state.tree, state.tree.transforms.get(root), ctx, _findOfTransformer);
  96. return ctx.ret;
  97. });
  98. }
  99. export function ofTransformerWithError<T extends StateTransformer<any, A, any>, A extends StateObject>(t: T, root: StateTransform.Ref = StateTransform.RootRef) {
  100. return build(() => state => {
  101. const ctx = { ret: [] as StateObjectCell<A, StateTransform<T>>[], cells: state.cells, t };
  102. StateTree.doPreOrder(state.tree, state.tree.transforms.get(root), ctx, _findOfTransformerWithError);
  103. return ctx.ret;
  104. });
  105. }
  106. function _findRootsOfType(n: StateTransform, _: any, s: { type: StateObject.Type, roots: StateObjectCell[], cells: State.Cells }) {
  107. const cell = s.cells.get(n.ref);
  108. if (cell && cell.obj && cell.obj.type === s.type) {
  109. s.roots.push(cell);
  110. return false;
  111. }
  112. return true;
  113. }
  114. function _findOfType(n: StateTransform, _: any, s: { type: StateObject.Type, ret: StateObjectCell[], cells: State.Cells }) {
  115. const cell = s.cells.get(n.ref);
  116. if (cell && cell.obj && cell.obj.type === s.type) {
  117. s.ret.push(cell);
  118. }
  119. return true;
  120. }
  121. function _findOfTransformer(n: StateTransform, _: any, s: { t: StateTransformer, ret: StateObjectCell[], cells: State.Cells }) {
  122. const cell = s.cells.get(n.ref);
  123. if (cell && cell.obj && cell.transform.transformer === s.t) {
  124. s.ret.push(cell);
  125. }
  126. return true;
  127. }
  128. function _findOfTransformerWithError(n: StateTransform, _: any, s: { t: StateTransformer, ret: StateObjectCell[], cells: State.Cells }) {
  129. const cell = s.cells.get(n.ref);
  130. if (cell && cell.status === 'error' && cell.transform.transformer === s.t) {
  131. s.ret.push(cell);
  132. }
  133. return true;
  134. }
  135. }
  136. registerModifier('flatMap', flatMap);
  137. export function flatMap(b: Selector, f: (obj: StateObjectCell, state: State) => CellSeq) {
  138. const q = compile(b);
  139. return build(() => (state: State) => {
  140. const ret: StateObjectCell[] = [];
  141. for (const n of q(state)) {
  142. for (const m of f(n, state)) {
  143. ret.push(m);
  144. }
  145. }
  146. return ret;
  147. });
  148. }
  149. registerModifier('mapObject', mapObject);
  150. export function mapObject(b: Selector, f: (n: StateObjectCell, state: State) => StateObjectCell | undefined) {
  151. const q = compile(b);
  152. return build(() => (state: State) => {
  153. const ret: StateObjectCell[] = [];
  154. for (const n of q(state)) {
  155. const x = f(n, state);
  156. if (x) ret.push(x);
  157. }
  158. return ret;
  159. });
  160. }
  161. registerModifier('unique', unique);
  162. export function unique(b: Selector) {
  163. const q = compile(b);
  164. return build(() => (state: State) => {
  165. const set = new Set<string>();
  166. const ret: StateObjectCell[] = [];
  167. for (const n of q(state)) {
  168. if (!n) continue;
  169. if (!set.has(n.transform.ref)) {
  170. set.add(n.transform.ref);
  171. ret.push(n);
  172. }
  173. }
  174. return ret;
  175. })
  176. }
  177. registerModifier('first', first);
  178. export function first(b: Selector) {
  179. const q = compile(b);
  180. return build(() => (state: State) => {
  181. const r = q(state);
  182. return r.length ? [r[0]] : [];
  183. });
  184. }
  185. registerModifier('filter', filter);
  186. export function filter(b: Selector, p: (n: StateObjectCell) => boolean) { return flatMap(b, n => p(n) ? [n] : []); }
  187. registerModifier('withStatus', withStatus);
  188. export function withStatus(b: Selector, s: StateObjectCell.Status) { return filter(b, n => n.status === s); }
  189. registerModifier('withTag', withTag);
  190. export function withTag(b: Selector, tag: string) { return filter(b, n => !!n.transform.tags && n.transform.tags.indexOf(tag) >= 0); }
  191. registerModifier('subtree', subtree);
  192. export function subtree(b: Selector) {
  193. return flatMap(b, (n, s) => {
  194. const nodes = [] as string[];
  195. StateTree.doPreOrder(s.tree, s.tree.transforms.get(n.transform.ref), nodes, (x, _, ctx) => { ctx.push(x.ref) });
  196. return nodes.map(x => s.cells.get(x)!);
  197. });
  198. }
  199. registerModifier('children', children);
  200. export function children(b: Selector) {
  201. return flatMap(b, (n, s) => {
  202. const nodes: StateObjectCell[] = [];
  203. s.tree.children.get(n.transform.ref).forEach(c => nodes.push(s.cells.get(c!)!));
  204. return nodes;
  205. });
  206. }
  207. registerModifier('ofType', ofType);
  208. export function ofType(b: Selector, t: StateObject.Ctor) { return filter(b, n => n.obj ? n.obj.type === t.type : false); }
  209. registerModifier('ancestorOfType', ancestorOfType);
  210. export function ancestorOfType(b: Selector, types: StateObject.Ctor[]) { return unique(mapObject(b, (n, s) => findAncestorOfType(s.tree, s.cells, n.transform.ref, types))); }
  211. registerModifier('withTransformer', withTransformer);
  212. export function withTransformer(b: Selector, t: StateTransformer) { return filter(b, o => o.transform.transformer === t); }
  213. registerModifier('rootOfType', rootOfType);
  214. export function rootOfType(b: Selector, types: StateObject.Ctor[]) { return unique(mapObject(b, (n, s) => findRootOfType(s.tree, s.cells, n.transform.ref, types))); }
  215. registerModifier('parent', parent);
  216. export function parent(b: Selector) { return unique(mapObject(b, (n, s) => s.cells.get(s.tree.transforms.get(n.transform.ref)!.parent))); }
  217. export function findAncestorOfType<T extends StateObject.Ctor>(tree: StateTree, cells: State.Cells, root: StateTransform.Ref, types: T[]): StateObjectCell<StateObject.From<T>> | undefined {
  218. let current = tree.transforms.get(root)!, len = types.length;
  219. while (true) {
  220. current = tree.transforms.get(current.parent)!;
  221. const cell = cells.get(current.ref)!;
  222. if (!cell.obj) return void 0;
  223. const obj = cell.obj;
  224. for (let i = 0; i < len; i++) {
  225. if (obj.type === types[i].type) return cell as StateObjectCell<StateObject.From<T>>;
  226. }
  227. if (current.ref === StateTransform.RootRef) {
  228. return void 0;
  229. }
  230. }
  231. }
  232. export function findRootOfType(tree: StateTree, cells: State.Cells, root: StateTransform.Ref, types: StateObject.Ctor[]): StateObjectCell | undefined {
  233. let parent: StateObjectCell | undefined, _root = root;
  234. while (true) {
  235. const _parent = StateSelection.findAncestorOfType(tree, cells, _root, types);
  236. if (_parent) {
  237. parent = _parent;
  238. _root = _parent.transform.ref;
  239. } else {
  240. break;
  241. }
  242. }
  243. return parent;
  244. }
  245. export function findUniqueTagsInSubtree<K extends string = string>(tree: StateTree, root: StateTransform.Ref, tags: Set<K>): { [name in K]?: StateTransform.Ref } {
  246. return StateTree.doPreOrder(tree, tree.transforms.get(root), { refs: { }, tags }, _findUniqueTagsInSubtree).refs;
  247. }
  248. function _findUniqueTagsInSubtree(n: StateTransform, _: any, s: { refs: { [name: string]: StateTransform.Ref }, tags: Set<string> }) {
  249. if (n.tags) {
  250. for (const t of n.tags) {
  251. if (!s.tags.has(t)) continue;
  252. s.refs[t] = n.ref;
  253. break;
  254. }
  255. }
  256. return true;
  257. }
  258. export function findTagInSubtree(tree: StateTree, root: StateTransform.Ref, tag: string): StateTransform.Ref | undefined {
  259. return StateTree.doPreOrder(tree, tree.transforms.get(root), { ref: void 0, tag }, _findTagInSubtree).ref;
  260. }
  261. function _findTagInSubtree(n: StateTransform, _: any, s: { ref: string | undefined, tag: string }) {
  262. if (n.tags && n.tags.indexOf(s.tag) >= 0) {
  263. s.ref = n.ref;
  264. return false;
  265. }
  266. return true;
  267. }
  268. export function findWithAllTags<K extends string = string>(tree: StateTree, root: StateTransform.Ref, tags: Set<K>): StateTransform[] {
  269. return StateTree.doPreOrder(tree, tree.transforms.get(root), { refs: [], tags }, _findWithAllTags).refs;
  270. }
  271. function _findWithAllTags(n: StateTransform, _: any, s: { refs: StateTransform[], tags: Set<string> }) {
  272. if (n.tags) {
  273. const len = s.tags.size;
  274. let found = 0;
  275. for (const t of n.tags) {
  276. if (!s.tags.has(t)) continue;
  277. found++;
  278. if (found === len) {
  279. s.refs.push(n);
  280. break;
  281. }
  282. }
  283. } else if (s.tags.size === 0) {
  284. s.refs.push(n);
  285. }
  286. }
  287. }
  288. export { StateSelection }