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

adding inputs output struct based on argo naming for now

Browse Source
This commit is contained in:
mr 2025-01-30 09:45:13 +01:00
parent 826d7586b1
commit 787c01b4be
1 changed files with 15 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
models/workflow/workflow.go
View File

@ -52,8 +52,13 @@ func (w *Workflow) GetPricedItem(f func(item graph.GraphItem) bool, request *too
return list_datas return list_datas
} }
func (w *Workflow) GetByRelatedProcessing(processingID string, g func(item graph.GraphItem) bool) []resources.ResourceInterface { type Related struct {
storages := []resources.ResourceInterface{} Nodes []resources.ResourceInterface
Links []graph.GraphLink
}
func (w *Workflow) GetByRelatedProcessing(processingID string, g func(item graph.GraphItem) bool) map[string]Related {
related := map[string]Related{}
for _, link := range w.Graph.Links { for _, link := range w.Graph.Links {
nodeID := link.Destination.ID nodeID := link.Destination.ID
var node resources.ResourceInterface var node resources.ResourceInterface
@ -67,10 +72,16 @@ func (w *Workflow) GetByRelatedProcessing(processingID string, g func(item graph
_, node = item.GetResource() // we are looking for the storage as destination _, node = item.GetResource() // we are looking for the storage as destination
} }
if processingID == nodeID && node != nil { // if the storage is linked to the processing if processingID == nodeID && node != nil { // if the storage is linked to the processing
storages = append(storages, node) if _, ok := related[processingID]; !ok {
related[processingID] = Related{}
}
rel := related[processingID]
rel.Nodes = append(rel.Nodes, node)
rel.Links = append(rel.Links, link)
related[processingID] = rel
} }
} }
return storages return related
} }
func (ao *Workflow) VerifyAuth(request *tools.APIRequest) bool { func (ao *Workflow) VerifyAuth(request *tools.APIRequest) bool {