Method setupComposeInMemory

pkg/client/app/app.go:241–287

setupComposeInMemory handles the in-memory variant of SetupCompose. It parses the compose YAML that was passed via opts.InMemoryCompose (never written to disk), injects the keploy-agent service, serialises the result back to bytes, and configures the command to pipe the content via stdin ("-f -").

(extraArgs []string)

// injects the keploy-agent service, serialises the result back to bytes, and
// configures the command to pipe the content via stdin ("-f -").
func (a *App) setupComposeInMemory(extraArgs []string) error {
	var compose docker.Compose
	if err := yaml.Unmarshal(a.opts.InMemoryCompose, &compose); err != nil {
		return fmt.Errorf("failed to parse in-memory compose YAML: %w", err)
	}

	serviceInfo, err := a.docker.FindContainerInCompose(&compose, a.container)
	if err != nil {
		utils.LogError(a.logger, err, "failed to find container in in-memory compose")
		return err
	}

	a.opts.AppPorts = serviceInfo.Ports
	a.opts.AppNetworks = serviceInfo.Networks
	a.opts.ExtraArgs = extraArgs
	a.composeService = serviceInfo.AppServiceName

	if err := a.docker.ModifyComposeForAgent(&compose, a.opts, a.container); err != nil {
		utils.LogError(a.logger, err, "failed to modify in-memory compose for keploy integration")
		return err
	}

	if HookImpl != nil {
		changed, err := HookImpl.BeforeDockerComposeSetup(context.Background(), &compose, a.container)
		if err != nil {
			utils.LogError(a.logger, err, "hook failed during in-memory docker compose setup")
			return err
		}
		if changed {
			a.logger.Debug("Successfully ran BeforeDockerComposeSetup hook and modified volumes")
		}
	}

	content, err := a.docker.MarshalCompose(&compose)
	if err != nil {
		return fmt.Errorf("failed to serialise modified compose to YAML: %w", err)
	}
	a.composeContent = content

	// Ensure the command uses stdin ("-f -") and has the exit-code-from flags.
	a.cmd = ensureInMemoryComposeFlags(a.cmd, a.composeService)

	a.logger.Info("Running application using in-memory Keploy-generated Docker Compose (no file written to disk)",
		zap.String("cmd", a.cmd))

	return nil
}

func (a *App) SetAppCommand(appCommand string) {
	a.logger.Debug("Setting App Command", zap.String("cmd", appCommand))