Akatsuki-Misaki/ArchiSteamFarm
1
0
Fork 0
mirror of https://github.com/JustArchiNET/ArchiSteamFarm.git synced 2026-01-06 17:10:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add /Api/GamesToRedeemInBackground

Browse Source 
P.S. Not tested yet, too lazy to do so as of now.
This commit is contained in:
JustArchi
2018-02-14 19:14:33 +01:00
parent ca1fcf33d8
commit 3b234f0a4d
2 changed files with 103 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
ArchiSteamFarm/Bot.cs
View File

@@ -307,6 +307,15 @@ namespace ArchiSteamFarm {
return await BotDatabase.MobileAuthenticator.HandleConfirmations(confirmations, accept).ConfigureAwait(false);
}
internal async Task AddGamesToRedeemInBackground(IReadOnlyDictionary<string, string> gamesToRedeemInBackground) {
if ((gamesToRedeemInBackground == null) || (gamesToRedeemInBackground.Count == 0)) {
ArchiLogger.LogNullError(nameof(gamesToRedeemInBackground));
return;
}
await BotDatabase.AddGamesToRedeemInBackground(gamesToRedeemInBackground).ConfigureAwait(false);
}
internal async Task<bool> DeleteAllRelatedFiles() {
try {
await BotDatabase.MakeReadOnly().ConfigureAwait(false);
@@ -1350,7 +1359,7 @@ namespace ArchiSteamFarm {
gamesToRedeemInBackground[key] = game;
}
await BotDatabase.AddGamesToRedeemInBackground(gamesToRedeemInBackground).ConfigureAwait(false);
await AddGamesToRedeemInBackground(gamesToRedeemInBackground).ConfigureAwait(false);
File.Delete(filePath);
}
} catch (Exception e) {

104
ArchiSteamFarm/IPC.cs
View File

@@ -152,6 +152,8 @@ namespace ArchiSteamFarm {
case "Command":
case "Command/":
return await HandleApiCommand(context.Request, context.Response, arguments, ++argumentsIndex).ConfigureAwait(false);
case "GamesToRedeemInBackground/":
return await HandleApiGamesToRedeemInBackground(context.Request, context.Response, arguments, ++argumentsIndex).ConfigureAwait(false);
case "Log":
return await HandleApiLog(context, arguments, ++argumentsIndex).ConfigureAwait(false);
case "Structure/":
@@ -309,34 +311,34 @@ namespace ArchiSteamFarm {
return true;
}
BotRequest botRequest;
BotRequest jsonRequest;
try {
botRequest = JsonConvert.DeserializeObject<BotRequest>(body);
jsonRequest = JsonConvert.DeserializeObject<BotRequest>(body);
} catch (Exception e) {
await ResponseJsonObject(request, response, new GenericResponse(false, string.Format(Strings.ErrorParsingObject, nameof(botRequest)) + Environment.NewLine + e), HttpStatusCode.BadRequest).ConfigureAwait(false);
await ResponseJsonObject(request, response, new GenericResponse(false, string.Format(Strings.ErrorParsingObject, nameof(jsonRequest)) + Environment.NewLine + e), HttpStatusCode.BadRequest).ConfigureAwait(false);
return true;
}
string botName = WebUtility.UrlDecode(arguments[argumentsIndex]);
if (botRequest.KeepSensitiveDetails && Bot.Bots.TryGetValue(botName, out Bot bot)) {
if (string.IsNullOrEmpty(botRequest.BotConfig.SteamLogin)) {
botRequest.BotConfig.SteamLogin = bot.BotConfig.SteamLogin;
if (jsonRequest.KeepSensitiveDetails && Bot.Bots.TryGetValue(botName, out Bot bot)) {
if (string.IsNullOrEmpty(jsonRequest.BotConfig.SteamLogin)) {
jsonRequest.BotConfig.SteamLogin = bot.BotConfig.SteamLogin;
}
if (string.IsNullOrEmpty(botRequest.BotConfig.SteamParentalPIN)) {
botRequest.BotConfig.SteamParentalPIN = bot.BotConfig.SteamParentalPIN;
if (string.IsNullOrEmpty(jsonRequest.BotConfig.SteamParentalPIN)) {
jsonRequest.BotConfig.SteamParentalPIN = bot.BotConfig.SteamParentalPIN;
}
if (string.IsNullOrEmpty(botRequest.BotConfig.SteamPassword)) {
botRequest.BotConfig.SteamPassword = bot.BotConfig.SteamPassword;
if (string.IsNullOrEmpty(jsonRequest.BotConfig.SteamPassword)) {
jsonRequest.BotConfig.SteamPassword = bot.BotConfig.SteamPassword;
}
}
string filePath = Path.Combine(SharedInfo.ConfigDirectory, botName + ".json");
if (!await BotConfig.Write(filePath, botRequest.BotConfig).ConfigureAwait(false)) {
if (!await BotConfig.Write(filePath, jsonRequest.BotConfig).ConfigureAwait(false)) {
await ResponseJsonObject(request, response, new GenericResponse(false, "Writing bot config failed, check ASF log for details"), HttpStatusCode.BadRequest).ConfigureAwait(false);
return true;
}
@@ -399,6 +401,75 @@ namespace ArchiSteamFarm {
return true;
}
private static async Task<bool> HandleApiGamesToRedeemInBackground(HttpListenerRequest request, HttpListenerResponse response, string[] arguments, byte argumentsIndex) {
if ((request == null) || (response == null) || (arguments == null) || (argumentsIndex == 0)) {
ASF.ArchiLogger.LogNullError(nameof(request) + " || " + nameof(response) + " || " + nameof(arguments) + " || " + nameof(argumentsIndex));
return false;
}
switch (request.HttpMethod) {
case HttpMethods.Post:
return await HandleApiGamesToRedeemInBackgroundPost(request, response, arguments, argumentsIndex).ConfigureAwait(false);
default:
await ResponseStatusCode(request, response, HttpStatusCode.MethodNotAllowed).ConfigureAwait(false);
return true;
}
}
private static async Task<bool> HandleApiGamesToRedeemInBackgroundPost(HttpListenerRequest request, HttpListenerResponse response, string[] arguments, byte argumentsIndex) {
if ((request == null) || (response == null) || (arguments == null) || (argumentsIndex == 0)) {
ASF.ArchiLogger.LogNullError(nameof(request) + " || " + nameof(response) + " || " + nameof(arguments) + " || " + nameof(argumentsIndex));
return false;
}
if (arguments.Length <= argumentsIndex) {
return false;
}
string botName = WebUtility.UrlDecode(arguments[argumentsIndex]);
if (!Bot.Bots.TryGetValue(botName, out Bot bot)) {
await ResponseJsonObject(request, response, new GenericResponse(false, string.Format(Strings.BotNotFound, botName)), HttpStatusCode.BadRequest).ConfigureAwait(false);
return true;
}
const string requiredContentType = "application/json";
if (request.ContentType != requiredContentType) {
await ResponseJsonObject(request, response, new GenericResponse(false, nameof(request.ContentType) + " must be declared as " + requiredContentType), HttpStatusCode.NotAcceptable).ConfigureAwait(false);
return true;
}
string body;
using (StreamReader reader = new StreamReader(request.InputStream)) {
body = await reader.ReadToEndAsync().ConfigureAwait(false);
}
if (string.IsNullOrEmpty(body)) {
await ResponseJsonObject(request, response, new GenericResponse(false, string.Format(Strings.ErrorIsEmpty, nameof(body))), HttpStatusCode.BadRequest).ConfigureAwait(false);
return true;
}
GamesToRedeemInBackgroundRequest jsonRequest;
try {
jsonRequest = JsonConvert.DeserializeObject<GamesToRedeemInBackgroundRequest>(body);
} catch (Exception e) {
await ResponseJsonObject(request, response, new GenericResponse(false, string.Format(Strings.ErrorParsingObject, nameof(jsonRequest)) + Environment.NewLine + e), HttpStatusCode.BadRequest).ConfigureAwait(false);
return true;
}
if (jsonRequest.GamesToRedeemInBackground.Count == 0) {
await ResponseJsonObject(request, response, new GenericResponse(false, string.Format(Strings.ErrorIsEmpty, nameof(jsonRequest.GamesToRedeemInBackground))), HttpStatusCode.BadRequest).ConfigureAwait(false);
return true;
}
await bot.AddGamesToRedeemInBackground(jsonRequest.GamesToRedeemInBackground).ConfigureAwait(false);
await ResponseJsonObject(request, response, new GenericResponse(true, "OK")).ConfigureAwait(false);
return true;
}
private static async Task<bool> HandleApiLog(HttpListenerContext context, string[] arguments, byte argumentsIndex) {
if ((context == null) || (arguments == null) || (argumentsIndex == 0)) {
ASF.ArchiLogger.LogNullError(nameof(context) + " || " + nameof(arguments) + " || " + nameof(argumentsIndex));
@@ -894,6 +965,17 @@ namespace ArchiSteamFarm {
private BotRequest() { }
}
[SuppressMessage("ReSharper", "ClassCannotBeInstantiated")]
private sealed class GamesToRedeemInBackgroundRequest {
#pragma warning disable 649
[JsonProperty(Required = Required.Always)]
internal readonly Dictionary<string, string> GamesToRedeemInBackground;
#pragma warning restore 649
// Deserialized from JSON
private GamesToRedeemInBackgroundRequest() { }
}
private sealed class GenericResponse {
[JsonProperty]
private readonly string Message;