code-moniker-core 0.7.1

Core symbol-graph types and per-language extractors for code-moniker.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

namespace App.Order;

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;

// cm: def OrderStatus
public enum OrderStatus
{
	Draft,
	Paid,
	Cancelled
}

// cm: def Order
public record Order(string Id, OrderStatus Status, DateTimeOffset CreatedAt);

// cm: def IOrderRepository
public interface IOrderRepository
{
	Task<IReadOnlyList<Order>> FindExpiredAsync(DateTimeOffset now, CancellationToken token);
	Task CancelAsync(string id, CancellationToken token);
}

// cm: def OrderWorkflow
public sealed class OrderWorkflow
{
	private readonly IOrderRepository _repository;
	private readonly TimeProvider _timeProvider;

	public OrderWorkflow(IOrderRepository repository, TimeProvider timeProvider)
	{
		_repository = repository;
		_timeProvider = timeProvider;
	}

	// cm: def OrderWorkflow.CancelExpiredAsync
	public async Task<int> CancelExpiredAsync(CancellationToken token)
	{
		// cm: ref OrderWorkflow.CancelExpiredAsync.calls.FindExpiredAsync
		var expired = await _repository.FindExpiredAsync(_timeProvider.GetUtcNow(), token);
		foreach (var order in expired.Where(o => o.Status == OrderStatus.Draft))
		{
			await _repository.CancelAsync(order.Id, token);
		}
		return expired.Count;
	}
}