view sat_frontends/jp/cmd_ping.py @ 2766:93a421de0e3d

tools (common/data_objects): metadata parsing in BlogItems: metadata are parsed to deserialise some well known values like rsm index and count, and some properties have been added to have easier access. A "complete" property (or item in metadata) is set to True if we are on the last page, False if we are not, or None if we don't have enough data to know if we are on the last page or not.
author Goffi <goffi@goffi.org>
date Fri, 11 Jan 2019 16:35:13 +0100
parents 56bfe1b79204
children 003b8b4b56a7
line wrap: on
line source

#!/usr/bin/env python2
# -*- coding: utf-8 -*-

# jp: a SAT command line tool
# Copyright (C) 2009-2018 Jérôme Poisson (goffi@goffi.org)

# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.

# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU Affero General Public License for more details.

# 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 sat.core.i18n import _

__commands__ = ["Ping"]


class Ping(base.CommandBase):

    def __init__(self, host):
        super(Ping, self).__init__(host, 'ping', help=_('ping XMPP entity'))
        self.need_loop=True

    def add_parser_options(self):
        self.parser.add_argument(
            "jid", type=base.unicode_decoder, help=_(u"jid to ping")
        )
        self.parser.add_argument(
            "-d", "--delay-only", action="store_true", help=_(u"output delay only (in s)")
        )

    def _pingCb(self, pong_time):
        fmt = u"{time}" if self.args.delay_only else  u"PONG ({time} s)"
        self.disp(fmt.format(time=pong_time))
        self.host.quit()

    def start(self):
        self.host.bridge.ping(self.args.jid, self.profile,
            callback=self._pingCb, errback=self.errback)