|
10 | 10 |
|
11 | 11 |
|
12 | 12 | class BotContext(object):
|
13 |
| - def __init__(self, adapter, request: Activity): |
14 |
| - self.adapter = adapter |
15 |
| - self.activity = request |
16 |
| - self.responses: List[Activity] = [] |
17 |
| - self._services: dict = {} |
18 |
| - self._on_send_activities: Callable[[]] = [] |
19 |
| - self._on_update_activity: Callable[[]] = [] |
20 |
| - self._on_delete_activity: Callable[[]] = [] |
21 |
| - self.__responded: bool = False |
| 13 | + def __init__(self, adapter_or_context, request: Activity=None): |
| 14 | + if isinstance(adapter_or_context, BotContext): |
| 15 | + adapter_or_context.copy_to(self) |
| 16 | + else: |
| 17 | + self.adapter = adapter_or_context |
| 18 | + self.activity = request |
| 19 | + self.responses: List[Activity] = [] |
| 20 | + self._services: dict = {} |
| 21 | + self._on_send_activities: Callable[[]] = [] |
| 22 | + self._on_update_activity: Callable[[]] = [] |
| 23 | + self._on_delete_activity: Callable[[]] = [] |
| 24 | + self._responded = {'responded': False} |
22 | 25 |
|
23 | 26 | if self.adapter is None:
|
24 | 27 | raise TypeError('BotContext must be instantiated with an adapter.')
|
25 | 28 | if self.activity is None:
|
26 | 29 | raise TypeError('BotContext must be instantiated with a request parameter of type Activity.')
|
27 | 30 |
|
28 | 31 | def copy_to(self, context: 'BotContext') -> None:
|
29 |
| - for attribute in ['adapter', 'activity', 'responded', '_services', |
| 32 | + for attribute in ['adapter', 'activity', '_responded', '_services', |
30 | 33 | '_on_send_activities', '_on_update_activity', '_on_delete_activity']:
|
31 | 34 | setattr(context, attribute, getattr(self, attribute))
|
32 | 35 |
|
33 | 36 | @property
|
34 | 37 | def responded(self):
|
35 |
| - return self.__responded |
| 38 | + return self._responded['responded'] |
36 | 39 |
|
37 | 40 | @responded.setter
|
38 | 41 | def responded(self, value):
|
39 |
| - if type(value) != bool or value is False: |
| 42 | + if not value: |
40 | 43 | raise ValueError('BotContext.responded(): cannot set BotContext.responded to False.')
|
41 | 44 | else:
|
42 |
| - self.__responded = value |
| 45 | + self._responded['responded'] = True |
43 | 46 |
|
44 | 47 | def get(self, key: str) -> object:
|
45 | 48 | if not key or not isinstance(key, str):
|
@@ -92,6 +95,33 @@ async def update_activity(self, activity: Activity):
|
92 | 95 | async def delete_activity(self, reference: ConversationReference):
|
93 | 96 | return await self._emit(self._on_delete_activity, reference, self.adapter.delete_activity(self, reference))
|
94 | 97 |
|
| 98 | + def on_send_activities(self, handler) -> 'BotContext': |
| 99 | + """ |
| 100 | + Registers a handler to be notified of and potentially intercept the sending of activities. |
| 101 | + :param handler: |
| 102 | + :return: |
| 103 | + """ |
| 104 | + self._on_send_activities.append(handler) |
| 105 | + return self |
| 106 | + |
| 107 | + def on_update_activity(self, handler) -> 'BotContext': |
| 108 | + """ |
| 109 | + Registers a handler to be notified of and potentially intercept an activity being updated. |
| 110 | + :param handler: |
| 111 | + :return: |
| 112 | + """ |
| 113 | + self._on_update_activity.append(handler) |
| 114 | + return self |
| 115 | + |
| 116 | + def on_delete_activity(self, handler) -> 'BotContext': |
| 117 | + """ |
| 118 | + Registers a handler to be notified of and potentially intercept an activity being deleted. |
| 119 | + :param handler: |
| 120 | + :return: |
| 121 | + """ |
| 122 | + self._on_delete_activity.append(handler) |
| 123 | + return self |
| 124 | + |
95 | 125 | @staticmethod
|
96 | 126 | async def _emit(plugins, arg, logic):
|
97 | 127 | handlers = copy(plugins)
|
|
0 commit comments