revil-O/platypush
1
0
Fork 0
forked from platypush/platypush
Code Pull requests Activity

Merge branch '341/procedure-entities' into 341/procedure-entities-ui

Browse source
This commit is contained in:
Fabio Manganiello 2024-09-12 02:16:32 +02:00
commit c4610254f8
Signed by untrusted user: blacklight
GPG key ID: D90FBA7F76362774
1 changed files with 10 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
platypush/procedure/__init__.py
View file

@ -5,7 +5,7 @@ from dataclasses import dataclass
from functools import wraps
from queue import LifoQueue
from typing import Any, Optional
from typing import Any, List, Optional
from ..common import exec_wrapper
from ..config import Config
@ -110,6 +110,7 @@ class Procedure:
for request_config in requests:
# Check if it's a break/continue/return statement
if isinstance(request_config, str):
cls._flush_if_statements(reqs, if_config)
reqs.append(Statement.build(request_config))
continue
@ -118,6 +119,7 @@ class Procedure:
len(request_config.keys()) == 1
and list(request_config.keys())[0] == 'return'
):
cls._flush_if_statements(reqs, if_config)
reqs.append(ReturnStatement(argument=request_config['return']))
continue
@ -214,9 +216,7 @@ class Procedure:
request = Request.build(request_config)
reqs.append(request)
while not if_config.empty():
pending_if = if_config.get()
reqs.append(IfProcedure.build(**pending_if))
cls._flush_if_statements(reqs, if_config)
return procedure_class(
name=name,
@ -227,6 +227,12 @@ class Procedure:
**kwargs,
)
@staticmethod
def _flush_if_statements(requests: List, if_config: LifoQueue):
while not if_config.empty():
pending_if = if_config.get()
requests.append(IfProcedure.build(**pending_if))
@staticmethod
def _find_nearest_loop(stack):
for proc in stack[::-1]: