slim-kernel/tests/Supervisor/GenerateSupervisorConfigCommandTest.php at 47f887577794c0e01b2532ffc78e7cd2b343d986 · WonderNetwork/slim-kernel · GitHub

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
<?php

declare(strict_types=1);

namespace WonderNetwork\SlimKernel\Supervisor;

use PHPUnit\Framework\TestCase;
use Symfony\Component\Console\Input\ArgvInput;
use Symfony\Component\Console\Output\BufferedOutput;

final class GenerateSupervisorConfigCommandTest extends TestCase {
    public function testGeneratesConfig(): void {
        $programs = SupervisorConfiguration::start()
            ->withSimpleCommand('worker', 'bin/worker async')
            ->withPrograms(
                new SupervisorProgram(
                    name: 'jobs',
                    command: 'bin/worker jobs',
                    concurrency: 3,
                    startretries: 10,
                ),
            );
        $configDir = __DIR__.'/../Resources/Supervisor';
        $sut = new GenerateSupervisorConfigCommand(
            configDir: $configDir,
            configuration: $programs,
        );

        $output = new BufferedOutput();
        $argv = [(string) $sut->getName(), '--config-dir', $configDir, '/var/app/current'];
        $sut->run(new ArgvInput($argv), $output);

        self::assertSame(
            <<<EOF
            Writing worker configuration file to $configDir/worker.conf
            Writing jobs configuration file to $configDir/jobs.conf
            EOF,
            trim($output->fetch()),
        );

        $files = glob($configDir.'/*.conf') ?: [];
        sort($files);

        self::assertSame(["$configDir/jobs.conf", "$configDir/worker.conf"], $files);
        self::assertSame(
            <<<EOF
            [program:jobs]
            command=/var/app/current/bin/worker jobs
            process_name=%(program_name)s_%(process_num)02d
            numprocs=3
            startretries=10
            user=www-data
            autostart=true
            autorestart=true
            stderr_logfile=/var/log/supervisor/%(program_name)s_%(process_num)02d.err.log
            stderr_logfile_maxbytes=50MB
            stdout_logfile=/var/log/supervisor/%(program_name)s_%(process_num)02d.out.log
            stdout_logfile_maxbytes=50MB
            [program:worker]
            command=/var/app/current/bin/worker async
            process_name=worker
            numprocs=1
            startretries=15
            user=www-data
            autostart=true
            autorestart=true
            stderr_logfile=/var/log/supervisor/worker.err.log
            stderr_logfile_maxbytes=50MB
            stdout_logfile=/var/log/supervisor/worker.out.log
            stdout_logfile_maxbytes=50MB
            EOF,
            implode(
                "\n",
                array_map(
                    static fn (string $filename) => file_get_contents($filename),
                    $files,
                ),
            ),
        );
    }

    public function testGeneratesConfigWithStdio(): void {
        $programs = SupervisorConfiguration::start()
            ->withSimpleCommand('worker', 'bin/worker async')
            ->withPrograms(
                new SupervisorProgram(
                    name: 'jobs',
                    command: 'bin/worker jobs',
                    concurrency: 3,
                    startretries: 10,
                ),
            );
        $configDir = __DIR__.'/../Resources/Supervisor';
        $sut = new GenerateSupervisorConfigCommand(
            configDir: $configDir,
            configuration: $programs,
        );

        $output = new BufferedOutput();
        $argv = [(string) $sut->getName(), '--stdio', '--config-dir', $configDir, '/var/app/current'];
        $sut->run(new ArgvInput($argv), $output);

        $files = glob($configDir.'/*.conf') ?: [];
        sort($files);

        self::assertSame(
            <<<EOF
            [program:jobs]
            command=/var/app/current/bin/worker jobs
            process_name=%(program_name)s_%(process_num)02d
            numprocs=3
            startretries=10
            user=www-data
            autostart=true
            autorestart=true
            stderr_logfile=/dev/stderr
            stderr_logfile_maxbytes=0
            stdout_logfile=/dev/stdout
            stdout_logfile_maxbytes=0
            [program:worker]
            command=/var/app/current/bin/worker async
            process_name=worker
            numprocs=1
            startretries=15
            user=www-data
            autostart=true
            autorestart=true
            stderr_logfile=/dev/stderr
            stderr_logfile_maxbytes=0
            stdout_logfile=/dev/stdout
            stdout_logfile_maxbytes=0
            EOF,
            implode(
                "\n",
                array_map(
                    static fn (string $filename) => file_get_contents($filename),
                    $files,
                ),
            ),
        );
    }
}