iframe-proxy | Sunbelt Computer Software

164 lines (139 loc) · 4.39 KB
package handlers
	"encoding/json"
	"net/http"
	"github.com/layer5io/meshery/server/models"
	"github.com/layer5io/meshsync/pkg/model"
	"gorm.io/gorm/clause"
// swagger:route GET /api/system/meshsync/resources GetMeshSyncResources idGetMeshSyncResources
// Handle GET request for meshsync discovered resources
// ```?apiVersion={apiVersion}``` If apiVersion is unspecified then all models are returned
// ```?search={componentname}``` If search is non empty then a greedy search is performed
// ```?order={field}``` orders on the passed field
// ```?sort={[asc/desc]}``` Default behavior is asc
// ```?page={page-number}``` Default page number is 1
// ```?pagesize={pagesize}``` Default pagesize is 25. To return all results: ```pagesize=all```
// ```?annotation={annotaion}``` annotation is a boolean value. If true then annotations are returned
// ```?labels={labels}``` labels is a boolean value. If true then labels are returned
// ```?spec={spec}``` spec is a boolean value. If true then spec is returned
// ```?status={status}``` status is a boolean value. If true then status is returned
// ```?clusterId={[clusterId]}``` clusterId is array of string values. Required.
// responses:
// 200: []meshsyncResourcesResponseWrapper
func (h *Handler) GetMeshSyncResources(rw http.ResponseWriter, r *http.Request, _ *models.Preference, _ *models.User, provider models.Provider) {
	rw.Header().Set("Content-Type", "application/json")
	enc := json.NewEncoder(rw)
	var resources []model.KubernetesResource
	var totalCount int64
	limitstr := r.URL.Query().Get("pagesize")
	var limit int
	if limitstr != "all" {
		limit, _ = strconv.Atoi(limitstr)
		if limit <= 0 {
			limit = defaultPageSize
	pagestr := r.URL.Query().Get("page")
	page, _ := strconv.Atoi(pagestr)
	if page <= 0 {
	offset := (page - 1) * limit
	order := r.URL.Query().Get("order")
	sort := r.URL.Query().Get("sort")
	search := r.URL.Query().Get("search")
	apiVersion := r.URL.Query().Get("apiVersion")
	spec, _ := strconv.ParseBool(r.URL.Query().Get("spec"))
	status, _ := strconv.ParseBool(r.URL.Query().Get("status"))
	isAnnotaion, _ := strconv.ParseBool(r.URL.Query().Get("annotations"))
	isLabels, _ := strconv.ParseBool(r.URL.Query().Get("labels"))
	kind := r.URL.Query().Get("kind")
	filter := struct {
		ClusterIds []string `json:"clusterIds"`
	clusterIds := r.URL.Query().Get("clusterIds")
	if clusterIds != "" {
		err := json.Unmarshal([]byte(clusterIds), &filter.ClusterIds)
		if err != nil {
			h.log.Error(ErrFetchPattern(err))
			http.Error(rw, ErrFetchPattern(err).Error(), http.StatusInternalServerError)
		filter.ClusterIds = []string{}
	result := provider.GetGenericPersister().Model(&model.KubernetesResource{}).
		Preload("KubernetesResourceMeta").
		Where("kubernetes_resources.cluster_id IN (?)", filter.ClusterIds)
	if kind != "" {
		result = result.Where(&model.KubernetesResource{Kind: kind})
	if apiVersion != "" {
		result = result.Where(&model.KubernetesResource{APIVersion: apiVersion})
	if isLabels {
		result = result.Preload("KubernetesResourceMeta.Labels", "kind = ?", model.KindLabel)
	if isAnnotaion {
		result = result.Preload("KubernetesResourceMeta.Annotations", "kind = ?", model.KindAnnotation)
		result = result.Preload("Spec")
	if status {
		result = result.Preload("Status")
	if search != "" {
		result = result.Where(&model.KubernetesResourceObjectMeta{Name: `%` + search + `%`})
	result.Count(&totalCount)
	if limit != 0 {
		result = result.Limit(limit)
	if offset != 0 {
		result = result.Offset(offset)
	if order != "" {
		if sort == "desc" {
			result = result.Order(clause.OrderByColumn{Column: clause.Column{Name: order}, Desc: true})
			result = result.Order(order)
	err := result.Find(&resources).Error
	if err != nil {
		h.log.Error(ErrFetchMeshSyncResources(err))
		http.Error(rw, ErrFetchMeshSyncResources(err).Error(), http.StatusInternalServerError)
	var pgSize int
	if limitstr == "all" {
		pgSize = len(resources)
		pgSize = limit
	response := &models.MeshSyncResourcesAPIResponse{
		Page:       page,
		PageSize:   pgSize,
		TotalCount: totalCount,
		Resources:  resources,
	if err := enc.Encode(response); err != nil {
		h.log.Error(ErrFetchMeshSyncResources(err))
		http.Error(rw, ErrFetchMeshSyncResources(err).Error(), http.StatusInternalServerError)
Sunbelt Computer Software

PL/B Language Development and Support

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

FilesExpand file tree

meshsync_handler.go

Latest commit

History

meshsync_handler.go

File metadata and controls
