StepRunner::obtainDockerSocketMount() - Code Metrics - Inspection of "... respect DOCKER_HOST parameter" - ktomk/pipelines - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — test ( 3623cf...52bb81 )

by Tom

created 2019-12-28 08:32 UTC

StepRunner::obtainDockerSocketMount() A

↳ Parent: StepRunner

Complexity

Conditions	5
Paths	5

Size

Total Lines	25
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	11
CRAP Score	5

Importance

Changes

Metric	Value
cc	5
eloc	12
nc	5
nop	0
dl	0
loc	25
ccs	11
cts	11
cp	1
crap	5
rs	9.5555
c	0
b	0
f	0

<?php

/* this file is part of pipelines */

namespace Ktomk\Pipelines\Runner;

use Ktomk\Pipelines\Cli\Docker;
use Ktomk\Pipelines\Cli\Exec;
use Ktomk\Pipelines\Cli\Streams;
use Ktomk\Pipelines\DestructibleString;
use Ktomk\Pipelines\File\Image;
use Ktomk\Pipelines\File\Step;
use Ktomk\Pipelines\Lib;
use Ktomk\Pipelines\LibFs;
use Ktomk\Pipelines\LibTmp;
use Ktomk\Pipelines\Runner\Docker\ArtifactSource;
use Ktomk\Pipelines\Runner\Docker\Binary\Repository;
use Ktomk\Pipelines\Runner\Docker\ImageLogin;

/**
 * Runner for a single step of a pipeline
 */
class StepRunner
{
    /**
     * @var RunOpts
     */
    private $runOpts;

    /**
     * @var Directories
     */
    private $directories;

    /**
     * @var Exec
     */
    private $exec;

    /**
     * @var Flags
     */
    private $flags;

    /**
     * @var Env
     */
    private $env;

    /**
     * @var Streams
     */
    private $streams;

    /**
     * list of temporary directory destructible markers
     *
     * @var array
     */
    private $temporaryDirectories = array();

    /**
     * DockerSession constructor.
     *
     * @param RunOpts $runOpts
     * @param Directories $directories source repository root directory based directories object
     * @param Exec $exec
     * @param Flags $flags
     * @param Env $env
     * @param Streams $streams
     */
    public function __construct(
        RunOpts $runOpts,
        Directories $directories,
        Exec $exec,
        Flags $flags,
        Env $env,
        Streams $streams
    )
    {
        $this->runOpts = $runOpts;
        $this->directories = $directories;
        $this->exec = $exec;
        $this->flags = $flags;
        $this->env = $env;
        $this->streams = $streams;
    }

    /**
     * @param Step $step
     *
     * @return null|int exist status of step script or null if the run operation failed
     */
    public function runStep(Step $step)
    {
        $dir = $this->directories->getProjectDirectory();
        $env = $this->env;
        $exec = $this->exec;
        $streams = $this->streams;

        $env->setPipelinesProjectPath($dir);

        $container = StepContainer::create($step, $exec);

        $name = $container->generateName($this->runOpts->getPrefix(), $this->directories->getName());
        $env->setContainerName($name);

        $image = $step->getImage();

        # launch container
        $streams->out(sprintf(
            "\x1D+++ step #%d\n\n    name...........: %s\n    effective-image: %s\n    container......: %s\n",
            $step->getIndex() + 1,
            $step->getName() ? '"' . $step->getName() . '"' : '(unnamed)',
            $image->getName(),
            $name
        ));

        $id = $container->keepOrKill($this->flags->reuseContainer());

        $deployCopy = $this->flags->deployCopy();

        if (null === $id) {
            list($id, $status) = $this->runNewContainer($container, $dir, $deployCopy, $step);
            if (null === $id) {
                return $status;
            }
        }

        $streams->out(sprintf("    container-id...: %s\n\n", substr($id, 0, 12)));

        # TODO: different deployments, mount (default), mount-ro, copy
        if (null !== $result = $this->deployCopy($deployCopy, $id, $dir)) {
            return $result;
        }

        list($status, $message) = $this->deployDockerClient($step, $id);
        if (0 !== $status) {
            $this->streams->err(rtrim($message, "\n") . "\n");

            return $status;
        }

        $status = $this->runStepScript($step, $streams, $exec, $name);

        $this->captureStepArtifacts($step, $deployCopy && 0 === $status, $id, $dir);

        $this->shutdownStepContainer($container, $status);

        return $status;
    }

    /**
     * method to wrap new to have a test-point
     *
     * @return Repository
     */
    public function getDockerBinaryRepository()
    {
        $repo = Repository::create($this->exec, $this->directories);
        $repo->resolve($this->runOpts->getBinaryPackage());

        return $repo;
    }

    /**
     * @param Step $step
     * @param bool $copy
     * @param string $id container id
     * @param string $dir to put artifacts in (project directory)
     *
     * @throws \RuntimeException
     */
    private function captureStepArtifacts(Step $step, $copy, $id, $dir)
    {
        # capturing artifacts is only supported for deploy copy
        if (!$copy) {
            return;
        }

        $artifacts = $step->getArtifacts();

        if (null === $artifacts) {
            return;
        }

        $exec = $this->exec;
        $streams = $this->streams;

        $streams->out("\x1D+++ copying artifacts from container...\n");

        $source = new ArtifactSource($exec, $id, $dir);

        $patterns = $artifacts->getPatterns();
        foreach ($patterns as $pattern) {
            $this->captureArtifactPattern($source, $pattern, $dir);
        }

        $streams('');
    }

    /**
     * @param ArtifactSource $source
     * @param string $pattern
     * @param string $dir
     *
     * @throws \RuntimeException
     * @see Runner::captureStepArtifacts()
     *
     */
    private function captureArtifactPattern(ArtifactSource $source, $pattern, $dir)
    {
        $exec = $this->exec;
        $streams = $this->streams;

        $id = $source->getId();
        $paths = $source->findByPattern($pattern);
        if (empty($paths)) {
            return;
        }

        $chunks = Lib::arrayChunkByStringLength($paths, 131072, 4);

        foreach ($chunks as $paths) {
            $docker = Lib::cmd('docker', array('exec', '-w', '/app', $id));
            $tar = Lib::cmd('tar', array('c', '-f', '-', $paths));
            $unTar = Lib::cmd('tar', array('x', '-f', '-', '-C', $dir));

            $command = $docker . ' ' . $tar . ' | ' . $unTar;
            $status = $exec->pass($command, array());

            if (0 !== $status) {
                $streams->err(sprintf(
                    "pipelines: Artifact failure: '%s' (%d, %d paths, %d bytes)\n",
                    $pattern,
                    $status,
                    count($paths),
                    strlen($command)
                ));
            }
        }
    }

    /**
     * @param bool $copy
     * @param string $id container id
     * @param string $dir directory to copy contents into container
     *
     * @throws \RuntimeException
     * @return null|int null if all clear, integer for exit status
     */
    private function deployCopy($copy, $id, $dir)
    {
        if (!$copy) {
            return null;
        }

        $streams = $this->streams;
        $exec = $this->exec;

        $streams->out("\x1D+++ copying files into container...\n");

        $tmpDir = LibTmp::tmpDir('pipelines-cp.');
        $this->temporaryDirectories[] = DestructibleString::rmDir($tmpDir);
        LibFs::symlink($dir, $tmpDir . '/app');
        $cd = Lib::cmd('cd', array($tmpDir . '/.'));
        $tar = Lib::cmd('tar', array('c', '-h', '-f', '-', '--no-recursion', 'app'));
        $dockerCp = Lib::cmd('docker ', array('cp', '-', $id . ':/.'));
        $status = $exec->pass("${cd} && echo 'app' | ${tar} | ${dockerCp}", array());
        LibFs::unlink($tmpDir . '/app');
        if (0 !== $status) {
            $streams->err('pipelines: deploy copy failure\n');

            return $status;
        }

        $cd = Lib::cmd('cd', array($dir . '/.'));
        $tar = Lib::cmd('tar', array('c', '-f', '-', '.'));
        $dockerCp = Lib::cmd('docker ', array('cp', '-', $id . ':/app'));
        $status = $exec->pass("${cd} && ${tar} | ${dockerCp}", array());
        if (0 !== $status) {
            $streams->err('pipelines: deploy copy failure\n');

            return $status;
        }

        $streams('');

        return null;
    }

    /**
     * if there is the docker service in the step, deploy the
     * docker client
     *
     * @param Step $step
     * @param string $id
     *
     * @throws
     * @return array array(int $status, string $message)
     */
    private function deployDockerClient(Step $step, $id)
    {
        if (!$step->getServices()->has('docker')) {
            return array(0, '');
        }

        $this->streams->out(' +++ docker client install...: ');

        try {
            list($status, $message) = $this->getDockerBinaryRepository()->inject($id);
        } catch (\Exception $e) {
            $this->streams->out("pipelines internal failure.\n");

            throw new \InvalidArgumentException('inject docker client failed: ' . $e->getMessage(), 1, $e);
        }

        $this->streams->out("${message}\n");

        return array($status, $message);
    }

    /**
     * @param Image $image
     *
     * @throws \RuntimeException
     * @throws \InvalidArgumentException
     */
    private function imageLogin(Image $image)
    {
        $login = new ImageLogin($this->exec, $this->env->getResolver());
        $login->byImage($image);
    }

    /**
     * @param StepContainer $container
     * @param string $dir
     * @param bool $copy
     * @param Step $step
     *
     * @return array array(string|null $id, int $status)
     */
    private function runNewContainer(StepContainer $container, $dir, $copy, Step $step)
    {
        $env = $this->env;
        $exec = $this->exec;
        $streams = $this->streams;

        $image = $step->getImage();

        # process docker login if image demands so, but continue on failure
        $this->imageLogin($image);

        $mountDockerSock = $this->obtainDockerSocketMount();

        $parentName = $env->getValue('PIPELINES_PARENT_CONTAINER_NAME');
        $checkMount = $mountDockerSock && null !== $parentName;
        $deviceDir = $dir;
        if ($checkMount && '/app' === $dir) { // FIXME(tk): hard encoded /app
            $docker = new Docker($exec);
            $deviceDir = $docker->hostDevice($parentName, $dir);
            unset($docker);
            if ($deviceDir === $dir) {
                $deviceDir = $env->getPipelinesProjectPath($deviceDir);
            }
            if ($deviceDir === $dir) {
                $streams->err("pipelines: fatal: can not detect ${dir} mount point. preventing new container.\n");

                return array(null, 1);
            }
        }

        $mountWorkingDirectory = $copy
            ? array()
            // FIXME(tk): Never mount anything not matching /home/[a-zA-Z][a-zA-Z0-9]*/[^.].*/...
            //   + do realpath checking
            //   + prevent dot path injections (logical fix first)
            : array('--volume', "${deviceDir}:/app"); // FIXME(tk): hard encoded /app

        list($status, $out, $err) = $container->run(
            array(
                '-i', '--name', $container->getName(),
                $env->getArgs('-e'),
                $mountWorkingDirectory, '-e', 'BITBUCKET_CLONE_DIR=/app',
                $mountDockerSock,
                '--workdir', '/app', '--detach', '--entrypoint=/bin/sh', $image->getName(),
            )
        );
        if (0 !== $status) {
            $streams->out("    container-id...: *failure*\n\n");
            $streams->err("pipelines: setting up the container failed\n");
            $streams->err("${err}\n");
            $streams->out("${out}\n");
            $streams->out(sprintf("exit status: %d\n", $status));

            return array(null, $status);
        }
        $id = $container->getDisplayId();

        return array($id, $status);
    }

    /**
     * enable docker client inside docker by mounting docker socket
     *
     * @return array docker socket volume args for docker run, empty if not mounting
     */
    private function obtainDockerSocketMount()
    {
        $args = array();

        // FIXME give more controlling options, this is serious /!\
        if (!$this->flags->useDockerSocket()) {
            return $args;
        }

        $hostPathDockerSocket = $this->runOpts->getOption('docker.socket.path');

        $dockerHost = $this->env->getInheritValue('DOCKER_HOST');
        if (null !== $dockerHost && 0 === strpos($dockerHost, 'unix://')) {
            $hostPathDockerSocket = substr($dockerHost, 7);
        }

        $pathDockerSock = $this->runOpts->getOption('docker.socket.path');

        if (file_exists($hostPathDockerSocket)) {
            $args = array(
                '-v', sprintf('%s:%s', $hostPathDockerSocket, $pathDockerSock),
            );
        }

        return $args;
    }

    /**
     * @param Step $step
     * @param Streams $streams
     * @param Exec $exec
     * @param string $name container name
     *
     * @return null|int should never be null, status, non-zero if a command failed
     */
    private function runStepScript(Step $step, Streams $streams, Exec $exec, $name)
    {
        $script = $step->getScript();

        $buffer = Lib::cmd("<<'SCRIPT' docker", array(
            'exec', '-i', $name, '/bin/sh',
        ));
        $buffer .= "\n# this /bin/sh script is generated from a pipelines pipeline:\n";
        $buffer .= "set -e\n";
        foreach ($script as $line => $command) {
            $line && $buffer .= 'printf \'\\n\'' . "\n";
            $buffer .= 'printf \'\\035+ %s\\n\' ' . Lib::quoteArg($command) . "\n";
            $buffer .= $command . "\n";
        }
        $buffer .= "SCRIPT\n";

        $status = $exec->pass($buffer, array());

        if (0 !== $status) {
            $streams->err(sprintf("script non-zero exit status: %d\n", $status));
        }

        return $status;
    }

    /**
     * @param StepContainer $container
     * @param int $status
     */
    private function shutdownStepContainer(StepContainer $container, $status)
    {
        $flags = $this->flags;
        $id = $container->getDisplayId();

        # keep container on error
        if (0 !== $status && $flags->keepOnError()) {
            $this->streams->err(sprintf(
                "error, keeping container id %s\n",
                substr($id, 0, 12)
            ));

            return;
        }

        # keep or kill/remove container
        $container->killAndRemove($flags->killContainer(), $flags->removeContainer());

        if ($flags->keep()) {
            $this->streams->out(sprintf(
                "keeping container id %s\n",
                substr($id, 0, 12)
            ));
        }
    }
}


1		<?php
2
3		/* this file is part of pipelines */
4
5		namespace Ktomk\Pipelines\Runner;
6
7		use Ktomk\Pipelines\Cli\Docker;
8		use Ktomk\Pipelines\Cli\Exec;
9		use Ktomk\Pipelines\Cli\Streams;
10		use Ktomk\Pipelines\DestructibleString;
11		use Ktomk\Pipelines\File\Image;
12		use Ktomk\Pipelines\File\Step;
13		use Ktomk\Pipelines\Lib;
14		use Ktomk\Pipelines\LibFs;
15		use Ktomk\Pipelines\LibTmp;
16		use Ktomk\Pipelines\Runner\Docker\ArtifactSource;
17		use Ktomk\Pipelines\Runner\Docker\Binary\Repository;
18		use Ktomk\Pipelines\Runner\Docker\ImageLogin;
19
20		/**
21		* Runner for a single step of a pipeline
22		*/
23		class StepRunner
24		{
25		/**
26		* @var RunOpts
27		*/
28		private $runOpts;
29
30		/**
31		* @var Directories
32		*/
33		private $directories;
34
35		/**
36		* @var Exec
37		*/
38		private $exec;
39
40		/**
41		* @var Flags
42		*/
43		private $flags;
44
45		/**
46		* @var Env
47		*/
48		private $env;
49
50		/**
51		* @var Streams
52		*/
53		private $streams;
54
55		/**
56		* list of temporary directory destructible markers
57		*
58		* @var array
59		*/
60		private $temporaryDirectories = array();
61
62		/**
63		* DockerSession constructor.
64		*
65		* @param RunOpts $runOpts
66		* @param Directories $directories source repository root directory based directories object
67		* @param Exec $exec
68		* @param Flags $flags
69		* @param Env $env
70		* @param Streams $streams
71		*/
72	20	public function __construct(
73		RunOpts $runOpts,
74		Directories $directories,
75		Exec $exec,
76		Flags $flags,
77		Env $env,
78		Streams $streams
79		)
80		{
81	20	$this->runOpts = $runOpts;
82	20	$this->directories = $directories;
83	20	$this->exec = $exec;
84	20	$this->flags = $flags;
85	20	$this->env = $env;
86	20	$this->streams = $streams;
87	20	}
88
89		/**
90		* @param Step $step
91		*
92		* @return null\|int exist status of step script or null if the run operation failed
93		*/
94	19	public function runStep(Step $step)
95		{
96	19	$dir = $this->directories->getProjectDirectory();
97	19	$env = $this->env;
98	19	$exec = $this->exec;
99	19	$streams = $this->streams;
100
101	19	$env->setPipelinesProjectPath($dir);
102
103	19	$container = StepContainer::create($step, $exec);
104
105	19	$name = $container->generateName($this->runOpts->getPrefix(), $this->directories->getName());
106	19	$env->setContainerName($name);
107
108	19	$image = $step->getImage();
109
110		# launch container
111	19	$streams->out(sprintf(
112	19	"\x1D+++ step #%d\n\n name...........: %s\n effective-image: %s\n container......: %s\n",
113	19	$step->getIndex() + 1,
114	19	$step->getName() ? '"' . $step->getName() . '"' : '(unnamed)',
115	19	$image->getName(),
116	19	$name
117		));
118
119	19	$id = $container->keepOrKill($this->flags->reuseContainer());
120
121	19	$deployCopy = $this->flags->deployCopy();
122
123	19	if (null === $id) {
124	17	list($id, $status) = $this->runNewContainer($container, $dir, $deployCopy, $step);
125	17	if (null === $id) {
126	2	return $status;
127		}
128		}
129
130	17	$streams->out(sprintf(" container-id...: %s\n\n", substr($id, 0, 12)));
131
132		# TODO: different deployments, mount (default), mount-ro, copy
133	17	if (null !== $result = $this->deployCopy($deployCopy, $id, $dir)) {
134	2	return $result;
135		}
136
137	15	list($status, $message) = $this->deployDockerClient($step, $id);
138	14	if (0 !== $status) {
139	1	$this->streams->err(rtrim($message, "\n") . "\n");
140
141	1	return $status;
142		}
143
144	13	$status = $this->runStepScript($step, $streams, $exec, $name);
145
146	13	$this->captureStepArtifacts($step, $deployCopy && 0 === $status, $id, $dir);
147
148	13	$this->shutdownStepContainer($container, $status);
149
150	13	return $status;
151		}
152
153		/**
154		* method to wrap new to have a test-point
155		*
156		* @return Repository
157		*/
158	2	public function getDockerBinaryRepository()
159		{
160	2	$repo = Repository::create($this->exec, $this->directories);
161	2	$repo->resolve($this->runOpts->getBinaryPackage());
162
163	1	return $repo;
164		}
165
166		/**
167		* @param Step $step
168		* @param bool $copy
169		* @param string $id container id
170		* @param string $dir to put artifacts in (project directory)
171		*
172		* @throws \RuntimeException
173		*/
174	13	private function captureStepArtifacts(Step $step, $copy, $id, $dir)
175		{
176		# capturing artifacts is only supported for deploy copy
177	13	if (!$copy) {
178	8	return;
179		}
180
181	5	$artifacts = $step->getArtifacts();
182
183	5	if (null === $artifacts) {
184	2	return;
185		}
186
187	3	$exec = $this->exec;
188	3	$streams = $this->streams;
189
190	3	$streams->out("\x1D+++ copying artifacts from container...\n");
191
192	3	$source = new ArtifactSource($exec, $id, $dir);
193
194	3	$patterns = $artifacts->getPatterns();
195	3	foreach ($patterns as $pattern) {
196	3	$this->captureArtifactPattern($source, $pattern, $dir);
197		}
198
199	3	$streams('');
200	3	}
201
202		/**
203		* @param ArtifactSource $source
204		* @param string $pattern
205		* @param string $dir
206		*
207		* @throws \RuntimeException
208		* @see Runner::captureStepArtifacts()
209		*
210		*/
211	3	private function captureArtifactPattern(ArtifactSource $source, $pattern, $dir)
212		{
213	3	$exec = $this->exec;
214	3	$streams = $this->streams;
215
216	3	$id = $source->getId();
217	3	$paths = $source->findByPattern($pattern);
218	3	if (empty($paths)) {
219	1	return;
220		}
221
222	2	$chunks = Lib::arrayChunkByStringLength($paths, 131072, 4);
223
224	2	foreach ($chunks as $paths) {
225	2	$docker = Lib::cmd('docker', array('exec', '-w', '/app', $id));
226	2	$tar = Lib::cmd('tar', array('c', '-f', '-', $paths));
227	2	$unTar = Lib::cmd('tar', array('x', '-f', '-', '-C', $dir));
228
229	2	$command = $docker . ' ' . $tar . ' \| ' . $unTar;
230	2	$status = $exec->pass($command, array());
231
232	2	if (0 !== $status) {
233	1	$streams->err(sprintf(
234	1	"pipelines: Artifact failure: '%s' (%d, %d paths, %d bytes)\n",
235	1	$pattern,
236	1	$status,
237	1	count($paths),
238	1	strlen($command)
239		));
240		}
241		}
242	2	}
243
244		/**
245		* @param bool $copy
246		* @param string $id container id
247		* @param string $dir directory to copy contents into container
248		*
249		* @throws \RuntimeException
250		* @return null\|int null if all clear, integer for exit status
251		*/
252	17	private function deployCopy($copy, $id, $dir)
253		{
254	17	if (!$copy) {
255	10	return null;
256		}
257
258	7	$streams = $this->streams;
259	7	$exec = $this->exec;
260
261	7	$streams->out("\x1D+++ copying files into container...\n");
262
263	7	$tmpDir = LibTmp::tmpDir('pipelines-cp.');
264	7	$this->temporaryDirectories[] = DestructibleString::rmDir($tmpDir);
265	7	LibFs::symlink($dir, $tmpDir . '/app');
266	7	$cd = Lib::cmd('cd', array($tmpDir . '/.'));
267	7	$tar = Lib::cmd('tar', array('c', '-h', '-f', '-', '--no-recursion', 'app'));
268	7	$dockerCp = Lib::cmd('docker ', array('cp', '-', $id . ':/.'));
269		$status = $exec->pass("${cd} && echo 'app' \| ${tar} \| ${dockerCp}", array());
270		LibFs::unlink($tmpDir . '/app');
271	7	if (0 !== $status) {
272	1	$streams->err('pipelines: deploy copy failure\n');
273
274	1	return $status;
275		}
276
277	6	$cd = Lib::cmd('cd', array($dir . '/.'));
278	6	$tar = Lib::cmd('tar', array('c', '-f', '-', '.'));
279	6	$dockerCp = Lib::cmd('docker ', array('cp', '-', $id . ':/app'));
280	6	$status = $exec->pass("${cd} && ${tar} \| ${dockerCp}", array());
281	6	if (0 !== $status) {
282	1	$streams->err('pipelines: deploy copy failure\n');
283
284	1	return $status;
285		}
286
287	5	$streams('');
288
289	5	return null;
290		}
291
292		/**
293		* if there is the docker service in the step, deploy the
294		* docker client
295		*
296		* @param Step $step
297		* @param string $id
298		*
299		* @throws
300		* @return array array(int $status, string $message)
301		*/
302		private function deployDockerClient(Step $step, $id)
303		{
304	15	if (!$step->getServices()->has('docker')) {
305	12	return array(0, '');
306		}
307
308	3	$this->streams->out(' +++ docker client install...: ');
309
310		try {
311	3	list($status, $message) = $this->getDockerBinaryRepository()->inject($id);
312	1	} catch (\Exception $e) {
313	1	$this->streams->out("pipelines internal failure.\n");
314
315	1	throw new \InvalidArgumentException('inject docker client failed: ' . $e->getMessage(), 1, $e);
316		}
317
318	2	$this->streams->out("${message}\n");
319
320	2	return array($status, $message);
321		}
322
323		/**
324		* @param Image $image
325		*
326		* @throws \RuntimeException
327		* @throws \InvalidArgumentException
328		*/
329		private function imageLogin(Image $image)
330		{
331	17	$login = new ImageLogin($this->exec, $this->env->getResolver());
332	17	$login->byImage($image);
333	17	}
334
335		/**
336		* @param StepContainer $container
337		* @param string $dir
338		* @param bool $copy
339		* @param Step $step
340		*
341		* @return array array(string\|null $id, int $status)
342		*/
343		private function runNewContainer(StepContainer $container, $dir, $copy, Step $step)
344		{
345	17	$env = $this->env;
346	17	$exec = $this->exec;
347	17	$streams = $this->streams;
348
349	17	$image = $step->getImage();
350
351		# process docker login if image demands so, but continue on failure
352	17	$this->imageLogin($image);
353
354	17	$mountDockerSock = $this->obtainDockerSocketMount();
355
356	17	$parentName = $env->getValue('PIPELINES_PARENT_CONTAINER_NAME');
357	17	$checkMount = $mountDockerSock && null !== $parentName;
358	17	$deviceDir = $dir;
359	17	if ($checkMount && '/app' === $dir) { // FIXME(tk): hard encoded /app
360	1	$docker = new Docker($exec);
361	1	$deviceDir = $docker->hostDevice($parentName, $dir);
362	1	unset($docker);
363	1	if ($deviceDir === $dir) {
364	1	$deviceDir = $env->getPipelinesProjectPath($deviceDir);
365		}
366	1	if ($deviceDir === $dir) {
367	1	$streams->err("pipelines: fatal: can not detect ${dir} mount point. preventing new container.\n");
368
369	1	return array(null, 1);
370		}
371		}
372
373	16	$mountWorkingDirectory = $copy
374	7	? array()
375		// FIXME(tk): Never mount anything not matching /home/[a-zA-Z][a-zA-Z0-9]/[^.]./...
376		// + do realpath checking
377		// + prevent dot path injections (logical fix first)
378	16	: array('--volume', "${deviceDir}:/app"); // FIXME(tk): hard encoded /app
379
380	16	list($status, $out, $err) = $container->run(
381		array(
382	16	'-i', '--name', $container->getName(),
383	16	$env->getArgs('-e'),
384	16	$mountWorkingDirectory, '-e', 'BITBUCKET_CLONE_DIR=/app',
385	16	$mountDockerSock,
386	16	'--workdir', '/app', '--detach', '--entrypoint=/bin/sh', $image->getName(),
387		)
388		);
389	16	if (0 !== $status) {
390	1	$streams->out(" container-id...: failure\n\n");
391	1	$streams->err("pipelines: setting up the container failed\n");
392	1	$streams->err("${err}\n");
393	1	$streams->out("${out}\n");
394	1	$streams->out(sprintf("exit status: %d\n", $status));
395
396	1	return array(null, $status);
397		}
398	15	$id = $container->getDisplayId();
399
400	15	return array($id, $status);
401		}
402
403		/**
404		* enable docker client inside docker by mounting docker socket
405		*
406		* @return array docker socket volume args for docker run, empty if not mounting
407		*/
408		private function obtainDockerSocketMount()
409		{
410	17	$args = array();
411
412		// FIXME give more controlling options, this is serious /!\
413	17	if (!$this->flags->useDockerSocket()) {
414	1	return $args;
415		}
416
417	16	$hostPathDockerSocket = $this->runOpts->getOption('docker.socket.path');
418
419	16	$dockerHost = $this->env->getInheritValue('DOCKER_HOST');
420	16	if (null !== $dockerHost && 0 === strpos($dockerHost, 'unix://')) {
421	1	$hostPathDockerSocket = substr($dockerHost, 7);
422		}
423
424	16	$pathDockerSock = $this->runOpts->getOption('docker.socket.path');
425
426	16	if (file_exists($hostPathDockerSocket)) {
427		$args = array(
428	12	'-v', sprintf('%s:%s', $hostPathDockerSocket, $pathDockerSock),
429		);
430		}
431
432	16	return $args;
433		}
434
435		/**
436		* @param Step $step
437		* @param Streams $streams
438		* @param Exec $exec
439		* @param string $name container name
440		*
441		* @return null\|int should never be null, status, non-zero if a command failed
442		*/
443		private function runStepScript(Step $step, Streams $streams, Exec $exec, $name)
444		{
445	13	$script = $step->getScript();
446
447	13	$buffer = Lib::cmd("<<'SCRIPT' docker", array(
448	13	'exec', '-i', $name, '/bin/sh',
449		));
450	13	$buffer .= "\n# this /bin/sh script is generated from a pipelines pipeline:\n";
451	13	$buffer .= "set -e\n";
452	13	foreach ($script as $line => $command) {
453	13	$line && $buffer .= 'printf \'\\n\'' . "\n";
454	13	$buffer .= 'printf \'\\035+ %s\\n\' ' . Lib::quoteArg($command) . "\n";
455	13	$buffer .= $command . "\n";
456		}
457	13	$buffer .= "SCRIPT\n";
458
459	13	$status = $exec->pass($buffer, array());
460
461	13	if (0 !== $status) {
462	2	$streams->err(sprintf("script non-zero exit status: %d\n", $status));
463		}
464
465	13	return $status;
466		}
467
468		/**
469		* @param StepContainer $container
470		* @param int $status
471		*/
472		private function shutdownStepContainer(StepContainer $container, $status)
473		{
474	13	$flags = $this->flags;
475	13	$id = $container->getDisplayId();
476
477		# keep container on error
478	13	if (0 !== $status && $flags->keepOnError()) {
479	2	$this->streams->err(sprintf(
480	2	"error, keeping container id %s\n",
481	2	substr($id, 0, 12)
482		));
483
484	2	return;
485		}
486
487		# keep or kill/remove container
488	11	$container->killAndRemove($flags->killContainer(), $flags->removeContainer());
489
490	11	if ($flags->keep()) {
491	1	$this->streams->out(sprintf(
492	1	"keeping container id %s\n",
493	1	substr($id, 0, 12)
494		));
495		}
496	11	}
497		}
498

ktomk / pipelines

Push — test ( 3623cf...52bb81 )

StepRunner::obtainDockerSocketMount() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like