Change access token for migration

Author: abuzuhri

Source/FikaAmazonAPI.SampleCode/Program.cs

@@ -35,7 +35,21 @@ static async Task Main(string[] args)
                 IsActiveLimitRate = true
             });
 
-
+            AmazonConnection codeAmazonConnection = new AmazonConnection(new AmazonCredential()
+            {
+                AccessKey = config.GetSection("MWSAmazonAPI:AccessKey").Value,
+                SecretKey = config.GetSection("MWSAmazonAPI:SecretKey").Value,
+                ClientId = config.GetSection("MWSAmazonAPI:ClientId").Value,
+                ClientSecret = config.GetSection("MWSAmazonAPI:ClientSecret").Value,
+                MarketPlace = MarketPlace.GetMarketPlaceByID(config.GetSection("FikaAmazonAPI:MarketPlaceID").Value),
+                IsActiveLimitRate = true
+            });
+            var code = codeAmazonConnection.Authorization.GetAuthorizationCode(new Parameter.Authorization.ParameterAuthorizationCode()
+            {
+                developerId = "673740111638",
+                mwsAuthToken = "amzn.mws.f0b83c90-ac85-07fc-f35b-9b9021fcbcf3",
+                sellingPartnerId = "A3J37AJU4O9RHK"
+            });
 
             var aha = amazonConnection.ProductType.SearchDefinitionsProductTypes(new Parameter.ProductTypes.SearchDefinitionsProductTypesParameter()
             {

Source/FikaAmazonAPI/AmazonSpApiSDK/Models/Authorization/Error.cs

@@ -28,7 +28,7 @@ public partial class Error : IEquatable<Error>, IValidatableObject
         /// Initializes a new instance of the <see cref="Error" /> class.
         /// </summary>
         [JsonConstructorAttribute]
-        protected Error() { }
+        public Error() { }
         /// <summary>
         /// Initializes a new instance of the <see cref="Error" /> class.
         /// </summary>

Source/FikaAmazonAPI/Services/TokenGeneration.cs

@@ -3,9 +3,13 @@
 using FikaAmazonAPI.AmazonSpApiSDK.Models.Token;
 using FikaAmazonAPI.AmazonSpApiSDK.Runtime;
 using FikaAmazonAPI.Utils;
+using Newtonsoft.Json;
 using RestSharp;
 using System;
 using System.Collections.Generic;
+using System.Net.Http;
+using System.Net.Http.Headers;
+using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
 using static FikaAmazonAPI.AmazonSpApiSDK.Models.Token.CacheTokenData;
@@ -17,33 +21,54 @@ public static class TokenGeneration
 
         public static async Task<TokenResponse> RefreshAccessTokenAsync(AmazonCredential credentials, TokenDataType tokenDataType = TokenDataType.Normal)
         {
-            var lwaCredentials = new LWAAuthorizationCredentials()
+            if (tokenDataType == TokenDataType.MigrationOnly)
             {
-                ClientId = credentials.ClientId,
-                ClientSecret = credentials.ClientSecret,
-                Endpoint = new Uri(Constants.AmazonToeknEndPoint),
-                RefreshToken = credentials.RefreshToken,
-                Scopes = null
-            };
-            if (tokenDataType == TokenDataType.Grantless)
-                lwaCredentials.Scopes = new List<string>() { ScopeConstants.ScopeMigrationAPI, ScopeConstants.ScopeNotificationsAPI };
-            else if (tokenDataType == TokenDataType.MigrationOnly)
+                var accessToken = await GetAccessTokenForSPAPIMigration(credentials.ClientId, credentials.ClientSecret);
+                return accessToken;
+            }
+            else
             {
-                lwaCredentials = new LWAAuthorizationCredentials()
+                var lwaCredentials = new LWAAuthorizationCredentials()
                 {
                     ClientId = credentials.ClientId,
                     ClientSecret = credentials.ClientSecret,
                     Endpoint = new Uri(Constants.AmazonToeknEndPoint),
-                    Scopes = new List<string>() { ScopeConstants.ScopeMigrationAPI }
+                    RefreshToken = credentials.RefreshToken,
+                    Scopes = null
                 };
-            }
+                if (tokenDataType == TokenDataType.Grantless)
+                    lwaCredentials.Scopes = new List<string>() { ScopeConstants.ScopeMigrationAPI, ScopeConstants.ScopeNotificationsAPI };
 
-            var Client = new LWAClient(lwaCredentials);
-            var accessToken = await Client.GetAccessTokenAsync();
+                var Client = new LWAClient(lwaCredentials);
+                var accessToken = await Client.GetAccessTokenAsync();
 
-            return accessToken;
+                return accessToken;
+            }
         }
 
+        public static async Task<TokenResponse> GetAccessTokenForSPAPIMigration(string ClientId, string ClientSecret)
+        {
+            string data = string.Empty;
+
+            using (HttpClient client = new HttpClient())
+            {
+                client.BaseAddress = new Uri("https://api.amazon.com");
+                var byteArray = Encoding.ASCII.GetBytes($"{ClientId}:{ClientSecret}");
+                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Basic", Convert.ToBase64String(byteArray));
+
+                Dictionary<string, string> items = new Dictionary<string, string>();
+                items.Add("grant_type", "client_credentials");
+                items.Add("scope", "sellingpartnerapi::migration");
+                items.Add("client_id", ClientId);
+                items.Add("client_secret", ClientSecret);
+
+                FormUrlEncodedContent formUrlEncodedContent = new FormUrlEncodedContent(items);
+                var rs = client.PostAsync("/auth/o2/token", formUrlEncodedContent).Result;
+                data = await rs.Content.ReadAsStringAsync();
+            }
+
+            return JsonConvert.DeserializeObject<TokenResponse>(data);
+        }
 
         public static async Task<IRestRequest> SignWithSTSKeysAndSecurityTokenAsync(IRestRequest restRequest, string host, AmazonCredential amazonCredential, bool isMigration = false)
         {