Offline maps

sdkproject/Assets/Mapbox/Core/mapbox-sdk-cs/Platform/Cache/CacheItem.cs

@@ -13,7 +13,7 @@ public class CacheItem
 		public long AddedToCacheTicksUtc;
 		/// <summary> ETag value of API response. https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/ETag </summary>
 		public string ETag;
-		/// <summary> Can be 'null' as not all APIs populated this value. Last-Modified value of API response in GMT: https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Last-Modified </summary>
-		public DateTime? LastModified;
+
+		public DateTime ExpirationDate;
 	}
 }

sdkproject/Assets/Mapbox/Core/mapbox-sdk-cs/Platform/Cache/CachingWebFileSource.cs

@@ -5,14 +5,10 @@
 	using System.Collections.Generic;
 	using Mapbox.Unity.Utilities;
 	using Mapbox.Map;
-	using System.Collections;
-	using System.Linq;
 
 
 	public class CachingWebFileSource : IFileSource, IDisposable
 	{
-
-
 #if MAPBOX_DEBUG_CACHE
 		private string _className;
 #endif
@@ -22,6 +18,8 @@ public class CachingWebFileSource : IFileSource, IDisposable
 		private Func<string> _getMapsSkuToken;
 		private bool _autoRefreshCache;
 
+		private const string EtagHeaderName = "ETag";
+		private const string CacheControlHeaderName = "Cache-Control";
 
 		public CachingWebFileSource(string accessToken, Func<string> getMapsSkuToken, bool autoRefreshCache)
 		{
@@ -34,8 +32,7 @@ public CachingWebFileSource(string accessToken, Func<string> getMapsSkuToken, bo
 		}
 
 
-#region idisposable
-
+		#region idisposable
 
 		~CachingWebFileSource()
 		{
@@ -64,12 +61,12 @@ protected virtual void Dispose(bool disposeManagedResources)
 						}
 					}
 				}
+
 				_disposed = true;
 			}
 		}
 
-
-#endregion
+		#endregion
 
 
 		/// <summary>
@@ -102,7 +99,8 @@ public void Clear()
 		}
 
 
-		public void ReInit() {
+		public void ReInit()
+		{
 			foreach (var cache in _caches)
 			{
 				cache.ReInit();
@@ -118,7 +116,6 @@ string uri
 			, string tilesetId = null
 		)
 		{
-
 			if (string.IsNullOrEmpty(tilesetId))
 			{
 				throw new Exception("Cannot cache without a tileset id");
@@ -150,6 +147,7 @@ string uri
 					uriBuilder.Query = accessTokenQuery + "&" + mapsSkuToken;
 				}
 			}
+
 			string finalUrl = uriBuilder.ToString();
 
 #if MAPBOX_DEBUG_CACHE
@@ -166,58 +164,49 @@ string uri
 				callback(Response.FromCache(cachedItem.Data));
 
 				// check for updated tiles online if this is enabled in the settings
-				if (_autoRefreshCache)
+				if (cachedItem.ExpirationDate < DateTime.Now)
 				{
 					// check if tile on the web is newer than the one we already have locally
 					IAsyncRequestFactory.CreateRequest(
 						finalUrl,
-						(Response headerOnly) =>
+						timeout,
+						"If-None-Match", cachedItem.ETag,
+						(Response response) =>
 						{
 							// on error getting information from API just return. tile we have locally has already been returned above
-							if (headerOnly.HasError)
+							if (response.HasError || response.StatusCode == null)
 							{
 								return;
 							}
 
-							// TODO: remove Debug.Log before PR
-							//UnityEngine.Debug.LogFormat(
-							//	"{1}{0}cached:{2}{0}header:{3}"
-							//	, Environment.NewLine
-							//	, finalUrl
-							//	, cachedItem.ETag
-							//	, headerOnly.Headers["ETag"]
-							//);
-
 							// data from cache is the same as on the web:
 							//   * tile has already been returned above
 							//   * make sure all all other caches have it too, but don't force insert via cache.add(false)
 							// additional ETag empty check: for backwards compability with old caches
-							if (!string.IsNullOrEmpty(cachedItem.ETag) && cachedItem.ETag.Equals(headerOnly.Headers["ETag"]))
+							if (response.StatusCode == 304) // 304 NOT MODIFIED
 							{
-								foreach (var cache in _caches)
-								{
-									cache.Add(tilesetId, tileId, cachedItem, false);
-								}
+								cachedItem.ExpirationDate = response.GetExpirationDate();
+							}
+							else if (response.StatusCode == 200) // 200 OK, it means etag&data has changed so need to update cache
+							{
+								string eTag = response.GetETag();
+
+								// not all APIs populate 'Last-Modified' header
+								// don't log error if it's missing
+								DateTime expirationDate = response.GetExpirationDate();
+
+								cachedItem.Data = response.Data;
+								cachedItem.ETag = eTag;
+								cachedItem.ExpirationDate = expirationDate;
 							}
-							else
+
+							foreach (var cache in _caches)
 							{
-								// TODO: remove Debug.Log before PR
-								UnityEngine.Debug.LogWarningFormat(
-										"updating cached tile {1} tilesetId:{2}{0}cached etag:{3}{0}remote etag:{4}{0}{5}"
-										, Environment.NewLine
-										, tileId
-										, tilesetId
-										, cachedItem.ETag
-										, headerOnly.Headers["ETag"]
-										, finalUrl
-									);
-
-								// request updated tile and pass callback to return new data to subscribers
-								requestTileAndCache(finalUrl, tilesetId, tileId, timeout, callback);
+								cache.Add(tilesetId, tileId, cachedItem, true);
 							}
+
+							callback(Response.FromCache(cachedItem.Data));
 						}
-						, timeout
-						, HttpRequestType.Head
 					);
 				}
 
@@ -233,34 +222,18 @@ string uri
 			}
 		}
 
-
 		private IAsyncRequest requestTileAndCache(string url, string tilesetId, CanonicalTileId tileId, int timeout, Action<Response> callback)
 		{
 			return IAsyncRequestFactory.CreateRequest(
 				url,
-				(Response r) =>
+				(Response response) =>
 				{
 					// if the request was successful add tile to all caches
-					if (!r.HasError && null != r.Data)
+					if (!response.HasError && null != response.Data)
 					{
-						string eTag = string.Empty;
-						DateTime? lastModified = null;
-
-						if (!r.Headers.ContainsKey("ETag"))
-						{
-							UnityEngine.Debug.LogWarningFormat("no 'ETag' header present in response for {0}", url);
-						}
-						else
-						{
-							eTag = r.Headers["ETag"];
-						}
+						string eTag = response.GetETag();
 
-						// not all APIs populate 'Last-Modified' header
-						// don't log error if it's missing
-						if (r.Headers.ContainsKey("Last-Modified"))
-						{
-							lastModified = DateTime.ParseExact(r.Headers["Last-Modified"], "r", null);
-						}
+						DateTime expirationDate = response.GetExpirationDate();
 
 						// propagate to all caches forcing update
 						foreach (var cache in _caches)
@@ -270,27 +243,25 @@ private IAsyncRequest requestTileAndCache(string url, string tilesetId, Canonica
 								, tileId
 								, new CacheItem()
 								{
-									Data = r.Data,
+									Data = response.Data,
 									ETag = eTag,
-									LastModified = lastModified
+									ExpirationDate = expirationDate
 								}
 								, true // force insert/update
 							);
 						}
 					}
+
 					if (null != callback)
 					{
-						r.IsUpdate = true;
-						callback(r);
+						response.IsUpdate = true;
+						callback(response);
 					}
 				}, timeout);
 		}
 
-
 		class MemoryCacheAsyncRequest : IAsyncRequest
 		{
-
-
 			public string RequestUrl { get; private set; }
 
 
@@ -302,14 +273,14 @@ public MemoryCacheAsyncRequest(string requestUrl)
 
 			public bool IsCompleted
 			{
-				get
-				{
-					return true;
-				}
+				get { return true; }
 			}
 
 
-			public HttpRequestType RequestType { get { return HttpRequestType.Get; } }
+			public HttpRequestType RequestType
+			{
+				get { return HttpRequestType.Get; }
+			}
 
 
 			public void Cancel()
@@ -318,4 +289,4 @@ public void Cancel()
 			}
 		}
 	}
-}
+}

sdkproject/Assets/Mapbox/Core/mapbox-sdk-cs/Platform/Cache/ResponseStatic.cs

@@ -0,0 +1,48 @@
+using System;
+using Mapbox.Platform;
+using UnityEngine;
+
+public static class ResponseStatic
+{
+	private static string EtagHeaderName = "ETag";
+	private static string CacheControlHeaderName = "Cache-Control";
+
+	public static DateTime GetExpirationDate(this Response response)
+	{
+		DateTime expirationDate = DateTime.Now;
+		if (response.Headers.ContainsKey(CacheControlHeaderName))
+		{
+			var cacheEntries = response.Headers[CacheControlHeaderName].Split(',');
+			if (cacheEntries.Length > 0)
+			{
+				foreach (var entry in cacheEntries)
+				{
+					var value = entry.Split('=');
+					if (value[0] == "max-age")
+					{
+						expirationDate = expirationDate + TimeSpan.FromSeconds(int.Parse(value[1]));
+						return expirationDate;
+					}
+				}
+			}
+		}
+
+		return expirationDate;
+	}
+
+	public static string GetETag(this Response response)
+	{
+		string eTag = String.Empty;
+		if (!response.Headers.ContainsKey(EtagHeaderName))
+		{
+			Debug.LogWarning("no 'ETag' header present in response");
+		}
+		else
+		{
+			eTag = response.Headers[EtagHeaderName];
+		}
+
+		return eTag;
+	}
+
+}