Function newComposeBackupContext

agent/app/service/backup_compose.go:308–344

(req dto.CommonBackup, backupDir, fileName string)

}

func newComposeBackupContext(req dto.CommonBackup, backupDir, fileName string) (*composeBackupContext, error) {
	if req.Name == "" {
		return nil, fmt.Errorf("compose name is required")
	}
	dockerClient, err := dockerUtils.NewDockerClient()
	if err != nil {
		return nil, err
	}
	composePath, composeFiles, err := loadComposePathAndFiles(req.Name, dockerClient)
	if err != nil {
		_ = dockerClient.Close()
		return nil, err
	}
	filePath := path.Join(backupDir, fileName)
	tmpDir := path.Join(path.Dir(filePath), strings.TrimSuffix(path.Base(filePath), ".tar.gz"))
	ctx := &composeBackupContext{
		req:          req,
		composeName:  req.Name,
		composePath:  composePath,
		composeFiles: composeFiles,
		composeDir:   path.Dir(composeFiles[0]),
		fileOp:       files.NewFileOp(),
		dockerClient: dockerClient,
		backupDir:    backupDir,
		fileName:     fileName,
		filePath:     filePath,
		tmpDir:       tmpDir,
		meta: composeBackupMeta{
			ComposeName: req.Name,
			ComposePath: composePath,
			CreatedAt:   time.Now().Format(constant.DateTimeLayout),
			Files:       make([]composeBackupFile, 0),
			Containers:  make([]string, 0),
		},
	}
	return ctx, nil
}

func loadComposePathAndFiles(composeName string, dockerClient *client.Client) (string, []string, error) {
	composeRecord, _ := composeRepo.GetRecord(repo.WithByName(composeName))