core/oc-lib
6
0
Fork 0
Code Issues 7 Pull Requests Packages Projects Releases Wiki Activity

oclib setup

Browse Source
This commit is contained in:
mr
2026-03-17 16:09:39 +01:00
parent 7f8d697e4c
commit 5753450965
1 changed files with 24 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
models/workflow/workflow.go
View File

@@ -14,6 +14,7 @@ import (
"cloud.o-forge.io/core/oc-lib/models/common" "cloud.o-forge.io/core/oc-lib/models/common"
"cloud.o-forge.io/core/oc-lib/models/common/models" "cloud.o-forge.io/core/oc-lib/models/common/models"
"cloud.o-forge.io/core/oc-lib/models/common/pricing" "cloud.o-forge.io/core/oc-lib/models/common/pricing"
"cloud.o-forge.io/core/oc-lib/models/live"
"cloud.o-forge.io/core/oc-lib/models/peer" "cloud.o-forge.io/core/oc-lib/models/peer"
"cloud.o-forge.io/core/oc-lib/models/resources" "cloud.o-forge.io/core/oc-lib/models/resources"
"cloud.o-forge.io/core/oc-lib/models/utils" "cloud.o-forge.io/core/oc-lib/models/utils"
@@ -199,11 +200,30 @@ func (d *Workflow) ExtractFromPlantUML(plantUML multipart.File, request *tools.A
func (d *Workflow) generateResource(datas []resources.ResourceInterface, request *tools.APIRequest) error { func (d *Workflow) generateResource(datas []resources.ResourceInterface, request *tools.APIRequest) error {
for _, d := range datas { for _, d := range datas {
access := d.GetAccessor(request) if d.GetType() == tools.COMPUTE_RESOURCE.String() {
if _, _, err := access.LoadOne(d.GetID()); err == nil { access := live.NewAccessor[*live.LiveDatacenter](tools.LIVE_DATACENTER, request)
if b, err := json.Marshal(d); err == nil {
var liv live.LiveDatacenter
json.Unmarshal(b, &liv)
data, _, err := access.StoreOne(&liv)
if err == nil {
d.GetAccessor(request).CopyOne(data)
}
}
continue
} else if d.GetType() == tools.STORAGE_RESOURCE.String() {
access := live.NewAccessor[*live.LiveStorage](tools.LIVE_STORAGE, request)
if b, err := json.Marshal(d); err == nil {
var liv live.LiveStorage
json.Unmarshal(b, &liv)
data, _, err := access.StoreOne(&liv)
if err == nil {
d.GetAccessor(request).CopyOne(data)
}
}
continue continue
} }
_, _, err := access.StoreOne(d) _, _, err := d.GetAccessor(request).StoreOne(d)
fmt.Println("ERR", err) fmt.Println("ERR", err)
} }
return nil return nil
@@ -257,7 +277,7 @@ func (d *Workflow) extractResourcePlantUML(line string, resource resources.Resou
if len(splitted) <= 1 { if len(splitted) <= 1 {
return "", nil, errors.New("Can't deserialize Object, there's no name") return "", nil, errors.New("Can't deserialize Object, there's no name")
} }
resource.SetName(strings.ReplaceAll(splitted[1], "\\n", "")) resource.SetName(strings.ReplaceAll(splitted[1], "\\n", " "))
splittedComments := strings.Split(line, "'") splittedComments := strings.Split(line, "'")
if len(splittedComments) > 1 { if len(splittedComments) > 1 {