Create CommonResourceService and OrderBuilder

[arvados-workbench2.git] / src / common / api / common-resource-service.ts

diff --git a/src/common/api/common-resource-service.ts b/src/common/api/common-resource-service.ts
new file mode 100644 (file)
index 0000000..e49d2a0
--- /dev/null
+++ b/src/common/api/common-resource-service.ts
@@ -0,0 +1,106 @@
+// Copyright (C) The Arvados Authors. All rights reserved.
+//
+// SPDX-License-Identifier: AGPL-3.0
+
+import * as _ from "lodash";
+import FilterBuilder from "./filter-builder";
+import OrderBuilder from "./order-builder";
+import { AxiosInstance } from "axios";
+
+export interface Resource {
+    uuid: string;
+    ownerUuid: string;
+    createdAt: string;
+    modifiedByClientUuid: string;
+    modifiedByUserUuid: string;
+    modifiedAt: string;
+    href: string;
+    kind: string;
+    etag: string;
+}
+
+export interface ListArguments {
+    limit: number;
+    offset: number;
+    filters?: FilterBuilder;
+    order?: OrderBuilder;
+    select?: string[];
+    distinct?: boolean;
+    count?: string;
+}
+
+export interface ListResults<T> {
+    kind: string;
+    offset: number;
+    limit: number;
+    items: T[];
+    itemsAvailable: number;
+}
+
+export default class CommonResourceService<T extends Resource> {
+
+    serverApi: AxiosInstance;
+    resourceType: string;
+
+    static mapResponseKeys = (response: any): Promise<any> =>
+        CommonResourceService.mapKeys(_.camelCase)(response.data)
+
+    static mapKeys = (mapFn: (key: string) => string) =>
+        (value: any): any => {
+            switch (true) {
+                case _.isPlainObject(value):
+                    return Object
+                        .keys(value)
+                        .map(key => [key, mapFn(key)])
+                        .reduce((newValue, [key, newKey]) => ({
+                            ...newValue,
+                            [newKey]: CommonResourceService.mapKeys(mapFn)(value[key])
+                        }), {});
+                case _.isArray(value):
+                    return value.map(CommonResourceService.mapKeys(mapFn));
+                default:
+                    return value;
+            }
+        }
+
+    constructor(serverApi: AxiosInstance, resourceType: string) {
+        this.serverApi = serverApi;
+        this.resourceType = "/" + resourceType;
+    }
+
+    create() {
+        throw new Error("Not implemented");
+    }
+
+    delete(uuid: string): Promise<T> {
+        return this.serverApi
+            .delete(this.resourceType + "/" + uuid)
+            .then(CommonResourceService.mapResponseKeys);
+    }
+
+    get(uuid: string) {
+        return this.serverApi
+            .get<T>(this.resourceType + "/" + uuid)
+            .then(CommonResourceService.mapResponseKeys);
+    }
+
+    list(args: ListArguments): Promise<ListResults<T>> {
+        const { filters, order, ...other } = args;
+        const params = {
+            ...other,
+            filters: filters ? filters.get() : undefined,
+            order: order ? order.get() : undefined
+        };
+        return this.serverApi
+            .get(this.resourceType, {
+                params: CommonResourceService.mapKeys(_.snakeCase)(params)
+            })
+            .then(CommonResourceService.mapResponseKeys);
+    }
+
+    update(uuid: string) {
+        throw new Error("Not implemented");
+    }
+
+}
+