Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
using System;
using System.Threading.Tasks;
using Microsoft.Azure.Documents.Client;
using Shouldly;
using Xunit;
namespace Demo
{
public class CachingTests
{
private readonly DocumentClient _client;
private const string EndpointUrl = "https://localhost:8081";
private const string AuthorizationKey = "C2y6yDjf5/R+ob0N8A7Cgv30VRDJIWEHLM+4QDU5DE2nQ9nDuVTqobD4b8mGGyPMbIZnqyMsEcaGQy67XIw/Jw==";
private const string DatabaseId = "CachingDemo";
private const string CollectionId = "Customers";
public CachingTests()
{
_client = new DocumentClient(new Uri(EndpointUrl), AuthorizationKey);
}
[Fact]
public async Task Should_return_same_document_if_not_modified()
{
// Setup our Database and add a new Customer
var dbSetup = new DatabaseSetup(_client);
await dbSetup.Init(DatabaseId, CollectionId);
var customerId = Guid.NewGuid().ToString();
var addCustomer = new Customer(customerId, "Demo");
await dbSetup.AddCustomer(addCustomer);
// Fetch out the Document (Customer)
var document1 = await _client.GetDocumentById(dbSetup.Collection.SelfLink, customerId);
var document2 = await _client.GetDocumentById(dbSetup.Collection.SelfLink, customerId);
document1.GetHashCode().ShouldBe(document2.GetHashCode());
document1.ETag.ShouldBe(document2.ETag);
}
[Fact]
public async Task Should_return_new_document_if_modified()
{
// Setup our Database and add a new Customer
var dbSetup = new DatabaseSetup(_client);
await dbSetup.Init(DatabaseId, CollectionId);
var customerId = Guid.NewGuid().ToString();
var addCustomer = new Customer(customerId, "Demo");
await dbSetup.AddCustomer(addCustomer);
// Fetch out the Document (Customer)
var document1 = await _client.GetDocumentById(dbSetup.Collection.SelfLink, customerId);
// Using Access Conditions gives us the ability to use the ETag from our fetched document for optimistic concurrency.
var ac = new AccessCondition { Condition = document1.ETag, Type = AccessConditionType.IfMatch };
// Replace our document, which will succeed with the correct ETag
await dbSetup.Client.ReplaceDocumentAsync(document1.SelfLink, (Customer)(dynamic)document1,
new RequestOptions { AccessCondition = ac });
// Fetch out the Document (Customer) again
var document2 = await _client.GetDocumentById(dbSetup.Collection.SelfLink, customerId);
// Should be new Document with new ETag
document1.GetHashCode().ShouldNotBe(document2.GetHashCode());
document1.ETag.ShouldNotBe(document2.ETag);
}
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.