libervia-backend: sat_frontends/jp/cmd

comparison sat_frontends/jp/cmd_pubsub.py @ 3866:915fb230cb28

cli (blog, pubsub): new `attachments` subcommands: `pubsub/attachments` subcommands has a `get` and a `set` subcommand to manage attachments of a pubsub item. `blog` has the same subcommands, the only difference is that if `--node` is not specified, the default blog namespace will be used. rel 370

author	Goffi <goffi@goffi.org>
date	Wed, 20 Jul 2022 17:55:11 +0200
parents	f599e0e36444
children	1ab5fb468a41

comparison

equal deleted inserted replaced

-:59fbb66b2923
+:915fb230cb28
 self.display_uri(jid_)
 else:
 self.display_uri(None)
+class AttachmentGet(base.CommandBase):
+def __init__(self, host):
+super().__init__(
+host,
+"get",
+use_output=C.OUTPUT_LIST_DICT,
+use_pubsub=True,
+pubsub_flags={C.SERVICE, C.NODE, C.SINGLE_ITEM},
+help=_("get data attached to an item"),
+)
+def add_parser_options(self):
+self.parser.add_argument(
+"-j",
+"--jid",
+action="append",
+dest="jids",
+help=_(
+"get attached data published only by those JIDs (DEFAULT: get all "
+"attached data)"
+)
+)
+async def start(self):
+try:
+attached_data, __ = await self.host.bridge.psAttachmentsGet(
+self.args.service,
+self.args.node,
+self.args.item,
+self.args.jids or [],
+"",
+self.profile,
+)
+except Exception as e:
+self.disp(f"can't get attached data: {e}", error=True)
+self.host.quit(C.EXIT_BRIDGE_ERRBACK)
+else:
+attached_data = data_format.deserialise(attached_data, type_check=list)
+await self.output(attached_data)
+self.host.quit(C.EXIT_OK)
+class AttachmentSet(base.CommandBase):
+def __init__(self, host):
+super().__init__(
+host,
+"set",
+use_pubsub=True,
+pubsub_flags={C.SERVICE, C.NODE, C.SINGLE_ITEM},
+help=_("attach data to an item"),
+)
+def add_parser_options(self):
+self.parser.add_argument(
+"-R",
+"--replace",
+action="store_true",
+help=_(
+"replace previous versions of attachments (DEFAULT: update previous "
+"version)"
+)
+)
+self.parser.add_argument(
+"-N",
+"--noticed",
+metavar="BOOLEAN",
+nargs="?",
+default="keep",
+help=_("mark item as (un)noticed (DEFAULT: keep current value))")
+)
+self.parser.add_argument(
+"-r",
+"--reactions",
+# FIXME: to be replace by "extend" when we stop supporting python 3.7
+action="append",
+help=_("add emojis to react to an item")
+)
+async def start(self):
+mb_data = {
+"service": self.args.service,
+"node": self.args.node,
+"id": self.args.item,
+"extra": {}
+}
+operation = "replace" if self.args.replace else "update"
+if self.args.noticed != "keep":
+if self.args.noticed is None:
+self.args.noticed = C.BOOL_TRUE
+mb_data["extra"]["noticed"] = C.bool(self.args.noticed)
+if self.args.reactions is not None:
+mb_data["extra"]["reaction"] = {
+"operation": operation,
+"reactions": [r for emojis in self.args.reactions for r in emojis]
+}
+if not mb_data["extra"]:
+self.parser.error(_("At leat one attachment must be specified."))
+try:
+await self.host.bridge.psAttachmentsSet(
+data_format.serialise(mb_data),
+self.profile,
+)
+except Exception as e:
+self.disp(f"can't attach data to item: {e}", error=True)
+self.host.quit(C.EXIT_BRIDGE_ERRBACK)
+else:
+self.disp("data attached")
+self.host.quit(C.EXIT_OK)
+class Attachments(base.CommandBase):
+subcommands = (AttachmentGet, AttachmentSet)
+def __init__(self, host):
+super().__init__(
+host,
+"attachments",
+use_profile=False,
+help=_("set or retrieve items attachments"),
+)
 class HookCreate(base.CommandBase):
 def __init__(self, host):
 base.CommandBase.__init__(
 self,
 host,
 Subscriptions,
 Affiliations,
 Reference,
 Search,
 Transform,
+Attachments,
 Hook,
 Uri,
 Node,
 Cache,
 )

Mercurial > libervia-backend

comparison sat_frontends/jp/cmd_pubsub.py @ 3866:915fb230cb28