Skip to content

reorder mount step #7

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
pablomendezroyo wants to merge 1 commit into
base: main
Choose a base branch
from
Open

reorder mount step #7

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 6 additions & 5 deletions internal/adapters/composite/ensurer/ensurer.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -40,24 +40,25 @@ func NewEnsurerAdapter(dappManager *dappmanager.DappManagerAdapter, brain *brain
}

// EnsureEnvironment validates the environment and prepares it for testing.
// It sets the staker config, installs the package, stops the container, mounts the NFS, and starts the container.
// It sets the staker config, stops the container, mounts the NFS, starts the container, and updates the package.
func (e *EnsurerAdapter) EnsureEnvironment(ctx context.Context, mountConfig domain.Mount, stakerConfig domain.StakerConfig, pkg domain.Pkg) error {
if err := e.DappManager.SetStakerConfig(ctx, stakerConfig); err != nil {
return fmt.Errorf("failed to set staker config for DNP: %w", err)
}
if err := e.DappManager.PackageInstall(ctx, pkg); err != nil {
return fmt.Errorf("failed to install package: %w", err)
}
volumeTarget, err := e.Docker.StopAndGetVolumeTarget(ctx, stakerConfig.ExecutionContainerName, stakerConfig.ExecutionVolumeName)
if err != nil {
return fmt.Errorf("failed to stop container and get volume: %w", err)
}

// mount the NFS to the volume target before updating the package (if its a EC package it must start with same DB version)
if err := e.Mount.MountNFS(ctx, mountConfig.Path, volumeTarget); err != nil {
return fmt.Errorf("failed to mount NFS: %w", err)
}
if err := e.Docker.StartContainer(ctx, stakerConfig.ExecutionContainerName); err != nil {
return fmt.Errorf("failed to start container: %w", err)
}
// TODO: either if it is a EC or CC package should we wait here for the client to be synced to simulate real conditions?
if err := e.DappManager.PackageInstall(ctx, pkg); err != nil {
return fmt.Errorf("failed to install package: %w", err)
}
return nil
}