12
12
FileConsentCardResponse ,
13
13
TeamsChannelData ,
14
14
TeamsChannelAccount ,
15
- MessageActionsPayload ,
16
15
MessagingExtensionAction ,
17
16
MessagingExtensionQuery ,
18
17
O365ConnectorCardActionQuery ,
19
- TaskModuleRequest
18
+ TaskModuleRequest ,
20
19
)
21
20
from botframework .connector import Channels
22
- import json
23
- from typing import List
21
+
24
22
25
23
class TeamsActivityHandler (ActivityHandler ):
26
24
async def on_turn (self , turn_context : TurnContext ):
@@ -68,7 +66,8 @@ async def on_invoke_activity(self, turn_context: TurnContext):
68
66
69
67
if turn_context .activity .name == "actionableMessage/executeAction" :
70
68
await self .on_teams_o365_connector_card_action (
71
- turn_context , O365ConnectorCardActionQuery (** turn_context .activity .value )
69
+ turn_context ,
70
+ O365ConnectorCardActionQuery (** turn_context .activity .value ),
72
71
)
73
72
return self ._create_invoke_response ()
74
73
@@ -82,7 +81,8 @@ async def on_invoke_activity(self, turn_context: TurnContext):
82
81
if turn_context .activity .name == "composeExtension/query" :
83
82
return self ._create_invoke_response (
84
83
await self .on_teams_messaging_extension_query (
85
- turn_context , MessagingExtensionQuery (** turn_context .activity .value )
84
+ turn_context ,
85
+ MessagingExtensionQuery (** turn_context .activity .value ),
86
86
)
87
87
)
88
88
@@ -96,21 +96,24 @@ async def on_invoke_activity(self, turn_context: TurnContext):
96
96
if turn_context .activity .name == "composeExtension/submitAction" :
97
97
return self ._create_invoke_response (
98
98
await self .on_teams_messaging_extension_submit_action_dispatch (
99
- turn_context , MessagingExtensionAction (** turn_context .activity .value )
99
+ turn_context ,
100
+ MessagingExtensionAction (** turn_context .activity .value ),
100
101
)
101
102
)
102
103
103
104
if turn_context .activity .name == "composeExtension/fetchTask" :
104
105
return self ._create_invoke_response (
105
106
await self .on_teams_messaging_extension_fetch_task (
106
- turn_context , MessagingExtensionAction (** turn_context .activity .value )
107
+ turn_context ,
108
+ MessagingExtensionAction (** turn_context .activity .value ),
107
109
)
108
110
)
109
111
110
112
if turn_context .activity .name == "composeExtension/querySettingUrl" :
111
113
return self ._create_invoke_response (
112
114
await self .on_teams_messaging_extension_configuration_query_settings_url (
113
- turn_context , MessagingExtensionQuery (** turn_context .activity .value )
115
+ turn_context ,
116
+ MessagingExtensionQuery (** turn_context .activity .value ),
114
117
)
115
118
)
116
119
@@ -151,7 +154,9 @@ async def on_teams_signin_verify_state(self, turn_context: TurnContext):
151
154
raise _InvokeResponseException (status_code = HTTPStatus .NOT_IMPLEMENTED )
152
155
153
156
async def on_teams_file_consent (
154
- self , turn_context : TurnContext , file_consent_card_response : FileConsentCardResponse
157
+ self ,
158
+ turn_context : TurnContext ,
159
+ file_consent_card_response : FileConsentCardResponse ,
155
160
):
156
161
if file_consent_card_response .action == "accept" :
157
162
await self .on_teams_file_consent_accept_activity (
@@ -171,12 +176,16 @@ async def on_teams_file_consent(
171
176
)
172
177
173
178
async def on_teams_file_consent_accept_activity ( # pylint: disable=unused-argument
174
- self , turn_context : TurnContext , file_consent_card_response : FileConsentCardResponse
179
+ self ,
180
+ turn_context : TurnContext ,
181
+ file_consent_card_response : FileConsentCardResponse ,
175
182
):
176
183
raise _InvokeResponseException (status_code = HTTPStatus .NOT_IMPLEMENTED )
177
184
178
185
async def on_teams_file_consent_decline_activity ( # pylint: disable=unused-argument
179
- self , turn_context : TurnContext , file_consent_card_response : FileConsentCardResponse
186
+ self ,
187
+ turn_context : TurnContext ,
188
+ file_consent_card_response : FileConsentCardResponse ,
180
189
):
181
190
raise _InvokeResponseException (status_code = HTTPStatus .NOT_IMPLEMENTED )
182
191
@@ -196,7 +205,7 @@ async def on_teams_messaging_extension_query( # pylint: disable=unused-argument
196
205
raise _InvokeResponseException (status_code = HTTPStatus .NOT_IMPLEMENTED )
197
206
198
207
async def on_teams_messaging_extension_select_item ( # pylint: disable=unused-argument
199
- self , turn_context : TurnContext , query
208
+ self , turn_context : TurnContext , query
200
209
):
201
210
raise _InvokeResponseException (status_code = HTTPStatus .NOT_IMPLEMENTED )
202
211
@@ -269,7 +278,7 @@ async def on_teams_task_module_submit( # pylint: disable=unused-argument
269
278
raise _InvokeResponseException (status_code = HTTPSt
F438
atus .NOT_IMPLEMENTED )
270
279
271
280
async def on_conversation_update_activity (self , turn_context : TurnContext ):
272
-
281
+
273
282
if turn_context .activity .channel_id == Channels .ms_teams :
274
283
channel_data = TeamsChannelData (** turn_context .activity .channel_data )
275
284
if turn_context .activity .members_added :
@@ -287,7 +296,9 @@ async def on_conversation_update_activity(self, turn_context: TurnContext):
287
296
if channel_data :
288
297
if channel_data .event_type == "channelCreated" :
289
298
return await self .on_teams_channel_created_activity (
290
- ChannelInfo (** channel_data .channel ), channel_data .team , turn_context
299
+ ChannelInfo (** channel_data .channel ),
300
+ channel_data .team ,
301
+ turn_context ,
291
302
)
292
303
if channel_data .event_type == "channelDeleted" :
293
304
return await self .on_teams_channel_deleted_activity (
@@ -298,15 +309,17 @@ async def on_conversation_update_activity(self, turn_context: TurnContext):
298
309
channel_data .channel , channel_data .team , turn_context
299
310
)
300
311
if channel_data .event_type == "teamRenamed" :
301
- return await self .on_teams_team_renamed_activity (channel_data .team , turn_context )
312
+ return await self .on_teams_team_renamed_activity (
313
+ channel_data .team , turn_context
314
+ )
302
315
return await super ().on_conversation_update_activity (turn_context )
303
316
304
317
return await super ().on_conversation_update_activity (turn_context )
305
318
306
319
async def on_teams_channel_created_activity ( # pylint: disable=unused-argument
307
320
self , channel_info : ChannelInfo , team_info : TeamInfo , turn_context : TurnContext
308
321
):
309
- return
322
+ return
310
323
311
324
async def on_teams_team_renamed_activity ( # pylint: disable=unused-argument
312
325
self , team_info : TeamInfo , turn_context : TurnContext
@@ -350,13 +363,19 @@ async def on_teams_members_added_dispatch_activity( # pylint: disable=unused-ar
350
363
del new_account_json ["additional_properties" ]
351
364
member = TeamsChannelAccount (** new_account_json )
352
365
team_accounts_added .append (member )
353
- return await self .on_teams_members_added_activity (team_accounts_added , turn_context )
366
+ return await self .on_teams_members_added_activity (
367
+ team_accounts_added , turn_context
368
+ )
354
369
355
370
async def on_teams_members_added_activity (
356
371
self , teams_members_added : [TeamsChannelAccount ], turn_context : TurnContext
357
372
):
358
- teams_members_added = [ ChannelAccount (** member .serialize ()) for member in teams_members_added ]
359
- return await super ().on_members_added_activity (teams_members_added , turn_context )
373
+ teams_members_added = [
374
+ ChannelAccount (** member .serialize ()) for member in teams_members_added
375
+ ]
376
+ return await super ().on_members_added_activity (
377
+ teams_members_added , turn_context
378
+ )
360
379
361
380
async def on_teams_members_removed_dispatch_activity ( # pylint: disable=unused-argument
362
381
self ,
@@ -378,7 +397,9 @@ async def on_teams_members_removed_dispatch_activity( # pylint: disable=unused-
378
397
async def on_teams_members_removed_activity (
379
398
self , teams_members_removed : [TeamsChannelAccount ], turn_context : TurnContext
380
399
):
381
- members_removed = [ChannelAccount (** member .serialize ()) for member in teams_members_removed ]
400
+ members_removed = [
401
+ ChannelAccount (** member .serialize ()) for member in teams_members_removed
402
+ ]
382
403
return await super ().on_members_removed_activity (members_removed , turn_context )
383
404
384
405
async def on_teams_channel_deleted_activity ( # pylint: disable=unused-argument
0 commit comments