Add copy saved objects among workspaces functionality (opensearch-pro…

…ject#53)

* Add copy saved objects among workspaces functionality

Signed-off-by: gaobinlong <[email protected]>

Signed-off-by: gaobinlong <[email protected]>

* Fix bug

Signed-off-by: gaobinlong <[email protected]>

* Fix bug

Signed-off-by: gaobinlong <[email protected]>

---------

Signed-off-by: gaobinlong <[email protected]>

src/core/server/saved_objects/routes/copy.ts

@@ -0,0 +1,82 @@
+/*
+ * SPDX-License-Identifier: Apache-2.0
+ *
+ * The OpenSearch Contributors require contributions made to
+ * this file be licensed under the Apache-2.0 license or a
+ * compatible open source license.
+ *
+ * Any modifications Copyright OpenSearch Contributors. See
+ * GitHub history for details.
+ */
+
+import { schema } from '@osd/config-schema';
+import { IRouter } from '../../http';
+import { SavedObjectConfig } from '../saved_objects_config';
+import { exportSavedObjectsToStream } from '../export';
+import { validateObjects } from './utils';
+import { importSavedObjectsFromStream } from '../import';
+
+export const registerCopyRoute = (router: IRouter, config: SavedObjectConfig) => {
+  const { maxImportExportSize } = config;
+
+  router.post(
+    {
+      path: '/_copy',
+      validate: {
+        body: schema.object({
+          objects: schema.maybe(
+            schema.arrayOf(
+              schema.object({
+                type: schema.string(),
+                id: schema.string(),
+              }),
+              { maxSize: maxImportExportSize }
+            )
+          ),
+          includeReferencesDeep: schema.boolean({ defaultValue: false }),
+          targetWorkspace: schema.string(),
+        }),
+      },
+    },
+    router.handleLegacyErrors(async (context, req, res) => {
+      const savedObjectsClient = context.core.savedObjects.client;
+      const { objects, includeReferencesDeep, targetWorkspace } = req.body;
+
+      // need to access the registry for type validation, can't use the schema for this
+      const supportedTypes = context.core.savedObjects.typeRegistry
+        .getImportableAndExportableTypes()
+        .map((t) => t.name);
+
+      if (objects) {
+        const validationError = validateObjects(objects, supportedTypes);
+        if (validationError) {
+          return res.badRequest({
+            body: {
+              message: validationError,
+            },
+          });
+        }
+      }
+
+      const objectsListStream = await exportSavedObjectsToStream({
+        savedObjectsClient,
+        objects,
+        exportSizeLimit: maxImportExportSize,
+        includeReferencesDeep,
+        excludeExportDetails: true,
+      });
+
+      const result = await importSavedObjectsFromStream({
+        savedObjectsClient: context.core.savedObjects.client,
+        typeRegistry: context.core.savedObjects.typeRegistry,
+        readStream: objectsListStream,
+        objectLimit: maxImportExportSize,
+        overwrite: false,
+        createNewCopies: true,
+        workspaces: [targetWorkspace],
+      });
+
+      return res.ok({ body: result });
+    })
+  );
+};

src/core/server/saved_objects/routes/index.ts

@@ -45,6 +45,7 @@ import { registerExportRoute } from './export';
 import { registerImportRoute } from './import';
 import { registerResolveImportErrorsRoute } from './resolve_import_errors';
 import { registerMigrateRoute } from './migrate';
+import { registerCopyRoute } from './copy';
 
 export function registerRoutes({
   http,
@@ -70,6 +71,7 @@ export function registerRoutes({
   registerLogLegacyImportRoute(router, logger);
   registerExportRoute(router, config);
   registerImportRoute(router, config);
+  registerCopyRoute(router, config);
   registerResolveImportErrorsRoute(router, config);
 
   const internalRouter = http.createRouter('/internal/saved_objects/');

src/plugins/saved_objects_management/public/constants.ts

@@ -29,3 +29,5 @@ export const SAVED_QUERIES_WORDINGS = i18n.translate(
     defaultMessage: 'Saved filters',
   }
 );
+
+export const SAVED_OBJECT_TYPE_WORKSAPCE = 'workspace';

src/plugins/saved_objects_management/public/lib/copy_saved_objects.ts

@@ -0,0 +1,27 @@
+/*
+ * SPDX-License-Identifier: Apache-2.0
+ *
+ * The OpenSearch Contributors require contributions made to
+ * this file be licensed under the Apache-2.0 license or a
+ * compatible open source license.
+ *
+ * Any modifications Copyright OpenSearch Contributors. See
+ * GitHub history for details.
+ */
+
+import { HttpStart } from 'src/core/public';
+
+export async function copySavedObjects(
+  http: HttpStart,
+  objects: any[],
+  includeReferencesDeep: boolean = true,
+  targetWorkspace: string
+) {
+  return await http.post('/api/saved_objects/_copy', {
+    body: JSON.stringify({
+      objects,
+      includeReferencesDeep,
+      targetWorkspace,
+    }),
+  });
+}

src/plugins/saved_objects_management/public/lib/index.ts

@@ -57,3 +57,4 @@ export { extractExportDetails, SavedObjectsExportResultDetails } from './extract
 export { createFieldList } from './create_field_list';
 export { getAllowedTypes } from './get_allowed_types';
 export { filterQuery } from './filter_query';
+export { copySavedObjects } from './copy_saved_objects';