Add tests for core utilities

src/Proto.Actor/InternalsVisibleTo.cs

@@ -8,4 +8,5 @@
 
 [assembly: InternalsVisibleTo("Proto.Cluster")]
 [assembly: InternalsVisibleTo("Proto.Remote")]
-[assembly: InternalsVisibleTo("Proto.OpenTelemetry.Tests")]
+[assembly: InternalsVisibleTo("Proto.OpenTelemetry.Tests")]
+[assembly: InternalsVisibleTo("Proto.Actor.Tests")]

tests/Proto.Actor.Tests/ActorMetricsTests.cs

@@ -0,0 +1,29 @@
+using System.Collections.Generic;
+using System.Diagnostics.Metrics;
+using Proto.Metrics;
+using Xunit;
+
+namespace Proto.Tests;
+
+public class ActorMetricsTests
+{
+    [Fact]
+    public void CounterProducesMeasurement()
+    {
+        var measurements = new List<long>();
+        using var listener = new MeterListener();
+        listener.InstrumentPublished = (instrument, l) =>
+        {
+            if (instrument.Name == ActorMetrics.ActorSpawnCount.Name)
+            {
+                l.EnableMeasurementEvents(instrument);
+            }
+        };
+        listener.SetMeasurementEventCallback<long>((instrument, value, tags, state) => measurements.Add(value));
+        listener.Start();
+
+        ActorMetrics.ActorSpawnCount.Add(5);
+
+        Assert.Contains(5, measurements);
+    }
+}

tests/Proto.Actor.Tests/DeduplicationContextTests.cs

@@ -0,0 +1,43 @@
+using System;
+using System.Threading.Tasks;
+using Proto.Deduplication;
+using Proto;
+using Xunit;
+
+namespace Proto.Tests;
+
+public class DeduplicationContextTests
+{
+    [Fact]
+    public async Task DuplicatesAreIgnored()
+    {
+        await using var system = new ActorSystem();
+        var context = system.Root;
+        var count = 0;
+
+        var props = Props.FromFunc(ctx =>
+        {
+            if (ctx.Message is string)
+            {
+                count++;
+            }
+            return Task.CompletedTask;
+        }).WithContextDecorator(c => new DeduplicationContext<string>(
+            c,
+            TimeSpan.FromSeconds(5),
+            (MessageEnvelope env, out string? key) =>
+            {
+                key = env.Message as string;
+                return key != null;
+            }
+        ));
+
+        var pid = context.Spawn(props);
+        context.Send(pid, "one");
+        context.Send(pid, "one");
+        context.Send(pid, "two");
+        await Task.Delay(100);
+
+        Assert.Equal(2, count);
+    }
+}

tests/Proto.Actor.Tests/FunctionActorTests.cs

@@ -0,0 +1,30 @@
+using System.Threading.Tasks;
+using Xunit;
+
+namespace Proto.Tests;
+
+public class FunctionActorTests
+{
+    [Fact]
+    public async Task FunctionActorHandlesMessages()
+    {
+        await using var system = new ActorSystem();
+        var context = system.Root;
+        var received = false;
+
+        var props = Props.FromFunc(ctx =>
+        {
+            if (ctx.Message is string)
+            {
+                received = true;
+            }
+            return Task.CompletedTask;
+        });
+
+        var pid = context.Spawn(props);
+        context.Send(pid, "hello");
+        await Task.Delay(50);
+
+        Assert.True(received);
+    }
+}

tests/Proto.Actor.Tests/ObservableGaugeWrapperTests.cs

@@ -0,0 +1,31 @@
+using System;
+using System.Collections.Generic;
+using System.Diagnostics.Metrics;
+using System.Linq;
+using Proto.Metrics;
+using Xunit;
+
+namespace Proto.Tests;
+
+public class ObservableGaugeWrapperTests
+{
+    [Fact]
+    public void ObserverManagementWorks()
+    {
+        var gauge = new ObservableGaugeWrapper<int>();
+        Func<IEnumerable<Measurement<int>>> obs1 = () => new[] { new Measurement<int>(1) };
+        Func<IEnumerable<Measurement<int>>> obs2 = () => new[] { new Measurement<int>(2) };
+
+        gauge.AddObserver(obs1);
+        gauge.AddObserver(obs2);
+
+        var values = gauge.Observe().Select(m => m.Value).ToArray();
+        Assert.Contains(1, values);
+        Assert.Contains(2, values);
+
+        gauge.RemoveObserver(obs1);
+        values = gauge.Observe().Select(m => m.Value).ToArray();
+        Assert.DoesNotContain(1, values);
+        Assert.Contains(2, values);
+    }
+}