Mercurial > libervia-backend
diff plugins/plugin_xep_0077.py @ 30:d6b613764dd7
new plugin for xep 0077 (In-Band registration): first draft
- wix: register in gateways manager now call the in-band registration process
author | Goffi <goffi@goffi.org> |
---|---|
date | Tue, 08 Dec 2009 04:19:41 +0100 |
parents | |
children | b9bb5d8e0cc7 |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/plugins/plugin_xep_0077.py Tue Dec 08 04:19:41 2009 +0100 @@ -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"]