GitVita
New repositoryImport repositoryNew issue
Your repositories Your dashboard Sign in

microsoft/teams.net

Public

mirrored from https://github.com/microsoft/teams.netAvailable

Watch0Fork0Star0
CodeCommitsIssuesPull requestsActionsInsightsSecurity
core/integration-test-au

Branches

Tags

  • No tags available.
0Branches0Tags
Go to file
Add file
Code

Clone

HTTPS

Download ZIP

teams.net/core/test/IntegrationTests

core/test/IntegrationTests/ConversationClientTests.cs

171lines · modecode

RawDownload
Latest commit unavailable.
1// Copyright (c) Microsoft Corporation.
2// Licensed under the MIT License.
3
4using Microsoft.Teams.Core;
5using Microsoft.Teams.Core.Schema;
6using Xunit.Abstractions;
7
8namespace IntegrationTests;
9
10/// <summary>
11/// Integration tests for core <see cref="ConversationClient"/> making real API calls.
12/// </summary>
13public class ConversationClientTests : IClassFixture<IntegrationTestFixture>
14{
15 private readonly IntegrationTestFixture _f;
16 private readonly ITestOutputHelper _output;
17
18 public ConversationClientTests(IntegrationTestFixture fixture, ITestOutputHelper output)
19 {
20 _f = fixture;
21 _f.OutputHelper = output;
22 _output = output;
23 }
24
25 [Fact(Timeout = 5000)]
26 public async Task SendActivity()
27 {
28 CoreActivity activity = CoreActivity.CreateBuilder()
29 .WithType(ActivityType.Message)
30 .WithFrom(IntegrationTestFixture.GetConversationAccountWithAgenticProperties())
31 .WithServiceUrl(_f.ServiceUrl)
32 .WithConversation(new(_f.ConversationId))
33 .WithProperty("text", $"[ConversationClient] SendActivity at `{DateTime.UtcNow:s}`")
34 .Build();
35
36 SendActivityResponse? res = await _f.ConversationClient.SendActivityAsync(activity);
37
38 Assert.NotNull(res);
39 Assert.NotNull(res.Id);
40 _output.WriteLine($"Sent activity: {res.Id}");
41 }
42
43 [Fact(Timeout = 5000)]
44 public async Task UpdateActivity()
45 {
46 CoreActivity activity = CoreActivity.CreateBuilder()
47 .WithType(ActivityType.Message)
48 .WithFrom(IntegrationTestFixture.GetConversationAccountWithAgenticProperties())
49 .WithServiceUrl(_f.ServiceUrl)
50 .WithConversation(new(_f.ConversationId))
51 .WithProperty("text", $"[ConversationClient] Original at `{DateTime.UtcNow:s}`")
52 .Build();
53
54 SendActivityResponse? sent = await _f.ConversationClient.SendActivityAsync(activity);
55 Assert.NotNull(sent?.Id);
56
57 CoreActivity updated = CoreActivity.CreateBuilder()
58 .WithType(ActivityType.Message)
59 .WithFrom(IntegrationTestFixture.GetConversationAccountWithAgenticProperties())
60 .WithServiceUrl(_f.ServiceUrl)
61 .WithConversation(new(_f.ConversationId))
62 .WithProperty("text", $"[ConversationClient] Updated at `{DateTime.UtcNow:s}`")
63 .Build();
64
65 UpdateActivityResponse res = await _f.ConversationClient.UpdateActivityAsync(
66 _f.ConversationId, sent.Id, updated, false, _f.AgenticIdentity);
67
68 Assert.NotNull(res?.Id);
69 _output.WriteLine($"Updated activity: {res.Id}");
70 }
71
72 [Fact(Timeout = 5000)]
73 public async Task DeleteActivity()
74 {
75 CoreActivity activity = CoreActivity.CreateBuilder()
76 .WithType(ActivityType.Message)
77 .WithFrom(IntegrationTestFixture.GetConversationAccountWithAgenticProperties())
78 .WithServiceUrl(_f.ServiceUrl)
79 .WithConversation(new(_f.ConversationId))
80 .WithProperty("text", $"[ConversationClient] To delete at `{DateTime.UtcNow:s}`")
81 .Build();
82
83 SendActivityResponse? sent = await _f.ConversationClient.SendActivityAsync(activity);
84 Assert.NotNull(sent?.Id);
85
86 await Task.Delay(2000);
87
88 await _f.ConversationClient.DeleteActivityAsync(
89 _f.ConversationId, sent.Id, _f.ServiceUrl, _f.AgenticIdentity);
90
91 _output.WriteLine($"Deleted activity: {sent.Id}");
92 }
93
94 [Fact(Timeout = 5000)]
95 public async Task GetConversationMembers()
96 {
97 IList<ConversationAccount> members = await _f.ConversationClient.GetConversationMembersAsync(_f.ConversationId, _f.ServiceUrl, _f.AgenticIdentity);
98
99 Assert.NotNull(members);
100 Assert.NotEmpty(members);
101
102 foreach (ConversationAccount m in members.Take(5))
103 {
104 _output.WriteLine($"Member: {m.Id} — {m.Name}");
105 }
106 }
107
108 [Fact(Timeout = 5000)]
109 public async Task GetConversationMember()
110 {
111 // Get MRI-format member ID from the members list first
112 IList<ConversationAccount> members = await _f.ConversationClient.GetConversationMembersAsync(_f.ConversationId, _f.ServiceUrl, _f.AgenticIdentity);
113 Assert.NotEmpty(members);
114 string memberId = members[0].Id!;
115
116 ConversationAccount member = await _f.ConversationClient.GetConversationMemberAsync<ConversationAccount>(_f.ConversationId, memberId, _f.ServiceUrl, _f.AgenticIdentity);
117
118 Assert.NotNull(member);
119 Assert.Equal(memberId, member.Id);
120 _output.WriteLine($"Member: {member.Id} — {member.Name}");
121 }
122
123 [Fact(Timeout = 5000)]
124 public async Task GetPagedMembers()
125 {
126 PagedMembersResult result = await _f.ConversationClient.GetConversationPagedMembersAsync(_f.ConversationId, _f.ServiceUrl, pageSize: 5, agenticIdentity: _f.AgenticIdentity);
127
128 Assert.NotNull(result?.Members);
129 Assert.NotEmpty(result.Members);
130
131 List<ConversationAccount> members = result.Members.ToList();
132
133 do
134 {
135 result = await _f.ConversationClient.GetConversationPagedMembersAsync(_f.ConversationId, _f.ServiceUrl, 5, result.ContinuationToken, _f.AgenticIdentity, null, CancellationToken.None);
136 members.AddRange(result.Members!);
137
138 } while (result.ContinuationToken is not null);
139
140
141 foreach (ConversationAccount m in members.TakeLast(5))
142 {
143 _output.WriteLine($"Member: {m.Id} — {m.Name}");
144 }
145 }
146
147 [Fact]
148 public async Task AddAndDeleteReaction()
149 {
150 CoreActivity activity = CoreActivity.CreateBuilder()
151 .WithType(ActivityType.Message)
152 .WithServiceUrl(_f.ServiceUrl)
153 .WithFrom(IntegrationTestFixture.GetConversationAccountWithAgenticProperties())
154 .WithConversation(new(_f.ConversationId))
155 .WithProperty("text", $"[ConversationClient] Reaction test at `{DateTime.UtcNow:s}`")
156 .Build();
157
158 SendActivityResponse? sent = await _f.ConversationClient.SendActivityAsync(activity);
159 Assert.NotNull(sent?.Id);
160
161 await _f.ConversationClient.AddReactionAsync(
162 _f.ConversationId, sent.Id, "like", _f.ServiceUrl, _f.AgenticIdentity);
163 _output.WriteLine("Added 'like' reaction");
164
165 await Task.Delay(1000);
166
167 await _f.ConversationClient.DeleteReactionAsync(
168 _f.ConversationId, sent.Id, "like", _f.ServiceUrl, _f.AgenticIdentity);
169 _output.WriteLine("Removed 'like' reaction");
170 }
171}
172