comparison sat_pubsub/mam.py @ 367:a772f7dac930

backend, storage(pgsql): creation/update date + serial ids: /!\ this patch updates pgqsl schema /!\ Had to set 2 features in the same patch, to avoid updating 2 times the schema. 1) creation/last modification date: column keeping the date of creation of items is renamed from "date" to "created" the date of last modification of items is saved in the new "updated" column 2) serial ids: this experimental feature allows to have ids in series (i.e. 1, 2, 3, etc.) instead of UUID. This is a convenience feature and there are some drawbacks: - PostgreSQL sequences are used, so gaps can happen (see PostgreSQL documentation for more details) - if somebody create an item with a future id in the series, the series will adapt, which can have undesired effect, and may lead to item fail if several items are created at the same time. For instance if next id in series is "8", and somebody hads already created item "8" and "256", the item will be created with biggest value in items +1 (i.e. 257). if 2 people want to create item in this situation, the second will fail with a conflict error.
author Goffi <goffi@goffi.org>
date Sat, 04 Nov 2017 21:31:32 +0100
parents 5580f08c7b91
children
comparison
equal deleted inserted replaced
366:81e6d4a516c3 367:a772f7dac930
102 for item_data in items_data: 102 for item_data in items_data:
103 if item_data.item.name == 'set' and item_data.item.uri == rsm.NS_RSM: 103 if item_data.item.name == 'set' and item_data.item.uri == rsm.NS_RSM:
104 assert rsm_elt is None 104 assert rsm_elt is None
105 rsm_elt = item_data.item 105 rsm_elt = item_data.item
106 elif item_data.item.name == 'item': 106 elif item_data.item.name == 'item':
107 msg_data.append([item_data.item['id'], make_message(item_data.item), item_data.date]) 107 msg_data.append([item_data.item['id'], make_message(item_data.item), item_data.created])
108 else: 108 else:
109 log.msg("WARNING: unknown element: {}".format(item_data.item.name)) 109 log.msg("WARNING: unknown element: {}".format(item_data.item.name))
110 if pep: 110 if pep:
111 # we need to send privileged message 111 # we need to send privileged message
112 # so me manage the sending ourself, and return 112 # so me manage the sending ourself, and return
118 118
119 d.addErrback(self._mapErrors) 119 d.addErrback(self._mapErrors)
120 d.addCallback(cb) 120 d.addCallback(cb)
121 return d 121 return d
122 122
123 def forwardPEPMessage(self, mam_request, id_, elt, date): 123 def forwardPEPMessage(self, mam_request, id_, elt, created):
124 msg = domish.Element((None, 'message')) 124 msg = domish.Element((None, 'message'))
125 msg['from'] = self.backend.privilege.server_jid.full() 125 msg['from'] = self.backend.privilege.server_jid.full()
126 msg['to'] = mam_request.sender.full() 126 msg['to'] = mam_request.sender.full()
127 result = msg.addElement((mam.NS_MAM, 'result')) 127 result = msg.addElement((mam.NS_MAM, 'result'))
128 if mam_request.query_id is not None: 128 if mam_request.query_id is not None:
129 result['queryid'] = mam_request.query_id 129 result['queryid'] = mam_request.query_id
130 result['id'] = id_ 130 result['id'] = id_
131 forward = result.addElement((const.NS_FORWARD, 'forwarded')) 131 forward = result.addElement((const.NS_FORWARD, 'forwarded'))
132 forward.addChild(delay.Delay(date).toElement()) 132 forward.addChild(delay.Delay(created).toElement())
133 forward.addChild(elt) 133 forward.addChild(elt)
134 self.backend.privilege.sendMessage(msg) 134 self.backend.privilege.sendMessage(msg)
135 135
136 def onPrefsGetRequest(self, requestor): 136 def onPrefsGetRequest(self, requestor):
137 """ 137 """