chris/pixelfed
1
0
Fork 0
forked from mirror/pixelfed
Code Pull requests Activity

Update AutospamUpdateCachedDataPipeline

Browse source
This commit is contained in:
Daniel Supernault 2023-05-17 04:44:35 -06:00
parent 5abc2445a7
commit a11e1ee3f8
No known key found for this signature in database
GPG key ID: 0DEF1C662C9033F7
1 changed files with 23 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
app/Jobs/AutospamPipeline/AutospamUpdateCachedDataPipeline.php
View file

@ -52,9 +52,11 @@ class AutospamUpdateCachedDataPipeline implements ShouldQueue
} }
} }
$newSpamCount = count($spam['words']['spam']); $newSpamCount = count($spam['words']['spam']);
if($newSpamCount) {
$spam['documents']['spam'] = $newSpamCount; $spam['documents']['spam'] = $newSpamCount;
arsort($spam['words']['spam']); arsort($spam['words']['spam']);
Storage::put(AutospamService::MODEL_SPAM_PATH, json_encode($spam, JSON_UNESCAPED_SLASHES|JSON_PRETTY_PRINT)); Storage::put(AutospamService::MODEL_SPAM_PATH, json_encode($spam, JSON_UNESCAPED_SLASHES|JSON_PRETTY_PRINT));
}
$hamExists = Storage::exists(AutospamService::MODEL_HAM_PATH); $hamExists = Storage::exists(AutospamService::MODEL_HAM_PATH);
if($hamExists) { if($hamExists) {
@ -80,11 +82,13 @@ class AutospamUpdateCachedDataPipeline implements ShouldQueue
} }
$newHamCount = count($ham['words']['ham']); $newHamCount = count($ham['words']['ham']);
if($newHamCount) {
$ham['documents']['ham'] = $newHamCount; $ham['documents']['ham'] = $newHamCount;
arsort($ham['words']['ham']); arsort($ham['words']['ham']);
Storage::put(AutospamService::MODEL_HAM_PATH, json_encode($ham, JSON_UNESCAPED_SLASHES|JSON_PRETTY_PRINT)); Storage::put(AutospamService::MODEL_HAM_PATH, json_encode($ham, JSON_UNESCAPED_SLASHES|JSON_PRETTY_PRINT));
}
if($newSpamCount && $newHamCount) {
$combined = [ $combined = [
'documents' => [ 'documents' => [
'spam' => $newSpamCount, 'spam' => $newSpamCount,
@ -97,6 +101,8 @@ class AutospamUpdateCachedDataPipeline implements ShouldQueue
]; ];
Storage::put(AutospamService::MODEL_FILE_PATH, json_encode($combined, JSON_PRETTY_PRINT,JSON_UNESCAPED_SLASHES)); Storage::put(AutospamService::MODEL_FILE_PATH, json_encode($combined, JSON_PRETTY_PRINT,JSON_UNESCAPED_SLASHES));
}
Cache::forget(AutospamService::MODEL_CACHE_KEY); Cache::forget(AutospamService::MODEL_CACHE_KEY);
Cache::forget(AutospamService::CHCKD_CACHE_KEY); Cache::forget(AutospamService::CHCKD_CACHE_KEY);
} }