using System;
using System.IO;
using System.Linq;
using System.Text;
using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Auth;
using Microsoft.WindowsAzure.Storage.Blob;
using Microsoft.WindowsAzure.Storage.RetryPolicies;
using Microsoft.WindowsAzure.Storage.Table;

namespace AzureRAGeoRepSample
{
	class Program
	{
		private static string AccountName = "name";
		private static string AccountKey = "key";

		private static string BlobName = "TestBlob.txt";

		static void Main(string[] args)
		{
			try
			{
				var timestamp = DateTimeOffset.UtcNow.ToString();
				var cred = new StorageCredentials(AccountName, AccountKey);

				//Primary
				Console.WriteLine("Primary ---------------");
				var container = CreateContainer(cred);
				Console.WriteLine("Primary Uri: {0}\r\nSecondary Uri: {1}", container.StorageUri.PrimaryUri, container.StorageUri.SecondaryUri);

				Console.WriteLine("Primary Write --");
				WriteBlob(container, timestamp);
				Console.WriteLine("Primary Read --");
				ReadBlob(container);

				Console.ReadLine();

				Console.WriteLine("Secondary ---------------");
				var container2 = CreateContainer(cred, true);
				Console.WriteLine("Primary Uri: {0}\r\nSecondary Uri: {1}", container2.StorageUri.PrimaryUri, container2.StorageUri.SecondaryUri);

				Console.WriteLine("Secondary Read --");
				ReadBlob(container2);
			}
			catch (Exception ex)
			{
				Console.WriteLine("Error: {0}",ex.Message);
			}
			Console.ReadLine();
		}

		static CloudBlobContainer CreateContainer(StorageCredentials cred, bool isSecondary = false)
		{
			var storageAccount = new CloudStorageAccount(cred, false);
			var client = storageAccount.CreateCloudBlobClient();

			var container = client.GetContainerReference("test");

			if (isSecondary)
			{
				client.LocationMode = LocationMode.SecondaryOnly;
				var georep = client.GetServiceStats().GeoReplication;
				Console.WriteLine("GeoRep Status: {0}\r\nGeoRep LastSyncTime: {1}", georep.Status, georep.LastSyncTime);
			}
			else
			{
				container.CreateIfNotExists();
				container.SetPermissions(new BlobContainerPermissions()
				{
					PublicAccess = BlobContainerPublicAccessType.Blob,
				});
			}


			return container;
		}

		static void WriteBlob(CloudBlobContainer container, string text)
		{
			var blob = container.GetBlockBlobReference(BlobName);
			Console.WriteLine("Write body: " + text);
			blob.UploadText(text);
			blob.Properties.ContentType = "text/plain";
			blob.SetProperties();
		}

		static void ReadBlob(CloudBlobContainer container)
		{
			var blob = container.GetBlobReferenceFromServer(BlobName);
			blob.FetchAttributes();

			Console.WriteLine("\tPrimary Blob Uri: {0}\r\n\tSecondary Blob Uri: {1}", blob.StorageUri.PrimaryUri, blob.StorageUri.SecondaryUri);
			Console.WriteLine("\tBlob last modified: {0}", blob.Properties.LastModified);

			using (var s = new MemoryStream())
			{
				blob.DownloadToStream(s);
				Console.WriteLine("\tRead body: {0}", Encoding.UTF8.GetString(s.ToArray()));
			}
		}
	}
}

LocationMode.PrimaryOnly
LocationMode.PrimaryThenSecondary
LocationMode.SecondaryOnly
LocationMode.SecondaryThenPrimary

			var t = storageAccount.CreateCloudTableClient();
			var tt = t.GetTableReference("$MetricsHourPrimaryTransactionsBlob");
			foreach (var l in tt.CreateQuery<DynamicTableEntity>().Select(x => x).Take(2).ToList())
			{
				Console.WriteLine(l.PartitionKey, l.RowKey);
				l.Properties
					.Where(x => x.Value.PropertyType == EdmType.Int64)
					.Take(5)
					.ToList()
					.ForEach(pair => Console.WriteLine("\t\tkey: {0} value: {1}", pair.Key, pair.Value.Int64Value));
			}
			tt = t.GetTableReference("$MetricsHourSecondaryTransactionsBlob");
			foreach (var l in tt.CreateQuery<DynamicTableEntity>().Select(x => x).Take(2).ToList())
			{
				Console.WriteLine(l.PartitionKey, l.RowKey);
				l.Properties
					.Where(x => x.Value.PropertyType == EdmType.Int64)
					.Take(5)
					.ToList()
					.ForEach(pair => Console.WriteLine("\t\tkey: {0} value: {1}", pair.Key, pair.Value.Int64Value));
			}