lndmanaged: implement lndmanage daemon

lndmanage/grpc_compiled/build_grpc.sh

@@ -15,6 +15,7 @@ python -m grpc_tools.protoc --proto_path=googleapis:. --python_out=. --grpc_pyth
 python -m grpc_tools.protoc --proto_path=googleapis:. --python_out=. --grpc_python_out=. router.proto
 python -m grpc_tools.protoc --proto_path=googleapis:. --python_out=. --grpc_python_out=. walletkit.proto
 python -m grpc_tools.protoc --proto_path=googleapis:. --python_out=. --grpc_python_out=. signer.proto
+python -m grpc_tools.protoc --proto_path=googleapis:. --python_out=. --grpc_python_out=. manager.proto
 
 # fix import paths
 sed -i -- 's@import lightning_pb2 as lightning__pb2@from lndmanage.grpc_compiled import lightning_pb2 as lightning__pb2@' lightning_pb2_grpc.py
@@ -30,3 +31,5 @@ sed -i -- 's@import signer_pb2 as signer__pb2@from lndmanage.grpc_compiled impor
 
 sed -i -- 's@import signer_pb2 as signer__pb2@from lndmanage.grpc_compiled import signer_pb2 as signer__pb2@' walletkit_pb2_grpc.py
 sed -i -- 's@import walletkit_pb2 as walletkit__pb2@from lndmanage.grpc_compiled import walletkit_pb2 as walletkit__pb2@' walletkit_pb2_grpc.py
+
+sed -i -- 's@import manager_pb2 as manager__pb2@from lndmanage.grpc_compiled import manager_pb2 as manager__pb2@' manager_pb2_grpc.py

lndmanage/grpc_compiled/manager.proto

@@ -0,0 +1,25 @@
+syntax = "proto3";
+
+option objc_class_prefix = "MNG";
+
+package managerpc;
+
+// blah.
+service Mangager {
+  // blah.
+  rpc RunningServices(RunningServicesRequest) returns (RunningServicesResponse) {}
+}
+
+// blah.
+message RunningServicesRequest {
+}
+
+// blah.
+message RunningServicesResponse {
+    repeated RunningService services = 1;
+}
+
+// blah.
+message RunningService {
+    string name = 1;
+}

lndmanage/grpc_compiled/manager_pb2_grpc.py

@@ -0,0 +1,70 @@
+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
+import grpc
+
+from lndmanage.grpc_compiled import manager_pb2 as manager__pb2
+
+
+class MangagerStub(object):
+    """blah.
+    """
+
+    def __init__(self, channel):
+        """Constructor.
+
+        Args:
+            channel: A grpc.Channel.
+        """
+        self.RunningServices = channel.unary_unary(
+                '/managerpc.Mangager/RunningServices',
+                request_serializer=manager__pb2.RunningServicesRequest.SerializeToString,
+                response_deserializer=manager__pb2.RunningServicesResponse.FromString,
+                )
+
+
+class MangagerServicer(object):
+    """blah.
+    """
+
+    def RunningServices(self, request, context):
+        """blah.
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+
+def add_MangagerServicer_to_server(servicer, server):
+    rpc_method_handlers = {
+            'RunningServices': grpc.unary_unary_rpc_method_handler(
+                    servicer.RunningServices,
+                    request_deserializer=manager__pb2.RunningServicesRequest.FromString,
+                    response_serializer=manager__pb2.RunningServicesResponse.SerializeToString,
+            ),
+    }
+    generic_handler = grpc.method_handlers_generic_handler(
+            'managerpc.Mangager', rpc_method_handlers)
+    server.add_generic_rpc_handlers((generic_handler,))
+
+
+ # This class is part of an EXPERIMENTAL API.
+class Mangager(object):
+    """blah.
+    """
+
+    @staticmethod
+    def RunningServices(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/managerpc.Mangager/RunningServices',
+            manager__pb2.RunningServicesRequest.SerializeToString,
+            manager__pb2.RunningServicesResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)