split up hal store into multiple files

Author: thefringeninja

src/SqlStreamStoreBrowser.tsx

@@ -33,7 +33,7 @@ const getSelfAlias = (links: HalLinks) =>
         .flatMap(rel => links[rel])
         .filter(({ rel }) => rel && rel.indexOf('streamStore:') === 0)
         .filter(
-            ({ rel, href }) =>
+            ({ href }) =>
                 !!links.self.filter(link => link.href === href).length,
         )
         .map(({ rel }) => rel);
@@ -58,7 +58,7 @@ const state$ = createState<SqlStreamStoreBrowserState>(
         store.hal$.links$.map(links => ['_links', () => links]),
         store.hal$.forms$.map(forms => ['forms', () => forms]),
         store.hal$.loading$.map(loading => ['loading', () => loading]),
-        store.hal$.mediaType$.map(mediaType => ['mediaType', () => mediaType]),
+        store.mediaType$.map(mediaType => ['mediaType', () => mediaType]),
         themes.theme$.map(theme => ['theme', () => theme]),
     ),
     obs.of({

src/stream-store/store/hal.ts

@@ -0,0 +1,11 @@
+import { HalResource } from '../../../types';
+import { hal, mediaTypes } from '../../../utils';
+import actions from '../../actions';
+import mediaType$ from '../mediaType';
+
+const body$ = actions.get.response
+    .zip(mediaType$)
+    .filter(([, mediaType]) => mediaType === mediaTypes.hal)
+    .map(([{ body }]) => hal.normalizeResource(body as HalResource));
+
+export default body$;

src/stream-store/store/hal/body.ts

@@ -0,0 +1,23 @@
+import { JSONSchema7 } from 'json-schema';
+import { HalResource } from 'types';
+import body$ from './body';
+
+const isJsonSchema = (schema: JSONSchema7 & HalResource) =>
+    schema && schema.$schema && schema.$schema.endsWith('schema#');
+
+const forms$ = body$
+    .map(({ _embedded }) => _embedded)
+    .map(embedded =>
+        Object.keys(embedded)
+            .filter(rel => isJsonSchema(embedded[rel][0]))
+            .reduce(
+                (akk, rel) => ({
+                    ...akk,
+                    [rel]: embedded[rel][0],
+                }),
+                // tslint:disable-next-line:no-object-literal-type-assertion
+                {} as JSONSchema7,
+            ),
+    );
+
+export default forms$;

src/stream-store/store/hal/forms.ts

@@ -0,0 +1,13 @@
+import body$ from './body';
+import forms$ from './forms';
+import links$ from './links';
+import loading$ from './loading';
+import url$ from './url';
+
+export default {
+    body$,
+    forms$,
+    links$,
+    loading$,
+    url$,
+};

src/stream-store/store/hal/index.ts

@@ -0,0 +1,9 @@
+import { hal } from 'utils';
+import body$ from './body';
+import url$ from './url';
+
+const links$ = body$
+    .zip(url$)
+    .map(([{ _links }, url]) => hal.resolveLinks(url, _links));
+
+export default links$;

src/stream-store/store/hal/links.ts

@@ -0,0 +1,31 @@
+import { Observable as obs } from 'rxjs';
+import actions from '../../actions';
+
+const verbs = Object.keys(actions);
+
+const requests$ = obs.merge(
+    ...verbs.map((verb: keyof typeof actions) => actions[verb].request),
+);
+
+const responses$ = obs.merge(
+    ...verbs.map((verb: keyof typeof actions) => actions[verb].response),
+);
+
+const delayedRequests$ = requests$.delay(1000);
+
+const loading$ = requests$
+    .timestamp()
+    .combineLatest(
+        responses$.timestamp(),
+        delayedRequests$.timestamp(),
+        (
+            { timestamp: requestTs },
+            { timestamp: responseTs },
+            { timestamp: delayedTs },
+        ) =>
+            requestTs > responseTs &&
+            delayedTs > responseTs &&
+            delayedTs >= requestTs,
+    );
+
+export default loading$;

src/stream-store/store/hal/loading.ts

@@ -0,0 +1,29 @@
+import { createAction } from 'reactive';
+import { Observable } from 'rxjs';
+import rels from 'stream-store/rels';
+import uriTemplate from 'uri-template';
+import links$ from './links';
+
+const isPotentialStreamId = (data: any) =>
+    typeof data === 'number' || typeof data === 'string';
+
+const clickPotentialStreamId = createAction<any>().filter(
+    isPotentialStreamId,
+) as Observable<number | string>;
+
+const pattern$ = Observable.merge(
+    clickPotentialStreamId.map(pattern => pattern),
+    clickPotentialStreamId.map(pattern => String(pattern).replace(/-/g, '')),
+).distinct();
+
+const template$ = links$
+    .filter(links => !!links[rels.browse])
+    .map(links => links[rels.browse][0])
+    .map(link => uriTemplate.parse(decodeURI(link.href)));
+
+pattern$.combineLatest(template$, (p, template) => ({
+    headers: { authorization: '' },
+    link: {
+        href: template.expand({ p, t: 'e' }),
+    },
+}));

src/stream-store/store/hal/streamBrowser.ts

@@ -0,0 +1,5 @@
+import actions from '../../actions';
+
+const url$ = actions.get.response.map(({ url }) => url);
+
+export default url$;

src/stream-store/store/hal/url.ts

@@ -1,7 +1,9 @@
 import hal$ from './hal';
 import markdown$ from './markdown';
+import mediaType$ from './mediaType';
 
 export default {
     hal$,
     markdown$,
+    mediaType$,
 };