1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167
|
package main
import (
"fmt"
"os"
"strings"
"github.com/containers/buildah"
buildahcli "github.com/containers/buildah/pkg/cli"
"github.com/containers/buildah/pkg/parse"
"github.com/pkg/errors"
"github.com/sirupsen/logrus"
"github.com/spf13/cobra"
)
type runInputOptions struct {
addHistory bool
capAdd []string
capDrop []string
hostname string
isolation string
mounts []string
runtime string
runtimeFlag []string
noPivot bool
terminal bool
volumes []string
*buildahcli.NameSpaceResults
}
func init() {
var (
runDescription = "\n Runs a specified command using the container's root filesystem as a root\n filesystem, using configuration settings inherited from the container's\n image or as specified using previous calls to the config command."
opts runInputOptions
)
namespaceResults := buildahcli.NameSpaceResults{}
runCommand := &cobra.Command{
Use: "run",
Short: "Run a command inside of the container",
Long: runDescription,
RunE: func(cmd *cobra.Command, args []string) error {
opts.NameSpaceResults = &namespaceResults
return runCmd(cmd, args, opts)
},
Example: `buildah run containerID -- ps -auxw
buildah run --tty containerID /bin/bash
buildah run --volume /path/on/host:/path/in/container:ro,z containerID /bin/sh`,
}
runCommand.SetUsageTemplate(UsageTemplate())
flags := runCommand.Flags()
flags.SetInterspersed(false)
flags.BoolVar(&opts.addHistory, "add-history", false, "add an entry for this operation to the image's history. Use BUILDAH_HISTORY environment variable to override. (default false)")
flags.StringSliceVar(&opts.capAdd, "cap-add", []string{}, "add the specified capability (default [])")
flags.StringSliceVar(&opts.capDrop, "cap-drop", []string{}, "drop the specified capability (default [])")
flags.StringVar(&opts.hostname, "hostname", "", "set the hostname inside of the container")
flags.StringVar(&opts.isolation, "isolation", buildahcli.DefaultIsolation(), "`type` of process isolation to use. Use BUILDAH_ISOLATION environment variable to override.")
// Do not set a default runtime here, we'll do that later in the processing.
flags.StringVar(&opts.runtime, "runtime", "", "`path` to an alternate OCI runtime")
flags.StringSliceVar(&opts.runtimeFlag, "runtime-flag", []string{}, "add global flags for the container runtime")
flags.BoolVar(&opts.noPivot, "no-pivot", false, "do not use pivot root to jail process inside rootfs")
// TODO add-third alias for tty
flags.BoolVarP(&opts.terminal, "terminal", "t", false, "allocate a pseudo-TTY in the container")
flags.BoolVar(&opts.terminal, "tty", false, "allocate a pseudo-TTY in the container")
if err := flags.MarkHidden("tty"); err != nil {
panic(fmt.Sprintf("error marking tty flag as hidden: %v", err))
}
flags.StringArrayVarP(&opts.volumes, "volume", "v", []string{}, "bind mount a host location into the container while running the command")
flags.StringArrayVar(&opts.mounts, "mount", []string{}, "Attach a filesystem mount to the container (default [])")
userFlags := getUserFlags()
namespaceFlags := buildahcli.GetNameSpaceFlags(&namespaceResults)
flags.AddFlagSet(&userFlags)
flags.AddFlagSet(&namespaceFlags)
flags.SetNormalizeFunc(buildahcli.AliasFlags)
rootCmd.AddCommand(runCommand)
}
func runCmd(c *cobra.Command, args []string, iopts runInputOptions) error {
if len(args) == 0 {
return errors.Errorf("container ID must be specified")
}
name := args[0]
args = Tail(args)
if len(args) > 0 && args[0] == "--" {
args = args[1:]
}
if len(args) == 0 {
return errors.Errorf("command must be specified")
}
store, err := getStore(c)
if err != nil {
return err
}
builder, err := openBuilder(getContext(), store, name)
if err != nil {
return errors.Wrapf(err, "error reading build container %q", name)
}
isolation, err := parse.IsolationOption(c.Flag("isolation").Value.String())
if err != nil {
return err
}
runtimeFlags := []string{}
for _, arg := range iopts.runtimeFlag {
runtimeFlags = append(runtimeFlags, "--"+arg)
}
noPivot := iopts.noPivot || (os.Getenv("BUILDAH_NOPIVOT") != "")
namespaceOptions, networkPolicy, err := parse.NamespaceOptions(c)
if err != nil {
return err
}
options := buildah.RunOptions{
Hostname: iopts.hostname,
Runtime: iopts.runtime,
Args: runtimeFlags,
NoPivot: noPivot,
User: c.Flag("user").Value.String(),
Isolation: isolation,
NamespaceOptions: namespaceOptions,
ConfigureNetwork: networkPolicy,
CNIPluginPath: iopts.CNIPlugInPath,
CNIConfigDir: iopts.CNIConfigDir,
AddCapabilities: iopts.capAdd,
DropCapabilities: iopts.capDrop,
}
if c.Flag("terminal").Changed {
if iopts.terminal {
options.Terminal = buildah.WithTerminal
} else {
options.Terminal = buildah.WithoutTerminal
}
}
mounts, err := parse.GetVolumes(iopts.volumes, iopts.mounts)
if err != nil {
return err
}
options.Mounts = mounts
runerr := builder.Run(args, options)
if runerr != nil {
logrus.Debugf("error running %v in container %q: %v", args, builder.Container, runerr)
}
if runerr == nil {
shell := "/bin/sh -c"
if len(builder.Shell()) > 0 {
shell = strings.Join(builder.Shell(), " ")
}
conditionallyAddHistory(builder, c, "%s %s", shell, strings.Join(args, " "))
return builder.Save()
}
return runerr
}
|