diff --git a/model_nodes/node_callback_models.py b/model_nodes/node_callback_models.py index a0f17c6..a945e35 100644 --- a/model_nodes/node_callback_models.py +++ b/model_nodes/node_callback_models.py @@ -23,7 +23,6 @@ class CallbackNodeCoreSchemaData(BaseModel): """ Pydantic модель для данных портов узла callback """ - then_port_number: Optional[int] = Field(default=0, description="Номер порта для перехода по Связи Then (LINK)") class CallbackNodeCoreSchema(BaseModel): diff --git a/model_nodes/node_each_models.py b/model_nodes/node_each_models.py index 76cf954..ebb933f 100644 --- a/model_nodes/node_each_models.py +++ b/model_nodes/node_each_models.py @@ -23,8 +23,6 @@ class EachNodeCoreSchemaData(BaseModel): """ Pydantic модель для данных портов узла each """ - then_port_number: Optional[int] = Field(default=0, description="Номер порта для перехода по Связи Then (LINK)") - else_port_number: Optional[int] = Field(default=1, description="Номер порта для перехода по Связи Else (LINK)") class EachNodeCoreSchema(BaseModel): diff --git a/model_nodes/node_if_models.py b/model_nodes/node_if_models.py index c8bd360..5cfa218 100644 --- a/model_nodes/node_if_models.py +++ b/model_nodes/node_if_models.py @@ -23,8 +23,6 @@ class IfNodeCoreSchemaData(BaseModel): """ Pydantic модель для данных портов узла if """ - then_port_number: Optional[int] = Field(default=0, description="Номер порта для перехода по Связи Then (LINK)") - else_port_number: Optional[int] = Field(default=1, description="Номер порта для перехода по Связи Else (LINK)") class IfNodeCoreSchema(BaseModel): diff --git a/model_nodes/node_listen_models.py b/model_nodes/node_listen_models.py index 8eb3ae6..23b835e 100644 --- a/model_nodes/node_listen_models.py +++ b/model_nodes/node_listen_models.py @@ -22,9 +22,9 @@ class ListenNodeLinks(BaseModel): class ListenNodeCoreSchemaData(BaseModel): """ - Pydantic модель для данных портов узла listen + Pydantic модель для """ - then_port_number: Optional[int] = Field(default=0, description="Номер порта для перехода по Связи Then (LINK)") + is_start: bool = Field(default=False, description="Является ли узел стартовым") diff --git a/model_nodes/node_run_models.py b/model_nodes/node_run_models.py index 0738fe7..949ccd2 100644 --- a/model_nodes/node_run_models.py +++ b/model_nodes/node_run_models.py @@ -23,7 +23,7 @@ class RunNodeCoreSchemaData(BaseModel): """ Pydantic модель для данных портов узла run """ - then_port_number: Optional[int] = Field(default=0, description="Номер порта для перехода по Связи Then (LINK)") + class RunNodeCoreSchema(BaseModel): diff --git a/model_nodes/node_set_models.py b/model_nodes/node_set_models.py index 7bd1473..6147629 100644 --- a/model_nodes/node_set_models.py +++ b/model_nodes/node_set_models.py @@ -23,7 +23,7 @@ class SetNodeCoreSchemaData(BaseModel): """ Pydantic модель для данных портов узла set """ - then_port_number: Optional[int] = Field(default=0, description="Номер порта для перехода по Связи then (LINK)") + class SetNodeCoreSchema(BaseModel): diff --git a/model_nodes/node_switch_models.py b/model_nodes/node_switch_models.py index 7d4e8c2..3ecf246 100644 --- a/model_nodes/node_switch_models.py +++ b/model_nodes/node_switch_models.py @@ -23,8 +23,7 @@ class SwitchNodeCoreSchemaData(BaseModel): """ Pydantic модель для данных портов узла switch """ - default_port_number: Optional[int] = Field(default=0, description="Номер порта для перехода по Связи default (LINK)") - case_1_port_number: Optional[int] = Field(default=1, description="Номер порта для перехода по Связи case_1 (LINK)") + class SwitchNodeCoreSchema(BaseModel): diff --git a/model_nodes/node_test_models.py b/model_nodes/node_test_models.py index f50b87e..04398f1 100644 --- a/model_nodes/node_test_models.py +++ b/model_nodes/node_test_models.py @@ -21,7 +21,7 @@ class TestNodeCoreSchemaData(BaseModel): """ Pydantic модель для данных портов узла test """ - node_port_number: Optional[int] = Field(default=0, description="Номер порта для перехода по Связи Then (LINK)") + class TestNodeCoreSchema(BaseModel): diff --git a/model_nodes/node_trigger_models.py b/model_nodes/node_trigger_models.py index 7814e1b..546be18 100644 --- a/model_nodes/node_trigger_models.py +++ b/model_nodes/node_trigger_models.py @@ -23,7 +23,7 @@ class TriggerNodeCoreSchemaData(BaseModel): """ Pydantic модель для данных портов узла trigger """ - then_port_number: Optional[int] = Field(default=0, description="Номер порта для перехода по Связи Then (LINK)") + class TriggerNodeCoreSchema(BaseModel): diff --git a/model_nodes/node_wait_models.py b/model_nodes/node_wait_models.py index 352f5c7..210602c 100644 --- a/model_nodes/node_wait_models.py +++ b/model_nodes/node_wait_models.py @@ -23,7 +23,7 @@ class WaitNodeCoreSchemaData(BaseModel): """ Pydantic модель для данных портов узла wait """ - then_port_number: Optional[int] = Field(default=0, description="Номер порта для перехода по Связи then (LINK)") + class WaitNodeCoreSchema(BaseModel): diff --git a/model_nodes/node_while_models.py b/model_nodes/node_while_models.py index b4bcd6c..d8f0f93 100644 --- a/model_nodes/node_while_models.py +++ b/model_nodes/node_while_models.py @@ -23,8 +23,7 @@ class WhileNodeCoreSchemaData(BaseModel): """ Pydantic модель для данных портов узла while """ - then_port_number: Optional[int] = Field(default=0, description="Номер порта для перехода по Связи Then (LINK)") - else_port_number: Optional[int] = Field(default=1, description="Номер порта для перехода по Связи Else (LINK)") + class WhileNodeCoreSchema(BaseModel): diff --git a/nodes/vork_node_callback.py b/nodes/vork_node_callback.py index a1f12bd..5ca1f9e 100644 --- a/nodes/vork_node_callback.py +++ b/nodes/vork_node_callback.py @@ -33,17 +33,13 @@ class VorkNodeCallback(VorkNode): Валидирует данные узла callback и возвращает схему """ try: - # Валидируем данные узла + validated_data = self.validate_data() - # Валидируем связи узла validated_links = self.validate_links() - node_data = CallbackNodeCoreSchemaData( - then_port_number=0 - ) + node_data = None - # Создаем схему с валидированными данными return CallbackNodeCoreSchema( ps_id=validated_data.ps_id, node_type=validated_data.node_type, diff --git a/nodes/vork_node_each.py b/nodes/vork_node_each.py index 283dd30..88dc669 100644 --- a/nodes/vork_node_each.py +++ b/nodes/vork_node_each.py @@ -33,19 +33,12 @@ class VorkNodeEach(VorkNode): Валидирует данные узла each и возвращает схему """ try: - # Валидируем данные узла validated_data = self.validate_data() - # Валидируем связи узла validated_links = self.validate_links() - # Создаем данные портов (аналогично if) - node_data = EachNodeCoreSchemaData( - then_port_number=0, - else_port_number=1, - ) + node_data = None - # Создаем схему с валидированными данными return EachNodeCoreSchema( ps_id=validated_data.ps_id, node_type=validated_data.node_type, diff --git a/nodes/vork_node_if.py b/nodes/vork_node_if.py index a0fef48..976dc7f 100644 --- a/nodes/vork_node_if.py +++ b/nodes/vork_node_if.py @@ -28,19 +28,12 @@ class VorkNodeIf(VorkNode): и возвращает схему с валидированными данными. """ try: - # Валидируем данные validated_data = self.validate_data() - # Валидируем связи validated_links = self.validate_links() - # Создаем вложенную схему с данными портов - node_data = IfNodeCoreSchemaData( - then_port_number=0, - else_port_number=1, - ) + node_data = None - # Создаем схему с валидированными данными из экземпляра return IfNodeCoreSchema( ps_id=validated_data.ps_id, node_type=validated_data.node_type, diff --git a/nodes/vork_node_listen.py b/nodes/vork_node_listen.py index 9dad076..4dbce87 100644 --- a/nodes/vork_node_listen.py +++ b/nodes/vork_node_listen.py @@ -33,18 +33,14 @@ class VorkNodeListen(VorkNode): Валидирует данные узла listen и возвращает схему """ try: - # Валидируем данные узла validated_data = self.validate_data() - # Валидируем связи узла validated_links = self.validate_links() node_data = ListenNodeCoreSchemaData( - then_port_number=0, is_start=validated_data.is_start ) - # Создаем схему с валидированными данными return ListenNodeCoreSchema( ps_id=validated_data.ps_id, node_type=validated_data.node_type, diff --git a/nodes/vork_node_run.py b/nodes/vork_node_run.py index ba5b056..b11f19d 100644 --- a/nodes/vork_node_run.py +++ b/nodes/vork_node_run.py @@ -33,17 +33,13 @@ class VorkNodeRun(VorkNode): Валидирует данные узла run и возвращает схему """ try: - # Валидируем данные узла + validated_data = self.validate_data() - # Валидируем связи узла validated_links = self.validate_links() - node_data = RunNodeCoreSchemaData( - then_port_number=0 - ) + node_data = None - # Создаем схему с валидированными данными return RunNodeCoreSchema( ps_id=validated_data.ps_id, node_type=validated_data.node_type, diff --git a/nodes/vork_node_set.py b/nodes/vork_node_set.py index 2ab7530..b6e70f7 100644 --- a/nodes/vork_node_set.py +++ b/nodes/vork_node_set.py @@ -33,18 +33,13 @@ class VorkNodeSet(VorkNode): Валидирует данные узла set и возвращает схему """ try: - # Валидируем данные узла + validated_data = self.validate_data() - # Валидируем связи узла validated_links = self.validate_links() - # Создаем данные портов - node_data = SetNodeCoreSchemaData( - then_port_number=0, - ) + node_data = None - # Создаем схему с валидированными данными return SetNodeCoreSchema( ps_id=validated_data.ps_id, node_type=validated_data.node_type, diff --git a/nodes/vork_node_switch.py b/nodes/vork_node_switch.py index 0aa8e66..5200be7 100644 --- a/nodes/vork_node_switch.py +++ b/nodes/vork_node_switch.py @@ -40,10 +40,7 @@ class VorkNodeSwitch(VorkNode): validated_links = self.validate_links() # Создаем данные портов (default=0, case_1=1) - node_data = SwitchNodeCoreSchemaData( - default_port_number=0, - case_1_port_number=1, - ) + node_data = None # Создаем схему с валидированными данными return SwitchNodeCoreSchema( diff --git a/nodes/vork_node_trigger.py b/nodes/vork_node_trigger.py index 2f8504d..581c72b 100644 --- a/nodes/vork_node_trigger.py +++ b/nodes/vork_node_trigger.py @@ -33,17 +33,12 @@ class VorkNodeTrigger(VorkNode): Валидирует данные узла trigger и возвращает схему """ try: - # Валидируем данные узла validated_data = self.validate_data() - # Валидируем связи узла validated_links = self.validate_links() - node_data = TriggerNodeCoreSchemaData( - then_port_number=0 - ) + node_data = None - # Создаем схему с валидированными данными return TriggerNodeCoreSchema( ps_id=validated_data.ps_id, node_type=validated_data.node_type, diff --git a/nodes/vork_node_wait.py b/nodes/vork_node_wait.py index 20fab2c..404fe63 100644 --- a/nodes/vork_node_wait.py +++ b/nodes/vork_node_wait.py @@ -33,18 +33,12 @@ class VorkNodeWait(VorkNode): Валидирует данные узла wait и возвращает схему """ try: - # Валидируем данные узла validated_data = self.validate_data() - # Валидируем связи узла validated_links = self.validate_links() - # Создаем данные портов - node_data = WaitNodeCoreSchemaData( - then_port_number=0, - ) + node_data = None - # Создаем схему с валидированными данными return WaitNodeCoreSchema( ps_id=validated_data.ps_id, node_type=validated_data.node_type, diff --git a/nodes/vork_node_while.py b/nodes/vork_node_while.py index a327d97..b015a99 100644 --- a/nodes/vork_node_while.py +++ b/nodes/vork_node_while.py @@ -33,19 +33,13 @@ class VorkNodeWhile(VorkNode): Валидирует данные узла while и возвращает схему """ try: - # Валидируем данные узла + validated_data = self.validate_data() - # Валидируем связи узла validated_links = self.validate_links() - # Создаем данные портов (аналогично if) - node_data = WhileNodeCoreSchemaData( - then_port_number=0, - else_port_number=1, - ) + node_data = None - # Создаем схему с валидированными данными return WhileNodeCoreSchema( ps_id=validated_data.ps_id, node_type=validated_data.node_type,