1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
|
"""
Creating a SleekXMPP Plugin
This is a minimal implementation of XEP-0077 to serve
as a tutorial for creating SleekXMPP plugins.
"""
from sleekxmpp.plugins.base import base_plugin
from sleekxmpp.xmlstream.handler.callback import Callback
from sleekxmpp.xmlstream.matcher.xpath import MatchXPath
from sleekxmpp.xmlstream import ElementBase, ET, register_stanza_plugin
from sleekxmpp import Iq
from user import User
from config import config
from sleekxmpp.plugins.xep_0004 import Form
import logging
logger = logging.getLogger(__name__)
class Registration(ElementBase):
namespace = 'jabber:iq:register'
name = 'query'
plugin_attrib = 'register'
interfaces = set(('registered', 'remove', 'instructions', 'form'))
sub_interfaces = interfaces
subitem = (Form,)
def get_registered(self):
present = self.xml.find('{%s}registered' % self.namespace)
return present is not None
def get_remove(self):
present = self.xml.find('{%s}remove' % self.namespace)
return present is not None
def set_registered(self, registered):
if registered:
self.add_field('registered')
else:
del self['registered']
def set_remove(self, remove):
if remove:
self.addField('remove')
else:
del self['remove']
def add_field(self, name):
itemXML = ET.Element('{%s}%s' % (self.namespace, name))
self.xml.append(itemXML)
def add_form(self):
aliasform = Form(None, self)
aliasform.addField(ftype = "hidden", var = "FORM_TYPE", value = "alias:register")
aliasform.addField(var = "pubkey", ftype = "text-single", label = "Public Key", required = True)
aliasform.addField(var = "privkey", ftype = "text-single", label = "Private Key", required = True)
def get_form(self):
return Form(self.xml.find('{jabber:x:data}x')).getValues()
def set_form(self, values):
Form(self.xml.find('{jabber:x:data}x')).setValues(values)
class xep_0077(base_plugin):
"""
XEP-0077 In-Band Registration
"""
def plugin_init(self):
self.description = "In-Band Registration"
self.xep = "0077"
self.form_fields = ("privkey", "pubkey")
self.form_instructions = "Please provide the following information to register\
an alias account"
self.xmpp.register_handler(
Callback('In-Band Registration',
MatchXPath('{%s}iq/{jabber:iq:register}query' % self.xmpp.default_ns),
self.__handle_registration))
register_stanza_plugin(Iq, Registration)
def post_init(self):
base_plugin.post_init(self)
self.xmpp['xep_0030'].add_feature("jabber:iq:register")
def __handle_registration(self, iq):
registrant = User(iq['from'].bare)
logger.info('User {} sent registration iq'.format(iq['from'].bare))
if iq['type'] == 'get':
# Registration form requested
self.send_registration_form(iq, registrant)
elif iq['type'] == 'set':
if iq['register']['remove']:
# Remove an account
registrant.unregister()
self.xmpp.event('unregistered_user', iq)
iq.reply().send()
return
registration_info = iq['register']['form']
for field in self.form_fields:
if not registration_info[field]:
# Incomplete Registration
self._send_error(iq, '406', 'modify', 'not-acceptable',
"Please fill in all fields.")
return
try:
registrant.register(registration_info)
# Successful registration
#self.xmpp.event('registered_user', iq)
iq.reply().setPayload(iq['register'].xml)
iq.send()
except:
return
else:
# Conflicting registration
self._send_error(iq, '409', 'cancel', 'conflict',
"That username is already taken.")
def setForm(self, *fields):
self.form_fields = fields
def set_instructions(self, instructions):
self.form_instructions = instructions
def send_registration_form(self, iq, registrant):
reg = iq['register']
reg.add_form()
if self.form_instructions:
reg['instructions'] = self.form_instructions
if registrant.is_registered():
reg['registered'] = True
reg['form'] = registrant.get_registration()
iq.reply().setPayload(reg.xml)
iq.send()
def _send_error(self, iq, code, error_type, name, text = ''):
iq.reply().setPayload(iq['register'].xml)
iq.error()
iq['error']['code'] = code
iq['error']['type'] = error_type
iq['error']['condition'] = name
iq['error']['text'] = text
iq.send()
if __name__=='__main__':
test = Registration()
test.add_form()
print '{}\n'.format(test['form'])
values = {'privkey': 'pomme', 'pubkey': 'poire', 'salt': 'abricot'}
test['form']=values
print test
|
