core/oc-catalog
6
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

working oc-catalog + enum ref

Browse Source
This commit is contained in:
mr
2025-01-17 17:03:32 +01:00
parent 4b8f129564
commit 99b42f6d02
14 changed files with 1295 additions and 361 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
controllers/resource.go
View File

@@ -1,6 +1,8 @@
package controllers
import (
"fmt"
oclib "cloud.o-forge.io/core/oc-lib"
beego "github.com/beego/beego/v2/server/web"
)
@@ -12,17 +14,17 @@ type ResourceController struct {
// @Title GetAll
// @Description find resource by id
// @Param is_draft query string false "draft wished"
// @Success 200 {resource} models.resource
// @router / [get]
func (o *ResourceController) GetAll() {
user, peerID, groups := oclib.ExtractTokenInfo(*o.Ctx.Request)
results := map[string]interface{}{}
isDraft := o.Ctx.Input.Query("is_draft")
for _, resource := range []oclib.LibDataEnum{
oclib.LibDataEnum(oclib.DATA_RESOURCE),
oclib.LibDataEnum(oclib.COMPUTE_RESOURCE),
oclib.LibDataEnum(oclib.STORAGE_RESOURCE),
oclib.LibDataEnum(oclib.PROCESSING_RESOURCE),
oclib.LibDataEnum(oclib.WORKFLOW_RESOURCE)} {
d := oclib.LoadAll(resource)
data_collection, comp_collection, storage_collection,
processing_collection, workflow_collection} {
d := oclib.NewRequest(resource, user, peerID, groups, nil).LoadAll(isDraft == "true")
if d.Code != 200 || len(d.Data) == 0 {
results[resource.String()] = []interface{}{}
} else {
@@ -36,18 +38,19 @@ func (o *ResourceController) GetAll() {
// @Title Get
// @Description find resource by key word
// @Param search path string true "the search you want to get"
// @Param is_draft query string false "draft wished"
// @Success 200 {resource} models.resource
// @router /search/:search [get]
func (o *ResourceController) Search() {
user, peerID, groups := oclib.ExtractTokenInfo(*o.Ctx.Request)
search := o.Ctx.Input.Param(":search")
isDraft := o.Ctx.Input.Query("is_draft")
results := map[string]interface{}{}
for _, resource := range []oclib.LibDataEnum{
oclib.LibDataEnum(oclib.DATA_RESOURCE),
oclib.LibDataEnum(oclib.COMPUTE_RESOURCE),
oclib.LibDataEnum(oclib.STORAGE_RESOURCE),
oclib.LibDataEnum(oclib.PROCESSING_RESOURCE),
oclib.LibDataEnum(oclib.WORKFLOW_RESOURCE)} {
d := oclib.Search(nil, search, resource)
data_collection, comp_collection, storage_collection,
processing_collection, workflow_collection} {
fmt.Println("search", search)
d := oclib.NewRequest(resource, user, peerID, groups, nil).Search(nil, search, isDraft == "true")
if d.Code != 200 || len(d.Data) == 0 {
results[resource.String()] = []interface{}{}
} else {
@@ -64,15 +67,13 @@ func (o *ResourceController) Search() {
// @Success 200 {resource} models.resource
// @router /:id [get]
func (o *ResourceController) Get() {
user, peerID, groups := oclib.ExtractTokenInfo(*o.Ctx.Request)
id := o.Ctx.Input.Param(":id")
results := map[string]interface{}{}
for _, resource := range []oclib.LibDataEnum{
oclib.LibDataEnum(oclib.DATA_RESOURCE),
oclib.LibDataEnum(oclib.COMPUTE_RESOURCE),
oclib.LibDataEnum(oclib.STORAGE_RESOURCE),
oclib.LibDataEnum(oclib.PROCESSING_RESOURCE),
oclib.LibDataEnum(oclib.WORKFLOW_RESOURCE)} {
d := oclib.LoadOne(resource, id)
data_collection, comp_collection, storage_collection,
processing_collection, workflow_collection} {
d := oclib.NewRequest(resource, user, peerID, groups, nil).LoadOne(id)
if d.Code != 200 {
results[resource.String()] = nil
} else {
@@ -89,15 +90,14 @@ func (o *ResourceController) Get() {
// @Success 200 {resource} delete success!
// @router /:id [delete]
func (o *ResourceController) Delete() {
user, peerID, groups := oclib.ExtractTokenInfo(*o.Ctx.Request)
id := o.Ctx.Input.Param(":id")
results := map[string]interface{}{}
for _, resource := range []oclib.LibDataEnum{
oclib.LibDataEnum(oclib.DATA_RESOURCE),
oclib.LibDataEnum(oclib.COMPUTE_RESOURCE),
oclib.LibDataEnum(oclib.STORAGE_RESOURCE),
oclib.LibDataEnum(oclib.PROCESSING_RESOURCE),
oclib.LibDataEnum(oclib.WORKFLOW_RESOURCE)} {
d := oclib.DeleteOne(resource, id)
data_collection, comp_collection, storage_collection,
processing_collection, workflow_collection,
} {
d := oclib.NewRequest(resource, user, peerID, groups, nil).DeleteOne(id)
if d.Code != 200 {
results[resource.String()] = nil
} else {