<commit_before># -*- coding: utf-8 -*-

"""
    This program is free software; you can redistribute it and/or modify
    it under the terms of the GNU 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 General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program; if not, see <http://www.gnu.org/licenses/>.
    
    @author: RaNaN
    @interface-version: 0.2
"""

from pyxmpp.all import JID,Message
from pyxmpp.jabber.client import JabberClient
from pyxmpp.interface import implements
from pyxmpp.interfaces import *

from module.plugins.hooks.IRCInterface import IRCInterface

class XMPPInterface(IRCInterface, JabberClient):
    __name__ = "XMPPInterface"
    __version__ = "0.1"
    __description__ = """connect to jabber and let owner perform different tasks"""
    __config__ = [("activated", "bool", "Activated", "False"),
        ("jid", "str", "Jabber ID", "<EMAIL>"),
        ("pw", "str", "Password", ""),
        ("owners", "str", "List of JIDs accepting commands from", "<EMAIL>;<EMAIL>"),
        ("info_file", "bool", "Inform about every file finished", "False"),
        ("info_pack", "bool", "Inform about every package finished", "True")]
    __author_name__ = ("RaNaN")
    __author_mail__ = ("<EMAIL>")
        
    implements(IMessageHandlersProvider)
    
    def __init__(self, core):
        IRCInterface.__init__(self, core)
        
        self.jid = JID(self.getConfig("jid"))
        password = self.getConfig("pw")
        
        # if bare JID is provided add a resource -- it is required
        if not self.jid.resource:
            self.jid=JID(self.jid.node, self.jid.domain, "pyLoad")
     
        tls_settings = None

        # setup client with provided connection information
        # and identity data
        JabberClient.__init__(self, self.jid, password,
                disco_name="pyLoad XMPP Client", disco_type="bot",
                tls_settings = tls_settings)

        self.interface_providers = [
            VersionHandler(self),
            self,
        ]
            
    def coreReady(self):
        self.new_package = {}
    
        self.start()
                
    def packageFinished(self, pypack):
        
        try:
            if self.getConfig("info_pack"):
                self.announce(_("Package finished: %s") % pypack.name)
        except:
            pass
        
    def downloadFinished(self, pyfile):
        try:
            if self.getConfig("info_file"):
                self.announce(_("Download finished: %(name)s @ %(plugin)s") % {"name": pyfile.name, "plugin": pyfile.pluginname} )
        except:
            pass
             
    def run(self):
        # connect to IRC etc.
        self.connect()
        try:        
            self.loop(1)
        except Exception, ex:
            self.core.log.error("pyLoad XMPP: %s" % str(ex))
            
    def stream_state_changed(self,state,arg):
        """This one is called when the state of stream connecting the component
        to a server changes. This will usually be used to let the user
        know what is going on."""
        self.log.debug("pyLoad XMPP: *** State changed: %s %r ***" % (state,arg) )

    def disconnected(self):
        self.log.debug("pyLoad XMPP: Client was disconnected")

    def stream_closed(self,stream):
        self.log.debug("pyLoad XMPP: Stream was closed | %s" % stream)

    def stream_error(self,err):
        self.log.debug("pyLoad XMPP: Stream Error: %s" % err)

    def get_message_handlers(self):
        """Return list of (message_type, message_handler) tuples.

        The handlers returned will be called when matching message is received
        in a client session."""
        return [
            ("normal", self.message),
            ]

    def message(self,stanza):
        """Message handler for the component."""
        subject=stanza.get_subject()
        body=stanza.get_body()
        t=stanza.get_type()
        self.log.debug(u'pyLoad XMPP: Message from %s received.' % (unicode(stanza.get_from(),)))
        self.log.debug(u'pyLoad XMPP: Body: %s' % body)
        
        if stanza.get_type()=="headline":
            # 'headline' messages should never be replied to
            return True
        if subject:
            subject=u"Re: "+subject
            
        to_jid = stanza.get_from()
        from_jid = stanza.get_to()

        #j = JID()
        to_name = to_jid.as_utf8()
        from_name = from_jid.as_utf8()
        
        names = self.getConfig("owners").split(";")
        
        if to_name in names or to_jid.node+"@"+to_jid.domain in names:
            
            messages = []
            
            trigger = "pass"
            args = None
            
            temp = body.split()
            trigger = temp[0]
            if len(temp) > 1:
                args = temp[1:]
        
            handler = getattr(self, "event_%s" % trigger, self.event_pass)
            try:
                res = handler(args)
                for line in res:
                    m=Message(
                        to_jid=to_jid,
                        from_jid=from_jid,
                        stanza_type=stanza.get_type(),
                        subject=subject,
                        body=line)
                    
                    messages.append(m)
            except Exception, e:
                    self.log.error("pyLoad XMPP: "+ repr(e))
            
            return messages
        
        else:
            return True
        
            
    def announce(self, message):
        """ send message to all owners"""
        for user in self.getConfig("owners").split(";"):

            self.log.debug("pyLoad XMPP: Send message to %s" % user)
            
            to_jid = JID(user)
            
            m = Message(from_jid=self.jid,
                        to_jid=to_jid,
                        stanza_type="chat",
                        body=message)

            stream = self.get_stream()
            if not stream:
                self.connect()
                stream = self.get_stream()
                
            stream.send(m)
        
           
class VersionHandler(object):
    """Provides handler for a version query.
    
    This class will answer version query and announce 'jabber:iq:version' namespace
    in the client's disco#info results."""
    
    implements(IIqHandlersProvider, IFeaturesProvider)

    def __init__(self, client):
        """Just remember who created this."""
        self.client = client

    def get_features(self):
        """Return namespace which should the client include in its reply to a
        disco#info query."""
        return ["jabber:iq:version"]

    def get_iq_get_handlers(self):
        """Return list of tuples (element_name, namespace, handler) describing
        handlers of <iq type='get'/> stanzas"""
        return [
            ("query", "jabber:iq:version", self.get_version),
            ]

    def get_iq_set_handlers(self):
        """Return empty list, as this class provides no <iq type='set'/> stanza handler."""<commit_msg>xmpp reconnect fix<commit_after># -*- coding: utf-8 -*-

"""
    This program is free software; you can redistribute it and/or modify
    it under the terms of the GNU 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 General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program; if not, see <http://www.gnu.org/licenses/>.
    
    @author: RaNaN
    @interface-version: 0.2
"""

from pyxmpp.all import JID,Message
from pyxmpp.jabber.client import JabberClient
from pyxmpp.interface import implements
from pyxmpp.interfaces import *

from module.plugins.hooks.IRCInterface import IRCInterface

class XMPPInterface(IRCInterface, JabberClient):
    __name__ = "XMPPInterface"
    __version__ = "0.1"
    __description__ = """connect to jabber and let owner perform different tasks"""
    __config__ = [("activated", "bool", "Activated", "False"),
        ("jid", "str", "Jabber ID", "<EMAIL>"),
        ("pw", "str", "Password", ""),
        ("owners", "str", "List of JIDs accepting commands from", "<EMAIL>;<EMAIL>"),
        ("info_file", "bool", "Inform about every file finished", "False"),
        ("info_pack", "bool", "Inform about every package finished", "True")]
    __author_name__ = ("RaNaN")
    __author_mail__ = ("<EMAIL>")
        
    implements(IMessageHandlersProvider)
    
    def __init__(self, core):
        IRCInterface.__init__(self, core)
        
        self.jid = JID(self.getConfig("jid"))
        password = self.getConfig("pw")
        
        # if bare JID is provided add a resource -- it is required
        if not self.jid.resource:
            self.jid=JID(self.jid.node, self.jid.domain, "pyLoad")
     
        tls_settings = None

        # setup client with provided connection information
        # and identity data
        JabberClient.__init__(self, self.jid, password,
                disco_name="pyLoad XMPP Client", disco_type="bot",
                tls_settings = tls_settings)

        self.interface_providers = [
            VersionHandler(self),
            self,
        ]
            
    def coreReady(self):
        self.new_package = {}
    
        self.start()
                
    def packageFinished(self, pypack):
        
        try:
            if self.getConfig("info_pack"):
                self.announce(_("Package finished: %s") % pypack.name)
        except:
            pass
        
    def downloadFinished(self, pyfile):
        try:
            if self.getConfig("info_file"):
                self.announce(_("Download finished: %(name)s @ %(plugin)s") % {"name": pyfile.name, "plugin": pyfile.pluginname} )
        except:
            pass
             
    def run(self):
        # connect to IRC etc.
        self.connect()
        try:        
            self.loop(1)
        except Exception, ex:
            self.core.log.error("pyLoad XMPP: %s" % str(ex))
            
    def stream_state_changed(self,state,arg):
        """This one is called when the state of stream connecting the component
        to a server changes. This will usually be used to let the user
        know what is going on."""
        self.log.debug("pyLoad XMPP: *** State changed: %s %r ***" % (state,arg) )

    def disconnected(self):
        self.log.debug("pyLoad XMPP: Client was disconnected")

    def stream_closed(self,stream):
        self.log.debug("pyLoad XMPP: Stream was closed | %s" % stream)

    def stream_error(self,err):
        self.log.debug("pyLoad XMPP: Stream Error: %s" % err)

    def get_message_handlers(self):
        """Return list of (message_type, message_handler) tuples.

        The handlers returned will be called when matching message is received
        in a client session."""
        return [
            ("normal", self.message),
            ]

    def message(self,stanza):
        """Message handler for the component."""
        subject=stanza.get_subject()
        body=stanza.get_body()
        t=stanza.get_type()
        self.log.debug(u'pyLoad XMPP: Message from %s received.' % (unicode(stanza.get_from(),)))
        self.log.debug(u'pyLoad XMPP: Body: %s' % body)
        
        if stanza.get_type()=="headline":
            # 'headline' messages should never be replied to
            return True
        if subject:
            subject=u"Re: "+subject
            
        to_jid = stanza.get_from()
        from_jid = stanza.get_to()

        #j = JID()
        to_name = to_jid.as_utf8()
        from_name = from_jid.as_utf8()
        
        names = self.getConfig("owners").split(";")
        
        if to_name in names or to_jid.node+"@"+to_jid.domain in names:
            
            messages = []
            
            trigger = "pass"
            args = None
            
            temp = body.split()
            trigger = temp[0]
            if len(temp) > 1:
                args = temp[1:]
        
            handler = getattr(self, "event_%s" % trigger, self.event_pass)
            try:
                res = handler(args)
                for line in res:
                    m=Message(
                        to_jid=to_jid,
                        from_jid=from_jid,
                        stanza_type=stanza.get_type(),
                        subject=subject,
                        body=line)
                    
                    messages.append(m)
            except Exception, e:
                    self.log.error("pyLoad XMPP: "+ repr(e))
            
            return messages
        
        else:
            return True
        
            
    def announce(self, message):
        """ send message to all owners"""
        for user in self.getConfig("owners").split(";"):

            self.log.debug("pyLoad XMPP: Send message to %s" % user)
            
            to_jid = JID(user)
            
            m = Message(from_jid=self.jid,
                        to_jid=to_jid,
                        stanza_type="chat",
                        body=message)

            stream = self.get_stream()
            if not stream:
                self.connect()
                stream = self.get_stream()
                
            stream.send(m)

    def beforeReconnecting(self, ip):
        self.disconnect()

    def afterReconnecting(self, ip):
        self.connect()
           
class VersionHandler(object):
    """Provides handler for a version query.
    
    This class will answer version query and announce 'jabber:iq:version' namespace
    in the client's disco#info results."""
    
    implements(IIqHandlersProvider, IFeaturesProvider)

    def __init__(self, client):
        """Just remember who created this."""
        self.client = client

    def get_features(self):
        """Return namespace which should the client include in its reply to a
        disco#info query."""
        return ["jabber:iq:version"]

    def get_iq_get_handlers(self):
        """Return list of tuples (element_name, namespace, handler) describing
        handlers of <iq type='get'/> stanzas"""
        return [
            ("query", "jabber:iq:version", self.get_version),
            ]

    def get_iq_set_handlers(self):
        """Return empty list, as this class provides no <iq type='set'/> stanza handler."""
{'fraction_non_alphanumeric': 0.10477965650379444, 'fraction_numerical': 0.0015976567700705631, 'mean_word_length': 1.8560836501901141, 'pattern_counts': {'":': 6, '<': 17, '<?xml version=': 0, '>': 19, 'https://': 0, 'lorem ipsum': 0, 'www.': 2, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 4, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '4136391', 'n_tokens_mistral': 4263, 'n_tokens_neox': 4164, 'n_words': 1195}