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

setup

Browse Source
This commit is contained in:
mr
2026-03-17 13:52:43 +01:00
parent 8fd4f5faef
commit b3dbc7687e
1 changed files with 14 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
models/workflow/workflow.go
View File

@@ -271,31 +271,31 @@ func (d *Workflow) extractResourcePlantUML(line string, resource resources.Resou
json.Unmarshal([]byte(comment), instance) json.Unmarshal([]byte(comment), instance)
} }
// deserializer les instances... une instance doit par défaut avoir certaines valeurs d'accès. // deserializer les instances... une instance doit par défaut avoir certaines valeurs d'accès.
graphID := uuid.New() item := d.getNewGraphItem(dataName, resource)
graphItem := &graph.GraphItem{ if item != nil {
ID: graphID.String(), d.Graph.Items[item.ID] = *item
}
graphItem = d.getNewGraphItem(dataName, graphItem, resource)
if graphItem != nil {
d.Graph.Items[graphID.String()] = *graphItem
} }
return varName, graphItem, nil return varName, item, nil
} }
func (d *Workflow) getNewGraphItem(dataName string, graphItem *graph.GraphItem, resource resources.ResourceInterface) *graph.GraphItem { func (d *Workflow) getNewGraphItem(dataName string, resource resources.ResourceInterface) *graph.GraphItem {
if resource == nil { if resource == nil {
return nil return nil
} }
graphItem := &graph.GraphItem{
ID: uuid.New().String(),
}
switch dataName { switch dataName {
case "Data": case "Data":
d.Datas = append(d.Datas, resource.GetID()) d.Datas = append(d.Datas, resource.GetID())
d.DataResources = append(d.DataResources, resource.(*resources.DataResource)) d.DataResources = append(d.DataResources, resource.(*resources.DataResource))
fmt.Println("r", graphItem, resource)
graphItem.Data = resource.(*resources.DataResource) graphItem.Data = resource.(*resources.DataResource)
case "Processing": case "Processing":
d.Processings = append(d.Processings, resource.GetID()) d.Processings = append(d.Processings, resource.GetID())
d.ProcessingResources = append(d.ProcessingResources, resource.(*resources.ProcessingResource)) d.ProcessingResources = append(d.ProcessingResources, resource.(*resources.ProcessingResource))
fmt.Println("r", graphItem, resource)
graphItem.Processing = resource.(*resources.ProcessingResource) graphItem.Processing = resource.(*resources.ProcessingResource)
case "Event": case "Event":
access := resources.NewAccessor[*resources.NativeTool](tools.NATIVE_TOOL, &tools.APIRequest{ access := resources.NewAccessor[*resources.NativeTool](tools.NATIVE_TOOL, &tools.APIRequest{
@@ -309,15 +309,17 @@ func (d *Workflow) getNewGraphItem(dataName string, graphItem *graph.GraphItem,
case "Storage": case "Storage":
d.Storages = append(d.Storages, resource.GetID()) d.Storages = append(d.Storages, resource.GetID())
d.StorageResources = append(d.StorageResources, resource.(*resources.StorageResource)) d.StorageResources = append(d.StorageResources, resource.(*resources.StorageResource))
fmt.Println("r", graphItem, resource)
graphItem.Storage = resource.(*resources.StorageResource) graphItem.Storage = resource.(*resources.StorageResource)
case "ComputeUnit": case "ComputeUnit":
d.Computes = append(d.Computes, resource.GetID()) d.Computes = append(d.Computes, resource.GetID())
d.ComputeResources = append(d.ComputeResources, resource.(*resources.ComputeResource)) d.ComputeResources = append(d.ComputeResources, resource.(*resources.ComputeResource))
fmt.Println("r", graphItem, resource)
graphItem.Compute = resource.(*resources.ComputeResource) graphItem.Compute = resource.(*resources.ComputeResource)
default: default:
return graphItem return nil
} }
return graphItem return nil
} }
func (d *Workflow) getNewInstance(dataName string, name string, peerID string) resources.ResourceInstanceITF { func (d *Workflow) getNewInstance(dataName string, name string, peerID string) resources.ResourceInstanceITF {