Method SearchWorkspaces

idm/workspace/rest/handler.go:198–253

(req *restful.Request, rsp *restful.Response)

}

func (h *WorkspaceHandler) SearchWorkspaces(req *restful.Request, rsp *restful.Response) error {

	ctx := req.Request.Context()
	var restRequest rest.SearchWorkspaceRequest
	if err := req.ReadEntity(&restRequest); err != nil {
		return err
	}

	// Transform to standard query
	query := &service.Query{
		Limit:     restRequest.Limit,
		Offset:    restRequest.Offset,
		GroupBy:   restRequest.GroupBy,
		Operation: restRequest.Operation,
	}

	for _, q := range restRequest.Queries {
		anyfied, _ := anypb.New(q)
		query.SubQueries = append(query.SubQueries, anyfied)
	}

	var er error
	if query.ResourcePolicyQuery, er = h.RestToServiceResourcePolicy(ctx, restRequest.ResourcePolicyQuery); er != nil {
		return errors.Tag(er, errors.StatusForbidden)
	}

	cli := idmc.WorkspaceServiceClient(ctx)

	collection := &rest.WorkspaceCollection{}
	var uuids []string
	wss := make(map[string]*idm.Workspace)

	streamer, err := cli.SearchWorkspace(ctx, &idm.SearchWorkspaceRequest{
		Query: query,
	})
	if err = commons.ForEach(streamer, err, func(resp *idm.SearchWorkspaceResponse) error {
		resp.Workspace.PoliciesContextEditable = h.IsContextEditable(ctx, resp.Workspace.UUID, resp.Workspace.Policies)
		uuids = append(uuids, resp.Workspace.UUID)
		wss[resp.Workspace.UUID] = resp.Workspace
		collection.Workspaces = append(collection.Workspaces, resp.Workspace)
		collection.Total++
		return nil
	}); err != nil {
		return err
	}
	if len(collection.Workspaces) > 0 {
		if e := permissions.LoadRootNodesForWorkspaces(ctx, uuids, wss, h.virtualPathResolver()); e != nil {
			log.Logger(ctx).Warn("Error while calling LoadRootNodesForWorkspaces", zap.Error(e))
		}
		if e := permissions.BulkReadDefaultRights(ctx, uuids, wss); e != nil {
			log.Logger(ctx).Warn("Error while calling BulkReadDefaultRights", zap.Error(e))
		}
	}
	return rsp.WriteEntity(collection)

}

func (h *WorkspaceHandler) loadPoliciesForResource(ctx context.Context, resourceId string, resourceClient interface{}) (policies []*service.ResourcePolicy, e error) {