@@ -15,22 +15,22 @@ |
||
| 15 | 15 | // } |
| 16 | 16 | |
| 17 | 17 | $container->register('app.service.logger', App\Service\Logger::class) |
| 18 | - ->setPublic(false); |
|
| 18 | + ->setPublic(false); |
|
| 19 | 19 | $container->register('app.service.subject', App\Service\EventSubject::class) |
| 20 | - ->setPublic(false); |
|
| 20 | + ->setPublic(false); |
|
| 21 | 21 | $container->register('app.service.config', App\Service\Config::class) |
| 22 | - ->addMethodCall('loadYaml', ['config.yaml']) |
|
| 23 | - ->setPublic(false); |
|
| 22 | + ->addMethodCall('loadYaml', ['config.yaml']) |
|
| 23 | + ->setPublic(false); |
|
| 24 | 24 | $container->register('app.service.webhookd', App\Service\Webhookd::class) |
| 25 | - ->addArgument(new Reference('app.service.subject')) |
|
| 26 | - ->setPublic(false); |
|
| 25 | + ->addArgument(new Reference('app.service.subject')) |
|
| 26 | + ->setPublic(false); |
|
| 27 | 27 | $container->register('app.command.webhookd', App\Command\WebhookdCommand::class) |
| 28 | - ->addArgument(new Reference('app.service.webhookd')) |
|
| 29 | - ->addArgument(new Reference('app.service.subject')) |
|
| 30 | - ->addArgument(new Reference('app.service.config')) |
|
| 31 | - ->setPublic(false); |
|
| 28 | + ->addArgument(new Reference('app.service.webhookd')) |
|
| 29 | + ->addArgument(new Reference('app.service.subject')) |
|
| 30 | + ->addArgument(new Reference('app.service.config')) |
|
| 31 | + ->setPublic(false); |
|
| 32 | 32 | $container->register('app', Application::class) |
| 33 | - ->addMethodCall('add', [new Reference('app.command.webhookd')]); |
|
| 33 | + ->addMethodCall('add', [new Reference('app.command.webhookd')]); |
|
| 34 | 34 | |
| 35 | 35 | // $container->autowire(App\Command\WebhookdCommand::class)->addTag('console.command'); |
| 36 | 36 | // // arguments: |
@@ -9,7 +9,7 @@ discard block |
||
| 9 | 9 | |
| 10 | 10 | require_once 'vendor/autoload.php'; |
| 11 | 11 | |
| 12 | -go(function () { |
|
| 12 | +go(function() { |
|
| 13 | 13 | $logLevel = ($_ENV['LOG_LEVEL'] ?: Logger::ERROR); |
| 14 | 14 | $logger = new Logger('gitlab-webhook'); |
| 15 | 15 | if (defined('STDERR')) { |
@@ -21,7 +21,7 @@ discard block |
||
| 21 | 21 | ->setRetries(0) |
| 22 | 22 | ->build(); |
| 23 | 23 | $logger->pushHandler(new ElasticsearchHandler($client, ['index' => 'monolog-'.date('Y.m.d')], $logLevel)); |
| 24 | - $logger->pushProcessor(function ($record) { |
|
| 24 | + $logger->pushProcessor(function($record) { |
|
| 25 | 25 | $record['extra']['host'] = $_ENV['HOSTNAME']; |
| 26 | 26 | return $record; |
| 27 | 27 | }); |
@@ -31,7 +31,7 @@ discard block |
||
| 31 | 31 | $subject->attach(new App\Observers\DockerBuilder); |
| 32 | 32 | |
| 33 | 33 | $server = new Server('127.0.0.1', 9601); |
| 34 | - $server->handle(function (Connection $conn) use ($subject) { |
|
| 34 | + $server->handle(function(Connection $conn) use ($subject) { |
|
| 35 | 35 | $data = $conn->recv(); |
| 36 | 36 | $subject->receive($data); |
| 37 | 37 | // $conn->send("world\n"); |
@@ -2,7 +2,7 @@ |
||
| 2 | 2 | |
| 3 | 3 | $http = new Swoole\Http\Server('0.0.0.0', 9501); |
| 4 | 4 | |
| 5 | -$http->on('request', function ($request, $response) { |
|
| 5 | +$http->on('request', function($request, $response) { |
|
| 6 | 6 | $client = new Swoole\Coroutine\Client(SWOOLE_SOCK_TCP); |
| 7 | 7 | $client->connect('127.0.0.1', 9601, 0.5); |
| 8 | 8 | // 调用connect将触发协程切换 |