feat: delete ports
This commit is contained in:
@@ -23,7 +23,6 @@ class CallbackNodeCoreSchemaData(BaseModel):
|
|||||||
"""
|
"""
|
||||||
Pydantic модель для данных портов узла callback
|
Pydantic модель для данных портов узла callback
|
||||||
"""
|
"""
|
||||||
then_port_number: Optional[int] = Field(default=0, description="Номер порта для перехода по Связи Then (LINK)")
|
|
||||||
|
|
||||||
|
|
||||||
class CallbackNodeCoreSchema(BaseModel):
|
class CallbackNodeCoreSchema(BaseModel):
|
||||||
|
|||||||
@@ -23,8 +23,6 @@ class EachNodeCoreSchemaData(BaseModel):
|
|||||||
"""
|
"""
|
||||||
Pydantic модель для данных портов узла each
|
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):
|
class EachNodeCoreSchema(BaseModel):
|
||||||
|
|||||||
@@ -23,8 +23,6 @@ class IfNodeCoreSchemaData(BaseModel):
|
|||||||
"""
|
"""
|
||||||
Pydantic модель для данных портов узла if
|
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):
|
class IfNodeCoreSchema(BaseModel):
|
||||||
|
|||||||
@@ -22,9 +22,9 @@ class ListenNodeLinks(BaseModel):
|
|||||||
|
|
||||||
class ListenNodeCoreSchemaData(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="Является ли узел стартовым")
|
is_start: bool = Field(default=False, description="Является ли узел стартовым")
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -23,7 +23,7 @@ class RunNodeCoreSchemaData(BaseModel):
|
|||||||
"""
|
"""
|
||||||
Pydantic модель для данных портов узла run
|
Pydantic модель для данных портов узла run
|
||||||
"""
|
"""
|
||||||
then_port_number: Optional[int] = Field(default=0, description="Номер порта для перехода по Связи Then (LINK)")
|
|
||||||
|
|
||||||
|
|
||||||
class RunNodeCoreSchema(BaseModel):
|
class RunNodeCoreSchema(BaseModel):
|
||||||
|
|||||||
@@ -23,7 +23,7 @@ class SetNodeCoreSchemaData(BaseModel):
|
|||||||
"""
|
"""
|
||||||
Pydantic модель для данных портов узла set
|
Pydantic модель для данных портов узла set
|
||||||
"""
|
"""
|
||||||
then_port_number: Optional[int] = Field(default=0, description="Номер порта для перехода по Связи then (LINK)")
|
|
||||||
|
|
||||||
|
|
||||||
class SetNodeCoreSchema(BaseModel):
|
class SetNodeCoreSchema(BaseModel):
|
||||||
|
|||||||
@@ -23,8 +23,7 @@ class SwitchNodeCoreSchemaData(BaseModel):
|
|||||||
"""
|
"""
|
||||||
Pydantic модель для данных портов узла switch
|
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):
|
class SwitchNodeCoreSchema(BaseModel):
|
||||||
|
|||||||
@@ -21,7 +21,7 @@ class TestNodeCoreSchemaData(BaseModel):
|
|||||||
"""
|
"""
|
||||||
Pydantic модель для данных портов узла test
|
Pydantic модель для данных портов узла test
|
||||||
"""
|
"""
|
||||||
node_port_number: Optional[int] = Field(default=0, description="Номер порта для перехода по Связи Then (LINK)")
|
|
||||||
|
|
||||||
|
|
||||||
class TestNodeCoreSchema(BaseModel):
|
class TestNodeCoreSchema(BaseModel):
|
||||||
|
|||||||
@@ -23,7 +23,7 @@ class TriggerNodeCoreSchemaData(BaseModel):
|
|||||||
"""
|
"""
|
||||||
Pydantic модель для данных портов узла trigger
|
Pydantic модель для данных портов узла trigger
|
||||||
"""
|
"""
|
||||||
then_port_number: Optional[int] = Field(default=0, description="Номер порта для перехода по Связи Then (LINK)")
|
|
||||||
|
|
||||||
|
|
||||||
class TriggerNodeCoreSchema(BaseModel):
|
class TriggerNodeCoreSchema(BaseModel):
|
||||||
|
|||||||
@@ -23,7 +23,7 @@ class WaitNodeCoreSchemaData(BaseModel):
|
|||||||
"""
|
"""
|
||||||
Pydantic модель для данных портов узла wait
|
Pydantic модель для данных портов узла wait
|
||||||
"""
|
"""
|
||||||
then_port_number: Optional[int] = Field(default=0, description="Номер порта для перехода по Связи then (LINK)")
|
|
||||||
|
|
||||||
|
|
||||||
class WaitNodeCoreSchema(BaseModel):
|
class WaitNodeCoreSchema(BaseModel):
|
||||||
|
|||||||
@@ -23,8 +23,7 @@ class WhileNodeCoreSchemaData(BaseModel):
|
|||||||
"""
|
"""
|
||||||
Pydantic модель для данных портов узла while
|
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):
|
class WhileNodeCoreSchema(BaseModel):
|
||||||
|
|||||||
@@ -33,17 +33,13 @@ class VorkNodeCallback(VorkNode):
|
|||||||
Валидирует данные узла callback и возвращает схему
|
Валидирует данные узла callback и возвращает схему
|
||||||
"""
|
"""
|
||||||
try:
|
try:
|
||||||
# Валидируем данные узла
|
|
||||||
validated_data = self.validate_data()
|
validated_data = self.validate_data()
|
||||||
|
|
||||||
# Валидируем связи узла
|
|
||||||
validated_links = self.validate_links()
|
validated_links = self.validate_links()
|
||||||
|
|
||||||
node_data = CallbackNodeCoreSchemaData(
|
node_data = None
|
||||||
then_port_number=0
|
|
||||||
)
|
|
||||||
|
|
||||||
# Создаем схему с валидированными данными
|
|
||||||
return CallbackNodeCoreSchema(
|
return CallbackNodeCoreSchema(
|
||||||
ps_id=validated_data.ps_id,
|
ps_id=validated_data.ps_id,
|
||||||
node_type=validated_data.node_type,
|
node_type=validated_data.node_type,
|
||||||
|
|||||||
@@ -33,19 +33,12 @@ class VorkNodeEach(VorkNode):
|
|||||||
Валидирует данные узла each и возвращает схему
|
Валидирует данные узла each и возвращает схему
|
||||||
"""
|
"""
|
||||||
try:
|
try:
|
||||||
# Валидируем данные узла
|
|
||||||
validated_data = self.validate_data()
|
validated_data = self.validate_data()
|
||||||
|
|
||||||
# Валидируем связи узла
|
|
||||||
validated_links = self.validate_links()
|
validated_links = self.validate_links()
|
||||||
|
|
||||||
# Создаем данные портов (аналогично if)
|
node_data = None
|
||||||
node_data = EachNodeCoreSchemaData(
|
|
||||||
then_port_number=0,
|
|
||||||
else_port_number=1,
|
|
||||||
)
|
|
||||||
|
|
||||||
# Создаем схему с валидированными данными
|
|
||||||
return EachNodeCoreSchema(
|
return EachNodeCoreSchema(
|
||||||
ps_id=validated_data.ps_id,
|
ps_id=validated_data.ps_id,
|
||||||
node_type=validated_data.node_type,
|
node_type=validated_data.node_type,
|
||||||
|
|||||||
@@ -28,19 +28,12 @@ class VorkNodeIf(VorkNode):
|
|||||||
и возвращает схему с валидированными данными.
|
и возвращает схему с валидированными данными.
|
||||||
"""
|
"""
|
||||||
try:
|
try:
|
||||||
# Валидируем данные
|
|
||||||
validated_data = self.validate_data()
|
validated_data = self.validate_data()
|
||||||
|
|
||||||
# Валидируем связи
|
|
||||||
validated_links = self.validate_links()
|
validated_links = self.validate_links()
|
||||||
|
|
||||||
# Создаем вложенную схему с данными портов
|
node_data = None
|
||||||
node_data = IfNodeCoreSchemaData(
|
|
||||||
then_port_number=0,
|
|
||||||
else_port_number=1,
|
|
||||||
)
|
|
||||||
|
|
||||||
# Создаем схему с валидированными данными из экземпляра
|
|
||||||
return IfNodeCoreSchema(
|
return IfNodeCoreSchema(
|
||||||
ps_id=validated_data.ps_id,
|
ps_id=validated_data.ps_id,
|
||||||
node_type=validated_data.node_type,
|
node_type=validated_data.node_type,
|
||||||
|
|||||||
@@ -33,18 +33,14 @@ class VorkNodeListen(VorkNode):
|
|||||||
Валидирует данные узла listen и возвращает схему
|
Валидирует данные узла listen и возвращает схему
|
||||||
"""
|
"""
|
||||||
try:
|
try:
|
||||||
# Валидируем данные узла
|
|
||||||
validated_data = self.validate_data()
|
validated_data = self.validate_data()
|
||||||
|
|
||||||
# Валидируем связи узла
|
|
||||||
validated_links = self.validate_links()
|
validated_links = self.validate_links()
|
||||||
|
|
||||||
node_data = ListenNodeCoreSchemaData(
|
node_data = ListenNodeCoreSchemaData(
|
||||||
then_port_number=0,
|
|
||||||
is_start=validated_data.is_start
|
is_start=validated_data.is_start
|
||||||
)
|
)
|
||||||
|
|
||||||
# Создаем схему с валидированными данными
|
|
||||||
return ListenNodeCoreSchema(
|
return ListenNodeCoreSchema(
|
||||||
ps_id=validated_data.ps_id,
|
ps_id=validated_data.ps_id,
|
||||||
node_type=validated_data.node_type,
|
node_type=validated_data.node_type,
|
||||||
|
|||||||
@@ -33,17 +33,13 @@ class VorkNodeRun(VorkNode):
|
|||||||
Валидирует данные узла run и возвращает схему
|
Валидирует данные узла run и возвращает схему
|
||||||
"""
|
"""
|
||||||
try:
|
try:
|
||||||
# Валидируем данные узла
|
|
||||||
validated_data = self.validate_data()
|
validated_data = self.validate_data()
|
||||||
|
|
||||||
# Валидируем связи узла
|
|
||||||
validated_links = self.validate_links()
|
validated_links = self.validate_links()
|
||||||
|
|
||||||
node_data = RunNodeCoreSchemaData(
|
node_data = None
|
||||||
then_port_number=0
|
|
||||||
)
|
|
||||||
|
|
||||||
# Создаем схему с валидированными данными
|
|
||||||
return RunNodeCoreSchema(
|
return RunNodeCoreSchema(
|
||||||
ps_id=validated_data.ps_id,
|
ps_id=validated_data.ps_id,
|
||||||
node_type=validated_data.node_type,
|
node_type=validated_data.node_type,
|
||||||
|
|||||||
@@ -33,18 +33,13 @@ class VorkNodeSet(VorkNode):
|
|||||||
Валидирует данные узла set и возвращает схему
|
Валидирует данные узла set и возвращает схему
|
||||||
"""
|
"""
|
||||||
try:
|
try:
|
||||||
# Валидируем данные узла
|
|
||||||
validated_data = self.validate_data()
|
validated_data = self.validate_data()
|
||||||
|
|
||||||
# Валидируем связи узла
|
|
||||||
validated_links = self.validate_links()
|
validated_links = self.validate_links()
|
||||||
|
|
||||||
# Создаем данные портов
|
node_data = None
|
||||||
node_data = SetNodeCoreSchemaData(
|
|
||||||
then_port_number=0,
|
|
||||||
)
|
|
||||||
|
|
||||||
# Создаем схему с валидированными данными
|
|
||||||
return SetNodeCoreSchema(
|
return SetNodeCoreSchema(
|
||||||
ps_id=validated_data.ps_id,
|
ps_id=validated_data.ps_id,
|
||||||
node_type=validated_data.node_type,
|
node_type=validated_data.node_type,
|
||||||
|
|||||||
@@ -40,10 +40,7 @@ class VorkNodeSwitch(VorkNode):
|
|||||||
validated_links = self.validate_links()
|
validated_links = self.validate_links()
|
||||||
|
|
||||||
# Создаем данные портов (default=0, case_1=1)
|
# Создаем данные портов (default=0, case_1=1)
|
||||||
node_data = SwitchNodeCoreSchemaData(
|
node_data = None
|
||||||
default_port_number=0,
|
|
||||||
case_1_port_number=1,
|
|
||||||
)
|
|
||||||
|
|
||||||
# Создаем схему с валидированными данными
|
# Создаем схему с валидированными данными
|
||||||
return SwitchNodeCoreSchema(
|
return SwitchNodeCoreSchema(
|
||||||
|
|||||||
@@ -33,17 +33,12 @@ class VorkNodeTrigger(VorkNode):
|
|||||||
Валидирует данные узла trigger и возвращает схему
|
Валидирует данные узла trigger и возвращает схему
|
||||||
"""
|
"""
|
||||||
try:
|
try:
|
||||||
# Валидируем данные узла
|
|
||||||
validated_data = self.validate_data()
|
validated_data = self.validate_data()
|
||||||
|
|
||||||
# Валидируем связи узла
|
|
||||||
validated_links = self.validate_links()
|
validated_links = self.validate_links()
|
||||||
|
|
||||||
node_data = TriggerNodeCoreSchemaData(
|
node_data = None
|
||||||
then_port_number=0
|
|
||||||
)
|
|
||||||
|
|
||||||
# Создаем схему с валидированными данными
|
|
||||||
return TriggerNodeCoreSchema(
|
return TriggerNodeCoreSchema(
|
||||||
ps_id=validated_data.ps_id,
|
ps_id=validated_data.ps_id,
|
||||||
node_type=validated_data.node_type,
|
node_type=validated_data.node_type,
|
||||||
|
|||||||
@@ -33,18 +33,12 @@ class VorkNodeWait(VorkNode):
|
|||||||
Валидирует данные узла wait и возвращает схему
|
Валидирует данные узла wait и возвращает схему
|
||||||
"""
|
"""
|
||||||
try:
|
try:
|
||||||
# Валидируем данные узла
|
|
||||||
validated_data = self.validate_data()
|
validated_data = self.validate_data()
|
||||||
|
|
||||||
# Валидируем связи узла
|
|
||||||
validated_links = self.validate_links()
|
validated_links = self.validate_links()
|
||||||
|
|
||||||
# Создаем данные портов
|
node_data = None
|
||||||
node_data = WaitNodeCoreSchemaData(
|
|
||||||
then_port_number=0,
|
|
||||||
)
|
|
||||||
|
|
||||||
# Создаем схему с валидированными данными
|
|
||||||
return WaitNodeCoreSchema(
|
return WaitNodeCoreSchema(
|
||||||
ps_id=validated_data.ps_id,
|
ps_id=validated_data.ps_id,
|
||||||
node_type=validated_data.node_type,
|
node_type=validated_data.node_type,
|
||||||
|
|||||||
@@ -33,19 +33,13 @@ class VorkNodeWhile(VorkNode):
|
|||||||
Валидирует данные узла while и возвращает схему
|
Валидирует данные узла while и возвращает схему
|
||||||
"""
|
"""
|
||||||
try:
|
try:
|
||||||
# Валидируем данные узла
|
|
||||||
validated_data = self.validate_data()
|
validated_data = self.validate_data()
|
||||||
|
|
||||||
# Валидируем связи узла
|
|
||||||
validated_links = self.validate_links()
|
validated_links = self.validate_links()
|
||||||
|
|
||||||
# Создаем данные портов (аналогично if)
|
node_data = None
|
||||||
node_data = WhileNodeCoreSchemaData(
|
|
||||||
then_port_number=0,
|
|
||||||
else_port_number=1,
|
|
||||||
)
|
|
||||||
|
|
||||||
# Создаем схему с валидированными данными
|
|
||||||
return WhileNodeCoreSchema(
|
return WhileNodeCoreSchema(
|
||||||
ps_id=validated_data.ps_id,
|
ps_id=validated_data.ps_id,
|
||||||
node_type=validated_data.node_type,
|
node_type=validated_data.node_type,
|
||||||
|
|||||||
Reference in New Issue
Block a user