Mercurial > libervia-pubsub

comparison idavoll/memory_storage.py @ 139:8f6956b9a688

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Follow API change in Twisted Xish, while still being compatible with Twisted Xish 0.1.0.
author Ralph Meijer <ralphm@ik.nu>
date Wed, 27 Apr 2005 19:45:41 +0000
parents ffc3c706b0fb
children 812300cdbc22
comparison
equal deleted inserted replaced
138:635e433810ef 139:8f6956b9a688
147 self._itemlist = [] 147 self._itemlist = []
148 148
149 def store_items(self, items, publisher): 149 def store_items(self, items, publisher):
150 for data in items: 150 for data in items:
151 id = data["id"] 151 id = data["id"]
152 item = (data.toXml(), publisher) 152 data = data.toXml()
153 if isinstance(data, str):
154 data = data.decode('utf-8')
155 item = (data, publisher)
153 if id in self._items: 156 if id in self._items:
154 self._itemlist.remove(self._items[id]) 157 self._itemlist.remove(self._items[id])
155 self._items[id] = item 158 self._items[id] = item
156 self._itemlist.append(item) 159 self._itemlist.append(item)
157 160
174 def get_items(self, max_items=None): 177 def get_items(self, max_items=None):
175 if max_items: 178 if max_items:
176 list = self._itemlist[-max_items:] 179 list = self._itemlist[-max_items:]
177 else: 180 else:
178 list = self._itemlist 181 list = self._itemlist
179 return defer.succeed([unicode(item[0], 'utf-8') for item in list]) 182 return defer.succeed([item[0] for item in list])
180 183
181 def get_items_by_id(self, item_ids): 184 def get_items_by_id(self, item_ids):
182 items = [] 185 items = []
183 for item_id in item_ids: 186 for item_id in item_ids:
184 try: 187 try:
185 item = self._items[item_id] 188 item = self._items[item_id]
186 except KeyError: 189 except KeyError:
187 pass 190 pass
188 else: 191 else:
189 items.append(unicode(item[0], 'utf-8')) 192 items.append(item[0])
190 return defer.succeed(items) 193 return defer.succeed(items)
191 194
192 def purge(self): 195 def purge(self):
193 self._items = {} 196 self._items = {}
194 self._itemlist = [] 197 self._itemlist = []