libervia-backend: sat_frontends/jp/cmd

jp (roster): added resync command to do a full roster resynchronisation

comparison

equal deleted inserted replaced

-:82b781c46841
+:7c8773723200
 # You should have received a copy of the GNU Affero General Public License
 # along with this program.  If not, see <http://www.gnu.org/licenses/>.
 import base
+from collections import OrderedDict
+from functools import partial
+from sat.core.i18n import _
 from sat_frontends.jp.constants import Const as C
-from sat.core.i18n import _
 from twisted.words.protocols.jabber import jid
-from collections import OrderedDict
 __commands__ = ["Roster"]
 args.append(u"\t".join(groups) if groups else "")
 print u";".join(["{}"] * field_count).format(*args).encode("utf-8")
 self.host.quit()
+class Resync(base.CommandBase):
+def __init__(self, host):
+super(Resync, self).__init__(
+host, 'resync', help=_(u'do a full resynchronisation of roster with server'))
+self.need_loop = True
+def add_parser_options(self):
+pass
+def rosterResyncCb(self):
+self.disp(_(u"Roster resynchronized"))
+self.host.quit(C.EXIT_OK)
+def start(self):
+self.host.bridge.rosterResync(profile_key=self.host.profile,
+callback=self.rosterResyncCb,
+errback=partial(
+self.errback,
+msg=_(u"can't resynchronise roster: {}"),
+exit_code=C.EXIT_BRIDGE_ERRBACK,
+))
 class Roster(base.CommandBase):
-subcommands = (Get, Stats, Purge)
+subcommands = (Get, Stats, Purge, Resync)
 def __init__(self, host):
 super(Roster, self).__init__(host, 'roster', use_profile=True, help=_("Manage an entity's roster"))

Mercurial > libervia-backend