Skip to content

Commit 009f8a5

Browse files
raphael-goetzraphael-goetz
committed
feat: added flow to test new emitter
1 parent 5c417de commit 009f8a5

1 file changed

Lines changed: 398 additions & 0 deletions

File tree

‎flows/10_multiple_respond.json‎

Lines changed: 398 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,398 @@
1+
{
2+
"name": "10_multiple_respond",
3+
"description": "This flow checks if the emitter is working correctly, only works with taurus-manual",
4+
"inputs": [
5+
{
6+
"input": {
7+
"http_method": "GET",
8+
"headers": {
9+
"Content-Type": "text/plain"
10+
},
11+
"payload": {
12+
"users": [
13+
{
14+
"age": 22,
15+
"email": "joe@text.com",
16+
"name": "joe doe"
17+
},
18+
{
19+
"age": 56,
20+
"email": "tom@text.com",
21+
"name": "timmy doe"
22+
},
23+
{
24+
"age": 88,
25+
"email": "willy@text.com",
26+
"name": "willy wokner"
27+
},
28+
{
29+
"age": 12,
30+
"email": "jeffy@text.com",
31+
"name": "jeff jefferson"
32+
}
33+
]
34+
}
35+
},
36+
"expected_result": {
37+
"headers": {
38+
"x": "y"
39+
},
40+
"http_status_code": 200,
41+
"payload": [
42+
"timmy doe",
43+
"willy wokner"
44+
]
45+
}
46+
},
47+
{
48+
"input": {
49+
"http_method": "GET",
50+
"headers": {
51+
"Content-Type": "text/plain"
52+
},
53+
"payload": null
54+
},
55+
"expected_result": {
56+
"headers": {
57+
"x": "y"
58+
},
59+
"http_status_code": 200,
60+
"payload": []
61+
}
62+
}
63+
],
64+
"flow": {
65+
"flowId": "1",
66+
"projectId": "1",
67+
"type": "REST",
68+
"settings": [
69+
{
70+
"databaseId": "1",
71+
"flowSettingId": "httpURL",
72+
"value": {
73+
"stringValue": "/10"
74+
}
75+
},
76+
{
77+
"databaseId": "2",
78+
"flowSettingId": "httpMethod",
79+
"value": {
80+
"stringValue": "POST"
81+
}
82+
}
83+
],
84+
"startingNodeId": "7",
85+
"nodeFunctions": [
86+
{
87+
"databaseId": "7",
88+
"runtimeFunctionId": "std::list::filter",
89+
"parameters": [
90+
{
91+
"databaseId": "14",
92+
"runtimeParameterId": "list",
93+
"value": {
94+
"referenceValue": {
95+
"paths": [
96+
{
97+
"path": "payload"
98+
},
99+
{
100+
"path": "users"
101+
}
102+
],
103+
"flowInput": {}
104+
}
105+
}
106+
},
107+
{
108+
"databaseId": "15",
109+
"runtimeParameterId": "predicate",
110+
"value": {
111+
"nodeFunctionId": "8"
112+
}
113+
}
114+
],
115+
"nextNodeId": "2"
116+
},
117+
{
118+
"databaseId": "8",
119+
"runtimeFunctionId": "std::number::is_greater",
120+
"parameters": [
121+
{
122+
"databaseId": "16",
123+
"runtimeParameterId": "first",
124+
"value": {
125+
"referenceValue": {
126+
"paths": [
127+
{
128+
"path": "age"
129+
}
130+
],
131+
"inputType": {
132+
"nodeId": "7",
133+
"parameterIndex": "1"
134+
}
135+
}
136+
}
137+
},
138+
{
139+
"databaseId": "20",
140+
"runtimeParameterId": "second",
141+
"value": {
142+
"literalValue": {
143+
"numberValue": {
144+
"integer": "35"
145+
}
146+
}
147+
}
148+
}
149+
],
150+
"nextNodeId": "9"
151+
},
152+
{
153+
"databaseId": "9",
154+
"runtimeFunctionId": "std::control::if_else",
155+
"parameters": [
156+
{
157+
"databaseId": "17",
158+
"runtimeParameterId": "condition",
159+
"value": {
160+
"referenceValue": {
161+
"nodeId": "8"
162+
}
163+
}
164+
},
165+
{
166+
"databaseId": "21",
167+
"runtimeParameterId": "runnable",
168+
"value": {
169+
"nodeFunctionId": "1"
170+
}
171+
},
172+
{
173+
"databaseId": "22",
174+
"runtimeParameterId": "else_runnable",
175+
"value": {
176+
"nodeFunctionId": "3"
177+
}
178+
}
179+
],
180+
"nextNodeId": "5"
181+
},
182+
{
183+
"databaseId": "1",
184+
"runtimeFunctionId": "std::control::return",
185+
"parameters": [
186+
{
187+
"databaseId": "1",
188+
"runtimeParameterId": "value",
189+
"value": {
190+
"literalValue": {
191+
"boolValue": true
192+
}
193+
}
194+
}
195+
]
196+
},
197+
{
198+
"databaseId": "3",
199+
"runtimeFunctionId": "std::control::return",
200+
"parameters": [
201+
{
202+
"databaseId": "6",
203+
"runtimeParameterId": "value",
204+
"value": {
205+
"literalValue": {
206+
"boolValue": false
207+
}
208+
}
209+
}
210+
]
211+
},
212+
{
213+
"databaseId": "5",
214+
"runtimeFunctionId": "std::control::return",
215+
"parameters": [
216+
{
217+
"databaseId": "10",
218+
"runtimeParameterId": "value",
219+
"value": {
220+
"literalValue": {
221+
"boolValue": true
222+
}
223+
}
224+
}
225+
]
226+
},
227+
{
228+
"databaseId": "2",
229+
"runtimeFunctionId": "std::list::size",
230+
"parameters": [
231+
{
232+
"databaseId": "3",
233+
"runtimeParameterId": "list",
234+
"value": {
235+
"referenceValue": {
236+
"nodeId": "7"
237+
}
238+
}
239+
}
240+
],
241+
"nextNodeId": "10"
242+
},
243+
{
244+
"databaseId": "6",
245+
"runtimeFunctionId": "std::control::return",
246+
"parameters": [
247+
{
248+
"databaseId": "13",
249+
"runtimeParameterId": "value",
250+
"value": {
251+
"referenceValue": {
252+
"paths": [
253+
{
254+
"path": "name"
255+
}
256+
],
257+
"inputType": {
258+
"nodeId": "10",
259+
"parameterIndex": "1"
260+
}
261+
}
262+
}
263+
}
264+
]
265+
},
266+
{
267+
"databaseId": "10",
268+
"runtimeFunctionId": "std::list::map",
269+
"parameters": [
270+
{
271+
"databaseId": "23",
272+
"runtimeParameterId": "list",
273+
"value": {
274+
"referenceValue": {
275+
"nodeId": "7"
276+
}
277+
}
278+
},
279+
{
280+
"databaseId": "24",
281+
"runtimeParameterId": "transform",
282+
"value": {
283+
"nodeFunctionId": "6"
284+
}
285+
}
286+
],
287+
"nextNodeId": "11"
288+
},
289+
{
290+
"databaseId": "11",
291+
"runtimeFunctionId": "http::response::create",
292+
"parameters": [
293+
{
294+
"databaseId": "27",
295+
"runtimeParameterId": "http_status_code",
296+
"value": {
297+
"literalValue": {
298+
"numberValue": {
299+
"integer": "200"
300+
}
301+
}
302+
}
303+
},
304+
{
305+
"databaseId": "30",
306+
"runtimeParameterId": "headers",
307+
"value": {
308+
"literalValue": {
309+
"structValue": {
310+
"fields": {
311+
"x": {
312+
"stringValue": "y"
313+
}
314+
}
315+
}
316+
}
317+
}
318+
},
319+
{
320+
"databaseId": "31",
321+
"runtimeParameterId": "payload",
322+
"value": {
323+
"referenceValue": {
324+
"nodeId": "10"
325+
}
326+
}
327+
}
328+
],
329+
"nextNodeId": "4"
330+
},
331+
{
332+
"databaseId": "4",
333+
"nextNodeId": "20",
334+
"runtimeFunctionId": "rest::control::respond",
335+
"parameters": [
336+
{
337+
"databaseId": "8",
338+
"runtimeParameterId": "http_response",
339+
"value": {
340+
"referenceValue": {
341+
"nodeId": "11"
342+
}
343+
}
344+
}
345+
]
346+
},
347+
{
348+
"nextNodeId": "21",
349+
"databaseId": "20",
350+
"runtimeFunctionId": "rest::control::respond",
351+
"parameters": [
352+
{
353+
"databaseId": "8",
354+
"runtimeParameterId": "http_response",
355+
"value": {
356+
"referenceValue": {
357+
"nodeId": "11"
358+
}
359+
}
360+
}
361+
]
362+
},
363+
{
364+
"databaseId": "21",
365+
"nextNodeId": "22",
366+
"runtimeFunctionId": "rest::control::respond",
367+
"parameters": [
368+
{
369+
"databaseId": "8",
370+
"runtimeParameterId": "http_response",
371+
"value": {
372+
"referenceValue": {
373+
"nodeId": "11"
374+
}
375+
}
376+
}
377+
]
378+
},
379+
{
380+
"databaseId": "22",
381+
"runtimeFunctionId": "std::control::return",
382+
"parameters": [
383+
{
384+
"databaseId": "8",
385+
"runtimeParameterId": "http_response",
386+
"value": {
387+
"referenceValue": {
388+
"nodeId": "11"
389+
}
390+
}
391+
}
392+
]
393+
}
394+
],
395+
"projectSlug": "project",
396+
"signature": "(httpURL: HTTP_URL, httpMethod: HTTP_METHOD): { payload: { users: { name: TEXT, email: TEXT, age: NUMBER }[] }, headers: I }"
397+
}
398+
}

0 commit comments

Comments
 (0)