Merge pull request #267 from code0-tech/feat/#266

Nico Sammito · web-flow · commit 60d472359d96 · 2026-03-12T14:50:30.000+01:00
Update to 0.0.58 Tucana
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -8,7 +8,7 @@ edition = "2024"
 [workspace.dependencies]
 serde = "1.0.219"
 serde_json = "1.0.140"
-tucana = "0.0.56"
+tucana = "0.0.58"
 clap = "4.5.41"
 colored = "3.0"
 tabled = "0.20"
diff --git a/crates/cli/src/analyser/data_type.rs b/crates/cli/src/analyser/data_type.rs
@@ -47,12 +47,12 @@ impl Analyser {
             ));
         }
 
-        if dt.signature == "" {
+        if dt.r#type == "" {
             self.reporter.add(Diagnose::new(
                 dt.identifier.clone(),
                 adt.original_definition.clone(),
                 DiagnosticKind::NullField {
-                    field_name: "signature".into(),
+                    field_name: "type".into(),
                 },
             ));
         }
diff --git a/crates/cli/src/analyser/flow_type.rs b/crates/cli/src/analyser/flow_type.rs
@@ -8,6 +8,18 @@ impl Analyser {
         let name = flow.identifier.clone();
         let original = aft.original_definition.clone();
 
+        for linked in flow.linked_data_type_identifiers.clone() {
+            if !self.data_type_identifier_exists(linked.as_str(), None) {
+                self.reporter.add(Diagnose::new(
+                    name.clone(),
+                    original.clone(),
+                    DiagnosticKind::UndefinedDataTypeIdentifier {
+                        identifier: linked.clone(),
+                    },
+                ));
+            }
+        }
+
         if flow.display_icon.is_empty() {
             self.reporter.add(Diagnose::new(
                 name.clone(),
@@ -65,31 +77,43 @@ impl Analyser {
             ));
         }
 
-        if let Some(identifier) = &flow.input_type_identifier
+        if let Some(identifier) = &flow.input_type
             && identifier == ""
         {
             self.reporter.add(Diagnose::new(
                 name.clone(),
                 original.clone(),
                 DiagnosticKind::NullField {
-                    field_name: "input_type_identifier".into(),
+                    field_name: "input_type".into(),
                 },
             ));
         }
 
-        if let Some(identifier) = &flow.return_type_identifier
+        if let Some(identifier) = &flow.return_type
             && identifier == ""
         {
             self.reporter.add(Diagnose::new(
                 name.clone(),
                 original.clone(),
                 DiagnosticKind::NullField {
-                    field_name: "return_type_identifier".into(),
+                    field_name: "return_type".into(),
                 },
             ));
         }
 
         for setting in &flow.settings {
+            for linked in setting.linked_data_type_identifiers.clone() {
+                if !self.data_type_identifier_exists(linked.as_str(), None) {
+                    self.reporter.add(Diagnose::new(
+                        name.clone(),
+                        original.clone(),
+                        DiagnosticKind::UndefinedDataTypeIdentifier {
+                            identifier: linked.clone(),
+                        },
+                    ));
+                }
+            }
+
             if setting.name.is_empty() {
                 self.reporter.add(Diagnose::new(
                     setting.identifier.clone(),
@@ -108,12 +132,12 @@ impl Analyser {
                     },
                 ));
             }
-            if !self.data_type_identifier_exists(&setting.data_type_identifier, None) {
+            if !self.data_type_identifier_exists(&setting.r#type, None) {
                 self.reporter.add(Diagnose::new(
                     name.clone(),
                     original.clone(),
                     DiagnosticKind::UndefinedDataTypeIdentifier {
-                        identifier: setting.data_type_identifier.clone(),
+                        identifier: setting.r#type.clone(),
                     },
                 ));
             }
diff --git a/definitions/cron/data_type/type/cron_day_of_month.proto.json b/definitions/cron/data_type/type/cron_day_of_month.proto.json
@@ -25,6 +25,6 @@
       "content": "Cron Day of Month"
     }
   ],
-  "linked_data_type_identifiers": [],
-  "signature": "string"
+  "linkedDataTypeIdentifiers": [],
+  "type": "string"
 }
diff --git a/definitions/cron/data_type/type/cron_day_of_week.proto.json b/definitions/cron/data_type/type/cron_day_of_week.proto.json
@@ -25,6 +25,6 @@
       "content": "Cron Day of Week"
     }
   ],
-  "linked_data_type_identifiers": [],
-  "signature": "string | 'MON' | 'TUE' | 'WED' | 'THU' | 'FRI' | 'SAT' | 'SUN'"
+  "linkedDataTypeIdentifiers": [],
+  "type": "string | 'MON' | 'TUE' | 'WED' | 'THU' | 'FRI' | 'SAT' | 'SUN'"
 }
diff --git a/definitions/cron/data_type/type/cron_hour.proto.json b/definitions/cron/data_type/type/cron_hour.proto.json
@@ -25,6 +25,6 @@
       "content": "Cron Hour"
     }
   ],
-  "linked_data_type_identifiers": [],
-  "signature": "string"
+  "linkedDataTypeIdentifiers": [],
+  "type": "string"
 }
diff --git a/definitions/cron/data_type/type/cron_minute.proto.json b/definitions/cron/data_type/type/cron_minute.proto.json
@@ -25,6 +25,6 @@
       "content": "Cron Minute"
     }
   ],
-  "linked_data_type_identifiers": [],
-  "signature": "string"
+  "linkedDataTypeIdentifiers": [],
+  "type": "string"
 }
diff --git a/definitions/cron/data_type/type/cron_month.proto.json b/definitions/cron/data_type/type/cron_month.proto.json
@@ -25,6 +25,6 @@
       "content": "Cron Month"
     }
   ],
-  "linked_data_type_identifiers": [],
-  "signature": "string | 'JAN' | 'FEB' | 'MAR' | 'APR' | 'MAY' | 'JUN' | 'JUL' | 'AUG' | 'SEP' | 'OCT' | 'NOV' | 'DEC' "
+  "linkedDataTypeIdentifiers": [],
+  "type": "string | 'JAN' | 'FEB' | 'MAR' | 'APR' | 'MAY' | 'JUN' | 'JUL' | 'AUG' | 'SEP' | 'OCT' | 'NOV' | 'DEC' "
 }
diff --git a/definitions/cron/flow_type/cron.proto.json b/definitions/cron/flow_type/cron.proto.json
@@ -4,7 +4,10 @@
 		{
 			"identifier": "CRON_MINUTE",
 			"unique": "NONE",
-			"dataTypeIdentifier": "CRON_MINUTE",
+			"type": "CRON_MINUTE",
+			"linkedDataTypeIdentifiers": [
+				"CRON_MINUTE"
+			],
 			"defaultValue": null,
 			"name": [
 				{
@@ -22,7 +25,10 @@
 		{
 			"identifier": "CRON_HOUR",
 			"unique": "NONE",
-			"dataTypeIdentifier": "CRON_HOUR",
+			"type": "CRON_HOUR",
+			"linkedDataTypeIdentifiers": [
+				"CRON_HOUR"
+			],
 			"defaultValue": null,
 			"name": [
 				{
@@ -40,7 +46,10 @@
 		{
 			"identifier": "CRON_DAY_OF_MONTH",
 			"unique": "NONE",
-			"dataTypeIdentifier": "CRON_DAY_OF_MONTH",
+			"type": "CRON_DAY_OF_MONTH",
+			"linkedDataTypeIdentifiers": [
+				"CRON_DAY_OF_MONTH"
+			],
 			"defaultValue": null,
 			"name": [
 				{
@@ -58,7 +67,10 @@
 		{
 			"identifier": "CRON_MONTH",
 			"unique": "NONE",
-			"dataTypeIdentifier": "CRON_MONTH",
+			"type": "CRON_MONTH",
+			"linkedDataTypeIdentifiers": [
+				"CRON_MONTH"
+			],
 			"defaultValue": null,
 			"name": [
 				{
@@ -76,7 +88,10 @@
 		{
 			"identifier": "CRON_DAY_OF_WEEK",
 			"unique": "NONE",
-			"dataTypeIdentifier": "CRON_DAY_OF_WEEK",
+			"type": "CRON_DAY_OF_WEEK",
+			"linkedDataTypeIdentifiers": [
+				"CRON_DAY_OF_WEEK"
+			],
 			"defaultValue": null,
 			"name": [
 				{
diff --git a/definitions/rest/data_type/rest_adapter_input.proto.json b/definitions/rest/data_type/rest_adapter_input.proto.json
@@ -22,8 +22,8 @@
 	"genericKeys": [
 		"T"
 	],
-	"linked_data_type_identifiers": [
+	"linkedDataTypeIdentifiers": [
 		"OBJECT"
 	],
-	"signature": "{ body: T, headers: OBJECT<{}> }"
+	"type": "{ body: T, headers: OBJECT<{}> }"
 }
diff --git a/definitions/rest/flow_type/rest.proto.json b/definitions/rest/flow_type/rest.proto.json
@@ -4,7 +4,10 @@
     {
       "identifier": "HTTP_URL",
       "unique": "PROJECT",
-      "dataTypeIdentifier": "HTTP_URL",
+      "type": "HTTP_URL",
+      "linkedDataTypeIdentifiers": [
+        "HTTP_URL"
+      ],
       "name": [
         {
           "code": "en-US",
@@ -21,7 +24,10 @@
     {
       "identifier": "HTTP_METHOD",
       "unique": "NONE",
-      "dataTypeIdentifier": "HTTP_METHOD",
+      "type": "HTTP_METHOD",
+      "linkedDataTypeIdentifiers": [
+        "HTTP_METHOD"
+      ],
       "name": [
         {
           "code": "en-US",
@@ -36,8 +42,12 @@
       ]
     }
   ],
-  "inputTypeIdentifier": "REST_ADAPTER_INPUT",
-  "returnTypeIdentifier": "HTTP_RESPONSE",
+  "inputType": "REST_ADAPTER_INPUT",
+  "returnType": "HTTP_RESPONSE",
+  "linkedDataTypeIdentifiers": [
+    "REST_ADAPTER_INPUT",
+    "HTTP_RESPONSE"
+  ],
   "editable": false,
   "name": [
     {
diff --git a/definitions/standard/data_type/array/list.proto.json b/definitions/standard/data_type/array/list.proto.json
@@ -20,5 +20,5 @@
 	],
 	"genericKeys": ["T"],
 	"rules": [],
-	"signature": "T[]"
+	"type": "T[]"
 }
diff --git a/definitions/standard/data_type/node/comparator.proto.json b/definitions/standard/data_type/node/comparator.proto.json
@@ -20,7 +20,7 @@
 	],
 	"rules": [],
 	"genericKeys": ["I"],
-	"signature": "(left: I, right: I): NUMBER",
+	"type": "(left: I, right: I): NUMBER",
 	"linkedDataTypeIdentifiers": [
 		"NUMBER"
 	]
diff --git a/definitions/standard/data_type/node/consumer.proto.json b/definitions/standard/data_type/node/consumer.proto.json
@@ -20,5 +20,5 @@
 	],
 	"rules": [],
 	"genericKeys": ["T"],
-	"signature": "(item: T): void"
+	"type": "(item: T): void"
 }
diff --git a/definitions/standard/data_type/node/predicate.proto.json b/definitions/standard/data_type/node/predicate.proto.json
@@ -20,8 +20,8 @@
 	],
 	"rules": [],
 	"genericKeys": ["T"],
-	"signature": "(item: T): BOOLEAN",
-	"linked_data_type_identifiers": [
+	"type": "(item: T): BOOLEAN",
+	"linkedDataTypeIdentifiers": [
 		"BOOLEAN"
 	]
 }
diff --git a/definitions/standard/data_type/node/runnable.proto.json b/definitions/standard/data_type/node/runnable.proto.json
@@ -19,5 +19,5 @@
 		}
 	],
 	"rules": [],
-	"signature": "(): void"
+	"type": "(): void"
 }
diff --git a/definitions/standard/data_type/node/transform.proto.json b/definitions/standard/data_type/node/transform.proto.json
@@ -20,5 +20,5 @@
 	],
 	"rules": [],
 	"genericKeys": ["I", "R"],
-	"signature": "(item: I): R"
+	"type": "(item: I): R"
 }
diff --git a/definitions/standard/data_type/object/http_request.proto.json b/definitions/standard/data_type/object/http_request.proto.json
@@ -18,10 +18,10 @@
 			"content": "HTTP Request"
 		}
 	],
-	"signature": "{ method: HTTP_METHOD, url: HTTP_URL, body: T, headers: OBJECT<{}> }",
+	"type": "{ method: HTTP_METHOD, url: HTTP_URL, body: T, headers: OBJECT<{}> }",
 	"genericKeys": ["T"],
 	"rules": [],
-	"linked_data_type_identifiers": [
+	"linkedDataTypeIdentifiers": [
 		"HTTP_METHOD",
 		"HTTP_URL",
 		"OBJECT"
diff --git a/definitions/standard/data_type/object/http_response.proto.json b/definitions/standard/data_type/object/http_response.proto.json
@@ -19,8 +19,8 @@
 		}
 	],
 	"genericKeys": ["T"],
-	"signature": "{ body: T, headers: OBJECT<{}>, status_code: HTTP_STATUS_CODE }",
-	"linked_data_type_identifiers": [
+	"type": "{ body: T, headers: OBJECT<{}>, status_code: HTTP_STATUS_CODE }",
+	"linkedDataTypeIdentifiers": [
 		"HTTP_STATUS_CODE",
 		"OBJECT"
 	],
diff --git a/definitions/standard/data_type/object/object.proto.json b/definitions/standard/data_type/object/object.proto.json
diff --git a/definitions/standard/data_type/primitive/boolean.proto.json b/definitions/standard/data_type/primitive/boolean.proto.json
diff --git a/definitions/standard/data_type/primitive/number.proto.json b/definitions/standard/data_type/primitive/number.proto.json
diff --git a/definitions/standard/data_type/primitive/text.proto.json b/definitions/standard/data_type/primitive/text.proto.json
diff --git a/definitions/standard/data_type/type/http_method.proto.json b/definitions/standard/data_type/type/http_method.proto.json
diff --git a/definitions/standard/data_type/type/http_status_code.proto.json b/definitions/standard/data_type/type/http_status_code.proto.json
diff --git a/definitions/standard/data_type/type/http_url.proto.json b/definitions/standard/data_type/type/http_url.proto.json
diff --git a/definitions/standard/data_type/type/text_encoding.proto.json b/definitions/standard/data_type/type/text_encoding.proto.json

Original file line number	Diff line number	Diff line change
`@@ -47,12 +47,12 @@ impl Analyser {`
`47`	`47`	`));`
`48`	`48`	`}`
`49`	`49`
`50`		`- if dt.signature == "" {`
	`50`	`+ if dt.r#type == "" {`
`51`	`51`	`self.reporter.add(Diagnose::new(`
`52`	`52`	`dt.identifier.clone(),`
`53`	`53`	`adt.original_definition.clone(),`
`54`	`54`	`DiagnosticKind::NullField {`
`55`		`- field_name: "signature".into(),`
	`55`	`+ field_name: "type".into(),`
`56`	`56`	`},`
`57`	`57`	`));`
`58`	`58`	`}`
Original file line number	Diff line number	Diff line change
`@@ -25,6 +25,6 @@`
`25`	`25`	`"content": "Cron Day of Month"`
`26`	`26`	`}`
`27`	`27`	`],`
`28`		`- "linked_data_type_identifiers": [],`
`29`		`- "signature": "string"`
	`28`	`+ "linkedDataTypeIdentifiers": [],`
	`29`	`+ "type": "string"`
`30`	`30`	`}`