summaryrefslogtreecommitdiff
path: root/tests/Agent.Windows.Tests
diff options
context:
space:
mode:
Diffstat (limited to 'tests/Agent.Windows.Tests')
-rw-r--r--tests/Agent.Windows.Tests/CrashScenarioBootstrap.cs6
-rw-r--r--tests/Agent.Windows.Tests/SecurityPolicyTests.cs147
2 files changed, 152 insertions, 1 deletions
diff --git a/tests/Agent.Windows.Tests/CrashScenarioBootstrap.cs b/tests/Agent.Windows.Tests/CrashScenarioBootstrap.cs
index 7dd3629..dd170ab 100644
--- a/tests/Agent.Windows.Tests/CrashScenarioBootstrap.cs
+++ b/tests/Agent.Windows.Tests/CrashScenarioBootstrap.cs
@@ -26,6 +26,12 @@ internal static class CrashScenarioBootstrap
var acl = new TaskAclManager(AppContainerProfile.EnsureFixed().Sid, new MemorySecurityAuditSink(), journal);
_ = acl.Grant(taskId, Path.Combine(root, "resource"), FileCapability.Read | FileCapability.Write);
break;
+ case "acl-inheritance":
+ var inheritedAcl = new TaskAclManager(
+ new System.Security.Principal.SecurityIdentifier("S-1-15-2-330000001-330000002-330000003-330000004-330000005-330000006-330000007"),
+ new MemorySecurityAuditSink(), journal);
+ _ = inheritedAcl.Grant(taskId, Path.Combine(root, "resource"), FileCapability.Read | FileCapability.Write);
+ break;
case "acl-before":
byte[] descriptor = FileSystemAclExtensions.GetAccessControl(new DirectoryInfo(Path.Combine(root, "resource")), AccessControlSections.Access)
.GetSecurityDescriptorBinaryForm();
diff --git a/tests/Agent.Windows.Tests/SecurityPolicyTests.cs b/tests/Agent.Windows.Tests/SecurityPolicyTests.cs
index d54ab13..8d920b2 100644
--- a/tests/Agent.Windows.Tests/SecurityPolicyTests.cs
+++ b/tests/Agent.Windows.Tests/SecurityPolicyTests.cs
@@ -192,6 +192,75 @@ public sealed class SecurityPolicyTests
}
[Fact]
+ public void Root_acl_inheritance_covers_existing_and_new_descendants_and_restores_exactly()
+ {
+ using TestDirectory directory = new();
+ using TestDirectory state = new();
+ string existingDirectory = Path.Combine(directory.Path, "existing");
+ string existingFile = Path.Combine(existingDirectory, "before.txt");
+ Directory.CreateDirectory(existingDirectory);
+ File.WriteAllText(existingFile, "before");
+ byte[] rootBefore = AccessDescriptor(directory.Path);
+ byte[] existingBefore = AccessDescriptor(existingFile);
+ var sid = new System.Security.Principal.SecurityIdentifier(
+ "S-1-15-2-310000001-310000002-310000003-310000004-310000005-310000006-310000007");
+ var audit = new MemorySecurityAuditSink();
+ Guid taskId = Guid.NewGuid();
+ TaskResourceJournal journal = TaskResourceJournal.Create(Path.Combine(state.Path, "journals"), taskId);
+ TaskAclManager manager = new(sid, audit, journal);
+
+ AclSnapshot snapshot = manager.Grant(taskId, directory.Path, FileCapability.Read | FileCapability.Write);
+ JournalEntry aclEntry = Assert.Single(journal.Entries);
+ Assert.Equal("acl", aclEntry.Kind);
+ Assert.Equal(directory.Path, aclEntry.Target, ignoreCase: true);
+ Assert.Contains(AccessRules(directory.Path, sid), static rule => !rule.IsInherited);
+ Assert.Contains(AccessRules(existingFile, sid), static rule => rule.IsInherited);
+
+ string createdDirectory = Path.Combine(directory.Path, "created");
+ string createdFile = Path.Combine(createdDirectory, "during.txt");
+ Directory.CreateDirectory(createdDirectory);
+ File.WriteAllText(createdFile, "during");
+ Assert.Contains(AccessRules(createdFile, sid), static rule => rule.IsInherited);
+
+ manager.Restore(taskId, snapshot);
+ journal.CompleteAndDelete();
+
+ Assert.Equal(Convert.ToHexString(rootBefore), Convert.ToHexString(AccessDescriptor(directory.Path)));
+ Assert.Equal(Convert.ToHexString(existingBefore), Convert.ToHexString(AccessDescriptor(existingFile)));
+ Assert.Empty(AccessRules(existingFile, sid));
+ Assert.Empty(AccessRules(createdFile, sid));
+ SecurityAuditEvent applied = Assert.Single(audit.Events, item => item.Event == "acl.apply");
+ Assert.Equal("root_inheritance", applied.Data["scope"]);
+ Assert.Single(audit.Events, item => item.Event == "acl.restore");
+ Assert.Empty(Directory.EnumerateFiles(Path.Combine(state.Path, "journals")));
+ }
+
+ [Fact]
+ public void Root_acl_inheritance_does_not_override_a_protected_descendant()
+ {
+ using TestDirectory directory = new();
+ string protectedDirectory = Path.Combine(directory.Path, "protected");
+ Directory.CreateDirectory(protectedDirectory);
+ DirectorySecurity protectedAcl = FileSystemAclExtensions.GetAccessControl(
+ new DirectoryInfo(protectedDirectory), AccessControlSections.Access);
+ protectedAcl.SetAccessRuleProtection(isProtected: true, preserveInheritance: true);
+ FileSystemAclExtensions.SetAccessControl(new DirectoryInfo(protectedDirectory), protectedAcl);
+ var sid = new System.Security.Principal.SecurityIdentifier(
+ "S-1-15-2-320000001-320000002-320000003-320000004-320000005-320000006-320000007");
+ TaskAclManager manager = new(sid, new MemorySecurityAuditSink());
+
+ AclSnapshot snapshot = manager.Grant(Guid.NewGuid(), directory.Path, FileCapability.Read);
+ try
+ {
+ Assert.Empty(AccessRules(protectedDirectory, sid));
+ }
+ finally
+ {
+ manager.Restore(Guid.NewGuid(), snapshot);
+ }
+ }
+
+ [Fact]
public void Brokered_process_runs_in_fixed_app_container_with_task_acl()
{
AppContainerProfile profile = AppContainerProfile.EnsureFixed();
@@ -273,14 +342,18 @@ public sealed class SecurityPolicyTests
string journals = Path.Combine(directory.Path, "journals");
string resource = Path.Combine(directory.Path, "resource");
Directory.CreateDirectory(resource);
+ string child = Path.Combine(resource, "existing.txt");
+ File.WriteAllText(child, "existing");
byte[] aclBefore = FileSystemAclExtensions.GetAccessControl(new DirectoryInfo(resource), AccessControlSections.Access)
.GetSecurityDescriptorBinaryForm();
+ byte[] childAclBefore = AccessDescriptor(child);
var audit = new MemorySecurityAuditSink();
Guid taskId = Guid.NewGuid();
TaskResourceJournal journal = TaskResourceJournal.Create(journals, taskId);
var acl = new TaskAclManager(profile.Sid, audit, journal);
_ = acl.Grant(taskId, resource, FileCapability.Read | FileCapability.Write);
+ Assert.Contains(AccessRules(child, profile.Sid), static rule => rule.IsInherited);
Assert.False(LoopbackExemption.Contains(profile.Sid));
Guid loopbackEntry = journal.Prepare("network.loopback_exemption", profile.Sid.Value,
@@ -307,6 +380,8 @@ public sealed class SecurityPolicyTests
byte[] aclAfter = FileSystemAclExtensions.GetAccessControl(new DirectoryInfo(resource), AccessControlSections.Access)
.GetSecurityDescriptorBinaryForm();
Assert.Equal(Convert.ToHexString(aclBefore), Convert.ToHexString(aclAfter));
+ Assert.Equal(Convert.ToHexString(childAclBefore), Convert.ToHexString(AccessDescriptor(child)));
+ Assert.Empty(AccessRules(child, profile.Sid));
Assert.Empty(Directory.EnumerateFiles(journals));
}
@@ -324,9 +399,12 @@ public sealed class SecurityPolicyTests
string resourceDirectory = Path.Combine(directory.Path, "resource");
string resourceFile = Path.Combine(directory.Path, "resource.txt");
Directory.CreateDirectory(resourceDirectory);
+ string childFile = Path.Combine(resourceDirectory, "child.txt");
+ File.WriteAllText(childFile, "child-before-crash");
File.WriteAllText(resourceFile, "before-crash");
byte[] aclBefore = FileSystemAclExtensions.GetAccessControl(new DirectoryInfo(resourceDirectory), AccessControlSections.Access)
.GetSecurityDescriptorBinaryForm();
+ byte[] childAclBefore = AccessDescriptor(childFile);
Guid taskId = Guid.NewGuid();
using var child = new Process
{
@@ -358,6 +436,8 @@ public sealed class SecurityPolicyTests
byte[] aclAfter = FileSystemAclExtensions.GetAccessControl(new DirectoryInfo(resourceDirectory), AccessControlSections.Access)
.GetSecurityDescriptorBinaryForm();
Assert.Equal(Convert.ToHexString(aclBefore), Convert.ToHexString(aclAfter));
+ Assert.Equal(Convert.ToHexString(childAclBefore), Convert.ToHexString(AccessDescriptor(childFile)));
+ Assert.Empty(AccessRules(childFile, AppContainerProfile.EnsureFixed().Sid));
Assert.False(LoopbackExemption.Contains(AppContainerProfile.EnsureFixed().Sid));
string backups = Path.Combine(directory.Path, "backups");
Assert.True(!Directory.Exists(backups) || !Directory.EnumerateFileSystemEntries(backups).Any());
@@ -371,6 +451,51 @@ public sealed class SecurityPolicyTests
}
}
+ [Fact]
+ public void Independent_process_crash_recovers_root_inheritance_from_existing_child()
+ {
+ using TestDirectory directory = new();
+ string resource = Path.Combine(directory.Path, "resource");
+ string childFile = Path.Combine(resource, "child.txt");
+ Directory.CreateDirectory(resource);
+ File.WriteAllText(childFile, "before-crash");
+ byte[] rootBefore = AccessDescriptor(resource);
+ byte[] childBefore = AccessDescriptor(childFile);
+ var sid = new System.Security.Principal.SecurityIdentifier(
+ "S-1-15-2-330000001-330000002-330000003-330000004-330000005-330000006-330000007");
+ Guid taskId = Guid.NewGuid();
+ using var child = new Process
+ {
+ StartInfo = new ProcessStartInfo
+ {
+ FileName = Environment.ProcessPath!,
+ UseShellExecute = false,
+ CreateNoWindow = true,
+ Environment =
+ {
+ ["AGENT_MCP_CRASH_SCENARIO"] = "acl-inheritance",
+ ["AGENT_MCP_CRASH_ROOT"] = directory.Path,
+ ["AGENT_MCP_CRASH_TASK"] = taskId.ToString("D")
+ }
+ }
+ };
+
+ Assert.True(child.Start());
+ Assert.True(child.WaitForExit(30_000));
+ Assert.NotEqual(0, child.ExitCode);
+ Assert.False(File.Exists(Path.Combine(directory.Path, "crash-error.txt")),
+ File.Exists(Path.Combine(directory.Path, "crash-error.txt")) ? File.ReadAllText(Path.Combine(directory.Path, "crash-error.txt")) : string.Empty);
+ Assert.Contains(AccessRules(childFile, sid), static rule => rule.IsInherited);
+
+ RecoveryResult recovered = new RecoveryManager(Path.Combine(directory.Path, "journals"), new MemorySecurityAuditSink()).RecoverAll();
+
+ Assert.True(recovered.IsClean, string.Join(Environment.NewLine, recovered.Errors));
+ Assert.Equal(Convert.ToHexString(rootBefore), Convert.ToHexString(AccessDescriptor(resource)));
+ Assert.Equal(Convert.ToHexString(childBefore), Convert.ToHexString(AccessDescriptor(childFile)));
+ Assert.Empty(AccessRules(childFile, sid));
+ Assert.Empty(Directory.EnumerateFiles(Path.Combine(directory.Path, "journals")));
+ }
+
private static bool ProcessExists(int pid)
{
try { using Process process = Process.GetProcessById(pid); return !process.HasExited; }
@@ -440,7 +565,8 @@ public sealed class SecurityPolicyTests
string backups = Path.Combine(directory.Path, "backups");
Assert.True(!Directory.Exists(backups) || !Directory.EnumerateFileSystemEntries(backups).Any());
Assert.Contains(audit.Events, item => item.Event == "wfp.remove" && item.Data["residual_filters"] == "0");
- Assert.Contains(audit.Events, item => item.Event == "acl.restore");
+ Assert.Single(audit.Events, item => item.Event == "acl.apply");
+ Assert.Single(audit.Events, item => item.Event == "acl.restore");
}
[Fact(Timeout = 60_000)]
@@ -514,6 +640,25 @@ public sealed class SecurityPolicyTests
private static RestrictedProcessResult Curl(RestrictedProcessLauncher launcher, Guid taskId, string curl, string url, string cwd) =>
launcher.Run(taskId, curl, ["--noproxy", "*", "--silent", "--show-error", "--max-time", "2", url], cwd, TimeSpan.FromSeconds(10));
+ private static byte[] AccessDescriptor(string path)
+ {
+ FileSystemSecurity security = Directory.Exists(path)
+ ? FileSystemAclExtensions.GetAccessControl(new DirectoryInfo(path), AccessControlSections.Access)
+ : FileSystemAclExtensions.GetAccessControl(new FileInfo(path), AccessControlSections.Access);
+ return security.GetSecurityDescriptorBinaryForm();
+ }
+
+ private static FileSystemAccessRule[] AccessRules(string path, System.Security.Principal.SecurityIdentifier sid)
+ {
+ FileSystemSecurity security = Directory.Exists(path)
+ ? FileSystemAclExtensions.GetAccessControl(new DirectoryInfo(path), AccessControlSections.Access)
+ : FileSystemAclExtensions.GetAccessControl(new FileInfo(path), AccessControlSections.Access);
+ return security.GetAccessRules(includeExplicit: true, includeInherited: true, typeof(System.Security.Principal.SecurityIdentifier))
+ .OfType<FileSystemAccessRule>()
+ .Where(rule => rule.IdentityReference == sid && rule.AccessControlType == AccessControlType.Allow)
+ .ToArray();
+ }
+
private sealed class TestDirectory : IDisposable
{
public TestDirectory()
generated by cgit v1.2.3 (git 2.39.1) at 2026-10-19 21:22:08 +0000