if schema_string not in self._children[key]:
self._children[key][schema_string] = MessageTemplateRegistry()
self._children[key][schema_string].insert(reduced_template, client)
- if client in self._templates:
- del self._templates[client]
+ if client not in self._templates:
+ self._templates[client] = []
+ self._templates[client].append(template)
def delete(self, client: str) -> bool:
"""Unregister a client from all templates.
>>> r.get_templates('Client 6')
[{'k1': {'const': 'v1'}}, {'k2': {'const': 'v1'}}]
"""
- if client not in self._templates:
- self._templates[client] = []
- if client in self._clients:
- self._templates[client].append(MessageTemplate())
- for key in self._children:
- for schema_string in self._children[key]:
- schema = json.loads(schema_string)
- child = self._children[key][schema_string]
- for template in child.get_templates(client):
- current = MessageTemplate({key: schema})
- current.update(template)
- self._templates[client].append(current)
- return self._templates[client]
+ if client in self._templates:
+ return self._templates[client]
+ return []
class BusException(Exception):