maxmustermann/pulumi
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[auto/dotnet] Introduce failing tests to test throwing exception during up

Browse source
This commit is contained in:
Ville Penttinen 2021-05-14 18:12:09 +03:00
parent f378e68367
commit 077efd1ccf
1 changed files with 159 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

159
sdk/dotnet/Pulumi.Automation.Tests/LocalWorkspaceTests.cs
View file

@ -1218,6 +1218,165 @@ namespace Pulumi.Automation.Tests
}
}
[Fact]
public async Task ThrowingExceptionDuringUpShouldNotDeleteResourcesInlineProgram()
{
var program = PulumiFn.Create(() =>
{
var config = new Config();
var a = new ComponentResource("test:res:a", "a", null);
if (config.GetBoolean("ShouldFail") == true) throw new InvalidOperationException("ShouldFail");
var b = new ComponentResource("test:res:b", "b", null);
var c = new ComponentResource("test:res:c", "c", null);
});
Assert.IsType<PulumiFnInline>(program);
var stackName = $"{RandomStackName()}";
var projectName = "test_optionally_failing_stack";
using var stack = await LocalWorkspace.CreateStackAsync(new InlineProgramArgs(projectName, stackName, program)
{
EnvironmentVariables = new Dictionary<string, string?>()
{
["PULUMI_CONFIG_PASSPHRASE"] = "test",
}
});
var config = new Dictionary<string, ConfigValue>()
{
["ShouldFail"] = new ConfigValue("false"),
};
try
{
await stack.SetAllConfigAsync(config);
// pulumi up
var upResult = await stack.UpAsync();
Assert.Equal(UpdateKind.Update, upResult.Summary.Kind);
Assert.Equal(UpdateState.Succeeded, upResult.Summary.Result);
Assert.True(upResult.Summary.ResourceChanges!.TryGetValue(OperationType.Create, out var upCount));
Assert.Equal(4, upCount);
config["ShouldFail"] = new ConfigValue("true");
await stack.SetAllConfigAsync(config);
var sb = new System.Text.StringBuilder();
try
{
await stack.UpAsync(new UpOptions() { OnStandardOutput = msg => sb.AppendLine(msg) });
}
catch (InvalidOperationException ex) when (ex.Message == "ShouldFail")
{
// Expected
}
var upOutput = sb.ToString();
Assert.DoesNotContain("test:res:b b deleted", upOutput);
Assert.DoesNotContain("test:res:c c deleted", upOutput);
config["ShouldFail"] = new ConfigValue("false");
await stack.SetAllConfigAsync(config);
// pulumi preview
var previewResult = await stack.PreviewAsync(new PreviewOptions() { OnStandardOutput = Console.WriteLine });
Assert.True(previewResult.ChangeSummary.TryGetValue(OperationType.Same, out var sameCount));
Assert.Equal(4, sameCount);
}
finally
{
var destroyResult = await stack.DestroyAsync();
Assert.Equal(UpdateKind.Destroy, destroyResult.Summary.Kind);
Assert.Equal(UpdateState.Succeeded, destroyResult.Summary.Result);
await stack.Workspace.RemoveStackAsync(stackName);
}
}
private class OptionallyFailingStack : Stack
{
public OptionallyFailingStack()
{
var config = new Config();
var a = new ComponentResource("test:res:a", "a", null);
if (config.GetBoolean("ShouldFail") == true) throw new InvalidOperationException("ShouldFail");
var b = new ComponentResource("test:res:b", "b", null);
var c = new ComponentResource("test:res:c", "c", null);
}
}
[Fact]
public async Task ThrowingExceptionDuringUpShouldNotDeleteResources()
{
var program = PulumiFn.Create<OptionallyFailingStack>();
Assert.IsType<PulumiFn<OptionallyFailingStack>>(program);
var stackName = $"{RandomStackName()}";
var projectName = "test_optionally_failing_stack";
using var stack = await LocalWorkspace.CreateStackAsync(new InlineProgramArgs(projectName, stackName, program)
{
EnvironmentVariables = new Dictionary<string, string?>()
{
["PULUMI_CONFIG_PASSPHRASE"] = "test",
}
});
var config = new Dictionary<string, ConfigValue>()
{
["ShouldFail"] = new ConfigValue("false"),
};
try
{
await stack.SetAllConfigAsync(config);
// pulumi up
var upResult = await stack.UpAsync();
Assert.Equal(UpdateKind.Update, upResult.Summary.Kind);
Assert.Equal(UpdateState.Succeeded, upResult.Summary.Result);
Assert.True(upResult.Summary.ResourceChanges!.TryGetValue(OperationType.Create, out var upCount));
Assert.Equal(4, upCount);
config["ShouldFail"] = new ConfigValue("true");
await stack.SetAllConfigAsync(config);
var sb = new System.Text.StringBuilder();
try
{
await stack.UpAsync(new UpOptions() { OnStandardOutput = msg => sb.AppendLine(msg) });
}
catch (InvalidOperationException ex) when (ex.Message == "ShouldFail")
{
// Expected
}
var upOutput = sb.ToString();
Assert.DoesNotContain("test:res:b b deleted", upOutput);
Assert.DoesNotContain("test:res:c c deleted", upOutput);
config["ShouldFail"] = new ConfigValue("false");
await stack.SetAllConfigAsync(config);
// pulumi preview
var previewResult = await stack.PreviewAsync(new PreviewOptions() { OnStandardOutput = Console.WriteLine });
Assert.True(previewResult.ChangeSummary.TryGetValue(OperationType.Same, out var sameCount));
Assert.Equal(4, sameCount);
}
finally
{
var destroyResult = await stack.DestroyAsync();
Assert.Equal(UpdateKind.Destroy, destroyResult.Summary.Kind);
Assert.Equal(UpdateState.Succeeded, destroyResult.Summary.Result);
await stack.Workspace.RemoveStackAsync(stackName);
}
}
[Fact]
public async Task PulumiVersionTest()
{