New roastery metrics

src/Roastery/Agents/Agent.cs

@@ -9,14 +9,14 @@ namespace Roastery.Agents;
 abstract class Agent
 {
  protected delegate Task Behavior(CancellationToken cancellationToken);
-
+
  readonly int _meanBehaviorIntervalMilliseconds;
 
  protected Agent(int meanBehaviorIntervalMilliseconds)
  {
  _meanBehaviorIntervalMilliseconds = meanBehaviorIntervalMilliseconds;
  }
-
+
  public static Task Run(Agent agent, CancellationToken cancellationToken)
  {
  return Task.Run(() => agent.RunBehaviorsAsync(cancellationToken), cancellationToken);
@@ -32,8 +32,8 @@ async Task RunBehaviorsAsync(CancellationToken cancellationToken)
  {
  var behavior = Distribution.Uniform(behaviors);
 
- await Task.Delay((int)Distribution.Uniform(0, _meanBehaviorIntervalMilliseconds), cancellationToken);
-
+ await Task.Delay((int)Distribution.Uniform(0, _meanBehaviorIntervalMilliseconds), cancellationToken);
+
  try
  {
  await behavior(cancellationToken);
@@ -42,10 +42,9 @@ async Task RunBehaviorsAsync(CancellationToken cancellationToken)
  {
  // Exceptions are swallowed here; agents can log exceptions if they wish
  }
-
- await Task.Delay(_meanBehaviorIntervalMilliseconds / 2 +
- (int) (_meanBehaviorIntervalMilliseconds * Distribution.Uniform()), cancellationToken);
 
+ await Task.Delay(_meanBehaviorIntervalMilliseconds / 2 +
+ (int)(_meanBehaviorIntervalMilliseconds * Distribution.Uniform()), cancellationToken);
  }
  }
 

src/Roastery/Agents/ArchivingBatch.cs

@@ -14,7 +14,7 @@ class ArchivingBatch : Agent
  readonly HttpClient _client;
  readonly ILogger _logger;
 
- public ArchivingBatch(HttpClient client, ILogger logger)
+ public ArchivingBatch(HttpClient client, ILogger logger)
  : base(30000)
  {
  _client = client;
@@ -33,7 +33,7 @@ async Task DeleteAbandonedCarts(CancellationToken cancellationToken)
  try
  {
  _logger.Information("Identifying abandoned orders");
-
+
  var orders = await _client.GetAsync<List<Order>>("api/orders");
  foreach (var order in orders)
  {
@@ -60,7 +60,7 @@ async Task ArchiveShippedOrders(CancellationToken cancellationToken)
  try
  {
  _logger.Information("Archiving completed orders");
-
+
  var orders = await _client.GetAsync<List<Order>>("api/orders");
  foreach (var order in orders)
  {

src/Roastery/Agents/CatalogBatch.cs

@@ -1,9 +1,9 @@
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
 using Roastery.Model;
-using Roastery.Util;
 using Roastery.Web;
 using Serilog;
 using Serilog.Context;
@@ -27,21 +27,28 @@ protected override IEnumerable<Behavior> GetBehaviors()
  yield return CheckStock;
  }
 
+ const double LowStockThresholdKilograms = 40;
+
  async Task CheckStock(CancellationToken cancellationToken)
  {
  using var _ = LogContext.PushProperty("BatchId", Guid.NewGuid());
  try
  {
  _logger.Information("Checking stock levels");
-
+
+ var inventory = await _httpClient.GetAsync<List<Inventory>>("api/inventory");
+ var stockByBlend = inventory.ToDictionary(i => i.Blend, i => i.QuantityKilograms);
+
  foreach (var product in await _httpClient.GetAsync<List<Product>>("api/products"))
  {
- _logger.Information("Checking product {ProductDescription} ({ProductId})", product.FormatDescription(), product.Id);
-
- if (Distribution.OnceIn(30))
- _logger.Warning("Product {ProductId} is low on stock", product.Id);
-else if (Distribution.OnceIn(70))
+ _logger.Information("Checking product {ProductDescription} ({ProductId})", product.FormatDescription(),
+product.Id);
+
+var stock = stockByBlend.GetValueOrDefault(product.Blend);
+ if (stock < product.SizeInGrams / 1000.0)
  _logger.Warning("Product {ProductId} is out of stock", product.Id);
+ else if (stock < LowStockThresholdKilograms)
+ _logger.Warning("Product {ProductId} is low on stock", product.Id);
  }
  }
  catch (Exception ex)

src/Roastery/Agents/Customer.cs

@@ -39,18 +39,18 @@ async Task CreateOrder(CancellationToken cancellationToken)
  var orderPath = $"api/orders/{order.Id}";
  var addItemPath = $"{orderPath}/items";
  var products = await _httpClient.GetAsync<List<Product>>("api/products");
- var items = (int)Distribution.Uniform(1, 5);
+ var items = (int)Distribution.Uniform(1, 5);
  for (var i = 0; i < items; ++i)
  {
  await Task.Delay((int)Distribution.Uniform(5000, 20000), cancellationToken);
-
+
  var product = Distribution.Uniform(products);
  await _httpClient.PostAsync<OrderItem>(addItemPath, new OrderItem(order.Id!, product.Id!));
  }
 
  if (Distribution.OnceIn(15))
  return; // Abandon cart :-)
-
+
  // Customer has ~90s to place order before it'll be cleaned up as abandoned; some will be too slow
  await Task.Delay((int)Distribution.Uniform(10000, 70000), cancellationToken);
 

src/Roastery/Agents/FacilitySensors.cs

@@ -0,0 +1,80 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using Roastery.Metrics;
+using Roastery.Util;
+using Serilog;
+
+namespace Roastery.Agents;
+
+class FacilitySensors : Agent
+{
+ class AreaState
+ {
+ public AreaState(string area, double baseTemperature, double relativeHumidity)
+ {
+ Area = area;
+ BaseTemperature = baseTemperature;
+ RelativeHumidity = relativeHumidity;
+ }
+
+ public string Area { get; }
+ public double BaseTemperature { get; }
+ public double RelativeHumidity { get; set; }
+ }
+
+ readonly ILogger _logger;
+ readonly RoasteryProductionMetrics _metrics;
+
+ readonly AreaState[] _areas =
+ [
+ new("Roasting Floor", baseTemperature: 27, relativeHumidity: 52),
+ new("Green Bean Warehouse", baseTemperature: 19, relativeHumidity: 60)
+ ];
+
+ double _barometricPressure = 1015;
+
+ public FacilitySensors(ILogger logger, RoasteryProductionMetrics metrics)
+ : base(6000)
+ {
+ _logger = logger.ForContext<FacilitySensors>();
+ _metrics = metrics;
+ }
+
+ protected override IEnumerable<Behavior> GetBehaviors()
+ {
+ yield return SampleEnvironment;
+ }
+
+ Task SampleEnvironment(CancellationToken cancellationToken)
+ {
+ // Facility temperatures peak mid-afternoon and bottom out overnight
+ var hour = DateTime.Now.TimeOfDay.TotalHours;
+ var diurnalSwing = 3.5 * Math.Sin((hour - 9.0) / 24.0 * 2.0 * Math.PI);
+
+ _barometricPressure = Math.Clamp(_barometricPressure + Distribution.Uniform(0, 0.6) - 0.3, 990, 1035);
+
+ foreach (var area in _areas)
+ {
+ var temperature = area.BaseTemperature + diurnalSwing + Distribution.Uniform(0, 0.8) - 0.4;
+ area.RelativeHumidity = Math.Clamp(
+ area.RelativeHumidity + (58 - area.RelativeHumidity) * 0.02 + Distribution.Uniform(0, 2.4) - 1.2, 35,
+ 85);
+
+ _metrics.RecordAmbientConditions(
+ new RoasteryProductionMetrics.Sample.AmbientKey(area.Area),
+ new RoasteryProductionMetrics.Sample.AmbientGauges(
+ Math.Round(temperature, 1),
+ Math.Round(area.RelativeHumidity, 1),
+ Math.Round(_barometricPressure, 1)));
+
+ if (area.RelativeHumidity > 75 && Distribution.OnceIn(10))
+ _logger.Warning(
+ "Relative humidity in the {Area} has reached {RelativeHumidity:F0}%; green coffee should be stored below 65% RH",
+ area.Area, area.RelativeHumidity);
+ }
+
+ return Task.CompletedTask;
+ }
+}

src/Roastery/Agents/Agent.cs

@@ -9,14 +9,14 @@ namespace Roastery.Agents;
 abstract class Agent
 {
  protected delegate Task Behavior(CancellationToken cancellationToken);
-
+
  readonly int _meanBehaviorIntervalMilliseconds;
 
  protected Agent(int meanBehaviorIntervalMilliseconds)
  {
  _meanBehaviorIntervalMilliseconds = meanBehaviorIntervalMilliseconds;
  }
-
+
  public static Task Run(Agent agent, CancellationToken cancellationToken)
  {
  return Task.Run(() => agent.RunBehaviorsAsync(cancellationToken), cancellationToken);
@@ -32,8 +32,8 @@ async Task RunBehaviorsAsync(CancellationToken cancellationToken)
  {
  var behavior = Distribution.Uniform(behaviors);
 
- await Task.Delay((int)Distribution.Uniform(0, _meanBehaviorIntervalMilliseconds), cancellationToken);
-
+ await Task.Delay((int)Distribution.Uniform(0, _meanBehaviorIntervalMilliseconds), cancellationToken);
+
  try
  {
  await behavior(cancellationToken);
@@ -42,10 +42,9 @@ async Task RunBehaviorsAsync(CancellationToken cancellationToken)
  {
  // Exceptions are swallowed here; agents can log exceptions if they wish
  }
-
- await Task.Delay(_meanBehaviorIntervalMilliseconds / 2 +
- (int) (_meanBehaviorIntervalMilliseconds * Distribution.Uniform()), cancellationToken);
 
+ await Task.Delay(_meanBehaviorIntervalMilliseconds / 2 +
+ (int)(_meanBehaviorIntervalMilliseconds * Distribution.Uniform()), cancellationToken);
  }
  }
 

src/Roastery/Agents/ArchivingBatch.cs

@@ -14,7 +14,7 @@ class ArchivingBatch : Agent
  readonly HttpClient _client;
  readonly ILogger _logger;
 
- public ArchivingBatch(HttpClient client, ILogger logger)
+ public ArchivingBatch(HttpClient client, ILogger logger)
  : base(30000)
  {
  _client = client;
@@ -33,7 +33,7 @@ async Task DeleteAbandonedCarts(CancellationToken cancellationToken)
  try
  {
  _logger.Information("Identifying abandoned orders");
-
+
  var orders = await _client.GetAsync<List<Order>>("api/orders");
  foreach (var order in orders)
  {
@@ -60,7 +60,7 @@ async Task ArchiveShippedOrders(CancellationToken cancellationToken)
  try
  {
  _logger.Information("Archiving completed orders");
-
+
  var orders = await _client.GetAsync<List<Order>>("api/orders");
  foreach (var order in orders)
  {

src/Roastery/Agents/CatalogBatch.cs

@@ -1,9 +1,9 @@
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
 using Roastery.Model;
-using Roastery.Util;
 using Roastery.Web;
 using Serilog;
 using Serilog.Context;
@@ -27,21 +27,28 @@ protected override IEnumerable<Behavior> GetBehaviors()
  yield return CheckStock;
  }
 
+ const double LowStockThresholdKilograms = 40;
+
  async Task CheckStock(CancellationToken cancellationToken)
  {
  using var _ = LogContext.PushProperty("BatchId", Guid.NewGuid());
  try
  {
  _logger.Information("Checking stock levels");
-
+
+ var inventory = await _httpClient.GetAsync<List<Inventory>>("api/inventory");
+ var stockByBlend = inventory.ToDictionary(i => i.Blend, i => i.QuantityKilograms);
+
  foreach (var product in await _httpClient.GetAsync<List<Product>>("api/products"))
  {
- _logger.Information("Checking product {ProductDescription} ({ProductId})", product.FormatDescription(), product.Id);
-
- if (Distribution.OnceIn(30))
- _logger.Warning("Product {ProductId} is low on stock", product.Id);
-else if (Distribution.OnceIn(70))
+ _logger.Information("Checking product {ProductDescription} ({ProductId})", product.FormatDescription(),
+product.Id);
+
+var stock = stockByBlend.GetValueOrDefault(product.Blend);
+ if (stock < product.SizeInGrams / 1000.0)
  _logger.Warning("Product {ProductId} is out of stock", product.Id);
+ else if (stock < LowStockThresholdKilograms)
+ _logger.Warning("Product {ProductId} is low on stock", product.Id);
  }
  }
  catch (Exception ex)

src/Roastery/Agents/Customer.cs

@@ -39,18 +39,18 @@ async Task CreateOrder(CancellationToken cancellationToken)
  var orderPath = $"api/orders/{order.Id}";
  var addItemPath = $"{orderPath}/items";
  var products = await _httpClient.GetAsync<List<Product>>("api/products");
- var items = (int)Distribution.Uniform(1, 5);
+ var items = (int)Distribution.Uniform(1, 5);
  for (var i = 0; i < items; ++i)
  {
  await Task.Delay((int)Distribution.Uniform(5000, 20000), cancellationToken);
-
+
  var product = Distribution.Uniform(products);
  await _httpClient.PostAsync<OrderItem>(addItemPath, new OrderItem(order.Id!, product.Id!));
  }
 
  if (Distribution.OnceIn(15))
  return; // Abandon cart :-)
-
+
  // Customer has ~90s to place order before it'll be cleaned up as abandoned; some will be too slow
  await Task.Delay((int)Distribution.Uniform(10000, 70000), cancellationToken);
 

src/Roastery/Agents/FacilitySensors.cs

@@ -0,0 +1,80 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using Roastery.Metrics;
+using Roastery.Util;
+using Serilog;
+
+namespace Roastery.Agents;
+
+class FacilitySensors : Agent
+{
+ class AreaState
+ {
+ public AreaState(string area, double baseTemperature, double relativeHumidity)
+ {
+ Area = area;
+ BaseTemperature = baseTemperature;
+ RelativeHumidity = relativeHumidity;
+ }
+
+ public string Area { get; }
+ public double BaseTemperature { get; }
+ public double RelativeHumidity { get; set; }
+ }
+
+ readonly ILogger _logger;
+ readonly RoasteryProductionMetrics _metrics;
+
+ readonly AreaState[] _areas =
+ [
+ new("Roasting Floor", baseTemperature: 27, relativeHumidity: 52),
+ new("Green Bean Warehouse", baseTemperature: 19, relativeHumidity: 60)
+ ];
+
+ double _barometricPressure = 1015;
+
+ public FacilitySensors(ILogger logger, RoasteryProductionMetrics metrics)
+ : base(6000)
+ {
+ _logger = logger.ForContext<FacilitySensors>();
+ _metrics = metrics;
+ }
+
+ protected override IEnumerable<Behavior> GetBehaviors()
+ {
+ yield return SampleEnvironment;
+ }
+
+ Task SampleEnvironment(CancellationToken cancellationToken)
+ {
+ // Facility temperatures peak mid-afternoon and bottom out overnight
+ var hour = DateTime.Now.TimeOfDay.TotalHours;
+ var diurnalSwing = 3.5 * Math.Sin((hour - 9.0) / 24.0 * 2.0 * Math.PI);
+
+ _barometricPressure = Math.Clamp(_barometricPressure + Distribution.Uniform(0, 0.6) - 0.3, 990, 1035);
+
+ foreach (var area in _areas)
+ {
+ var temperature = area.BaseTemperature + diurnalSwing + Distribution.Uniform(0, 0.8) - 0.4;
+ area.RelativeHumidity = Math.Clamp(
+ area.RelativeHumidity + (58 - area.RelativeHumidity) * 0.02 + Distribution.Uniform(0, 2.4) - 1.2, 35,
+ 85);
+
+ _metrics.RecordAmbientConditions(
+ new RoasteryProductionMetrics.Sample.AmbientKey(area.Area),
+ new RoasteryProductionMetrics.Sample.AmbientGauges(
+ Math.Round(temperature, 1),
+ Math.Round(area.RelativeHumidity, 1),
+ Math.Round(_barometricPressure, 1)));
+
+ if (area.RelativeHumidity > 75 && Distribution.OnceIn(10))
+ _logger.Warning(
+ "Relative humidity in the {Area} has reached {RelativeHumidity:F0}%; green coffee should be stored below 65% RH",
+ area.Area, area.RelativeHumidity);
+ }
+
+ return Task.CompletedTask;
+ }
+}

src/Roastery/Agents/Agent.cs

@@ -9,14 +9,14 @@ namespace Roastery.Agents;
 abstract class Agent
 {
  protected delegate Task Behavior(CancellationToken cancellationToken);
-
+
  readonly int _meanBehaviorIntervalMilliseconds;
 
  protected Agent(int meanBehaviorIntervalMilliseconds)
  {
  _meanBehaviorIntervalMilliseconds = meanBehaviorIntervalMilliseconds;
  }
-
+
  public static Task Run(Agent agent, CancellationToken cancellationToken)
  {
  return Task.Run(() => agent.RunBehaviorsAsync(cancellationToken), cancellationToken);
@@ -32,8 +32,8 @@ async Task RunBehaviorsAsync(CancellationToken cancellationToken)
  {
  var behavior = Distribution.Uniform(behaviors);
 
- await Task.Delay((int)Distribution.Uniform(0, _meanBehaviorIntervalMilliseconds), cancellationToken);
-
+ await Task.Delay((int)Distribution.Uniform(0, _meanBehaviorIntervalMilliseconds), cancellationToken);
+
  try
  {
  await behavior(cancellationToken);
@@ -42,10 +42,9 @@ async Task RunBehaviorsAsync(CancellationToken cancellationToken)
  {
  // Exceptions are swallowed here; agents can log exceptions if they wish
  }
-
- await Task.Delay(_meanBehaviorIntervalMilliseconds / 2 +
- (int) (_meanBehaviorIntervalMilliseconds * Distribution.Uniform()), cancellationToken);
 
+ await Task.Delay(_meanBehaviorIntervalMilliseconds / 2 +
+ (int)(_meanBehaviorIntervalMilliseconds * Distribution.Uniform()), cancellationToken);
  }
  }
 

src/Roastery/Agents/ArchivingBatch.cs

@@ -14,7 +14,7 @@ class ArchivingBatch : Agent
  readonly HttpClient _client;
  readonly ILogger _logger;
 
- public ArchivingBatch(HttpClient client, ILogger logger)
+ public ArchivingBatch(HttpClient client, ILogger logger)
  : base(30000)
  {
  _client = client;
@@ -33,7 +33,7 @@ async Task DeleteAbandonedCarts(CancellationToken cancellationToken)
  try
  {
  _logger.Information("Identifying abandoned orders");
-
+
  var orders = await _client.GetAsync<List<Order>>("api/orders");
  foreach (var order in orders)
  {
@@ -60,7 +60,7 @@ async Task ArchiveShippedOrders(CancellationToken cancellationToken)
  try
  {
  _logger.Information("Archiving completed orders");
-
+
  var orders = await _client.GetAsync<List<Order>>("api/orders");
  foreach (var order in orders)
  {

src/Roastery/Agents/CatalogBatch.cs

@@ -1,9 +1,9 @@
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
 using Roastery.Model;
-using Roastery.Util;
 using Roastery.Web;
 using Serilog;
 using Serilog.Context;
@@ -27,21 +27,28 @@ protected override IEnumerable<Behavior> GetBehaviors()
  yield return CheckStock;
  }
 
+ const double LowStockThresholdKilograms = 40;
+
  async Task CheckStock(CancellationToken cancellationToken)
  {
  using var _ = LogContext.PushProperty("BatchId", Guid.NewGuid());
  try
  {
  _logger.Information("Checking stock levels");
-
+
+ var inventory = await _httpClient.GetAsync<List<Inventory>>("api/inventory");
+ var stockByBlend = inventory.ToDictionary(i => i.Blend, i => i.QuantityKilograms);
+
  foreach (var product in await _httpClient.GetAsync<List<Product>>("api/products"))
  {
- _logger.Information("Checking product {ProductDescription} ({ProductId})", product.FormatDescription(), product.Id);
-
- if (Distribution.OnceIn(30))
- _logger.Warning("Product {ProductId} is low on stock", product.Id);
-else if (Distribution.OnceIn(70))
+ _logger.Information("Checking product {ProductDescription} ({ProductId})", product.FormatDescription(),
+product.Id);
+
+var stock = stockByBlend.GetValueOrDefault(product.Blend);
+ if (stock < product.SizeInGrams / 1000.0)
  _logger.Warning("Product {ProductId} is out of stock", product.Id);
+ else if (stock < LowStockThresholdKilograms)
+ _logger.Warning("Product {ProductId} is low on stock", product.Id);
  }
  }
  catch (Exception ex)

src/Roastery/Agents/Customer.cs

@@ -39,18 +39,18 @@ async Task CreateOrder(CancellationToken cancellationToken)
  var orderPath = $"api/orders/{order.Id}";
  var addItemPath = $"{orderPath}/items";
  var products = await _httpClient.GetAsync<List<Product>>("api/products");
- var items = (int)Distribution.Uniform(1, 5);
+ var items = (int)Distribution.Uniform(1, 5);
  for (var i = 0; i < items; ++i)
  {
  await Task.Delay((int)Distribution.Uniform(5000, 20000), cancellationToken);
-
+
  var product = Distribution.Uniform(products);
  await _httpClient.PostAsync<OrderItem>(addItemPath, new OrderItem(order.Id!, product.Id!));
  }
 
  if (Distribution.OnceIn(15))
  return; // Abandon cart :-)
-
+
  // Customer has ~90s to place order before it'll be cleaned up as abandoned; some will be too slow
  await Task.Delay((int)Distribution.Uniform(10000, 70000), cancellationToken);
 

src/Roastery/Agents/FacilitySensors.cs

@@ -0,0 +1,80 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using Roastery.Metrics;
+using Roastery.Util;
+using Serilog;
+
+namespace Roastery.Agents;
+
+class FacilitySensors : Agent
+{
+ class AreaState
+ {
+ public AreaState(string area, double baseTemperature, double relativeHumidity)
+ {
+ Area = area;
+ BaseTemperature = baseTemperature;
+ RelativeHumidity = relativeHumidity;
+ }
+
+ public string Area { get; }
+ public double BaseTemperature { get; }
+ public double RelativeHumidity { get; set; }
+ }
+
+ readonly ILogger _logger;
+ readonly RoasteryProductionMetrics _metrics;
+
+ readonly AreaState[] _areas =
+ [
+ new("Roasting Floor", baseTemperature: 27, relativeHumidity: 52),
+ new("Green Bean Warehouse", baseTemperature: 19, relativeHumidity: 60)
+ ];
+
+ double _barometricPressure = 1015;
+
+ public FacilitySensors(ILogger logger, RoasteryProductionMetrics metrics)
+ : base(6000)
+ {
+ _logger = logger.ForContext<FacilitySensors>();
+ _metrics = metrics;
+ }
+
+ protected override IEnumerable<Behavior> GetBehaviors()
+ {
+ yield return SampleEnvironment;
+ }
+
+ Task SampleEnvironment(CancellationToken cancellationToken)
+ {
+ // Facility temperatures peak mid-afternoon and bottom out overnight
+ var hour = DateTime.Now.TimeOfDay.TotalHours;
+ var diurnalSwing = 3.5 * Math.Sin((hour - 9.0) / 24.0 * 2.0 * Math.PI);
+
+ _barometricPressure = Math.Clamp(_barometricPressure + Distribution.Uniform(0, 0.6) - 0.3, 990, 1035);
+
+ foreach (var area in _areas)
+ {
+ var temperature = area.BaseTemperature + diurnalSwing + Distribution.Uniform(0, 0.8) - 0.4;
+ area.RelativeHumidity = Math.Clamp(
+ area.RelativeHumidity + (58 - area.RelativeHumidity) * 0.02 + Distribution.Uniform(0, 2.4) - 1.2, 35,
+ 85);
+
+ _metrics.RecordAmbientConditions(
+ new RoasteryProductionMetrics.Sample.AmbientKey(area.Area),
+ new RoasteryProductionMetrics.Sample.AmbientGauges(
+ Math.Round(temperature, 1),
+ Math.Round(area.RelativeHumidity, 1),
+ Math.Round(_barometricPressure, 1)));
+
+ if (area.RelativeHumidity > 75 && Distribution.OnceIn(10))
+ _logger.Warning(
+ "Relative humidity in the {Area} has reached {RelativeHumidity:F0}%; green coffee should be stored below 65% RH",
+ area.Area, area.RelativeHumidity);
+ }
+
+ return Task.CompletedTask;
+ }
+}

src/Roastery/Agents/Agent.cs

@@ -9,14 +9,14 @@ namespace Roastery.Agents;
 abstract class Agent
 {
  protected delegate Task Behavior(CancellationToken cancellationToken);
-
+
  readonly int _meanBehaviorIntervalMilliseconds;
 
  protected Agent(int meanBehaviorIntervalMilliseconds)
  {
  _meanBehaviorIntervalMilliseconds = meanBehaviorIntervalMilliseconds;
  }
-
+
  public static Task Run(Agent agent, CancellationToken cancellationToken)
  {
  return Task.Run(() => agent.RunBehaviorsAsync(cancellationToken), cancellationToken);
@@ -32,8 +32,8 @@ async Task RunBehaviorsAsync(CancellationToken cancellationToken)
  {
  var behavior = Distribution.Uniform(behaviors);
 
- await Task.Delay((int)Distribution.Uniform(0, _meanBehaviorIntervalMilliseconds), cancellationToken);
-
+ await Task.Delay((int)Distribution.Uniform(0, _meanBehaviorIntervalMilliseconds), cancellationToken);
+
  try
  {
  await behavior(cancellationToken);
@@ -42,10 +42,9 @@ async Task RunBehaviorsAsync(CancellationToken cancellationToken)
  {
  // Exceptions are swallowed here; agents can log exceptions if they wish
  }
-
- await Task.Delay(_meanBehaviorIntervalMilliseconds / 2 +
- (int) (_meanBehaviorIntervalMilliseconds * Distribution.Uniform()), cancellationToken);
 
+ await Task.Delay(_meanBehaviorIntervalMilliseconds / 2 +
+ (int)(_meanBehaviorIntervalMilliseconds * Distribution.Uniform()), cancellationToken);
  }
  }
 

src/Roastery/Agents/ArchivingBatch.cs

@@ -14,7 +14,7 @@ class ArchivingBatch : Agent
  readonly HttpClient _client;
  readonly ILogger _logger;
 
- public ArchivingBatch(HttpClient client, ILogger logger)
+ public ArchivingBatch(HttpClient client, ILogger logger)
  : base(30000)
  {
  _client = client;
@@ -33,7 +33,7 @@ async Task DeleteAbandonedCarts(CancellationToken cancellationToken)
  try
  {
  _logger.Information("Identifying abandoned orders");
-
+
  var orders = await _client.GetAsync<List<Order>>("api/orders");
  foreach (var order in orders)
  {
@@ -60,7 +60,7 @@ async Task ArchiveShippedOrders(CancellationToken cancellationToken)
  try
  {
  _logger.Information("Archiving completed orders");
-
+
  var orders = await _client.GetAsync<List<Order>>("api/orders");
  foreach (var order in orders)
  {

src/Roastery/Agents/CatalogBatch.cs

@@ -1,9 +1,9 @@
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
 using Roastery.Model;
-using Roastery.Util;
 using Roastery.Web;
 using Serilog;
 using Serilog.Context;
@@ -27,21 +27,28 @@ protected override IEnumerable<Behavior> GetBehaviors()
  yield return CheckStock;
  }
 
+ const double LowStockThresholdKilograms = 40;
+
  async Task CheckStock(CancellationToken cancellationToken)
  {
  using var _ = LogContext.PushProperty("BatchId", Guid.NewGuid());
  try
  {
  _logger.Information("Checking stock levels");
-
+
+ var inventory = await _httpClient.GetAsync<List<Inventory>>("api/inventory");
+ var stockByBlend = inventory.ToDictionary(i => i.Blend, i => i.QuantityKilograms);
+
  foreach (var product in await _httpClient.GetAsync<List<Product>>("api/products"))
  {
- _logger.Information("Checking product {ProductDescription} ({ProductId})", product.FormatDescription(), product.Id);
-
- if (Distribution.OnceIn(30))
- _logger.Warning("Product {ProductId} is low on stock", product.Id);
-else if (Distribution.OnceIn(70))
+ _logger.Information("Checking product {ProductDescription} ({ProductId})", product.FormatDescription(),
+product.Id);
+
+var stock = stockByBlend.GetValueOrDefault(product.Blend);
+ if (stock < product.SizeInGrams / 1000.0)
  _logger.Warning("Product {ProductId} is out of stock", product.Id);
+ else if (stock < LowStockThresholdKilograms)
+ _logger.Warning("Product {ProductId} is low on stock", product.Id);
  }
  }
  catch (Exception ex)

src/Roastery/Agents/Customer.cs

@@ -39,18 +39,18 @@ async Task CreateOrder(CancellationToken cancellationToken)
  var orderPath = $"api/orders/{order.Id}";
  var addItemPath = $"{orderPath}/items";
  var products = await _httpClient.GetAsync<List<Product>>("api/products");
- var items = (int)Distribution.Uniform(1, 5);
+ var items = (int)Distribution.Uniform(1, 5);
  for (var i = 0; i < items; ++i)
  {
  await Task.Delay((int)Distribution.Uniform(5000, 20000), cancellationToken);
-
+
  var product = Distribution.Uniform(products);
  await _httpClient.PostAsync<OrderItem>(addItemPath, new OrderItem(order.Id!, product.Id!));
  }
 
  if (Distribution.OnceIn(15))
  return; // Abandon cart :-)
-
+
  // Customer has ~90s to place order before it'll be cleaned up as abandoned; some will be too slow
  await Task.Delay((int)Distribution.Uniform(10000, 70000), cancellationToken);
 

src/Roastery/Agents/FacilitySensors.cs

@@ -0,0 +1,80 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using Roastery.Metrics;
+using Roastery.Util;
+using Serilog;
+
+namespace Roastery.Agents;
+
+class FacilitySensors : Agent
+{
+ class AreaState
+ {
+ public AreaState(string area, double baseTemperature, double relativeHumidity)
+ {
+ Area = area;
+ BaseTemperature = baseTemperature;
+ RelativeHumidity = relativeHumidity;
+ }
+
+ public string Area { get; }
+ public double BaseTemperature { get; }
+ public double RelativeHumidity { get; set; }
+ }
+
+ readonly ILogger _logger;
+ readonly RoasteryProductionMetrics _metrics;
+
+ readonly AreaState[] _areas =
+ [
+ new("Roasting Floor", baseTemperature: 27, relativeHumidity: 52),
+ new("Green Bean Warehouse", baseTemperature: 19, relativeHumidity: 60)
+ ];
+
+ double _barometricPressure = 1015;
+
+ public FacilitySensors(ILogger logger, RoasteryProductionMetrics metrics)
+ : base(6000)
+ {
+ _logger = logger.ForContext<FacilitySensors>();
+ _metrics = metrics;
+ }
+
+ protected override IEnumerable<Behavior> GetBehaviors()
+ {
+ yield return SampleEnvironment;
+ }
+
+ Task SampleEnvironment(CancellationToken cancellationToken)
+ {
+ // Facility temperatures peak mid-afternoon and bottom out overnight
+ var hour = DateTime.Now.TimeOfDay.TotalHours;
+ var diurnalSwing = 3.5 * Math.Sin((hour - 9.0) / 24.0 * 2.0 * Math.PI);
+
+ _barometricPressure = Math.Clamp(_barometricPressure + Distribution.Uniform(0, 0.6) - 0.3, 990, 1035);
+
+ foreach (var area in _areas)
+ {
+ var temperature = area.BaseTemperature + diurnalSwing + Distribution.Uniform(0, 0.8) - 0.4;
+ area.RelativeHumidity = Math.Clamp(
+ area.RelativeHumidity + (58 - area.RelativeHumidity) * 0.02 + Distribution.Uniform(0, 2.4) - 1.2, 35,
+ 85);
+
+ _metrics.RecordAmbientConditions(
+ new RoasteryProductionMetrics.Sample.AmbientKey(area.Area),
+ new RoasteryProductionMetrics.Sample.AmbientGauges(
+ Math.Round(temperature, 1),
+ Math.Round(area.RelativeHumidity, 1),
+ Math.Round(_barometricPressure, 1)));
+
+ if (area.RelativeHumidity > 75 && Distribution.OnceIn(10))
+ _logger.Warning(
+ "Relative humidity in the {Area} has reached {RelativeHumidity:F0}%; green coffee should be stored below 65% RH",
+ area.Area, area.RelativeHumidity);
+ }
+
+ return Task.CompletedTask;
+ }
+}

src/Roastery/Agents/Agent.cs

@@ -9,14 +9,14 @@ namespace Roastery.Agents;
 abstract class Agent
 {
  protected delegate Task Behavior(CancellationToken cancellationToken);
-
+
  readonly int _meanBehaviorIntervalMilliseconds;
 
  protected Agent(int meanBehaviorIntervalMilliseconds)
  {
  _meanBehaviorIntervalMilliseconds = meanBehaviorIntervalMilliseconds;
  }
-
+
  public static Task Run(Agent agent, CancellationToken cancellationToken)
  {
  return Task.Run(() => agent.RunBehaviorsAsync(cancellationToken), cancellationToken);
@@ -32,8 +32,8 @@ async Task RunBehaviorsAsync(CancellationToken cancellationToken)
  {
  var behavior = Distribution.Uniform(behaviors);
 
- await Task.Delay((int)Distribution.Uniform(0, _meanBehaviorIntervalMilliseconds), cancellationToken);
-
+ await Task.Delay((int)Distribution.Uniform(0, _meanBehaviorIntervalMilliseconds), cancellationToken);
+
  try
  {
  await behavior(cancellationToken);
@@ -42,10 +42,9 @@ async Task RunBehaviorsAsync(CancellationToken cancellationToken)
  {
  // Exceptions are swallowed here; agents can log exceptions if they wish
  }
-
- await Task.Delay(_meanBehaviorIntervalMilliseconds / 2 +
- (int) (_meanBehaviorIntervalMilliseconds * Distribution.Uniform()), cancellationToken);
 
+ await Task.Delay(_meanBehaviorIntervalMilliseconds / 2 +
+ (int)(_meanBehaviorIntervalMilliseconds * Distribution.Uniform()), cancellationToken);
  }
  }
 

src/Roastery/Agents/ArchivingBatch.cs

@@ -14,7 +14,7 @@ class ArchivingBatch : Agent
  readonly HttpClient _client;
  readonly ILogger _logger;
 
- public ArchivingBatch(HttpClient client, ILogger logger)
+ public ArchivingBatch(HttpClient client, ILogger logger)
  : base(30000)
  {
  _client = client;
@@ -33,7 +33,7 @@ async Task DeleteAbandonedCarts(CancellationToken cancellationToken)
  try
  {
  _logger.Information("Identifying abandoned orders");
-
+
  var orders = await _client.GetAsync<List<Order>>("api/orders");
  foreach (var order in orders)
  {
@@ -60,7 +60,7 @@ async Task ArchiveShippedOrders(CancellationToken cancellationToken)
  try
  {
  _logger.Information("Archiving completed orders");
-
+
  var orders = await _client.GetAsync<List<Order>>("api/orders");
  foreach (var order in orders)
  {

src/Roastery/Agents/CatalogBatch.cs

@@ -1,9 +1,9 @@
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
 using Roastery.Model;
-using Roastery.Util;
 using Roastery.Web;
 using Serilog;
 using Serilog.Context;
@@ -27,21 +27,28 @@ protected override IEnumerable<Behavior> GetBehaviors()
  yield return CheckStock;
  }
 
+ const double LowStockThresholdKilograms = 40;
+
  async Task CheckStock(CancellationToken cancellationToken)
  {
  using var _ = LogContext.PushProperty("BatchId", Guid.NewGuid());
  try
  {
  _logger.Information("Checking stock levels");
-
+
+ var inventory = await _httpClient.GetAsync<List<Inventory>>("api/inventory");
+ var stockByBlend = inventory.ToDictionary(i => i.Blend, i => i.QuantityKilograms);
+
  foreach (var product in await _httpClient.GetAsync<List<Product>>("api/products"))
  {
- _logger.Information("Checking product {ProductDescription} ({ProductId})", product.FormatDescription(), product.Id);
-
- if (Distribution.OnceIn(30))
- _logger.Warning("Product {ProductId} is low on stock", product.Id);
-else if (Distribution.OnceIn(70))
+ _logger.Information("Checking product {ProductDescription} ({ProductId})", product.FormatDescription(),
+product.Id);
+
+var stock = stockByBlend.GetValueOrDefault(product.Blend);
+ if (stock < product.SizeInGrams / 1000.0)
  _logger.Warning("Product {ProductId} is out of stock", product.Id);
+ else if (stock < LowStockThresholdKilograms)
+ _logger.Warning("Product {ProductId} is low on stock", product.Id);
  }
  }
  catch (Exception ex)

src/Roastery/Agents/Customer.cs

@@ -39,18 +39,18 @@ async Task CreateOrder(CancellationToken cancellationToken)
  var orderPath = $"api/orders/{order.Id}";
  var addItemPath = $"{orderPath}/items";
  var products = await _httpClient.GetAsync<List<Product>>("api/products");
- var items = (int)Distribution.Uniform(1, 5);
+ var items = (int)Distribution.Uniform(1, 5);
  for (var i = 0; i < items; ++i)
  {
  await Task.Delay((int)Distribution.Uniform(5000, 20000), cancellationToken);
-
+
  var product = Distribution.Uniform(products);
  await _httpClient.PostAsync<OrderItem>(addItemPath, new OrderItem(order.Id!, product.Id!));
  }
 
  if (Distribution.OnceIn(15))
  return; // Abandon cart :-)
-
+
  // Customer has ~90s to place order before it'll be cleaned up as abandoned; some will be too slow
  await Task.Delay((int)Distribution.Uniform(10000, 70000), cancellationToken);
 

src/Roastery/Agents/FacilitySensors.cs

@@ -0,0 +1,80 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using Roastery.Metrics;
+using Roastery.Util;
+using Serilog;
+
+namespace Roastery.Agents;
+
+class FacilitySensors : Agent
+{
+ class AreaState
+ {
+ public AreaState(string area, double baseTemperature, double relativeHumidity)
+ {
+ Area = area;
+ BaseTemperature = baseTemperature;
+ RelativeHumidity = relativeHumidity;
+ }
+
+ public string Area { get; }
+ public double BaseTemperature { get; }
+ public double RelativeHumidity { get; set; }
+ }
+
+ readonly ILogger _logger;
+ readonly RoasteryProductionMetrics _metrics;
+
+ readonly AreaState[] _areas =
+ [
+ new("Roasting Floor", baseTemperature: 27, relativeHumidity: 52),
+ new("Green Bean Warehouse", baseTemperature: 19, relativeHumidity: 60)
+ ];
+
+ double _barometricPressure = 1015;
+
+ public FacilitySensors(ILogger logger, RoasteryProductionMetrics metrics)
+ : base(6000)
+ {
+ _logger = logger.ForContext<FacilitySensors>();
+ _metrics = metrics;
+ }
+
+ protected override IEnumerable<Behavior> GetBehaviors()
+ {
+ yield return SampleEnvironment;
+ }
+
+ Task SampleEnvironment(CancellationToken cancellationToken)
+ {
+ // Facility temperatures peak mid-afternoon and bottom out overnight
+ var hour = DateTime.Now.TimeOfDay.TotalHours;
+ var diurnalSwing = 3.5 * Math.Sin((hour - 9.0) / 24.0 * 2.0 * Math.PI);
+
+ _barometricPressure = Math.Clamp(_barometricPressure + Distribution.Uniform(0, 0.6) - 0.3, 990, 1035);
+
+ foreach (var area in _areas)
+ {
+ var temperature = area.BaseTemperature + diurnalSwing + Distribution.Uniform(0, 0.8) - 0.4;
+ area.RelativeHumidity = Math.Clamp(
+ area.RelativeHumidity + (58 - area.RelativeHumidity) * 0.02 + Distribution.Uniform(0, 2.4) - 1.2, 35,
+ 85);
+
+ _metrics.RecordAmbientConditions(
+ new RoasteryProductionMetrics.Sample.AmbientKey(area.Area),
+ new RoasteryProductionMetrics.Sample.AmbientGauges(
+ Math.Round(temperature, 1),
+ Math.Round(area.RelativeHumidity, 1),
+ Math.Round(_barometricPressure, 1)));
+
+ if (area.RelativeHumidity > 75 && Distribution.OnceIn(10))
+ _logger.Warning(
+ "Relative humidity in the {Area} has reached {RelativeHumidity:F0}%; green coffee should be stored below 65% RH",
+ area.Area, area.RelativeHumidity);
+ }
+
+ return Task.CompletedTask;
+ }
+}

src/Roastery/Agents/Agent.cs

@@ -9,14 +9,14 @@ namespace Roastery.Agents;
 abstract class Agent
 {
  protected delegate Task Behavior(CancellationToken cancellationToken);
-
+
  readonly int _meanBehaviorIntervalMilliseconds;
 
  protected Agent(int meanBehaviorIntervalMilliseconds)
  {
  _meanBehaviorIntervalMilliseconds = meanBehaviorIntervalMilliseconds;
  }
-
+
  public static Task Run(Agent agent, CancellationToken cancellationToken)
  {
  return Task.Run(() => agent.RunBehaviorsAsync(cancellationToken), cancellationToken);
@@ -32,8 +32,8 @@ async Task RunBehaviorsAsync(CancellationToken cancellationToken)
  {
  var behavior = Distribution.Uniform(behaviors);
 
- await Task.Delay((int)Distribution.Uniform(0, _meanBehaviorIntervalMilliseconds), cancellationToken);
-
+ await Task.Delay((int)Distribution.Uniform(0, _meanBehaviorIntervalMilliseconds), cancellationToken);
+
  try
  {
  await behavior(cancellationToken);
@@ -42,10 +42,9 @@ async Task RunBehaviorsAsync(CancellationToken cancellationToken)
  {
  // Exceptions are swallowed here; agents can log exceptions if they wish
  }
-
- await Task.Delay(_meanBehaviorIntervalMilliseconds / 2 +
- (int) (_meanBehaviorIntervalMilliseconds * Distribution.Uniform()), cancellationToken);
 
+ await Task.Delay(_meanBehaviorIntervalMilliseconds / 2 +
+ (int)(_meanBehaviorIntervalMilliseconds * Distribution.Uniform()), cancellationToken);
  }
  }
 

src/Roastery/Agents/ArchivingBatch.cs

@@ -14,7 +14,7 @@ class ArchivingBatch : Agent
  readonly HttpClient _client;
  readonly ILogger _logger;
 
- public ArchivingBatch(HttpClient client, ILogger logger)
+ public ArchivingBatch(HttpClient client, ILogger logger)
  : base(30000)
  {
  _client = client;
@@ -33,7 +33,7 @@ async Task DeleteAbandonedCarts(CancellationToken cancellationToken)
  try
  {
  _logger.Information("Identifying abandoned orders");
-
+
  var orders = await _client.GetAsync<List<Order>>("api/orders");
  foreach (var order in orders)
  {
@@ -60,7 +60,7 @@ async Task ArchiveShippedOrders(CancellationToken cancellationToken)
  try
  {
  _logger.Information("Archiving completed orders");
-
+
  var orders = await _client.GetAsync<List<Order>>("api/orders");
  foreach (var order in orders)
  {

src/Roastery/Agents/CatalogBatch.cs

@@ -1,9 +1,9 @@
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
 using Roastery.Model;
-using Roastery.Util;
 using Roastery.Web;
 using Serilog;
 using Serilog.Context;
@@ -27,21 +27,28 @@ protected override IEnumerable<Behavior> GetBehaviors()
  yield return CheckStock;
  }
 
+ const double LowStockThresholdKilograms = 40;
+
  async Task CheckStock(CancellationToken cancellationToken)
  {
  using var _ = LogContext.PushProperty("BatchId", Guid.NewGuid());
  try
  {
  _logger.Information("Checking stock levels");
-
+
+ var inventory = await _httpClient.GetAsync<List<Inventory>>("api/inventory");
+ var stockByBlend = inventory.ToDictionary(i => i.Blend, i => i.QuantityKilograms);
+
  foreach (var product in await _httpClient.GetAsync<List<Product>>("api/products"))
  {
- _logger.Information("Checking product {ProductDescription} ({ProductId})", product.FormatDescription(), product.Id);
-
- if (Distribution.OnceIn(30))
- _logger.Warning("Product {ProductId} is low on stock", product.Id);
-else if (Distribution.OnceIn(70))
+ _logger.Information("Checking product {ProductDescription} ({ProductId})", product.FormatDescription(),
+product.Id);
+
+var stock = stockByBlend.GetValueOrDefault(product.Blend);
+ if (stock < product.SizeInGrams / 1000.0)
  _logger.Warning("Product {ProductId} is out of stock", product.Id);
+ else if (stock < LowStockThresholdKilograms)
+ _logger.Warning("Product {ProductId} is low on stock", product.Id);
  }
  }
  catch (Exception ex)

src/Roastery/Agents/Customer.cs

@@ -39,18 +39,18 @@ async Task CreateOrder(CancellationToken cancellationToken)
  var orderPath = $"api/orders/{order.Id}";
  var addItemPath = $"{orderPath}/items";
  var products = await _httpClient.GetAsync<List<Product>>("api/products");
- var items = (int)Distribution.Uniform(1, 5);
+ var items = (int)Distribution.Uniform(1, 5);
  for (var i = 0; i < items; ++i)
  {
  await Task.Delay((int)Distribution.Uniform(5000, 20000), cancellationToken);
-
+
  var product = Distribution.Uniform(products);
  await _httpClient.PostAsync<OrderItem>(addItemPath, new OrderItem(order.Id!, product.Id!));
  }
 
  if (Distribution.OnceIn(15))
  return; // Abandon cart :-)
-
+
  // Customer has ~90s to place order before it'll be cleaned up as abandoned; some will be too slow
  await Task.Delay((int)Distribution.Uniform(10000, 70000), cancellationToken);
 

src/Roastery/Agents/FacilitySensors.cs

@@ -0,0 +1,80 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using Roastery.Metrics;
+using Roastery.Util;
+using Serilog;
+
+namespace Roastery.Agents;
+
+class FacilitySensors : Agent
+{
+ class AreaState
+ {
+ public AreaState(string area, double baseTemperature, double relativeHumidity)
+ {
+ Area = area;
+ BaseTemperature = baseTemperature;
+ RelativeHumidity = relativeHumidity;
+ }
+
+ public string Area { get; }
+ public double BaseTemperature { get; }
+ public double RelativeHumidity { get; set; }
+ }
+
+ readonly ILogger _logger;
+ readonly RoasteryProductionMetrics _metrics;
+
+ readonly AreaState[] _areas =
+ [
+ new("Roasting Floor", baseTemperature: 27, relativeHumidity: 52),
+ new("Green Bean Warehouse", baseTemperature: 19, relativeHumidity: 60)
+ ];
+
+ double _barometricPressure = 1015;
+
+ public FacilitySensors(ILogger logger, RoasteryProductionMetrics metrics)
+ : base(6000)
+ {
+ _logger = logger.ForContext<FacilitySensors>();
+ _metrics = metrics;
+ }
+
+ protected override IEnumerable<Behavior> GetBehaviors()
+ {
+ yield return SampleEnvironment;
+ }
+
+ Task SampleEnvironment(CancellationToken cancellationToken)
+ {
+ // Facility temperatures peak mid-afternoon and bottom out overnight
+ var hour = DateTime.Now.TimeOfDay.TotalHours;
+ var diurnalSwing = 3.5 * Math.Sin((hour - 9.0) / 24.0 * 2.0 * Math.PI);
+
+ _barometricPressure = Math.Clamp(_barometricPressure + Distribution.Uniform(0, 0.6) - 0.3, 990, 1035);
+
+ foreach (var area in _areas)
+ {
+ var temperature = area.BaseTemperature + diurnalSwing + Distribution.Uniform(0, 0.8) - 0.4;
+ area.RelativeHumidity = Math.Clamp(
+ area.RelativeHumidity + (58 - area.RelativeHumidity) * 0.02 + Distribution.Uniform(0, 2.4) - 1.2, 35,
+ 85);
+
+ _metrics.RecordAmbientConditions(
+ new RoasteryProductionMetrics.Sample.AmbientKey(area.Area),
+ new RoasteryProductionMetrics.Sample.AmbientGauges(
+ Math.Round(temperature, 1),
+ Math.Round(area.RelativeHumidity, 1),
+ Math.Round(_barometricPressure, 1)));
+
+ if (area.RelativeHumidity > 75 && Distribution.OnceIn(10))
+ _logger.Warning(
+ "Relative humidity in the {Area} has reached {RelativeHumidity:F0}%; green coffee should be stored below 65% RH",
+ area.Area, area.RelativeHumidity);
+ }
+
+ return Task.CompletedTask;
+ }
+}

src/Roastery/Agents/Agent.cs

@@ -9,14 +9,14 @@ namespace Roastery.Agents;
 abstract class Agent
 {
  protected delegate Task Behavior(CancellationToken cancellationToken);
-
+
  readonly int _meanBehaviorIntervalMilliseconds;
 
  protected Agent(int meanBehaviorIntervalMilliseconds)
  {
  _meanBehaviorIntervalMilliseconds = meanBehaviorIntervalMilliseconds;
  }
-
+
  public static Task Run(Agent agent, CancellationToken cancellationToken)
  {
  return Task.Run(() => agent.RunBehaviorsAsync(cancellationToken), cancellationToken);
@@ -32,8 +32,8 @@ async Task RunBehaviorsAsync(CancellationToken cancellationToken)
  {
  var behavior = Distribution.Uniform(behaviors);
 
- await Task.Delay((int)Distribution.Uniform(0, _meanBehaviorIntervalMilliseconds), cancellationToken);
-
+ await Task.Delay((int)Distribution.Uniform(0, _meanBehaviorIntervalMilliseconds), cancellationToken);
+
  try
  {
  await behavior(cancellationToken);
@@ -42,10 +42,9 @@ async Task RunBehaviorsAsync(CancellationToken cancellationToken)
  {
  // Exceptions are swallowed here; agents can log exceptions if they wish
  }
-
- await Task.Delay(_meanBehaviorIntervalMilliseconds / 2 +
- (int) (_meanBehaviorIntervalMilliseconds * Distribution.Uniform()), cancellationToken);
 
+ await Task.Delay(_meanBehaviorIntervalMilliseconds / 2 +
+ (int)(_meanBehaviorIntervalMilliseconds * Distribution.Uniform()), cancellationToken);
  }
  }
 

src/Roastery/Agents/ArchivingBatch.cs

@@ -14,7 +14,7 @@ class ArchivingBatch : Agent
  readonly HttpClient _client;
  readonly ILogger _logger;
 
- public ArchivingBatch(HttpClient client, ILogger logger)
+ public ArchivingBatch(HttpClient client, ILogger logger)
  : base(30000)
  {
  _client = client;
@@ -33,7 +33,7 @@ async Task DeleteAbandonedCarts(CancellationToken cancellationToken)
  try
  {
  _logger.Information("Identifying abandoned orders");
-
+
  var orders = await _client.GetAsync<List<Order>>("api/orders");
  foreach (var order in orders)
  {
@@ -60,7 +60,7 @@ async Task ArchiveShippedOrders(CancellationToken cancellationToken)
  try
  {
  _logger.Information("Archiving completed orders");
-
+
  var orders = await _client.GetAsync<List<Order>>("api/orders");
  foreach (var order in orders)
  {

src/Roastery/Agents/CatalogBatch.cs

@@ -1,9 +1,9 @@
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
 using Roastery.Model;
-using Roastery.Util;
 using Roastery.Web;
 using Serilog;
 using Serilog.Context;
@@ -27,21 +27,28 @@ protected override IEnumerable<Behavior> GetBehaviors()
  yield return CheckStock;
  }
 
+ const double LowStockThresholdKilograms = 40;
+
  async Task CheckStock(CancellationToken cancellationToken)
  {
  using var _ = LogContext.PushProperty("BatchId", Guid.NewGuid());
  try
  {
  _logger.Information("Checking stock levels");
-
+
+ var inventory = await _httpClient.GetAsync<List<Inventory>>("api/inventory");
+ var stockByBlend = inventory.ToDictionary(i => i.Blend, i => i.QuantityKilograms);
+
  foreach (var product in await _httpClient.GetAsync<List<Product>>("api/products"))
  {
- _logger.Information("Checking product {ProductDescription} ({ProductId})", product.FormatDescription(), product.Id);
-
- if (Distribution.OnceIn(30))
- _logger.Warning("Product {ProductId} is low on stock", product.Id);
-else if (Distribution.OnceIn(70))
+ _logger.Information("Checking product {ProductDescription} ({ProductId})", product.FormatDescription(),
+product.Id);
+
+var stock = stockByBlend.GetValueOrDefault(product.Blend);
+ if (stock < product.SizeInGrams / 1000.0)
  _logger.Warning("Product {ProductId} is out of stock", product.Id);
+ else if (stock < LowStockThresholdKilograms)
+ _logger.Warning("Product {ProductId} is low on stock", product.Id);
  }
  }
  catch (Exception ex)

src/Roastery/Agents/Customer.cs

@@ -39,18 +39,18 @@ async Task CreateOrder(CancellationToken cancellationToken)
  var orderPath = $"api/orders/{order.Id}";
  var addItemPath = $"{orderPath}/items";
  var products = await _httpClient.GetAsync<List<Product>>("api/products");
- var items = (int)Distribution.Uniform(1, 5);
+ var items = (int)Distribution.Uniform(1, 5);
  for (var i = 0; i < items; ++i)
  {
  await Task.Delay((int)Distribution.Uniform(5000, 20000), cancellationToken);
-
+
  var product = Distribution.Uniform(products);
  await _httpClient.PostAsync<OrderItem>(addItemPath, new OrderItem(order.Id!, product.Id!));
  }
 
  if (Distribution.OnceIn(15))
  return; // Abandon cart :-)
-
+
  // Customer has ~90s to place order before it'll be cleaned up as abandoned; some will be too slow
  await Task.Delay((int)Distribution.Uniform(10000, 70000), cancellationToken);
 

src/Roastery/Agents/FacilitySensors.cs

@@ -0,0 +1,80 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using Roastery.Metrics;
+using Roastery.Util;
+using Serilog;
+
+namespace Roastery.Agents;
+
+class FacilitySensors : Agent
+{
+ class AreaState
+ {
+ public AreaState(string area, double baseTemperature, double relativeHumidity)
+ {
+ Area = area;
+ BaseTemperature = baseTemperature;
+ RelativeHumidity = relativeHumidity;
+ }
+
+ public string Area { get; }
+ public double BaseTemperature { get; }
+ public double RelativeHumidity { get; set; }
+ }
+
+ readonly ILogger _logger;
+ readonly RoasteryProductionMetrics _metrics;
+
+ readonly AreaState[] _areas =
+ [
+ new("Roasting Floor", baseTemperature: 27, relativeHumidity: 52),
+ new("Green Bean Warehouse", baseTemperature: 19, relativeHumidity: 60)
+ ];
+
+ double _barometricPressure = 1015;
+
+ public FacilitySensors(ILogger logger, RoasteryProductionMetrics metrics)
+ : base(6000)
+ {
+ _logger = logger.ForContext<FacilitySensors>();
+ _metrics = metrics;
+ }
+
+ protected override IEnumerable<Behavior> GetBehaviors()
+ {
+ yield return SampleEnvironment;
+ }
+
+ Task SampleEnvironment(CancellationToken cancellationToken)
+ {
+ // Facility temperatures peak mid-afternoon and bottom out overnight
+ var hour = DateTime.Now.TimeOfDay.TotalHours;
+ var diurnalSwing = 3.5 * Math.Sin((hour - 9.0) / 24.0 * 2.0 * Math.PI);
+
+ _barometricPressure = Math.Clamp(_barometricPressure + Distribution.Uniform(0, 0.6) - 0.3, 990, 1035);
+
+ foreach (var area in _areas)
+ {
+ var temperature = area.BaseTemperature + diurnalSwing + Distribution.Uniform(0, 0.8) - 0.4;
+ area.RelativeHumidity = Math.Clamp(
+ area.RelativeHumidity + (58 - area.RelativeHumidity) * 0.02 + Distribution.Uniform(0, 2.4) - 1.2, 35,
+ 85);
+
+ _metrics.RecordAmbientConditions(
+ new RoasteryProductionMetrics.Sample.AmbientKey(area.Area),
+ new RoasteryProductionMetrics.Sample.AmbientGauges(
+ Math.Round(temperature, 1),
+ Math.Round(area.RelativeHumidity, 1),
+ Math.Round(_barometricPressure, 1)));
+
+ if (area.RelativeHumidity > 75 && Distribution.OnceIn(10))
+ _logger.Warning(
+ "Relative humidity in the {Area} has reached {RelativeHumidity:F0}%; green coffee should be stored below 65% RH",
+ area.Area, area.RelativeHumidity);
+ }
+
+ return Task.CompletedTask;
+ }
+}

src/Roastery/Agents/Agent.cs

@@ -9,14 +9,14 @@ namespace Roastery.Agents;
 abstract class Agent
 {
  protected delegate Task Behavior(CancellationToken cancellationToken);
-
+
  readonly int _meanBehaviorIntervalMilliseconds;
 
  protected Agent(int meanBehaviorIntervalMilliseconds)
  {
  _meanBehaviorIntervalMilliseconds = meanBehaviorIntervalMilliseconds;
  }
-
+
  public static Task Run(Agent agent, CancellationToken cancellationToken)
  {
  return Task.Run(() => agent.RunBehaviorsAsync(cancellationToken), cancellationToken);
@@ -32,8 +32,8 @@ async Task RunBehaviorsAsync(CancellationToken cancellationToken)
  {
  var behavior = Distribution.Uniform(behaviors);
 
- await Task.Delay((int)Distribution.Uniform(0, _meanBehaviorIntervalMilliseconds), cancellationToken);
-
+ await Task.Delay((int)Distribution.Uniform(0, _meanBehaviorIntervalMilliseconds), cancellationToken);
+
  try
  {
  await behavior(cancellationToken);
@@ -42,10 +42,9 @@ async Task RunBehaviorsAsync(CancellationToken cancellationToken)
  {
  // Exceptions are swallowed here; agents can log exceptions if they wish
  }
-
- await Task.Delay(_meanBehaviorIntervalMilliseconds / 2 +
- (int) (_meanBehaviorIntervalMilliseconds * Distribution.Uniform()), cancellationToken);
 
+ await Task.Delay(_meanBehaviorIntervalMilliseconds / 2 +
+ (int)(_meanBehaviorIntervalMilliseconds * Distribution.Uniform()), cancellationToken);
  }
  }
 

src/Roastery/Agents/ArchivingBatch.cs

@@ -14,7 +14,7 @@ class ArchivingBatch : Agent
  readonly HttpClient _client;
  readonly ILogger _logger;
 
- public ArchivingBatch(HttpClient client, ILogger logger)
+ public ArchivingBatch(HttpClient client, ILogger logger)
  : base(30000)
  {
  _client = client;
@@ -33,7 +33,7 @@ async Task DeleteAbandonedCarts(CancellationToken cancellationToken)
  try
  {
  _logger.Information("Identifying abandoned orders");
-
+
  var orders = await _client.GetAsync<List<Order>>("api/orders");
  foreach (var order in orders)
  {
@@ -60,7 +60,7 @@ async Task ArchiveShippedOrders(CancellationToken cancellationToken)
  try
  {
  _logger.Information("Archiving completed orders");
-
+
  var orders = await _client.GetAsync<List<Order>>("api/orders");
  foreach (var order in orders)
  {

src/Roastery/Agents/CatalogBatch.cs

@@ -1,9 +1,9 @@
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
 using Roastery.Model;
-using Roastery.Util;
 using Roastery.Web;
 using Serilog;
 using Serilog.Context;
@@ -27,21 +27,28 @@ protected override IEnumerable<Behavior> GetBehaviors()
  yield return CheckStock;
  }
 
+ const double LowStockThresholdKilograms = 40;
+
  async Task CheckStock(CancellationToken cancellationToken)
  {
  using var _ = LogContext.PushProperty("BatchId", Guid.NewGuid());
  try
  {
  _logger.Information("Checking stock levels");
-
+
+ var inventory = await _httpClient.GetAsync<List<Inventory>>("api/inventory");
+ var stockByBlend = inventory.ToDictionary(i => i.Blend, i => i.QuantityKilograms);
+
  foreach (var product in await _httpClient.GetAsync<List<Product>>("api/products"))
  {
- _logger.Information("Checking product {ProductDescription} ({ProductId})", product.FormatDescription(), product.Id);
-
- if (Distribution.OnceIn(30))
- _logger.Warning("Product {ProductId} is low on stock", product.Id);
-else if (Distribution.OnceIn(70))
+ _logger.Information("Checking product {ProductDescription} ({ProductId})", product.FormatDescription(),
+product.Id);
+
+var stock = stockByBlend.GetValueOrDefault(product.Blend);
+ if (stock < product.SizeInGrams / 1000.0)
  _logger.Warning("Product {ProductId} is out of stock", product.Id);
+ else if (stock < LowStockThresholdKilograms)
+ _logger.Warning("Product {ProductId} is low on stock", product.Id);
  }
  }
  catch (Exception ex)

src/Roastery/Agents/Customer.cs

@@ -39,18 +39,18 @@ async Task CreateOrder(CancellationToken cancellationToken)
  var orderPath = $"api/orders/{order.Id}";
  var addItemPath = $"{orderPath}/items";
  var products = await _httpClient.GetAsync<List<Product>>("api/products");
- var items = (int)Distribution.Uniform(1, 5);
+ var items = (int)Distribution.Uniform(1, 5);
  for (var i = 0; i < items; ++i)
  {
  await Task.Delay((int)Distribution.Uniform(5000, 20000), cancellationToken);
-
+
  var product = Distribution.Uniform(products);
  await _httpClient.PostAsync<OrderItem>(addItemPath, new OrderItem(order.Id!, product.Id!));
  }
 
  if (Distribution.OnceIn(15))
  return; // Abandon cart :-)
-
+
  // Customer has ~90s to place order before it'll be cleaned up as abandoned; some will be too slow
  await Task.Delay((int)Distribution.Uniform(10000, 70000), cancellationToken);
 

src/Roastery/Agents/FacilitySensors.cs

@@ -0,0 +1,80 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using Roastery.Metrics;
+using Roastery.Util;
+using Serilog;
+
+namespace Roastery.Agents;
+
+class FacilitySensors : Agent
+{
+ class AreaState
+ {
+ public AreaState(string area, double baseTemperature, double relativeHumidity)
+ {
+ Area = area;
+ BaseTemperature = baseTemperature;
+ RelativeHumidity = relativeHumidity;
+ }
+
+ public string Area { get; }
+ public double BaseTemperature { get; }
+ public double RelativeHumidity { get; set; }
+ }
+
+ readonly ILogger _logger;
+ readonly RoasteryProductionMetrics _metrics;
+
+ readonly AreaState[] _areas =
+ [
+ new("Roasting Floor", baseTemperature: 27, relativeHumidity: 52),
+ new("Green Bean Warehouse", baseTemperature: 19, relativeHumidity: 60)
+ ];
+
+ double _barometricPressure = 1015;
+
+ public FacilitySensors(ILogger logger, RoasteryProductionMetrics metrics)
+ : base(6000)
+ {
+ _logger = logger.ForContext<FacilitySensors>();
+ _metrics = metrics;
+ }
+
+ protected override IEnumerable<Behavior> GetBehaviors()
+ {
+ yield return SampleEnvironment;
+ }
+
+ Task SampleEnvironment(CancellationToken cancellationToken)
+ {
+ // Facility temperatures peak mid-afternoon and bottom out overnight
+ var hour = DateTime.Now.TimeOfDay.TotalHours;
+ var diurnalSwing = 3.5 * Math.Sin((hour - 9.0) / 24.0 * 2.0 * Math.PI);
+
+ _barometricPressure = Math.Clamp(_barometricPressure + Distribution.Uniform(0, 0.6) - 0.3, 990, 1035);
+
+ foreach (var area in _areas)
+ {
+ var temperature = area.BaseTemperature + diurnalSwing + Distribution.Uniform(0, 0.8) - 0.4;
+ area.RelativeHumidity = Math.Clamp(
+ area.RelativeHumidity + (58 - area.RelativeHumidity) * 0.02 + Distribution.Uniform(0, 2.4) - 1.2, 35,
+ 85);
+
+ _metrics.RecordAmbientConditions(
+ new RoasteryProductionMetrics.Sample.AmbientKey(area.Area),
+ new RoasteryProductionMetrics.Sample.AmbientGauges(
+ Math.Round(temperature, 1),
+ Math.Round(area.RelativeHumidity, 1),
+ Math.Round(_barometricPressure, 1)));
+
+ if (area.RelativeHumidity > 75 && Distribution.OnceIn(10))
+ _logger.Warning(
+ "Relative humidity in the {Area} has reached {RelativeHumidity:F0}%; green coffee should be stored below 65% RH",
+ area.Area, area.RelativeHumidity);
+ }
+
+ return Task.CompletedTask;
+ }
+}