KustoSchemaTools/KustoSchemaTools.Tests/Model/ContinuousExportModelTests.cs at 051ffd269628f9523e4501ddabf662a2e6be47f6 · github/KustoSchemaTools · GitHub

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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
using FluentAssertions;
using KustoSchemaTools.Model;

namespace KustoSchemaTools.Tests.Model
{
    public class ContinuousExportModelTests
    {
        [Fact]
        public void ContinuousExport_Should_Initialize_With_Default_Values()
        {
            // Act
            var continuousExport = new ContinuousExport();

            // Assert
            continuousExport.ExternalTable.Should().BeNull();
            continuousExport.Query.Should().BeNull();
            continuousExport.ManagedIdentity.Should().BeNull();
            continuousExport.IntervalBetweenRuns.Should().Be(0);
            continuousExport.ForcedLatencyInMinutes.Should().Be(0);
            continuousExport.SizeLimit.Should().Be(0);
            continuousExport.Distributed.Should().BeFalse();
        }

        [Fact]
        public void ContinuousExport_Should_Allow_Property_Assignment()
        {
            // Arrange
            var continuousExport = new ContinuousExport();

            // Act
            continuousExport.ExternalTable = "ExternalEvents";
            continuousExport.Query = "Events | where timestamp > ago(1h)";
            continuousExport.ManagedIdentity = "system";
            continuousExport.IntervalBetweenRuns = 30;
            continuousExport.ForcedLatencyInMinutes = 5;
            continuousExport.SizeLimit = 1000000;
            continuousExport.Distributed = true;

            // Assert
            continuousExport.ExternalTable.Should().Be("ExternalEvents");
            continuousExport.Query.Should().Be("Events | where timestamp > ago(1h)");
            continuousExport.ManagedIdentity.Should().Be("system");
            continuousExport.IntervalBetweenRuns.Should().Be(30);
            continuousExport.ForcedLatencyInMinutes.Should().Be(5);
            continuousExport.SizeLimit.Should().Be(1000000);
            continuousExport.Distributed.Should().BeTrue();
        }

        [Fact]
        public void ContinuousExport_Should_Generate_Creation_Script()
        {
            // Arrange
            var continuousExport = new ContinuousExport
            {
                ExternalTable = "ExternalEvents",
                Query = "Events | where timestamp > ago(1h)",
                ManagedIdentity = "system",
                IntervalBetweenRuns = 30,
                ForcedLatencyInMinutes = 5
            };

            // Act
            var scripts = continuousExport.CreateScripts("HourlyEvents", true);

            // Assert
            scripts.Should().NotBeEmpty();
            var script = scripts.First();
            script.Kind.Should().Be("ContinuousExport");
            script.Text.Should().Contain(".create-or-alter continuous-export HourlyEvents");
            script.Text.Should().Contain("to table ExternalEvents");
            script.Text.Should().Contain("Events | where timestamp > ago(1h)");
            script.Text.Should().Contain("intervalBetweenRuns=5m");
            script.Text.Should().Contain("managedIdentity='system'");
        }
    }
}