334 lines
14 KiB
C#
334 lines
14 KiB
C#
|
using System;
|
||
|
|
using System.Collections.Generic;
|
||
|
|
using System.Diagnostics;
|
||
|
|
using System.Globalization;
|
||
|
|
using System.Linq;
|
||
|
|
using System.Threading.Tasks;
|
||
|
|
using Windows.ApplicationModel.Core;
|
||
|
|
using Windows.ApplicationModel.Store;
|
||
|
|
using Windows.System;
|
||
|
|
using Windows.UI.Core;
|
||
|
|
|
||
|
|
#pragma warning disable 4014
|
||
|
|
namespace UnityEngine.Purchasing.Default
|
||
|
|
{
|
||
|
|
class WinRTStore : IWindowsIAP
|
||
|
|
{
|
||
|
|
|
||
|
|
private IWindowsIAPCallback callback;
|
||
|
|
private ICurrentApp currentApp;
|
||
|
|
private Dictionary<string, string> transactionIdToProductId = new Dictionary<string, string>();
|
||
|
|
|
||
|
|
private int m_loginDelay;
|
||
|
|
|
||
|
|
public WinRTStore(ICurrentApp currentApp)
|
||
|
|
{
|
||
|
|
this.currentApp = currentApp;
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
public void Initialize(IWindowsIAPCallback callback)
|
||
|
|
{
|
||
|
|
this.callback = callback;
|
||
|
|
this.m_loginDelay = 30;
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
public void Initialize(IWindowsIAPCallback callback, int delayTime = 30)
|
||
|
|
{
|
||
|
|
this.callback = callback;
|
||
|
|
this.m_loginDelay = delayTime;
|
||
|
|
}
|
||
|
|
|
||
|
|
public void SetLoginDelay(int delayTime)
|
||
|
|
{
|
||
|
|
this.m_loginDelay = delayTime;
|
||
|
|
}
|
||
|
|
|
||
|
|
public int LoginDelay()
|
||
|
|
{
|
||
|
|
return m_loginDelay;
|
||
|
|
}
|
||
|
|
|
||
|
|
public void RetrieveProducts(bool persistent)
|
||
|
|
{
|
||
|
|
RunOnUIThread(() =>
|
||
|
|
{
|
||
|
|
if (LoginDelay() > 0)
|
||
|
|
{
|
||
|
|
PollForProducts(persistent, 0, LoginDelay(), true, false);
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
PollForProducts(persistent, 0);
|
||
|
|
}
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
private async void PollForProducts(bool persistent, int delay, int retryCount = 10, bool tryLogin = false, bool loginAttempted = false, bool productsOnly = false)
|
||
|
|
{
|
||
|
|
await Task.Delay(delay);
|
||
|
|
try
|
||
|
|
{
|
||
|
|
var result = await DoRetrieveProducts(productsOnly);
|
||
|
|
callback.OnProductListReceived(result);
|
||
|
|
}
|
||
|
|
catch (Exception e)
|
||
|
|
{
|
||
|
|
|
||
|
|
LogError("PollForProducts() Exception (persistent = {0}, delay = {1}, retry = {2}), exception: {3}", persistent, delay, retryCount, e.Message);
|
||
|
|
|
||
|
|
// NB: persistent here is used to distinguish when this is used by restoreTransactions() so we will
|
||
|
|
// keep it intact and supplement for retries on initialization
|
||
|
|
//
|
||
|
|
if (persistent)
|
||
|
|
{
|
||
|
|
// This seems to indicate the App is not uploaded on
|
||
|
|
// the dev portal, but is undocumented by Microsoft.
|
||
|
|
if (e.Message.Contains("801900CC"))
|
||
|
|
{
|
||
|
|
LogError("Exception loading listing information: {0}", e.Message);
|
||
|
|
callback.OnProductListError("AppNotKnown");
|
||
|
|
// JDRjr: in the main store code this is not being checked correctly
|
||
|
|
// and will result in repeated init attempts. Leaving it for now, but broken...
|
||
|
|
}
|
||
|
|
else if (e.Message.Contains("80070525"))
|
||
|
|
{
|
||
|
|
LogError("PollForProducts() User not signed in error HResult = 0x{0:X} (delay = {1}, retry = {2})", e.HResult, delay, retryCount);
|
||
|
|
if ((delay == 0) && (productsOnly == false))
|
||
|
|
{
|
||
|
|
// First time failure give products only a try
|
||
|
|
PollForProducts(true, 1000, retryCount, tryLogin, loginAttempted, true);
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
// Gonna call this an error
|
||
|
|
LogError("Calling OnProductListError() delay = {0}, productsOnly = {1}", delay, productsOnly);
|
||
|
|
callback.OnProductListError("801900CC because the C# code is broken");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
// other (no special handling) error codes
|
||
|
|
// Wait up to 5 mins.
|
||
|
|
// JDRjr: this seems like too long...
|
||
|
|
delay = Math.Max(5000, delay);
|
||
|
|
var newDelay = Math.Min(300000, delay * 2);
|
||
|
|
PollForProducts(true, newDelay);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
// This is a restore attempt that has thrown an exception
|
||
|
|
// We should allow for a login attempt here as well...
|
||
|
|
if (tryLogin == true)
|
||
|
|
{
|
||
|
|
var uri = new Uri("ms-windows-store://signin");
|
||
|
|
var loginResult = await global::Windows.System.Launcher.LaunchUriAsync(uri);
|
||
|
|
|
||
|
|
PollForProducts(true, 1000, retryCount, false, true, false);
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
if (retryCount > 0)
|
||
|
|
{
|
||
|
|
if (loginAttempted)
|
||
|
|
{
|
||
|
|
// Will wait for retryCount seconds...
|
||
|
|
PollForProducts(true, 1000, --retryCount, false, true);
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
// Wait up to 5 mins.
|
||
|
|
delay = Math.Max(5000, delay);
|
||
|
|
var newDelay = Math.Min(300000, delay * 2);
|
||
|
|
PollForProducts(true, newDelay, --retryCount, false, false);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
callback.OnProductListError("801900CC because the C# code is broken");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
} // end of catch()
|
||
|
|
}
|
||
|
|
|
||
|
|
private async Task<WinProductDescription[]> DoRetrieveProducts(bool productsOnly)
|
||
|
|
{
|
||
|
|
ListingInformation result = await currentApp.LoadListingInformationAsync();
|
||
|
|
|
||
|
|
if (productsOnly == false)
|
||
|
|
{
|
||
|
|
// We need a comprehensive list of transaction IDs for owned items.
|
||
|
|
// Microsoft make this difficult by failing to provide transaction IDs
|
||
|
|
// on product licenses that are owned.
|
||
|
|
// Therefore two data sets are joined; unfulfilled consumables (which have product IDs)
|
||
|
|
// and transactions from the App receipt (Durables).
|
||
|
|
var unfulfilledConsumables = await currentApp.GetUnfulfilledConsumablesAsync();
|
||
|
|
var transactionMap = unfulfilledConsumables.ToDictionary(x => x.ProductId, x => x.TransactionId.ToString());
|
||
|
|
|
||
|
|
// Add transaction IDs from our app receipt.
|
||
|
|
string appReceipt = null;
|
||
|
|
try
|
||
|
|
{
|
||
|
|
appReceipt = await currentApp.RequestAppReceiptAsync();
|
||
|
|
}
|
||
|
|
catch (Exception e)
|
||
|
|
{
|
||
|
|
LogError("Unable to retrieve app receipt:{0}", e.Message);
|
||
|
|
}
|
||
|
|
|
||
|
|
var receiptTransactions = XMLUtils.ParseProducts(appReceipt);
|
||
|
|
foreach (var receiptTran in receiptTransactions)
|
||
|
|
{
|
||
|
|
transactionMap[receiptTran.productId] = receiptTran.transactionId;
|
||
|
|
}
|
||
|
|
|
||
|
|
// Create fake transaction Ids for any owned items that we can't find transaction IDs for.
|
||
|
|
foreach (var license in currentApp.LicenseInformation.ProductLicenses)
|
||
|
|
{
|
||
|
|
if (!transactionMap.ContainsKey(license.Key))
|
||
|
|
{
|
||
|
|
transactionMap[license.Key] = license.Key.GetHashCode().ToString();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
// Construct our products including receipts and transaction ID where owned
|
||
|
|
var productDescriptions = from listing in result.ProductListings.Values
|
||
|
|
let priceDecimal = TryParsePrice(listing.FormattedPrice)
|
||
|
|
let transactionId = transactionMap.ContainsKey(listing.ProductId) ? transactionMap[listing.ProductId] : null
|
||
|
|
let receipt = transactionId == null ? null : appReceipt
|
||
|
|
select new WinProductDescription(listing.ProductId,
|
||
|
|
listing.FormattedPrice, listing.Name, string.Empty, RegionInfo.CurrentRegion.ISOCurrencySymbol,
|
||
|
|
priceDecimal, receipt, transactionId);
|
||
|
|
|
||
|
|
// Transaction IDs tracked for finalising transactions
|
||
|
|
transactionIdToProductId = transactionMap.ToDictionary(x => x.Value, x => x.Key);
|
||
|
|
return productDescriptions.ToArray();
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
var productDescriptions = from listing in result.ProductListings.Values
|
||
|
|
let priceDecimal = TryParsePrice(listing.FormattedPrice)
|
||
|
|
select new WinProductDescription(listing.ProductId,
|
||
|
|
listing.FormattedPrice, listing.Name, string.Empty, RegionInfo.CurrentRegion.ISOCurrencySymbol,
|
||
|
|
priceDecimal, null, null);
|
||
|
|
return productDescriptions.ToArray();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
private decimal TryParsePrice(string formattedPrice)
|
||
|
|
{
|
||
|
|
decimal price = 0;
|
||
|
|
decimal.TryParse(formattedPrice, NumberStyles.Currency, CultureInfo.CurrentCulture, out price);
|
||
|
|
return price;
|
||
|
|
}
|
||
|
|
|
||
|
|
public void Purchase(string productId)
|
||
|
|
{
|
||
|
|
RunOnUIThread(async () =>
|
||
|
|
{
|
||
|
|
try
|
||
|
|
{
|
||
|
|
var result = await currentApp.RequestProductPurchaseAsync(productId);
|
||
|
|
switch (result.Status)
|
||
|
|
{
|
||
|
|
case ProductPurchaseStatus.Succeeded:
|
||
|
|
onPurchaseSucceeded(productId, result.ReceiptXml, result.TransactionId);
|
||
|
|
break;
|
||
|
|
case ProductPurchaseStatus.NotFulfilled:
|
||
|
|
case ProductPurchaseStatus.AlreadyPurchased:
|
||
|
|
case ProductPurchaseStatus.NotPurchased:
|
||
|
|
callback.OnPurchaseFailed(productId, result.Status.ToString());
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
catch (Exception e)
|
||
|
|
{
|
||
|
|
callback.OnPurchaseFailed(productId, e.Message);
|
||
|
|
}
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
private async Task FulfillConsumable(string productId, string transactionId)
|
||
|
|
{
|
||
|
|
try
|
||
|
|
{
|
||
|
|
var result = await currentApp.ReportConsumableFulfillmentAsync(productId, Guid.Parse(transactionId));
|
||
|
|
|
||
|
|
if (FulfillmentResult.Succeeded == result)
|
||
|
|
{
|
||
|
|
lock (transactionIdToProductId)
|
||
|
|
{
|
||
|
|
transactionIdToProductId.Remove(transactionId);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// It doesn't matter if the consumption succeeds or not.
|
||
|
|
// If it doesn't, it will eventually be retried automatically.
|
||
|
|
}
|
||
|
|
catch (Exception e)
|
||
|
|
{
|
||
|
|
LogError("Exception consuming {0} : {1} (non-fatal)", productId, e.Message);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
private void LogError(string message, params object[] formatArgs)
|
||
|
|
{
|
||
|
|
callback.logError(string.Format("UnityIAPWin8:" + message, formatArgs));
|
||
|
|
}
|
||
|
|
|
||
|
|
private void onPurchaseSucceeded(string productId, string receipt, Guid transactionId)
|
||
|
|
{
|
||
|
|
var tranId = transactionId.ToString();
|
||
|
|
// Make a note of which product this transaction pertains to.
|
||
|
|
lock (transactionIdToProductId)
|
||
|
|
{
|
||
|
|
transactionIdToProductId[tranId] = productId;
|
||
|
|
}
|
||
|
|
callback.OnPurchaseSucceeded(productId, receipt, tranId);
|
||
|
|
}
|
||
|
|
|
||
|
|
public void FinaliseTransaction(string transactionId)
|
||
|
|
{
|
||
|
|
RunOnUIThread(() =>
|
||
|
|
{
|
||
|
|
// We occasionally supply null transaction IDs,
|
||
|
|
// to the biller for owned non consumables.
|
||
|
|
// The biller will try to finalise these, so we
|
||
|
|
// ignore them.
|
||
|
|
if (!string.IsNullOrEmpty(transactionId))
|
||
|
|
{
|
||
|
|
if (transactionIdToProductId.ContainsKey(transactionId))
|
||
|
|
{
|
||
|
|
FulfillConsumable(transactionIdToProductId[transactionId], transactionId);
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
callback.logError("Nothing to fulfill for transaction " + transactionId);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
private static void RunOnUIThread(Action a)
|
||
|
|
{
|
||
|
|
CoreApplication.MainView.CoreWindow.Dispatcher.RunAsync(CoreDispatcherPriority.Normal, () =>
|
||
|
|
{
|
||
|
|
a();
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary>
|
||
|
|
/// Builds a dummy list of Products.
|
||
|
|
/// </summary>
|
||
|
|
/// <param name="products"> The list of product descriptions. </param>
|
||
|
|
public void BuildDummyProducts(List<WinProductDescription> products)
|
||
|
|
{
|
||
|
|
currentApp.BuildMockProducts(products);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
#pragma warning restore 4014
|