app controller config parsing

Author: polymerizedsage

synapse-api

@@ -8,6 +8,7 @@
 from synapse.client.nodes.stream_in import StreamIn
 from synapse.client.nodes.stream_out import StreamOut
 from synapse.client.nodes.disk_writer import DiskWriter
+from synapse.client.nodes.application_node import ApplicationNode
 
 from synapse.api.node_pb2 import NodeType
 
@@ -22,4 +23,5 @@
     NodeType.kSpikeSource: SpikeSource,
     NodeType.kStreamIn: StreamIn,
     NodeType.kStreamOut: StreamOut,
+    NodeType.kApplication: ApplicationNode,
 }

synapse/client/nodes/__init__.py

@@ -0,0 +1,25 @@
+from synapse.api.node_pb2 import NodeConfig, NodeType
+from synapse.api.nodes.application_pb2 import ApplicationNodeConfig
+from synapse.client.node import Node
+
+
+class ApplicationNode(Node):
+    type = NodeType.kApplication
+
+    def __init__(self, name: str):
+        self.name = name
+
+    def _to_proto(self):
+        n = NodeConfig()
+        p = ApplicationNodeConfig(name=self.name)
+        n.application.CopyFrom(p)
+        return n
+
+    @staticmethod
+    def _from_proto(proto: ApplicationNodeConfig):
+        if not proto:
+            raise ValueError("parameter 'proto' is missing")
+        if not isinstance(proto, ApplicationNodeConfig):
+            raise ValueError("proto is not of type ApplicationNodeConfig")
+
+        return ApplicationNode(name=proto.name)