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
|
# Slixmpp: The Slick XMPP Library
# Copyright (C) 2012 Nathanael C. Fritz, Lance J.T. Stout
# This file is part of Slixmpp.
# See the file LICENSE for copying permission.
import logging
from slixmpp import Iq, Message, Presence
from slixmpp.plugins import BasePlugin
from slixmpp.xmlstream import register_stanza_plugin
from slixmpp.xmlstream.handler import Callback
from slixmpp.xmlstream.matcher import StanzaPath
from slixmpp.plugins.xep_0297 import stanza, Forwarded
class XEP_0297(BasePlugin):
name = 'xep_0297'
description = 'XEP-0297: Stanza Forwarding'
dependencies = {'xep_0030', 'xep_0203'}
stanza = stanza
def plugin_init(self):
register_stanza_plugin(Message, Forwarded)
# While these are marked as iterable, that is just for
# making it easier to extract the forwarded stanza. There
# still can be only a single forwarded stanza.
register_stanza_plugin(Forwarded, Message, iterable=True)
register_stanza_plugin(Forwarded, Presence, iterable=True)
register_stanza_plugin(Forwarded, Iq, iterable=True)
register_stanza_plugin(Forwarded, self.xmpp['xep_0203'].stanza.Delay)
self.xmpp.register_handler(
Callback('Forwarded Stanza',
StanzaPath('message/forwarded'),
self._handle_forwarded))
def session_bind(self, jid):
self.xmpp['xep_0030'].add_feature('urn:xmpp:forward:0')
def plugin_end(self):
self.xmpp['xep_0030'].del_feature(feature='urn:xmpp:forward:0')
self.xmpp.remove_handler('Forwarded Stanza')
def forward(self, stanza=None, mto=None, mbody=None, mfrom=None, delay=None):
stanza.stream = None
msg = self.xmpp.Message()
msg['to'] = mto
msg['from'] = mfrom
msg['body'] = mbody
msg['forwarded']['stanza'] = stanza
if delay is not None:
msg['forwarded']['delay']['stamp'] = delay
msg.send()
def _handle_forwarded(self, msg):
self.xmpp.event('forwarded_stanza', msg)
|
