Building RequestBin with Durable Functions

01-create-bin.cs

[FunctionName(nameof(CreateBin))]
public async Task<IActionResult> CreateBin(
    [HttpTrigger(AuthorizationLevel.Anonymous, "post", Route="bins")] HttpRequest req,
    [DurableClient] IDurableClient client)
{
    ...
}

02-create-bin.cs

[FunctionName(nameof(CreateBin))]
public async Task<IActionResult> CreateBin(
    [HttpTrigger(AuthorizationLevel.Anonymous, "post", Route="bins")] HttpRequest req,
    [DurableClient] IDurableClient client)
{
    var binId = Guid.NewGuid();
    var bin = new EntityId("Bin", binId.ToString());

    ...
}

03-ibin.cs

public interface IBin
{
    void Add(BinItem item);
    void Reset();
}

04-bin.cs

[JsonObject(MemberSerialization = MemberSerialization.OptIn)]
public class Bin : IBin
{
    [JsonProperty("history")]
    public virtual List<BinItem> History { get; set; } = new List<BinItem>();

    public void Add(BinItem item)
    {
        if (item == null)
        {
            return;
        }

        this.History.Insert(0, item);
    }

    public void Reset()
    {
        this.History.Clear();
    }

    [FunctionName(nameof(Bin))]
    public static Task Run([EntityTrigger] IDurableEntityContext ctx) => ctx.DispatchAsync<Bin>();
}

05-create-bin.cs

[FunctionName(nameof(CreateBin))]
public async Task<IActionResult> CreateBin(
    [HttpTrigger(AuthorizationLevel.Anonymous, "post", Route="bins")] HttpRequest req,
    [DurableClient] IDurableClient client)
{
    ...

    await client.SignalEntityAsync<IBin>(bin, o => o.Add(null));

    ...
}

06-add-history.cs

[FunctionName(nameof(AddHistory))]
public async Task<IActionResult> AddHistory(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", "put", "patch", "delete", Route="bins/{binId}")] HttpRequest req,
    [DurableClient] IDurableClient client,
    string binId)
{
    var history = new BinItem();
    using (var reader = new StreamReader(req.Body))
    {
        history.Timestamp = DateTimeOffset.UtcNow.ToString("yyyy-MM-ddTHH:mm:ss.fffzzz");
        history.Method = req.Method;
        history.Headers = req.Headers.AsEnumerable().ToDictionary(p => p.Key, p => string.Join(";", p.Value));
        history.Queries = req.Query.ToDictionary(p => p.Key, p => string.Join(";", p.Value));
        history.Body = await reader.ReadToEndAsync();
    }

    ...
}

07-add-history.cs

[FunctionName(nameof(AddHistory))]
public async Task<IActionResult> AddHistory(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", "put", "patch", "delete", Route="bins/{binId}")] HttpRequest req,
    [DurableClient] IDurableClient client,
    string binId)
{
    ...

    var bin = new EntityId("Bin", binId);

    await client.SignalEntityAsync<IBin>(bin, o => o.Add(history));

    ...
}

08-get-history.cs

[FunctionName(nameof(GetHistory))]
public async Task<IActionResult> GetHistory(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", Route="bins/{binId}/history")] HttpRequest req,
    [DurableClient] IDurableClient client,
    string binId)
{
    var bin = new EntityId("Bin", binId);

    ...
}

09-get-history.cs

[FunctionName(nameof(GetHistory))]
public async Task<IActionResult> GetHistory(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", Route="bins/{binId}/history")] HttpRequest req,
    [DurableClient] IDurableClient client,
    string binId)
{
    ...

    var entity = await client.ReadEntityStateAsync<Bin>(bin);
    var payload = entity.EntityState;

    var result = new JsonObjectContentResult(HttpStatusCode.OK, payload);

    return result;
}

10-reset-history.cs

[FunctionName(nameof(ResetHistory))]
public async Task<IActionResult> ResetHistory(
    [HttpTrigger(AuthorizationLevel.Anonymous, "delete", Route="bins/{binId}/reset")] HttpRequest req,
    [DurableClient] IDurableClient client,
    string binId)
{
    var bin = new EntityId("Bin", binId);

    ...
}

11-reset-history.cs

[FunctionName(nameof(ResetHistory))]
public async Task<IActionResult> ResetHistory(
    [HttpTrigger(AuthorizationLevel.Anonymous, "delete", Route="bins/{binId}/reset")] HttpRequest req,
    [DurableClient] IDurableClient client,
    string binId)
{
    ...

    await client.SignalEntityAsync<IBin>(bin, o => o.Reset());

    ...
}

12-purge-bin.cs

[FunctionName(nameof(PurgeBin))]
public async Task<IActionResult> PurgeBin(
    [HttpTrigger(AuthorizationLevel.Anonymous, "delete", Route="bins/{binId}/purge")] HttpRequest req,
    [DurableClient] IDurableClient client,
    string binId)
{
    var bin = new EntityId("Bin", binId);

    ...
}

13-purge-bin.cs

[FunctionName(nameof(PurgeBin))]
public async Task<IActionResult> PurgeBin(
    [HttpTrigger(AuthorizationLevel.Anonymous, "delete", Route="bins/{binId}/purge")] HttpRequest req,
    [DurableClient] IDurableClient client,
    string binId)
{
    ...

    await client.PurgeInstanceHistoryAsync($"@{bin.EntityName}@{bin.EntityKey}");

    var result = new NoContentResult();

    return result;
}