Spawn remotesigner instances for integration tests (#24)

* Made the integration tests spawn remotesigner instances for each lightningd.

* fixes to make infrastructure more reliable

Author: ksedgwic

Makefile

@@ -393,6 +393,10 @@ else
 PYTEST_OPTS += -x
 endif
 
+ifneq ($(PYTEST_MOREOPTS),)
+PYTEST_OPTS += $(PYTEST_MOREOPTS)
+endif
+
 check-units:
 
 check: check-units installcheck check-protos pytest

contrib/pyln-testing/pyln/testing/utils.py

@@ -514,6 +514,33 @@ def getnewaddress(self):
         info = self.rpc.getaddressinfo(addr)
         return info['unconfidential']
 
+class RemoteSignerD(TailableProc):
+    def __init__(self, rsignerd_dir, rsignerd_port):
+        TailableProc.__init__(self, rsignerd_dir)
+        self.executable = env("REMOTE_SIGNER_CMD", 'rsignerd')
+        self.opts = [
+            '--datadir={}'.format(rsignerd_dir),
+            '--port={}'.format(rsignerd_port),
+        ]
+        self.prefix = 'rsignerd'
+        self.rsignerd_port = rsignerd_port
+
+    @property
+    def cmd_line(self):
+        return [self.executable] + self.opts
+
+    def start(self, stdin=None, stdout=None, stderr=None,
+              wait_for_initialized=True):
+        TailableProc.start(self, stdin, stdout, stderr)
+        # We need to always wait for initialization
+        self.wait_for_log("rsignerd [0-9]* ready on .*:{}".format(self.rsignerd_port))
+        logging.info("rsignerd started")
+
+    def stop(self, timeout=10):
+        logging.info("stopping rsignerd")
+        rc = TailableProc.stop(self, timeout)
+        logging.info("rsignerd stopped")
+        return rc
 
 class LightningD(TailableProc):
     def __init__(self, lightning_dir, bitcoindproxy, port=9735, random_hsm=False, node_id=0):
@@ -523,7 +550,9 @@ def __init__(self, lightning_dir, bitcoindproxy, port=9735, random_hsm=False, no
         self.port = port
         self.cmd_prefix = []
         self.disconnect_file = None
-
+        self.lightning_dir = lightning_dir
+        self.rsignerd_dir = os.path.join(lightning_dir, "remotesigner")
+                
         self.rpcproxy = bitcoindproxy
 
         self.opts = LIGHTNINGD_CONFIG.copy()
@@ -550,6 +579,9 @@ def __init__(self, lightning_dir, bitcoindproxy, port=9735, random_hsm=False, no
         if not os.path.exists(os.path.join(lightning_dir, TEST_NETWORK)):
             os.makedirs(os.path.join(lightning_dir, TEST_NETWORK))
 
+        if not os.path.exists(self.rsignerd_dir):
+            os.makedirs(self.rsignerd_dir)
+
         # Last 32-bytes of final part of dir -> seed.
         seed = (bytes(re.search('([^/]+)/*$', lightning_dir).group(1), encoding='utf-8') + bytes(32))[:32]
         if not random_hsm:
@@ -561,6 +593,8 @@ def __init__(self, lightning_dir, bitcoindproxy, port=9735, random_hsm=False, no
         self.prefix = 'lightningd-%d' % (node_id)
 
     def cleanup(self):
+        # Make sure the remotesigner is shutdown
+        self.rsignerd.stop()
         # To force blackhole to exit, disconnect file must be truncated!
         if self.disconnect_file:
             with open(self.disconnect_file, "w") as f:
@@ -583,11 +617,34 @@ def cmd_line(self):
 
     def start(self, stdin=None, stdout=None, stderr=None,
               wait_for_initialized=True):
-        self.opts['bitcoin-rpcport'] = self.rpcproxy.rpcport
-        TailableProc.start(self, stdin, stdout, stderr)
-        if wait_for_initialized:
-            self.wait_for_log("Server started with public key")
-        logging.info("LightningD started")
+        try:
+            # Start the remote signer first
+            rsignerd_port = reserve()
+            self.rsignerd = RemoteSignerD(self.rsignerd_dir, rsignerd_port)
+            self.rsignerd.start(stdin, stdout, stderr, wait_for_initialized)
+
+            # We can't do this in the constructor because we need a new port on each restart.
+            self.env['REMOTE_HSMD_ENDPOINT'] = 'localhost:{}'.format(rsignerd_port)
+
+            self.opts['bitcoin-rpcport'] = self.rpcproxy.rpcport
+            TailableProc.start(self, stdin, stdout, stderr)
+            if wait_for_initialized:
+                self.wait_for_log("Server started with public key")
+            logging.info("LightningD started")
+        except:
+            # LightningD didn't start, stop the remotesigner
+            self.rsignerd.stop()
+            raise
+
+    def stop(self, timeout=10):
+        # Stop the remote signer first
+        self.rsignerd.stop(timeout)
+        return TailableProc.stop(self, timeout)
+
+    def kill(self):
+        # Kill the remote signer first
+        self.rsignerd.kill()
+        TailableProc.kill(self)
 
     def wait(self, timeout=10):
         """Wait for the daemon to stop for up to timeout seconds

contrib/remote_hsmd/proxy.cc

@@ -59,8 +59,9 @@ proxy_stat map_status(Status const & status)
 	// FIXME - this is bogus, but the pytest framework loses our
 	// status_unusual messages.
 	if (code != StatusCode::OK) {
-		cerr << "PROXY-HSMD grpc::StatusCode " << int(code)
-		     << ": " << status.error_message()
+		cerr << "PID: " << getpid() << ' '
+		     << "PROXY-HSMD grpc::StatusCode " << int(code)
+ 		     << ": " << status.error_message()
 		     << endl;
 	}
 	switch (code) {
@@ -317,7 +318,8 @@ void proxy_setup()
 {
 	const char *endpointvar = getenv("REMOTE_HSMD_ENDPOINT");
 	const char *endpoint = endpointvar != NULL ? endpointvar : "localhost:50051";
-	STATUS_DEBUG("%s:%d %s endpoint:%s", __FILE__, __LINE__, __FUNCTION__, endpoint);
+	STATUS_DEBUG("%s:%d %s pid:%d, endpoint:%s", __FILE__, __LINE__, __FUNCTION__,
+		     getpid(), endpoint);
 	auto channel = grpc::CreateChannel(endpoint,
 					   grpc::InsecureChannelCredentials());
 	stub = Signer::NewStub(channel);

contrib/remote_hsmd/scripts/run-all-tests

@@ -1,10 +1,14 @@
 #!/usr/bin/sh
 
+
+
 SUBDAEMON='hsmd:remote_hsmd' \
+REMOTE_SIGNER_CMD=$(pwd)/../rust-lightning-signer/target/debug/server \
 make \
-PYTEST_PAR=1 \
+-j32 PYTEST_PAR=64 \
 DEVELOPER=1 \
 VALGRIND=0 \
 SLOW_MACHINE=1 \
+PYTEST_MOREOPTS='--timeout=300 --timeout_method=thread' \
 pytest
 

contrib/remote_hsmd/scripts/run-one-test

@@ -11,6 +11,7 @@ DEVELOPER=1 \
 VALGRIND=0 \
 SLOW_MACHINE=1 \
 SUBDAEMON='hsmd:remote_hsmd' \
+REMOTE_SIGNER_CMD=$(pwd)/../rust-lightning-signer/target/debug/server \
 pytest \
 $THETEST \
--v --timeout=550 --timeout_method=thread -x
+-v --timeout=300 --timeout_method=thread -x