annotate sat_pubsub.tac @ 318:d13526c0eb32

RSM improvments/refactoring: - a warning message is displayed if maxItems == 0 in getItems, and an empty list is returned in this case - use the new container.ItemData instead of doing tuple (un)packing - the list of ItemData => list of domish.Element conversion is done at the end of the workflow - rsm request is checked in self._items_rsm directly - better handling of Response.index in _items_rsm - itemsIdentifiers can't be used with RSM (the later will be ignored if this happen) - don't do approximative unpacking anymore in _items_rsm - countItems and getIndex have been refactored and renamed getItemsCount and getItemsIndex, don't use query duplications anymore - cleaned query handling in getItems - /!\ mam module is temporarly broken
author Goffi <goffi@goffi.org>
date Sun, 03 Jan 2016 18:33:22 +0100
parents 51af2ed8bd50
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
230
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
1 #!/usr/bin/python
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
2 #-*- coding: utf-8 -*-
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
3 # Copyright (c) 2003-2008 Ralph Meijer
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
4 # See LICENSE for details.
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
5
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
6 """
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
7 Example TAC for SàT Pubsub.
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
8 """
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
9
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
10 from twisted.application import service
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
11 from twisted.words.protocols.jabber.jid import JID
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
12
234
51af2ed8bd50 replaced idavoll imports by sat_pubsub imports
Goffi <goffi@goffi.org>
parents: 230
diff changeset
13 from sat_pubsub import tap
230
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
14
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
15 application = service.Application("sat_pubsub")
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
16
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
17 config = {
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
18 'jid': JID('sat-pubsub.necton3.int'),
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
19 'secret': 'pass',
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
20 'rhost': '127.0.0.1',
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
21 'rport': 5347,
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
22 'backend': 'pgsql',
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
23 'dbuser': 'goffi',
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
24 'dbpass': 'toto',
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
25 'dbname': "pubsub",
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
26 'dbhost': "localhost",
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
27 'dbport': None,
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
28 'verbose': True,
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
29 'hide-nodes': False,
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
30 }
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
31
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
32 idavollService = tap.makeService(config)
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
33 idavollService.setServiceParent(application)
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
34
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
35 # Set the maximum delay until trying to reconnect.
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
36 componentService = idavollService.getServiceNamed('component')
57d1d78190d0 renamed idavoll.tac to sat_pubsub.tac
Goffi <goffi@goffi.org>
parents:
diff changeset
37 componentService.factory.maxdelay = 300