Akatsuki-Misaki/ArchiSteamFarm
1
0
Fork 0
mirror of https://github.com/JustArchiNET/ArchiSteamFarm.git synced 2026-01-16 08:25:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add ability to send group messages for plugin developers (#3069)

Browse Source 
* Add GetClanChatInfo as public API function

* make JoinChatRoomGroup public API. add LeaveChatRoomGroup as public API

* Rename GetClanChatRoomInfo method. Change return type of GetClanChatRoomInfo method
This commit is contained in:
tre3p
2023-11-11 23:29:57 +03:00
committed by GitHub
parent e44b7d3248
commit be4a625dc2
2 changed files with 70 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
ArchiSteamFarm/Steam/Bot.cs
View File

@@ -2578,13 +2578,13 @@ public sealed class Bot : IAsyncDisposable, IDisposable {
} }
if (MasterChatGroupID == 0) { if (MasterChatGroupID == 0) {
ulong chatGroupID = await ArchiHandler.GetClanChatGroupID(BotConfig.SteamMasterClanID).ConfigureAwait(false); CClanChatRooms_GetClanChatRoomInfo_Response? clanChatRoomInfo = await ArchiHandler.GetClanChatRoomInfo(BotConfig.SteamMasterClanID).ConfigureAwait(false);
if (chatGroupID == 0) { if ((clanChatRoomInfo == null) || (clanChatRoomInfo.chat_group_summary.chat_group_id == 0)) {
return; return;
} }
MasterChatGroupID = chatGroupID; MasterChatGroupID = clanChatRoomInfo.chat_group_summary.chat_group_id;
} }
HashSet<ulong>? chatGroupIDs = await ArchiHandler.GetMyChatGroupIDs().ConfigureAwait(false); HashSet<ulong>? chatGroupIDs = await ArchiHandler.GetMyChatGroupIDs().ConfigureAwait(false);

105
ArchiSteamFarm/Steam/Integration/ArchiHandler.cs
View File

@@ -277,6 +277,42 @@ public sealed class ArchiHandler : ClientMsgHandler {
return response.Result == EResult.OK; return response.Result == EResult.OK;
} }
[PublicAPI]
public async Task<CClanChatRooms_GetClanChatRoomInfo_Response?> GetClanChatRoomInfo(ulong steamID) {
if ((steamID == 0) || !new SteamID(steamID).IsClanAccount) {
throw new ArgumentOutOfRangeException(nameof(steamID));
}
if (Client == null) {
throw new InvalidOperationException(nameof(Client));
}
if (!Client.IsConnected) {
return null;
}
CClanChatRooms_GetClanChatRoomInfo_Request request = new() {
autocreate = true,
steamid = steamID
};
SteamUnifiedMessages.ServiceMethodResponse response;
try {
response = await UnifiedClanChatRoomsService.SendMessage(x => x.GetClanChatRoomInfo(request)).ToLongRunningTask().ConfigureAwait(false);
} catch (Exception e) {
ArchiLogger.LogGenericWarningException(e);
return null;
}
if (response.Result != EResult.OK) {
return null;
}
return response.GetDeserializedResponse<CClanChatRooms_GetClanChatRoomInfo_Response>();
}
internal void AckChatMessage(ulong chatGroupID, ulong chatID, uint timestamp) { internal void AckChatMessage(ulong chatGroupID, ulong chatID, uint timestamp) {
if (chatGroupID == 0) { if (chatGroupID == 0) {
throw new ArgumentOutOfRangeException(nameof(chatGroupID)); throw new ArgumentOutOfRangeException(nameof(chatGroupID));
@@ -355,43 +391,6 @@ public sealed class ArchiHandler : ClientMsgHandler {
Client.Send(request); Client.Send(request);
} }
internal async Task<ulong> GetClanChatGroupID(ulong steamID) {
if ((steamID == 0) || !new SteamID(steamID).IsClanAccount) {
throw new ArgumentOutOfRangeException(nameof(steamID));
}
if (Client == null) {
throw new InvalidOperationException(nameof(Client));
}
if (!Client.IsConnected) {
return 0;
}
CClanChatRooms_GetClanChatRoomInfo_Request request = new() {
autocreate = true,
steamid = steamID
};
SteamUnifiedMessages.ServiceMethodResponse response;
try {
response = await UnifiedClanChatRoomsService.SendMessage(x => x.GetClanChatRoomInfo(request)).ToLongRunningTask().ConfigureAwait(false);
} catch (Exception e) {
ArchiLogger.LogGenericWarningException(e);
return 0;
}
if (response.Result != EResult.OK) {
return 0;
}
CClanChatRooms_GetClanChatRoomInfo_Response body = response.GetDeserializedResponse<CClanChatRooms_GetClanChatRoomInfo_Response>();
return body.chat_group_summary.chat_group_id;
}
internal async Task<uint?> GetLevel() { internal async Task<uint?> GetLevel() {
if (Client == null) { if (Client == null) {
throw new InvalidOperationException(nameof(Client)); throw new InvalidOperationException(nameof(Client));
@@ -517,7 +516,8 @@ public sealed class ArchiHandler : ClientMsgHandler {
return body.device_identifier; return body.device_identifier;
} }
internal async Task<bool> JoinChatRoomGroup(ulong chatGroupID) { [PublicAPI]
public async Task<bool> JoinChatRoomGroup(ulong chatGroupID) {
if (chatGroupID == 0) { if (chatGroupID == 0) {
throw new ArgumentOutOfRangeException(nameof(chatGroupID)); throw new ArgumentOutOfRangeException(nameof(chatGroupID));
} }
@@ -545,6 +545,35 @@ public sealed class ArchiHandler : ClientMsgHandler {
return response.Result == EResult.OK; return response.Result == EResult.OK;
} }
[PublicAPI]
public async Task<bool> LeaveChatRoomGroup(ulong chatGroupID) {
if (chatGroupID == 0) {
throw new ArgumentOutOfRangeException(nameof(chatGroupID));
}
if (Client == null) {
throw new InvalidOperationException(nameof(Client));
}
if (!Client.IsConnected) {
return false;
}
CChatRoom_LeaveChatRoomGroup_Request request = new() { chat_group_id = chatGroupID };
SteamUnifiedMessages.ServiceMethodResponse response;
try {
response = await UnifiedChatRoomService.SendMessage(x => x.LeaveChatRoomGroup(request)).ToLongRunningTask().ConfigureAwait(false);
} catch (Exception e) {
ArchiLogger.LogGenericWarningException(e);
return false;
}
return response.Result == EResult.OK;
}
internal async Task PlayGames(IReadOnlyCollection<uint> gameIDs, string? gameName = null) { internal async Task PlayGames(IReadOnlyCollection<uint> gameIDs, string? gameName = null) {
ArgumentNullException.ThrowIfNull(gameIDs); ArgumentNullException.ThrowIfNull(gameIDs);