# HG changeset patch
# User Goffi <goffi@goffi.org>
# Date 1489443537 -3600
# Node ID e0e06391ce9188e5eb6928dfdb8d09f1ff73185b
# Parent  d3e48c9a255e4d44f430ba24f7ad2e7fb9f7e670
jp (pubsub): added pubsub/node/info command to retrieve node configuration

diff -r d3e48c9a255e -r e0e06391ce91 frontends/src/jp/cmd_pubsub.py
--- a/frontends/src/jp/cmd_pubsub.py	Mon Mar 13 23:18:00 2017 +0100
+++ b/frontends/src/jp/cmd_pubsub.py	Mon Mar 13 23:18:57 2017 +0100
@@ -25,6 +25,52 @@
 __commands__ = ["Pubsub"]
 
 
+class NodeInfo(base.CommandBase):
+
+    def __init__(self, host):
+        base.CommandBase.__init__(self, host, 'info', use_output=C.OUTPUT_DICT, help=_(u'retrieve node configuration'))
+        self.need_loop=True
+
+    def add_parser_options(self):
+        self.parser.add_argument("-k", "--key", type=base.unicode_decoder, action='append', dest='keys',
+                                 help=_(u"data key to filter"))
+        self.parser.add_argument("node", type=base.unicode_decoder, help=_(u"node to request"))
+        self.parser.add_argument("service", type=base.unicode_decoder, nargs='?', default=u'',
+                                 help=_(u"JID of the PubSub service (default: request profile own pubsub)"))
+
+    def removePrefix(self, key):
+        return key[7:] if key.startswith(u"pubsub#") else key
+
+    def filterKey(self, key):
+        return any((key == k or key == u'pubsub#' + k) for k in self.args.keys)
+
+    def psNodeConfigurationGetCb(self, config_dict):
+        key_filter = (lambda k: True) if not self.args.keys else self.filterKey
+        config_dict = {self.removePrefix(k):v for k,v in config_dict.iteritems() if key_filter(k)}
+        self.output(config_dict)
+        self.host.quit()
+
+    def psNodeConfigurationGetEb(self, failure_):
+        self.disp(u"can't get node configuration: {reason}".format(
+            reason=failure_), error=True)
+        self.host.quit(C.EXIT_BRIDGE_ERRBACK)
+
+    def start(self):
+        self.host.bridge.psNodeConfigurationGet(
+            self.args.service,
+            self.args.node,
+            self.profile,
+            callback=self.psNodeConfigurationGetCb,
+            errback=self.psNodeConfigurationGetEb)
+
+
+class Node(base.CommandBase):
+    subcommands = (NodeInfo,)
+
+    def __init__(self, host):
+        super(Node, self).__init__(host, 'node', use_profile=False, help=_('node handling'))
+
+
 class Get(base.CommandBase):
 
     def __init__(self, host):
@@ -67,7 +113,7 @@
 
 
 class Pubsub(base.CommandBase):
-    subcommands = (Get,)
+    subcommands = (Get, Node)
 
     def __init__(self, host):
         super(Pubsub, self).__init__(host, 'pubsub', use_profile=False, help=_('PubSub nodes/items management'))