[procedures] Recursive serialization in procedures.to_yaml.

platypush/plugins/procedures/__init__.py

@@ -4,7 +4,16 @@ from contextlib import contextmanager
 from dataclasses import dataclass
 from multiprocessing import RLock
 from random import randint
-from typing import Callable, Collection, Generator, Iterable, Optional, Union
+from typing import (
+    Callable,
+    Collection,
+    Dict,
+    Generator,
+    Iterable,
+    List,
+    Optional,
+    Union,
+)
 
 import yaml
 from sqlalchemy.orm import Session
@@ -263,11 +272,7 @@ class ProceduresPlugin(RunnablePlugin, ProcedureEntityManager):
             proc = {
                 f'procedure.{name}'
                 + (f'({", ".join(args)})' if args else ''): [
-                    {
+                    self._serialize_action(action) for action in actions
-                        'action': action['action'],
-                        **({'args': action['args']} if action.get('args') else {}),
-                    }
-                    for action in actions
                 ]
             }
         else:
@@ -281,6 +286,26 @@ class ProceduresPlugin(RunnablePlugin, ProcedureEntityManager):
     def _normalize_name(name: Optional[str]) -> str:
         return re.sub(r'[^\w.]+', '_', (name or '').strip(' .'))
 
+    @classmethod
+    def _serialize_action(cls, data: Union[Iterable, Dict]) -> Union[Dict, List]:
+        if isinstance(data, dict):
+            if data.get('action'):
+                return {
+                    'action': data['action'],
+                    **({'args': data['args']} if data.get('args') else {}),
+                }
+
+            return {
+                k: (
+                    cls._serialize_action(v)
+                    if isinstance(v, (dict, list, tuple))
+                    else v
+                )
+                for k, v in data.items()
+            }
+        else:
+            return [cls._serialize_action(item) for item in data if item is not None]
+
     @contextmanager
     def _db_session(self) -> Generator[Session, None, None]:
         db: Optional[DbPlugin] = get_plugin(DbPlugin)