Add enabledOperators parameter for workspace name unique check

Signed-off-by: Hailong Cui <[email protected]>
ruanyl · Mar 27, 2024 · e2273ad · e2273ad
1 parent e3ce2e2
commit e2273ad
Show file tree

Hide file tree

Showing 7 changed files with 35 additions and 0 deletions.
diff --git a/src/core/public/saved_objects/saved_objects_client.ts b/src/core/public/saved_objects/saved_objects_client.ts
@@ -389,6 +389,7 @@ export class SavedObjectsClient {
       namespaces: 'namespaces',
       preference: 'preference',
       workspaces: 'workspaces',
+      enabledOperators: 'enabledOperators',
     };
 
     const renamedQuery = renameKeys<SavedObjectsFindOptions, any>(renameMap, {

diff --git a/src/core/server/saved_objects/service/lib/repository.ts b/src/core/server/saved_objects/service/lib/repository.ts
@@ -801,6 +801,7 @@ export class SavedObjectsRepository {
       workspaces,
       workspacesSearchOperator,
       ACLSearchParams,
+      enabledOperators,
     } = options;
 
     if (!type && !typeToNamespacesMap) {
@@ -877,6 +878,7 @@ export class SavedObjectsRepository {
           workspaces,
           workspacesSearchOperator,
           ACLSearchParams,
+          enabledOperators,
         }),
       },
     };

diff --git a/src/core/server/saved_objects/service/lib/search_dsl/query_params.test.ts b/src/core/server/saved_objects/service/lib/search_dsl/query_params.test.ts
@@ -506,6 +506,25 @@ describe('#getQueryParams', () => {
           );
         });
       });
+
+      describe('`enabledOperators` parameter', () => {
+        it('does not include flags when `enabledOperators` is not specified', () => {
+          const result = getQueryParams({
+            registry,
+            search,
+          });
+          expectResult(result, expect.not.objectContaining({ flags: expect.anything() }));
+        });
+
+        it('includes flags when `enabledOperators` specified', () => {
+          const result = getQueryParams({
+            registry,
+            search,
+            enabledOperators: 'all',
+          });
+          expectResult(result, expect.objectContaining({ flags: expect.stringMatching('all') }));
+        });
+      });
     });
 
     describe('when using prefix search (query.bool.should)', () => {

diff --git a/src/core/server/saved_objects/service/lib/search_dsl/query_params.ts b/src/core/server/saved_objects/service/lib/search_dsl/query_params.ts
@@ -170,6 +170,7 @@ interface QueryParams {
   workspaces?: string[];
   workspacesSearchOperator?: 'AND' | 'OR';
   ACLSearchParams?: SavedObjectsFindOptions['ACLSearchParams'];
+  enabledOperators?: SavedObjectsFindOptions['enabledOperators'];
 }
 
 export function getClauseForReference(reference: HasReferenceQueryParams) {
@@ -229,6 +230,7 @@ export function getQueryParams({
   workspaces,
   workspacesSearchOperator = 'AND',
   ACLSearchParams,
+  enabledOperators,
 }: QueryParams) {
   const types = getTypes(
     registry,
@@ -261,6 +263,7 @@ export function getQueryParams({
       searchFields,
       rootSearchFields,
       defaultSearchOperator,
+      enabledOperators,
     });
 
     if (useMatchPhrasePrefix) {
@@ -432,18 +435,21 @@ const getSimpleQueryStringClause = ({
   searchFields,
   rootSearchFields,
   defaultSearchOperator,
+  enabledOperators,
 }: {
   search: string;
   types: string[];
   searchFields?: string[];
   rootSearchFields?: string[];
   defaultSearchOperator?: string;
+  enabledOperators?: SavedObjectsFindOptions['enabledOperators'];
 }) => {
   return {
     simple_query_string: {
       query: search,
       ...getSimpleQueryStringTypeFields(types, searchFields, rootSearchFields),
       ...(defaultSearchOperator ? { default_operator: defaultSearchOperator } : {}),
+      ...(enabledOperators ? { flags: enabledOperators } : {}),
     },
   };
 };
diff --git a/src/core/server/saved_objects/service/lib/search_dsl/search_dsl.ts b/src/core/server/saved_objects/service/lib/search_dsl/search_dsl.ts
@@ -56,6 +56,7 @@ interface GetSearchDslOptions {
   workspaces?: string[];
   workspacesSearchOperator?: 'AND' | 'OR';
   ACLSearchParams?: SavedObjectsFindOptions['ACLSearchParams'];
+  enabledOperators?: SavedObjectsFindOptions['enabledOperators'];
 }
 
 export function getSearchDsl(
@@ -78,6 +79,7 @@ export function getSearchDsl(
     workspaces,
     workspacesSearchOperator,
     ACLSearchParams,
+    enabledOperators,
   } = options;
 
   if (!type) {
@@ -103,6 +105,7 @@ export function getSearchDsl(
       workspaces,
       workspacesSearchOperator,
       ACLSearchParams,
+      enabledOperators,
     }),
     ...getSortingParams(mappings, type, sortField, sortOrder),
   };

diff --git a/src/core/server/saved_objects/types.ts b/src/core/server/saved_objects/types.ts
@@ -92,6 +92,8 @@ export interface SavedObjectsFindOptions {
   search?: string;
   /** The fields to perform the parsed query against. See OpenSearch Simple Query String `fields` argument for more information */
   searchFields?: string[];
+  /** The enabled operators for OpenSearch Simple Query String. See OpenSearch Simple Query String `flags` argument for more information */
+  enabledOperators?: string;
   /**
    * The fields to perform the parsed query against. Unlike the `searchFields` argument, these are expected to be root fields and will not
    * be modified. If used in conjunction with `searchFields`, both are concatenated together.

diff --git a/src/plugins/workspace/server/workspace_client.ts b/src/plugins/workspace/server/workspace_client.ts
@@ -125,6 +125,7 @@ export class WorkspaceClient implements IWorkspaceClientImpl {
           type: WORKSPACE_TYPE,
           search: attributes.name,
           searchFields: ['name'],
+          enabledOperators: 'NONE', // disable all operators, treat workspace as literal string
         }
       );
       if (existingWorkspaceRes && existingWorkspaceRes.total > 0) {
@@ -250,6 +251,7 @@ export class WorkspaceClient implements IWorkspaceClientImpl {
           search: attributes.name,
           searchFields: ['name'],
           fields: ['_id'],
+          enabledOperators: 'NONE', // disable all operators, treat workspace as literal string
         });
         if (existingWorkspaceRes && existingWorkspaceRes.total > 0) {
           throw new Error(DUPLICATE_WORKSPACE_NAME_ERROR);