Function CreateTransformer

pkg/bridge/transformers.go:43–114

(ctx context.Context, dockerCli command.Cli, options CreateTransformerOptions)

}

func CreateTransformer(ctx context.Context, dockerCli command.Cli, options CreateTransformerOptions) error {
	if options.From == "" {
		options.From = DefaultTransformerImage
	}
	out, err := filepath.Abs(options.Dest)
	if err != nil {
		return err
	}

	if _, err := os.Stat(out); err == nil {
		return fmt.Errorf("output folder %s already exists", out)
	}

	tmpl := filepath.Join(out, "templates")
	err = os.MkdirAll(tmpl, 0o744)
	if err != nil && !os.IsExist(err) {
		return fmt.Errorf("cannot create output folder: %w", err)
	}

	if err := command.ValidateOutputPath(out); err != nil {
		return err
	}

	created, err := dockerCli.Client().ContainerCreate(ctx, client.ContainerCreateOptions{
		Image: options.From,
	})

	defer func() {
		_, _ = dockerCli.Client().ContainerRemove(context.Background(), created.ID, client.ContainerRemoveOptions{
			Force: true,
		})
	}()

	if err != nil {
		return err
	}
	resp, err := dockerCli.Client().CopyFromContainer(ctx, created.ID, client.CopyFromContainerOptions{
		SourcePath: templatesPath,
	})
	if err != nil {
		return err
	}
	defer func() {
		_ = resp.Content.Close()
	}()

	srcInfo := archive.CopyInfo{
		Path:   templatesPath,
		Exists: true,
		IsDir:  resp.Stat.Mode.IsDir(),
	}

	preArchive := resp.Content
	if srcInfo.RebaseName != "" {
		_, srcBase := archive.SplitPathDirEntry(srcInfo.Path)
		preArchive = archive.RebaseArchiveEntries(resp.Content, srcBase, srcInfo.RebaseName)
	}