diff --git a/ShareX.UploadersLib/BaseUploaders/Uploader.cs b/ShareX.UploadersLib/BaseUploaders/Uploader.cs index 90955e945..98f2a9286 100644 --- a/ShareX.UploadersLib/BaseUploaders/Uploader.cs +++ b/ShareX.UploadersLib/BaseUploaders/Uploader.cs @@ -511,7 +511,7 @@ private string ResponseToString(WebResponse response, ResponseType responseType return null; } - private string CreateQuery(Dictionary args) + protected string CreateQuery(Dictionary args) { if (args != null && args.Count > 0) { diff --git a/ShareX.UploadersLib/FileUploaders/AmazonS3.cs b/ShareX.UploadersLib/FileUploaders/AmazonS3.cs new file mode 100644 index 000000000..73f25a904 --- /dev/null +++ b/ShareX.UploadersLib/FileUploaders/AmazonS3.cs @@ -0,0 +1,209 @@ +#region License Information (GPL v3) + +/* + ShareX - A program that allows you to take screenshots and share any file type + Copyright (c) 2007-2017 ShareX Team + + This program is free software; you can redistribute it and/or + modify it under the terms of the GNU General Public License + as published by the Free Software Foundation; either version 2 + of the License, or (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. + + Optionally you can also view the license at . +*/ + +#endregion License Information (GPL v3) + +using ShareX.HelpersLib; +using ShareX.UploadersLib.Properties; +using System; +using System.Collections.Generic; +using System.Collections.Specialized; +using System.Drawing; +using System.Globalization; +using System.IO; +using System.Linq; +using System.Security.Cryptography; +using System.Text; +using System.Windows.Forms; + +namespace ShareX.UploadersLib.FileUploaders +{ + public class AmazonS3NewFileUploaderService : FileUploaderService + { + public override FileDestination EnumValue { get; } = FileDestination.AmazonS3; + + public override Icon ServiceIcon => Resources.AmazonS3; + + public override bool CheckConfig(UploadersConfig config) + { + return config.AmazonS3Settings != null && !string.IsNullOrEmpty(config.AmazonS3Settings.AccessKeyID) && + !string.IsNullOrEmpty(config.AmazonS3Settings.SecretAccessKey) && !string.IsNullOrEmpty(config.AmazonS3Settings.Bucket) && + !string.IsNullOrEmpty(config.AmazonS3Settings.Endpoint); + } + + public override GenericUploader CreateUploader(UploadersConfig config, TaskReferenceHelper taskInfo) + { + return new AmazonS3(config.AmazonS3Settings); + } + + public override TabPage GetUploadersConfigTabPage(UploadersConfigForm form) => form.tpAmazonS3; + } + + public sealed class AmazonS3 : FileUploader + { + private AmazonS3Settings Settings { get; set; } + + public AmazonS3(AmazonS3Settings settings) + { + Settings = settings; + } + + public override UploadResult Upload(Stream stream, string fileName) + { + string host = $"{Settings.Bucket}.s3.{Settings.Endpoint}.amazonaws.com"; + string algorithm = "AWS4-HMAC-SHA256"; + string credentialDate = DateTime.UtcNow.ToString("yyyyMMdd", CultureInfo.InvariantCulture); + string scope = $"{credentialDate}/{Settings.Endpoint}/s3/aws4_request"; + string credential = $"{Settings.AccessKeyID}/{scope}"; + string longDate = DateTime.UtcNow.ToString("yyyyMMddTHHmmssZ", CultureInfo.InvariantCulture); + string expiresTotalSeconds = ((long)TimeSpan.FromHours(1).TotalSeconds).ToString(); + string contentType = Helpers.GetMimeType(fileName); + + Dictionary args = new Dictionary(); + args.Add("X-Amz-Algorithm", algorithm); + args.Add("X-Amz-Credential", credential); + args.Add("X-Amz-Date", longDate); + args.Add("X-Amz-Expires", expiresTotalSeconds); + args.Add("X-Amz-SignedHeaders", "content-type;host;x-amz-acl;x-amz-storage-class"); + + NameValueCollection headers = new NameValueCollection(); + headers["content-type"] = contentType; + headers["host"] = host; + headers["x-amz-acl"] = "public-read"; + headers["x-amz-storage-class"] = Settings.UseReducedRedundancyStorage ? "REDUCED_REDUNDANCY" : "STANDARD"; + + string uploadPath = GetUploadPath(fileName); + string canonicalURI = URLHelpers.AddSlash(uploadPath, SlashType.Prefix); + canonicalURI = URLHelpers.URLPathEncode(canonicalURI); + + string canonicalQueryString = CreateQuery(args); + string canonicalHeaders = CreateCanonicalHeaders(headers); + string signedHeaders = GetSignedHeaders(headers); + + string canonicalRequest = "PUT" + "\n" + + canonicalURI + "\n" + + canonicalQueryString + "\n" + + canonicalHeaders + "\n" + + signedHeaders + "\n" + + "UNSIGNED-PAYLOAD"; + + string stringToSign = algorithm + "\n" + + longDate + "\n" + + scope + "\n" + + BytesToHex(ComputeHash(canonicalRequest)); + + string dateKey = ComputeHMAC("AWS4" + Settings.SecretAccessKey, credentialDate); + string dateRegionKey = ComputeHMAC(dateKey, Settings.Endpoint); + string dateRegionServiceKey = ComputeHMAC(dateRegionKey, "s3"); + string signingKey = ComputeHMAC(dateRegionServiceKey, "aws4_request"); + + string signature = StringToHex(ComputeHMAC(signingKey, stringToSign)); + + args.Add("X-Amz-Signature", signature); + + headers.Remove("content-type"); + headers.Remove("host"); + + string url = URLHelpers.ForcePrefix(host, "https://"); + url = URLHelpers.CombineURL(url, canonicalURI); + url = CreateQuery(url, args); + + NameValueCollection responseHeaders = SendRequestGetHeaders(HttpMethod.PUT, url, stream, contentType, null, headers); + + if (responseHeaders == null || responseHeaders.Count == 0) + { + Errors.Add("Upload to Amazon S3 failed. Check your access credentials."); + return null; + } + + string eTag = responseHeaders.Get("ETag"); + + if (eTag == null) + { + Errors.Add("Upload to Amazon S3 failed."); + return null; + } + + return new UploadResult + { + IsSuccess = true, + URL = URLHelpers.CombineURL($"https://s3.{Settings.Endpoint}.amazonaws.com", Settings.Bucket, uploadPath, fileName) + }; + } + + private string GetUploadPath(string fileName) + { + string path = NameParser.Parse(NameParserType.FolderPath, Settings.ObjectPrefix.Trim('/')); + return URLHelpers.CombineURL(path, fileName); + } + + private string CreateCanonicalHeaders(NameValueCollection headers) + { + string result = ""; + + foreach (string key in headers) + { + result += key.ToLowerInvariant() + ":" + headers[key].ToLowerInvariant().Trim() + "\n"; + } + + return result; + } + + private string GetSignedHeaders(NameValueCollection headers) + { + return string.Join(";", headers.AllKeys.Select(x => x.ToLowerInvariant())); + } + + private byte[] ComputeHash(string data) + { + byte[] bytes = Encoding.UTF8.GetBytes(data); + SHA256Managed hashstring = new SHA256Managed(); + byte[] hash = hashstring.ComputeHash(bytes); + return hash; + } + + private string ComputeHMAC(string data, string key) + { + using (HashAlgorithm hashAlgorithm = new HMACSHA256(Encoding.UTF8.GetBytes(key))) + { + byte[] buffer = Encoding.UTF8.GetBytes(data); + return Convert.ToBase64String(hashAlgorithm.ComputeHash(buffer)); + } + } + + private string BytesToHex(byte[] bytes) + { + StringBuilder sb = new StringBuilder(); + foreach (byte x in bytes) + { + sb.Append(string.Format("{0:x2}", x)); + } + return sb.ToString(); + } + + private string StringToHex(string text) + { + return BytesToHex(Encoding.UTF8.GetBytes(text)); + } + } +} \ No newline at end of file diff --git a/ShareX.UploadersLib/ShareX.UploadersLib.csproj b/ShareX.UploadersLib/ShareX.UploadersLib.csproj index f9f0b4635..474260a29 100644 --- a/ShareX.UploadersLib/ShareX.UploadersLib.csproj +++ b/ShareX.UploadersLib/ShareX.UploadersLib.csproj @@ -114,6 +114,7 @@ +