Dev: ui_corosync: add subcommand 'crm corosync link add' (jsc#PED-8083)

crmsh/ui_corosync.py

@@ -166,6 +166,30 @@ def do_update(self, context, *argv):
         logger.info("Use \"crm corosync diff\" to show the difference")
         logger.info("Use \"crm corosync push\" to sync")
 
+    def do_add(self, context, *argv):
+        lm = corosync.LinkManager.load_config_file()
+        if lm.totem_transport() != 'knet':
+            logger.error('Corosync is not using knet transport')
+            return False
+        try:
+            args = LinkArgumentParser().parse(argv)
+        except LinkArgumentParser.SyntaxException as e:
+            logger.error('%s', str(e))
+            print('Usage: link add <linknumber> <node>=<addr> ... [options <option>=<value> ...] ', file=sys.stderr)
+            return False
+        nodes = lm.links()[args.linknumber].nodes
+        node_addresses: dict[int, str] = dict()
+        for name, addr in args.nodes:
+            nodeid = next((x.nodeid for x in nodes if x.name == name), -1)
+            if nodeid == -1:
+                logger.error(f'Unknown node {name}.')
+            node_addresses[nodeid] = addr
+        lm.write_config_file(
+            lm.add_link(node_addresses, args.options)
+        )
+        logger.info("Use \"crm corosync diff\" to show the difference")
+        logger.info("Use \"crm corosync push\" to sync")
+
     def do_remove(self, context, linknumber: str):
         if not linknumber.isdecimal():
             raise ValueError(f'Invalid linknumber: {linknumber}')