HeuJung
c4beb116ad
서버가 외부 입력으로 목적지가 제어되는 outbound HTTP 요청을 보내는 지점을 전수 조사해, 내부망(사설 IP·루프백·링크로컬·메타데이터)과 host 위조를 차단한다. KVE-2026-1546(이니시스 인증 URL 접두사 매칭 우회)과 동일 클래스의 지점(언어팩 URL 설치, 스케줄 URL 호출, 배송비 계산 API, GitHub URL 판정)을 코어 공용 유틸 App\Support\OutboundUrlValidator 로 수렴시켰다. - 접두사 매칭을 host 완전일치로 교체 — userinfo(@) 위장과 접미사 확장 도메인 우회 벡터 차단. - 사내 서버 호출이 정당한 관리자 지점(스케줄·외부 API)은 신규 설정 security.allow_internal_outbound_urls(기본 off)로 옵트인. - 언어팩 URL 설치는 원격 코드 다운로드라 옵트인과 무관하게 내부 주소 항상 차단. - 웹소켓 연결 테스트는 localhost·사설 IP 가 정상 구성이므로 구조적 위조만 차단. 각 지점에 red 재현 → 수정 → green 회귀 테스트 + 실브라우저 E2E 로 검증. 수기 API 문서가 자동 재생성으로 소실되는 사고를 막는 PreToolUse 훅을 함께 추가한다.
461 lines
15 KiB
PHP
461 lines
15 KiB
PHP
<?php
|
|
|
|
namespace App\Services;
|
|
|
|
use App\Support\OutboundUrlValidator;
|
|
use Aws\S3\Exception\S3Exception;
|
|
use Aws\S3\S3Client;
|
|
use Illuminate\Http\Client\ConnectionException;
|
|
use Illuminate\Support\Facades\Http;
|
|
use Illuminate\Support\Facades\Log;
|
|
use Predis\Client;
|
|
|
|
/**
|
|
* 드라이버 연결 테스트 서비스
|
|
*
|
|
* S3, Redis, Memcached, Websocket 등 외부 서비스 드라이버의
|
|
* 연결 상태를 테스트합니다.
|
|
*/
|
|
class DriverConnectionTester
|
|
{
|
|
/**
|
|
* 설정에 따라 필요한 모든 드라이버 연결을 테스트합니다.
|
|
*
|
|
* @param array $settings 드라이버 설정 배열
|
|
* @return array 테스트 결과 배열
|
|
*/
|
|
public function testAll(array $settings): array
|
|
{
|
|
$results = [];
|
|
$allPassed = true;
|
|
|
|
// S3 테스트
|
|
if (($settings['storage_driver'] ?? 'local') === 's3') {
|
|
$results['s3'] = $this->testS3($settings);
|
|
if (! $results['s3']['success']) {
|
|
$allPassed = false;
|
|
}
|
|
}
|
|
|
|
// Redis 테스트 (캐시, 세션, 큐 중 하나라도 Redis 사용 시)
|
|
$needsRedis = ($settings['cache_driver'] ?? 'file') === 'redis'
|
|
|| ($settings['session_driver'] ?? 'file') === 'redis'
|
|
|| ($settings['queue_driver'] ?? 'sync') === 'redis';
|
|
|
|
if ($needsRedis) {
|
|
$results['redis'] = $this->testRedis($settings);
|
|
if (! $results['redis']['success']) {
|
|
$allPassed = false;
|
|
}
|
|
}
|
|
|
|
// Memcached 테스트
|
|
if (($settings['cache_driver'] ?? 'file') === 'memcached') {
|
|
$results['memcached'] = $this->testMemcached($settings);
|
|
if (! $results['memcached']['success']) {
|
|
$allPassed = false;
|
|
}
|
|
}
|
|
|
|
// Websocket 테스트
|
|
if ($settings['websocket_enabled'] ?? false) {
|
|
$results['websocket'] = $this->testWebsocket($settings);
|
|
if (! $results['websocket']['success']) {
|
|
$allPassed = false;
|
|
}
|
|
}
|
|
|
|
return [
|
|
'results' => $results,
|
|
'all_passed' => $allPassed,
|
|
];
|
|
}
|
|
|
|
/**
|
|
* S3 버킷 연결을 테스트합니다.
|
|
*
|
|
* @param array $config S3 설정 배열
|
|
* @return array 테스트 결과
|
|
*/
|
|
public function testS3(array $config): array
|
|
{
|
|
try {
|
|
// 필수 설정 확인
|
|
$bucket = $config['s3_bucket'] ?? '';
|
|
$region = $config['s3_region'] ?? '';
|
|
$accessKey = $config['s3_access_key'] ?? '';
|
|
$secretKey = $config['s3_secret_key'] ?? '';
|
|
|
|
if (empty($bucket) || empty($region) || empty($accessKey) || empty($secretKey)) {
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.s3_missing_config'),
|
|
];
|
|
}
|
|
|
|
// AWS SDK가 설치되어 있는지 확인
|
|
if (! class_exists(S3Client::class)) {
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.s3_sdk_missing'),
|
|
];
|
|
}
|
|
|
|
$startTime = microtime(true);
|
|
|
|
$client = new S3Client([
|
|
'version' => 'latest',
|
|
'region' => $region,
|
|
'credentials' => [
|
|
'key' => $accessKey,
|
|
'secret' => $secretKey,
|
|
],
|
|
'http' => [
|
|
'timeout' => 5,
|
|
'connect_timeout' => 3,
|
|
],
|
|
]);
|
|
|
|
// 버킷 존재 확인
|
|
$client->headBucket(['Bucket' => $bucket]);
|
|
|
|
$latency = round((microtime(true) - $startTime) * 1000, 2);
|
|
|
|
return [
|
|
'success' => true,
|
|
'message' => __('settings.s3_test_success'),
|
|
'latency' => $latency.'ms',
|
|
];
|
|
} catch (S3Exception $e) {
|
|
$errorMessage = match ($e->getAwsErrorCode()) {
|
|
'NoSuchBucket' => __('settings.s3_bucket_not_found'),
|
|
'AccessDenied' => __('settings.s3_access_denied'),
|
|
'InvalidAccessKeyId' => __('settings.s3_invalid_credentials'),
|
|
'SignatureDoesNotMatch' => __('settings.s3_invalid_credentials'),
|
|
default => __('settings.s3_test_failed'),
|
|
};
|
|
|
|
return [
|
|
'success' => false,
|
|
'message' => $errorMessage,
|
|
'error' => $e->getMessage(),
|
|
];
|
|
} catch (\Exception $e) {
|
|
Log::warning('S3 connection test failed', [
|
|
'error' => $e->getMessage(),
|
|
]);
|
|
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.s3_test_failed'),
|
|
'error' => $e->getMessage(),
|
|
];
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Redis 서버 연결을 테스트합니다.
|
|
*
|
|
* @param array $config Redis 설정 배열
|
|
* @return array 테스트 결과
|
|
*/
|
|
public function testRedis(array $config): array
|
|
{
|
|
try {
|
|
$host = $config['redis_host'] ?? '127.0.0.1';
|
|
$port = (int) ($config['redis_port'] ?? 6379);
|
|
$password = $config['redis_password'] ?? '';
|
|
$database = (int) ($config['redis_database'] ?? 0);
|
|
|
|
// PHP Redis 확장 확인
|
|
if (! extension_loaded('redis')) {
|
|
// Predis 사용 시도
|
|
if (! class_exists(Client::class)) {
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.redis_extension_missing'),
|
|
];
|
|
}
|
|
|
|
return $this->testRedisWithPredis($host, $port, $password, $database);
|
|
}
|
|
|
|
$startTime = microtime(true);
|
|
|
|
$redis = new \Redis;
|
|
$connected = @$redis->connect($host, $port, 3.0);
|
|
|
|
if (! $connected) {
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.redis_connection_failed'),
|
|
];
|
|
}
|
|
|
|
if (! empty($password)) {
|
|
if (! $redis->auth($password)) {
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.redis_auth_failed'),
|
|
];
|
|
}
|
|
}
|
|
|
|
$redis->select($database);
|
|
$pong = $redis->ping();
|
|
|
|
if ($pong !== true && $pong !== '+PONG') {
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.redis_ping_failed'),
|
|
];
|
|
}
|
|
|
|
$latency = round((microtime(true) - $startTime) * 1000, 2);
|
|
$redis->close();
|
|
|
|
return [
|
|
'success' => true,
|
|
'message' => __('settings.redis_test_success'),
|
|
'latency' => $latency.'ms',
|
|
];
|
|
} catch (\RedisException $e) {
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.redis_test_failed'),
|
|
'error' => $e->getMessage(),
|
|
];
|
|
} catch (\Exception $e) {
|
|
Log::warning('Redis connection test failed', [
|
|
'error' => $e->getMessage(),
|
|
]);
|
|
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.redis_test_failed'),
|
|
'error' => $e->getMessage(),
|
|
];
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Predis 라이브러리를 사용하여 Redis 연결을 테스트합니다.
|
|
*
|
|
* @param string $host 호스트
|
|
* @param int $port 포트
|
|
* @param string $password 비밀번호
|
|
* @param int $database 데이터베이스 번호
|
|
* @return array 테스트 결과
|
|
*/
|
|
private function testRedisWithPredis(string $host, int $port, string $password, int $database): array
|
|
{
|
|
try {
|
|
$startTime = microtime(true);
|
|
|
|
$options = [
|
|
'scheme' => 'tcp',
|
|
'host' => $host,
|
|
'port' => $port,
|
|
'database' => $database,
|
|
'timeout' => 3.0,
|
|
];
|
|
|
|
if (! empty($password)) {
|
|
$options['password'] = $password;
|
|
}
|
|
|
|
$client = new Client($options);
|
|
$pong = $client->ping();
|
|
|
|
if ($pong->getPayload() !== 'PONG') {
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.redis_ping_failed'),
|
|
];
|
|
}
|
|
|
|
$latency = round((microtime(true) - $startTime) * 1000, 2);
|
|
|
|
return [
|
|
'success' => true,
|
|
'message' => __('settings.redis_test_success'),
|
|
'latency' => $latency.'ms',
|
|
];
|
|
} catch (\Exception $e) {
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.redis_test_failed'),
|
|
'error' => $e->getMessage(),
|
|
];
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Memcached 서버 연결을 테스트합니다.
|
|
*
|
|
* @param array $config Memcached 설정 배열
|
|
* @return array 테스트 결과
|
|
*/
|
|
public function testMemcached(array $config): array
|
|
{
|
|
try {
|
|
// Memcached 확장 확인
|
|
if (! extension_loaded('memcached')) {
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.memcached_extension_missing'),
|
|
];
|
|
}
|
|
|
|
$host = $config['memcached_host'] ?? '127.0.0.1';
|
|
$port = (int) ($config['memcached_port'] ?? 11211);
|
|
|
|
$startTime = microtime(true);
|
|
|
|
$memcached = new \Memcached;
|
|
$memcached->setOption(\Memcached::OPT_CONNECT_TIMEOUT, 3000);
|
|
$memcached->addServer($host, $port);
|
|
|
|
// 테스트 키 설정/조회
|
|
$testKey = 'g7_connection_test_'.time();
|
|
$testValue = 'test_'.uniqid();
|
|
|
|
$setResult = $memcached->set($testKey, $testValue, 10);
|
|
|
|
if (! $setResult) {
|
|
$resultCode = $memcached->getResultCode();
|
|
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.memcached_connection_failed'),
|
|
'error' => "Result code: {$resultCode}",
|
|
];
|
|
}
|
|
|
|
$getValue = $memcached->get($testKey);
|
|
|
|
if ($getValue !== $testValue) {
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.memcached_test_failed'),
|
|
'error' => 'Set/Get verification failed',
|
|
];
|
|
}
|
|
|
|
// 테스트 키 삭제
|
|
$memcached->delete($testKey);
|
|
|
|
$latency = round((microtime(true) - $startTime) * 1000, 2);
|
|
|
|
return [
|
|
'success' => true,
|
|
'message' => __('settings.memcached_test_success'),
|
|
'latency' => $latency.'ms',
|
|
];
|
|
} catch (\Exception $e) {
|
|
Log::warning('Memcached connection test failed', [
|
|
'error' => $e->getMessage(),
|
|
]);
|
|
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.memcached_test_failed'),
|
|
'error' => $e->getMessage(),
|
|
];
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Websocket (Reverb) 서버 연결을 테스트합니다.
|
|
*
|
|
* @param array $config Websocket 설정 배열
|
|
* @return array 테스트 결과
|
|
*/
|
|
public function testWebsocket(array $config): array
|
|
{
|
|
try {
|
|
$host = $config['websocket_host'] ?? 'localhost';
|
|
$port = (int) ($config['websocket_port'] ?? 8080);
|
|
$scheme = $config['websocket_scheme'] ?? 'https';
|
|
|
|
// Reverb 서버 상태 확인 (기본 HTTP 엔드포인트)
|
|
$url = sprintf('%s://%s:%d', $scheme, $host, $port);
|
|
|
|
// Reverb 는 통상 localhost·사내 IP 에서 동작하므로 사설 주소 자체는 정상 구성이다.
|
|
// 다만 이 진단 요청을 임의 목적지 탐색에 전용하지 못하도록, 정상 설정에서는 나올 수
|
|
// 없는 값(userinfo 위장, http/https 이외 scheme, 제어문자 주입)은 거부한다.
|
|
if (! OutboundUrlValidator::isStructurallySafeUrl($url, ['schemes' => ['http', 'https']])) {
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.websocket_test_failed'),
|
|
'error' => __('settings.websocket_invalid_host'),
|
|
];
|
|
}
|
|
|
|
$startTime = microtime(true);
|
|
|
|
// HTTP 요청으로 서버 응답 확인
|
|
$response = Http::timeout(5)
|
|
->withOptions([
|
|
'verify' => false, // 로컬 개발 환경에서 SSL 인증서 검증 무시
|
|
])
|
|
->get($url);
|
|
|
|
$latency = round((microtime(true) - $startTime) * 1000, 2);
|
|
|
|
// Reverb는 루트 경로에서 200 또는 다른 응답을 반환
|
|
// 연결 자체가 성공하면 서버가 실행 중인 것으로 간주
|
|
if ($response->successful() || $response->status() < 500) {
|
|
return [
|
|
'success' => true,
|
|
'message' => __('settings.websocket_test_success'),
|
|
'latency' => $latency.'ms',
|
|
];
|
|
}
|
|
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.websocket_test_failed'),
|
|
'error' => "HTTP {$response->status()}",
|
|
];
|
|
} catch (ConnectionException $e) {
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.websocket_connection_refused'),
|
|
'error' => $e->getMessage(),
|
|
];
|
|
} catch (\Exception $e) {
|
|
Log::warning('Websocket connection test failed', [
|
|
'error' => $e->getMessage(),
|
|
]);
|
|
|
|
return [
|
|
'success' => false,
|
|
'message' => __('settings.websocket_test_failed'),
|
|
'error' => $e->getMessage(),
|
|
];
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 특정 드라이버만 테스트합니다.
|
|
*
|
|
* @param string $driver 드라이버 타입 (s3, redis, memcached, websocket)
|
|
* @param array $config 설정 배열
|
|
* @return array 테스트 결과
|
|
*/
|
|
public function testDriver(string $driver, array $config): array
|
|
{
|
|
return match ($driver) {
|
|
's3' => $this->testS3($config),
|
|
'redis' => $this->testRedis($config),
|
|
'memcached' => $this->testMemcached($config),
|
|
'websocket' => $this->testWebsocket($config),
|
|
default => [
|
|
'success' => false,
|
|
'message' => __('settings.unknown_driver'),
|
|
],
|
|
};
|
|
}
|
|
}
|