new plugin for xep 0077 (In-Band registration): first draft

- wix: register in gateways manager now call the in-band registration process

frontends/sat_bridge_frontend/DBus.py

@@ -61,6 +61,9 @@ class DBusBridgeFrontend(BridgeFrontend):
     def findGateways(self, target):
         return self.db_comm_iface.findGateways(target)
 
+    def in_band_register(self, target):
+        return self.db_comm_iface.in_band_register(target)
+    
     def setPresence(self, to="", type="", show="", status="", priority=0):
         return self.db_comm_iface.setPresence(to, type, show, status, priority)
 

frontends/wix/gateways.py

@@ -116,9 +116,19 @@ class GatewaysManager(wx.Frame):
         type_label.SetFont(self.italic_font)
 
         #The buttons
+        def register_cb(event):
+            """Called when register button is clicked"""
+            gateway_jid = event.GetEventObject().gateway_jid
+            id = self.host.bridge.in_band_register(gateway_jid)
+            self.host.current_action_ids.add(id)
+            print "register id:",id
+            event.Skip()
+
         button_font = wx.Font(6, wx.DEFAULT, wx.NORMAL, wx.BOLD)
         reg_button = wx.Button(self.panel, -1, "Register", size=wx.Size(-1, 8))
         reg_button.SetFont(button_font)
+        reg_button.gateway_jid = JID(gateway)
+        self.panel.Bind(wx.EVT_BUTTON, register_cb, reg_button)
 
         self.panel.sizer.Add(im_icon)
         self.panel.sizer.Add(label)

plugins/plugin_xep_0077.py

@@ -0,0 +1,68 @@
+#!/usr/bin/python
+# -*- coding: utf-8 -*-
+
+"""
+SAT plugin for managing xep-0077
+Copyright (C) 2009  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 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/>.
+"""
+
+from logging import debug, info, error
+from twisted.words.protocols.jabber import client, jid, xmlstream, error
+from twisted.words.protocols.jabber.xmlstream import IQ
+from twisted.internet import reactor
+import pdb
+
+NS_REG = 'jabber:iq:register'
+
+PLUGIN_INFO = {
+"name": "XEP 0077 Plugin",
+"import_name": "XEP_0077",
+"type": "XEP",
+"dependencies": [],
+"main": "XEP_0077",
+"description": """Implementation of SI File Transfert"""
+}
+
+class XEP_0077():
+
+    def __init__(self, host):
+        info("Plugin XEP_0077 initialization")
+        self.host = host
+        host.bridge.addMethod("in_band_register", ".communication", in_sign='s', out_sign='s', method=self.in_band_register)
+   
+    def reg_ok(self, answer):
+        """Called after the first get IQ"""
+        print "answer:",answer
+
+    def reg_err(self, failure):
+        """Called when something is wrong with registration"""
+        info ("Registration failure: %s" % str(failure.value))
+        answer_data = {}
+        answer_data['reason'] = 'unknown'
+        answer_data={"message":"%s [code: %s]" % (failure.value.condition, failure.value.code)}
+        answer_type = "ERROR"
+        self.host.bridge.actionResult(answer_type, failure.value.stanza['id'], answer_data)
+   
+    def in_band_register(self, target):
+        """register to a target JID"""
+        to_jid = jid.JID(target)
+        debug("Asking registration for [%s]" % target)
+        reg_request=IQ(self.host.xmlstream,'get')
+        reg_request["from"]=self.host.me.full()
+        reg_request["to"] = to_jid.full()
+        query=reg_request.addElement('query', NS_REG)
+        reg_request.send(to_jid.full()).addCallbacks(self.reg_ok, self.reg_err)
+        return reg_request["id"] 

plugins/plugin_xep_0100.py

@@ -48,7 +48,7 @@ class XEP_0100():
 
         for identity in disco.identities:
             if identity[0] == 'gateway':
-                print ("Found gateway (%s): %s" % (entity, disco.identities[identity]))
+                print ("Found gateway (%s): %s" % (entity.full(), disco.identities[identity]))
                 self.__gateways[request_id][entity.full()] = {
                     'name':disco.identities[identity],
                     'type':identity[1]

sat.tac

@@ -229,11 +229,11 @@ class RegisteringAuthenticator(xmlstream.ConnectAuthenticator):
         self.host.bridge.actionResult(answer_type, self.answer_id, answer_data)
         self.xmlstream.sendFooter()
         
-    def registrationFailure(self, error):
-        info ("Registration failure: %s" % str(error.value))
+    def registrationFailure(self, failure):
+        info ("Registration failure: %s" % str(failure.value))
         answer_type = "ERROR"
         answer_data = {}
-        if error.value.condition == 'conflict':
+        if failure.value.condition == 'conflict':
             answer_data['reason'] = 'conflict'
             answer_data={"message":"Username already exists, please choose an other one"}
         else: