Skip to content

Commit 430b23e

Browse files
committed
feat(ports): consolidate input/output port fields into unified ports property
feat(connections): remove bidirectional port logic and simplify routing
1 parent 64343ba commit 430b23e

60 files changed

Lines changed: 3986 additions & 3851 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

packages/demo/assets/data/database_schema.json

Lines changed: 327 additions & 319 deletions
Large diffs are not rendered by default.

packages/demo/assets/data/iot_data_pipeline.json

Lines changed: 250 additions & 229 deletions
Large diffs are not rendered by default.

packages/demo/assets/data/manufacturing_workflow.json

Lines changed: 893 additions & 812 deletions
Large diffs are not rendered by default.

packages/demo/assets/data/manufacturing_workflow_backup.json

Lines changed: 852 additions & 949 deletions
Large diffs are not rendered by default.

packages/demo/assets/data/quality_control_workflow.json

Lines changed: 276 additions & 253 deletions
Large diffs are not rendered by default.

packages/demo/assets/data/simple_workflow.json

Lines changed: 67 additions & 67 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,15 @@
55
"type": "DataSource",
66
"width": 150,
77
"height": 170,
8-
"inputPorts": [],
9-
"outputPorts": [
8+
"data": {
9+
"name": "CSV Data Source",
10+
"format": "CSV",
11+
"records": 10000
12+
},
13+
"x": 100,
14+
"y": 200,
15+
"zIndex": 1,
16+
"ports": [
1017
{
1118
"id": "data-out",
1219
"name": "Data",
@@ -15,24 +22,24 @@
1522
"offset": {
1623
"x": 2,
1724
"y": 40
18-
}
25+
},
26+
"type": "output"
1927
}
20-
],
21-
"data": {
22-
"name": "CSV Data Source",
23-
"format": "CSV",
24-
"records": 10000
25-
},
26-
"x": 100,
27-
"y": 200,
28-
"zIndex": 1
28+
]
2929
},
3030
{
3131
"id": "filter",
3232
"type": "Filter",
3333
"width": 150,
3434
"height": 170,
35-
"inputPorts": [
35+
"data": {
36+
"name": "Age Filter",
37+
"condition": "age > 18"
38+
},
39+
"x": 300,
40+
"y": 200,
41+
"zIndex": 2,
42+
"ports": [
3643
{
3744
"id": "data-in",
3845
"name": "Input",
@@ -41,10 +48,9 @@
4148
"offset": {
4249
"x": -2,
4350
"y": 40
44-
}
45-
}
46-
],
47-
"outputPorts": [
51+
},
52+
"type": "input"
53+
},
4854
{
4955
"id": "filtered-out",
5056
"name": "Filtered",
@@ -53,23 +59,24 @@
5359
"offset": {
5460
"x": 2,
5561
"y": 40
56-
}
62+
},
63+
"type": "output"
5764
}
58-
],
59-
"data": {
60-
"name": "Age Filter",
61-
"condition": "age > 18"
62-
},
63-
"x": 300,
64-
"y": 200,
65-
"zIndex": 2
65+
]
6666
},
6767
{
6868
"id": "transform",
6969
"type": "Transform",
7070
"width": 150,
7171
"height": 170,
72-
"inputPorts": [
72+
"data": {
73+
"name": "Normalize Data",
74+
"operation": "normalize"
75+
},
76+
"x": 500,
77+
"y": 200,
78+
"zIndex": 3,
79+
"ports": [
7380
{
7481
"id": "data-in",
7582
"name": "Input",
@@ -78,10 +85,9 @@
7885
"offset": {
7986
"x": -2,
8087
"y": 40
81-
}
82-
}
83-
],
84-
"outputPorts": [
88+
},
89+
"type": "input"
90+
},
8591
{
8692
"id": "transformed-out",
8793
"name": "Output",
@@ -90,23 +96,25 @@
9096
"offset": {
9197
"x": 2,
9298
"y": 40
93-
}
99+
},
100+
"type": "output"
94101
}
95-
],
96-
"data": {
97-
"name": "Normalize Data",
98-
"operation": "normalize"
99-
},
100-
"x": 500,
101-
"y": 200,
102-
"zIndex": 3
102+
]
103103
},
104104
{
105105
"id": "aggregate",
106106
"type": "Aggregate",
107107
"width": 150,
108108
"height": 170,
109-
"inputPorts": [
109+
"data": {
110+
"name": "Sum by Category",
111+
"groupBy": "category",
112+
"operation": "sum"
113+
},
114+
"x": 700,
115+
"y": 200,
116+
"zIndex": 4,
117+
"ports": [
110118
{
111119
"id": "data-in",
112120
"name": "Input",
@@ -115,10 +123,9 @@
115123
"offset": {
116124
"x": -2,
117125
"y": 40
118-
}
119-
}
120-
],
121-
"outputPorts": [
126+
},
127+
"type": "input"
128+
},
122129
{
123130
"id": "aggregated-out",
124131
"name": "Summary",
@@ -127,24 +134,24 @@
127134
"offset": {
128135
"x": 2,
129136
"y": 40
130-
}
137+
},
138+
"type": "output"
131139
}
132-
],
133-
"data": {
134-
"name": "Sum by Category",
135-
"groupBy": "category",
136-
"operation": "sum"
137-
},
138-
"x": 700,
139-
"y": 200,
140-
"zIndex": 4
140+
]
141141
},
142142
{
143143
"id": "output",
144144
"type": "Output",
145145
"width": 150,
146146
"height": 170,
147-
"inputPorts": [
147+
"data": {
148+
"name": "Export to Database",
149+
"destination": "PostgreSQL"
150+
},
151+
"x": 900,
152+
"y": 200,
153+
"zIndex": 5,
154+
"ports": [
148155
{
149156
"id": "data-in",
150157
"name": "Results",
@@ -153,17 +160,10 @@
153160
"offset": {
154161
"x": -2,
155162
"y": 40
156-
}
163+
},
164+
"type": "input"
157165
}
158-
],
159-
"outputPorts": [],
160-
"data": {
161-
"name": "Export to Database",
162-
"destination": "PostgreSQL"
163-
},
164-
"x": 900,
165-
"y": 200,
166-
"zIndex": 5
166+
]
167167
}
168168
],
169169
"connections": [
@@ -201,4 +201,4 @@
201201
"y": 0,
202202
"zoom": 1.0
203203
}
204-
}
204+
}

0 commit comments

Comments
 (0)