303 lines
11 KiB
PHP
303 lines
11 KiB
PHP
<?php
|
|
|
|
namespace sammo;
|
|
|
|
use sammo\Enums\APIRecoveryType;
|
|
|
|
class APIHelper
|
|
{
|
|
|
|
private function __construct()
|
|
{
|
|
//static only
|
|
}
|
|
|
|
public static function getSession(int $sessionMode): Session | APIRecoveryType
|
|
{
|
|
if ($sessionMode === BaseAPI::NO_SESSION) {
|
|
return DummySession::getInstance();
|
|
}
|
|
|
|
$session = Session::getInstance();
|
|
if($sessionMode & BaseAPI::REQ_LOGIN || $sessionMode & BaseAPI::REQ_GAME_LOGIN){
|
|
if(!$session->isLoggedIn()){
|
|
return APIRecoveryType::Login;
|
|
}
|
|
}
|
|
|
|
if($sessionMode & BaseAPI::REQ_GAME_LOGIN){
|
|
if(!$session->isGameLoggedIn()){
|
|
$tmpResult = false;
|
|
$session->loginGame($tmpResult);
|
|
if(!$tmpResult){
|
|
return APIRecoveryType::Gateway;
|
|
}
|
|
}
|
|
}
|
|
|
|
if ($sessionMode & BaseAPI::REQ_READ_ONLY) {
|
|
$session->setReadOnly();
|
|
}
|
|
return $session;
|
|
}
|
|
|
|
public static function launch(string $rootPath, string $actionPath, array $eParams = [], bool $loadRawInput = true)
|
|
{
|
|
if ($loadRawInput) {
|
|
try {
|
|
$rawInput = file_get_contents('php://input');
|
|
$input = Json::decode($rawInput);
|
|
} catch (\Exception $e) {
|
|
Json::dieWithReason($e->getMessage());
|
|
$input = null;
|
|
}
|
|
} else {
|
|
$input = null;
|
|
}
|
|
|
|
if (!$actionPath) {
|
|
Json::dieWithReason('path가 지정되지 않았습니다.');
|
|
}
|
|
if ($input && !is_array($input)) {
|
|
Json::dieWithReason('args가 array가 아닙니다.' . gettype($input));
|
|
}
|
|
if (!$input) {
|
|
$input = [];
|
|
}
|
|
|
|
if (class_exists('\\sammo\\UniqueConst')) {
|
|
$serverID = UniqueConst::$serverID;
|
|
$logPath = "{$rootPath}/logs/{$serverID}/api_log.db";
|
|
} else {
|
|
$realYearMonth = date('Y_m');
|
|
$logPath = "{$rootPath}/d_log/{$realYearMonth}_api_log.db";
|
|
}
|
|
$logDB = FileDB::db($logPath, __DIR__ . '/../../f_install/sql/api_log.sql');
|
|
$ip = $_SERVER['HTTP_X_FORWARDED_FOR'] ?? $_SERVER['REMOTE_ADDR'] ?? 'local';
|
|
$date = date('Y-m-d H:i:s');
|
|
|
|
//NOTE: array_merge([], {})의 상황이 가능함.
|
|
$actionArgs = array_merge($input, $eParams);
|
|
|
|
$filteredArgs = $actionArgs;
|
|
|
|
try {
|
|
$obj = buildAPIExecutorClass($actionPath, $rootPath, $actionArgs);
|
|
if (!$obj::$allowExternalAPI) {
|
|
Json::dieWithReason('외부에서는 호출할 수 없습니다.');
|
|
}
|
|
$validateResult = $obj->validateArgs();
|
|
if ($validateResult !== null) {
|
|
$logDB->insert('api_log', [
|
|
'user_id' => 0,
|
|
'ip' => $ip,
|
|
'date' => $date,
|
|
'path' => $actionPath,
|
|
'arg' => Json::encode($filteredArgs),
|
|
'aux' => Json::encode([
|
|
'result' => false,
|
|
'state' => 'validate',
|
|
'reason' => $validateResult
|
|
]),
|
|
]);
|
|
Json::dieWithReason($validateResult);
|
|
}
|
|
$filteredArgs = $obj->getFilteredArgs();
|
|
|
|
$sessionMode = $obj->getRequiredSessionMode();
|
|
$sessionOrFail = static::getSession($sessionMode);
|
|
|
|
if(!($sessionOrFail instanceof Session)){
|
|
$recoveryType = $sessionOrFail;
|
|
Json::dieWithReason($recoveryType->info(), $recoveryType);
|
|
}
|
|
$session = $sessionOrFail;
|
|
|
|
$modifiedSince = WebUtil::parseLastModified();
|
|
$reqEtags = WebUtil::parseETag();
|
|
|
|
$result = $obj->launch($session, $modifiedSince, $reqEtags);
|
|
if (is_string($result)) {
|
|
$logDB->insert('api_log', [
|
|
'user_id' => $session->userID ?? 0,
|
|
'ip' => $ip,
|
|
'date' => $date,
|
|
'path' => $actionPath,
|
|
'arg' => Json::encode($filteredArgs),
|
|
'aux' => Json::encode([
|
|
'result' => false,
|
|
'state' => 'launch',
|
|
'reason' => $result
|
|
]),
|
|
]);
|
|
Json::dieWithReason($result);
|
|
}
|
|
else if($result instanceof APIRecoveryType){
|
|
$recoveryType = $result;
|
|
$logDB->insert('api_log', [
|
|
'user_id' => $session->userID ?? 0,
|
|
'ip' => $ip,
|
|
'date' => $date,
|
|
'path' => $actionPath,
|
|
'arg' => Json::encode($filteredArgs),
|
|
'aux' => Json::encode([
|
|
'result' => false,
|
|
'state' => 'launch',
|
|
'reason' => $recoveryType->info(),
|
|
'recovery' => $recoveryType->value,
|
|
]),
|
|
]);
|
|
Json::dieWithReason($recoveryType->info(), $recoveryType);
|
|
}
|
|
|
|
$cache = $obj->tryCache();
|
|
$setCache = false;
|
|
if ($cache !== null) {
|
|
if ($cache->lastModified !== null || $cache->etag !== null) {
|
|
$setCache = true;
|
|
WebUtil::setCacheHeader($cache);
|
|
}
|
|
|
|
|
|
if ($modifiedSince !== null && $cache->lastModified !== null) {
|
|
$lastModifiedUnixTime = Util::toInt(TimeUtil::DateTimeToSeconds($cache->lastModified, true));
|
|
$modifiedSinceUnixTime = Util::toInt(TimeUtil::DateTimeToSeconds($modifiedSince));
|
|
if ($lastModifiedUnixTime === $modifiedSinceUnixTime) {
|
|
$logDB->insert('api_log', [
|
|
'user_id' => $session->userID ?? 0,
|
|
'ip' => $ip,
|
|
'date' => $date,
|
|
'path' => $actionPath,
|
|
'arg' => Json::encode($filteredArgs),
|
|
'aux' => Json::encode([
|
|
'result' => true,
|
|
'state' => 'cache_not_modified',
|
|
]),
|
|
]);
|
|
WebUtil::dieWithNotModified();
|
|
}
|
|
}
|
|
if ($reqEtags !== null && $reqEtags === $cache->etag) {
|
|
$logDB->insert('api_log', [
|
|
'user_id' => $session->userID ?? 0,
|
|
'ip' => $ip,
|
|
'date' => $date,
|
|
'path' => $actionPath,
|
|
'arg' => Json::encode($filteredArgs),
|
|
'aux' => Json::encode([
|
|
'result' => true,
|
|
'state' => 'cache_not_modified',
|
|
]),
|
|
]);
|
|
WebUtil::dieWithNotModified();
|
|
}
|
|
}
|
|
|
|
if ($result === null) {
|
|
$logDB->insert('api_log', [
|
|
'user_id' => $session->userID ?? 0,
|
|
'ip' => $ip,
|
|
'date' => $date,
|
|
'path' => $actionPath,
|
|
'arg' => Json::encode($filteredArgs),
|
|
'aux' => Json::encode([
|
|
'result' => true,
|
|
'state' => 'success_simple',
|
|
'set_cache' => $setCache,
|
|
]),
|
|
]);
|
|
Json::die([
|
|
'result' => true,
|
|
'reason' => 'success'
|
|
], $setCache ? 0 : Json::NO_CACHE);
|
|
}
|
|
$logDB->insert('api_log', [
|
|
'user_id' => $session->userID ?? 0,
|
|
'ip' => $ip,
|
|
'date' => $date,
|
|
'path' => $actionPath,
|
|
'arg' => Json::encode($filteredArgs),
|
|
'aux' => Json::encode([
|
|
'result' => true,
|
|
'state' => 'success_complex',
|
|
'set_cache' => $setCache,
|
|
]),
|
|
]);
|
|
$result['result'] = $result['result'] ?? true;
|
|
Json::die($result, $setCache ? 0 : Json::NO_CACHE);
|
|
} catch (\MeekroDBException $e) {
|
|
$session = Session::getInstance();
|
|
$errMsg = $e->getMessage();
|
|
$errTrace = $e->getTraceAsString();
|
|
$logDB->insert('api_log', [
|
|
'user_id' => $session->userID ?? 0,
|
|
'ip' => $ip,
|
|
'date' => $date,
|
|
'path' => $actionPath,
|
|
'arg' => Json::encode($filteredArgs),
|
|
'aux' => Json::encode([
|
|
'result' => false,
|
|
'state' => 'error_exception',
|
|
'errMsg' => $errMsg,
|
|
'errTrace' => $errTrace,
|
|
]),
|
|
]);
|
|
logError('MeekroDBException', $errMsg, $actionPath, $e->getTrace());
|
|
Json::dieWithReason("{$errMsg}\n{$errTrace}");
|
|
} catch (\Exception $e) {
|
|
$session = Session::getInstance();
|
|
$errMsg = $e->getMessage();
|
|
$errTrace = $e->getTraceAsString();
|
|
$logDB->insert('api_log', [
|
|
'user_id' => $session->userID ?? 0,
|
|
'ip' => $ip,
|
|
'date' => $date,
|
|
'path' => $actionPath,
|
|
'arg' => Json::encode($filteredArgs),
|
|
'aux' => Json::encode([
|
|
'result' => false,
|
|
'state' => 'error_exception',
|
|
'errMsg' => $errMsg,
|
|
'errTrace' => $errTrace,
|
|
]),
|
|
]);
|
|
Json::dieWithReason("{$errMsg}\n{$errTrace}");
|
|
} catch (\Throwable $e) {
|
|
logExceptionByCustomHandler($e, false);
|
|
$session = Session::getInstance();
|
|
$errMsg = $e->getMessage();
|
|
$errTrace = $e->getTraceAsString();
|
|
$logDB->insert('api_log', [
|
|
'user_id' => $session->userID ?? 0,
|
|
'ip' => $ip,
|
|
'date' => $date,
|
|
'path' => $actionPath,
|
|
'arg' => Json::encode($filteredArgs),
|
|
'aux' => Json::encode([
|
|
'result' => false,
|
|
'state' => 'error_throwable',
|
|
'errMsg' => $errMsg,
|
|
'errTrace' => $errTrace,
|
|
]),
|
|
]);
|
|
Json::dieWithReason("{$errMsg}\n{$errTrace}");
|
|
} catch (mixed $e) {
|
|
$session = Session::getInstance();
|
|
$errStr = strval($e);
|
|
$logDB->insert('api_log', [
|
|
'user_id' => $session->userID ?? 0,
|
|
'ip' => $ip,
|
|
'date' => $date,
|
|
'path' => $actionPath,
|
|
'arg' => Json::encode($filteredArgs),
|
|
'aux' => Json::encode([
|
|
'result' => false,
|
|
'state' => 'error_mixed',
|
|
'errMsg' => $errStr,
|
|
]),
|
|
]);
|
|
Json::dieWithReason($errStr);
|
|
}
|
|
}
|
|
}
|