|
|
|
@@ -24,8 +24,10 @@ internal sealed record LocalParityLaunchProfile(
|
|
|
|
|
string OverlayPath, string CatalogRoot, string PatternName, string EvidenceRoot, string? NetworkSettingsEndpoint = null,
|
|
|
|
|
LegacySettingsSnapshot? SettingsSnapshot = null);
|
|
|
|
|
|
|
|
|
|
internal sealed record LocalParityPrepared(LocalParityLaunchProfile Profile, PackageRequirement Requirement,
|
|
|
|
|
PackageManifest Manifest, ImmutableLocalPackage Package, PackageActivationResult Activation,
|
|
|
|
|
internal sealed record LocalParityPackage(PackageRequirement Requirement, PackageManifest Manifest,
|
|
|
|
|
ImmutableLocalPackage Package, PackageActivationResult Activation);
|
|
|
|
|
|
|
|
|
|
internal sealed record LocalParityPrepared(LocalParityLaunchProfile Profile, IReadOnlyList<LocalParityPackage> Packages,
|
|
|
|
|
string StarterPath, string StarterSha256);
|
|
|
|
|
|
|
|
|
|
internal sealed record LocalParityLaunchResult(int ProcessId, bool StartupVerified, bool PackageLoadConfirmed,
|
|
|
|
@@ -60,20 +62,23 @@ internal sealed class LocalParityLaunchService
|
|
|
|
|
var selection = adapter.ParseDownloadList(await File.ReadAllTextAsync(profile.DownloadListPath, ct));
|
|
|
|
|
var overlay = LegacyCompatibilityOverlayParser.Parse(await File.ReadAllTextAsync(profile.OverlayPath, ct));
|
|
|
|
|
var requirements = adapter.Join(pattern[0], selection, overlay);
|
|
|
|
|
if (requirements.Count != 1) throw new InvalidOperationException("LOCAL_PARITY_EXACTLY_ONE_PACKAGE_REQUIRED");
|
|
|
|
|
var requirement = requirements[0];
|
|
|
|
|
var source = Under(profile.CatalogRoot, requirement.PackageId, requirement.RequiredVersion);
|
|
|
|
|
var manifestPath = Under(source, "package.manifest.json");
|
|
|
|
|
var manifest = PackageManifestJson.Parse(await File.ReadAllTextAsync(manifestPath, ct));
|
|
|
|
|
if (!ManifestMatches(manifest, requirement)) throw new InvalidOperationException("LOCAL_PARITY_MANIFEST_REQUIREMENT_MISMATCH");
|
|
|
|
|
var store = new LocalPackageStore(profile.Root, new Sha256FileHasher());
|
|
|
|
|
var package = await store.MaterializeAsync(manifest, source, ct);
|
|
|
|
|
await store.BindAsync(requirement, package.Version, ct);
|
|
|
|
|
var activation = await store.ActivateImmutableAsync(package, requirement, ct);
|
|
|
|
|
if (activation.Outcome is not ("Activated" or "AlreadyActiveExact")) throw new InvalidOperationException("LOCAL_PARITY_ACTIVATION_" + activation.Outcome);
|
|
|
|
|
if (await store.ResolveAsync(requirement, ct) is null) throw new InvalidOperationException("LOCAL_PARITY_ACTIVE_REVALIDATION_FAILED");
|
|
|
|
|
var starter = await GenerateStarterAsync(profile, package, manifest, ct);
|
|
|
|
|
return new(profile, requirement, manifest, package, activation, starter.Path, starter.Sha256);
|
|
|
|
|
var prepared = new List<LocalParityPackage>();
|
|
|
|
|
foreach (var requirement in requirements)
|
|
|
|
|
{
|
|
|
|
|
var source = Under(profile.CatalogRoot, requirement.PackageId, requirement.RequiredVersion);
|
|
|
|
|
var manifestPath = Under(source, "package.manifest.json");
|
|
|
|
|
var manifest = PackageManifestJson.Parse(await File.ReadAllTextAsync(manifestPath, ct));
|
|
|
|
|
if (!ManifestMatches(manifest, requirement)) throw new InvalidOperationException("LOCAL_PARITY_MANIFEST_REQUIREMENT_MISMATCH");
|
|
|
|
|
var package = await store.MaterializeAsync(manifest, source, ct);
|
|
|
|
|
await store.BindAsync(requirement, package.Version, ct);
|
|
|
|
|
var activation = await store.ActivateImmutableAsync(package, requirement, ct);
|
|
|
|
|
if (activation.Outcome is not ("Activated" or "AlreadyActiveExact")) throw new InvalidOperationException("LOCAL_PARITY_ACTIVATION_" + activation.Outcome);
|
|
|
|
|
if (await store.ResolveAsync(requirement, ct) is null) throw new InvalidOperationException("LOCAL_PARITY_ACTIVE_REVALIDATION_FAILED");
|
|
|
|
|
prepared.Add(new(requirement, manifest, package, activation));
|
|
|
|
|
}
|
|
|
|
|
var starter = await GenerateStarterAsync(profile, prepared, ct);
|
|
|
|
|
return new(profile, prepared, starter.Path, starter.Sha256);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task<LocalParityLaunchResult> LaunchAsync(LocalParityPrepared prepared, CancellationToken ct)
|
|
|
|
@@ -90,6 +95,7 @@ internal sealed class LocalParityLaunchService
|
|
|
|
|
// Controlled-local only: accepted Plant runtime bootstrap. Keep /b and the owned SCR last.
|
|
|
|
|
psi.ArgumentList.Add("/b"); psi.ArgumentList.Add(prepared.StarterPath);
|
|
|
|
|
psi.Environment["P_REC_ANNOT_RUNTIME_MODE"] = "Smoke";
|
|
|
|
|
psi.Environment["P_REC_UPDATE_MARKER_ROOT"] = Path.Combine(Path.GetDirectoryName(prepared.StarterPath)!, "markers");
|
|
|
|
|
using var process = Process.Start(psi) ?? throw new InvalidOperationException("PLANT3D_PROCESS_NOT_CREATED");
|
|
|
|
|
await Task.Delay(TimeSpan.FromSeconds(30), ct);
|
|
|
|
|
var alive = !process.HasExited;
|
|
|
|
@@ -104,21 +110,23 @@ internal sealed class LocalParityLaunchService
|
|
|
|
|
var newLog = await reader.ReadToEndAsync(ct);
|
|
|
|
|
runtimeConfirmed = newLog.Contains("AssemblyInitializeCompleted", StringComparison.Ordinal) && newLog.Contains($"\"ProcessId\":{process.Id}", StringComparison.Ordinal);
|
|
|
|
|
}
|
|
|
|
|
var loaded = runtimeConfirmed;
|
|
|
|
|
var updatePackage = prepared.Packages.SingleOrDefault(x => string.Equals(x.Package.PackageId, "P_Rec_Update", StringComparison.Ordinal));
|
|
|
|
|
var updateInitialized = updatePackage is null || File.Exists(Path.Combine(Path.GetDirectoryName(prepared.StarterPath)!, "markers", "AssemblyInitializeCompleted.marker"));
|
|
|
|
|
var loaded = runtimeConfirmed && updateInitialized;
|
|
|
|
|
var terminal = alive && loaded ? "Succeeded" : "Blocked";
|
|
|
|
|
var settingsSnapshot = prepared.Profile.SettingsSnapshot is null ? null : new { sourceEndpointFingerprint = prepared.Profile.SettingsSnapshot.SourceFingerprint, prepared.Profile.SettingsSnapshot.Sha256, prepared.Profile.SettingsSnapshot.Length, prepared.Profile.SettingsSnapshot.LastWriteUtc, prepared.Profile.SettingsSnapshot.AcquiredUtc, prepared.Profile.SettingsSnapshot.OfflineFallback };
|
|
|
|
|
var evidence = new { schemaVersion = 3, launcherCommit = ThisCommit(), autodeskCommit = "68f5006", operationId, configuration = prepared.Profile.Name, selectedPattern = prepared.Profile.PatternName, settingsSnapshot, orderedPluginIds = new[] { prepared.Requirement.PackageId }, exactPackage = new { prepared.Package.PackageId, prepared.Package.Version, prepared.Manifest.Product, prepared.Manifest.ProductYear, prepared.Manifest.Architecture, prepared.Manifest.RolloutChannel }, manifestSha256 = await HashAsync(Path.Combine(prepared.Package.LocalPackageRoot, "package.manifest.json"), ct), payloads = prepared.Manifest.Files.Select(x => new { path = x.Path, x.Length, x.Sha256 }), materialization = "MaterializedOrAlreadyPresentExact", activation = prepared.Activation.Outcome, pointerGeneration = prepared.Activation.Receipt?.PointerGeneration, bootstrapMechanism="StartupScript", commandLineSwitch="/b", scriptWasLastArgument=true, scriptSha256=prepared.StarterSha256, plant = new { product = "Plant3D", year = 2026, executableFingerprint = Fingerprint(product.ExecutablePath, operationId), interactive = true, batchArgumentUsed = true }, process = new { pid = process.Id, newProcessCreated=true, startupVerified = alive, packageLoadConfirmed = loaded, markerConfirmed, runtimeJournalConfirmed = runtimeConfirmed, processInteractiveAfterScript=alive }, terminalState = terminal, sideEffects = new { corporateDfsUsed = false, corporateDfsWriteAttempted = false, directDfsExecutionAttempted = false, productionProjectAccessed = false, productionPointerMutationAttempted = false, machineWideSecurityChanged=false, productionDeploymentAttempted = false } };
|
|
|
|
|
var evidence = new { schemaVersion = 3, launcherCommit = ThisCommit(), autodeskCommit = "68f5006", operationId, configuration = prepared.Profile.Name, selectedPattern = prepared.Profile.PatternName, settingsSnapshot, orderedPluginIds = prepared.Packages.Select(x => x.Requirement.PackageId), exactPackages = prepared.Packages.Select(x => new { x.Package.PackageId, x.Package.Version, x.Manifest.Product, x.Manifest.ProductYear, x.Manifest.Architecture, x.Manifest.RolloutChannel, manifestSha256 = HashAsync(Path.Combine(x.Package.LocalPackageRoot, "package.manifest.json"), ct).GetAwaiter().GetResult(), payloads = x.Manifest.Files.Select(f => new { path = f.Path, f.Length, f.Sha256 }), activation = x.Activation.Outcome, pointerGeneration = x.Activation.Receipt?.PointerGeneration }), materialization = "MaterializedOrAlreadyPresentExact", bootstrapMechanism="StartupScript", commandLineSwitch="/b", scriptWasLastArgument=true, scriptSha256=prepared.StarterSha256, plant = new { product = "Plant3D", year = 2026, executableFingerprint = Fingerprint(product.ExecutablePath, operationId), interactive = true, batchArgumentUsed = true }, process = new { pid = process.Id, newProcessCreated=true, startupVerified = alive, packageLoadConfirmed = loaded, markerConfirmed, runtimeJournalConfirmed = runtimeConfirmed, updateInitialized, processInteractiveAfterScript=alive }, terminalState = terminal, sideEffects = new { corporateDfsUsed = false, corporateDfsWriteAttempted = false, directDfsExecutionAttempted = false, productionProjectAccessed = false, productionPointerMutationAttempted = false, machineWideSecurityChanged=false, productionDeploymentAttempted = false } };
|
|
|
|
|
var evidencePath = await WriteEvidenceAsync(evidenceDirectory, evidence, ct);
|
|
|
|
|
return new(process.Id, alive, loaded, evidencePath, terminal);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private static async Task<(string Path, string Sha256)> GenerateStarterAsync(LocalParityLaunchProfile profile, ImmutableLocalPackage package, PackageManifest manifest, CancellationToken ct)
|
|
|
|
|
private static async Task<(string Path, string Sha256)> GenerateStarterAsync(LocalParityLaunchProfile profile, IReadOnlyList<LocalParityPackage> packages, CancellationToken ct)
|
|
|
|
|
{
|
|
|
|
|
var starterRoot = Under(profile.Root, "bootstrap", Guid.NewGuid().ToString("N")); Directory.CreateDirectory(starterRoot);
|
|
|
|
|
var entry = Under(package.LocalPackageRoot, manifest.EntryAssembly);
|
|
|
|
|
if (!File.Exists(entry)) throw new InvalidOperationException("LOCAL_PARITY_ENTRY_MISSING");
|
|
|
|
|
var marker = Under(starterRoot, "pxp-oa-netload.marker");
|
|
|
|
|
var content = "_.FILEDIA\r\n0\r\n_.CMDDIA\r\n0\r\n_.NETLOAD\r\n\"" + entry.Replace("\"", "\\\"") + "\"\r\n";
|
|
|
|
|
var entries = packages.Select(x => Under(x.Package.LocalPackageRoot, x.Manifest.EntryAssembly)).ToArray();
|
|
|
|
|
if (entries.Any(x => !File.Exists(x))) throw new InvalidOperationException("LOCAL_PARITY_ENTRY_MISSING");
|
|
|
|
|
Directory.CreateDirectory(Under(starterRoot, "markers"));
|
|
|
|
|
var content = "_.FILEDIA\r\n0\r\n_.CMDDIA\r\n0\r\n" + string.Concat(entries.Select(entry => "_.NETLOAD\r\n\"" + entry.Replace("\"", "\\\"") + "\"\r\n"));
|
|
|
|
|
var path = Under(starterRoot, "startup.scr");
|
|
|
|
|
await File.WriteAllTextAsync(path, content, new UTF8Encoding(false), ct);
|
|
|
|
|
return (path, await HashAsync(path, ct));
|
|
|
|
|