93 lines
3.4 KiB
PHP
93 lines
3.4 KiB
PHP
<?php
|
|
|
|
namespace Pterodactyl\Http\Controllers\Api\Remote;
|
|
|
|
use Exception;
|
|
use Carbon\Carbon;
|
|
use Illuminate\Support\Str;
|
|
use Pterodactyl\Models\User;
|
|
use Webmozart\Assert\Assert;
|
|
use Pterodactyl\Models\Server;
|
|
use Pterodactyl\Models\ActivityLog;
|
|
use Illuminate\Support\Facades\Log;
|
|
use Pterodactyl\Models\ActivityLogSubject;
|
|
use Pterodactyl\Http\Controllers\Controller;
|
|
use Pterodactyl\Http\Requests\Api\Remote\ActivityEventRequest;
|
|
|
|
class ActivityProcessingController extends Controller
|
|
{
|
|
public function __invoke(ActivityEventRequest $request)
|
|
{
|
|
$tz = Carbon::now()->getTimezone();
|
|
|
|
/** @var \Pterodactyl\Models\Node $node */
|
|
$node = $request->attributes->get('node');
|
|
|
|
$servers = $node->servers()->whereIn('uuid', $request->servers())->get()->keyBy('uuid');
|
|
$users = User::query()->whereIn('uuid', $request->users())->get()->keyBy('uuid');
|
|
|
|
clock()->log($request->input('data'));
|
|
|
|
$logs = [];
|
|
foreach ($request->input('data') as $datum) {
|
|
/** @var \Pterodactyl\Models\Server|null $server */
|
|
$server = $servers->get($datum['server']);
|
|
if (is_null($server) || !Str::startsWith($datum['event'], 'server:')) {
|
|
continue;
|
|
}
|
|
|
|
try {
|
|
$when = Carbon::createFromFormat(
|
|
Carbon::RFC3339,
|
|
preg_replace('/(\.\d+)Z$/', 'Z', $datum['timestamp']),
|
|
'UTC'
|
|
);
|
|
} catch (Exception $exception) {
|
|
Log::warning($exception, ['timestamp' => $datum['timestamp']]);
|
|
|
|
// If we cannot parse the value for some reason don't blow up this request, just go ahead
|
|
// and log the event with the current time, and set the metadata value to have the original
|
|
// timestamp that was provided.
|
|
$when = Carbon::now();
|
|
$datum['metadata'] = array_merge($datum['metadata'] ?? [], ['original_timestamp' => $datum['timestamp']]);
|
|
}
|
|
|
|
$log = [
|
|
'ip' => empty($datum['ip']) ? '127.0.0.1' : $datum['ip'],
|
|
'event' => $datum['event'],
|
|
'properties' => json_encode($datum['metadata'] ?? []),
|
|
// We have to change the time to the current timezone due to the way Laravel is handling
|
|
// the date casting internally. If we just leave it in UTC it ends up getting double-cast
|
|
// and the time is way off.
|
|
'timestamp' => $when->setTimezone($tz),
|
|
];
|
|
|
|
if ($user = $users->get($datum['user'])) {
|
|
$log['actor_id'] = $user->id;
|
|
$log['actor_type'] = $user->getMorphClass();
|
|
}
|
|
|
|
if (!isset($logs[$datum['server']])) {
|
|
$logs[$datum['server']] = [];
|
|
}
|
|
|
|
$logs[$datum['server']][] = $log;
|
|
}
|
|
|
|
foreach ($logs as $key => $data) {
|
|
Assert::isInstanceOf($server = $servers->get($key), Server::class);
|
|
|
|
$batch = [];
|
|
foreach ($data as $datum) {
|
|
$id = ActivityLog::insertGetId($datum);
|
|
$batch[] = [
|
|
'activity_log_id' => $id,
|
|
'subject_id' => $server->id,
|
|
'subject_type' => $server->getMorphClass(),
|
|
];
|
|
}
|
|
|
|
ActivityLogSubject::insert($batch);
|
|
}
|
|
}
|
|
}
|