diff --git a/app/Jobs/InboxPipeline/InboxValidator.php b/app/Jobs/InboxPipeline/InboxValidator.php index bfc3457d..4fc1b75a 100644 --- a/app/Jobs/InboxPipeline/InboxValidator.php +++ b/app/Jobs/InboxPipeline/InboxValidator.php @@ -59,7 +59,7 @@ class InboxValidator implements ShouldQueue // Job processed already return 1; } - Cache::put($lockKey, 1, 300); + Cache::put($lockKey, 1, 3600); } if(!isset($headers['signature']) || !isset($headers['date'])) { @@ -155,6 +155,9 @@ class InboxValidator implements ShouldQueue ) { return; } + if(!isset($bodyDecoded['id'])) { + return; + } $signatureData = HttpSignature::parseSignatureHeader($signature); $keyId = Helpers::validateUrl($signatureData['keyId']); $id = Helpers::validateUrl($bodyDecoded['id']); diff --git a/app/Jobs/InboxPipeline/InboxWorker.php b/app/Jobs/InboxPipeline/InboxWorker.php index a888fd3c..44e3a1cb 100644 --- a/app/Jobs/InboxPipeline/InboxWorker.php +++ b/app/Jobs/InboxPipeline/InboxWorker.php @@ -55,7 +55,7 @@ class InboxWorker implements ShouldQueue // Job processed already return 1; } - Cache::put($lockKey, 1, 300); + Cache::put($lockKey, 1, 3600); } if(!isset($headers['signature']) || !isset($headers['date'])) { @@ -145,6 +145,9 @@ class InboxWorker implements ShouldQueue ) { return; } + if(!isset($bodyDecoded['id'])) { + return; + } $signatureData = HttpSignature::parseSignatureHeader($signature); $keyId = Helpers::validateUrl($signatureData['keyId']); $id = Helpers::validateUrl($bodyDecoded['id']);