From 86285e3233a05949c7924dba422f5f18440d61af Mon Sep 17 00:00:00 2001
From: Steven Fox <62109327+steven-fox@users.noreply.github.com>
Date: Fri, 6 Sep 2024 10:15:30 -0400
Subject: [PATCH] feat(hashtags): add SyncMissingQuestionHashtags command

---
 .../Commands/SyncMissingQuestionHashtags.php  | 69 +++++++++++++++++++
 .../SyncMissingQuestionHashtagsTest.php       | 25 +++++++
 2 files changed, 94 insertions(+)
 create mode 100644 app/Console/Commands/SyncMissingQuestionHashtags.php
 create mode 100644 tests/Console/SyncMissingQuestionHashtagsTest.php

diff --git a/app/Console/Commands/SyncMissingQuestionHashtags.php b/app/Console/Commands/SyncMissingQuestionHashtags.php
new file mode 100644
index 000000000..eb00a68eb
--- /dev/null
+++ b/app/Console/Commands/SyncMissingQuestionHashtags.php
@@ -0,0 +1,69 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Console\Commands;
+
+use App\EventActions\UpdateQuestionHashtags;
+use App\Models\Question;
+use Illuminate\Console\Command;
+use Illuminate\Database\Eloquent\Builder;
+
+final class SyncMissingQuestionHashtags extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'app:sync-missing-hashtags {runtime=28 : The maximum execution time of the command}';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Sync missing question hashtags';
+
+    /**
+     * Execute the console command.
+     */
+    public function handle(): void
+    {
+        $runtime = (int) $this->argument('runtime');
+        $runUntil = now()->addSeconds($runtime);
+        $halted = false;
+
+        $questions = Question::query()
+            ->whereDoesntHave('hashtags')
+            ->where(fn (Builder $where): Builder => $where
+                ->where('content', 'like', '%#%')
+                ->orWhere('answer', 'like', '%#%')
+            )
+            ->lazyByIdDesc();
+
+        $bar = $this->output->createProgressBar(count($questions));
+
+        $bar->start();
+
+        foreach ($questions as $question) {
+            if (now()->isAfter($runUntil)) {
+                $halted = true;
+                break;
+            }
+
+            (new UpdateQuestionHashtags($question))->handle();
+
+            $bar->advance();
+        }
+
+        if ($halted) {
+            $this->newLine();
+            $this->info('Halting process to limit runtime.');
+
+            return;
+        }
+
+        $bar->finish();
+    }
+}
diff --git a/tests/Console/SyncMissingQuestionHashtagsTest.php b/tests/Console/SyncMissingQuestionHashtagsTest.php
new file mode 100644
index 000000000..3c02d4524
--- /dev/null
+++ b/tests/Console/SyncMissingQuestionHashtagsTest.php
@@ -0,0 +1,25 @@
+<?php
+
+declare(strict_types=1);
+
+it('syncs hashtag relations for questions that are missing hashtags', function () {
+    /** @var Tests\TestCase $this */
+    $withHashtags = App\Models\Question::factory(10)->create(['answer' => 'has a #hashtag']);
+    $withoutHashtags = App\Models\Question::factory(10)->create(['answer' => 'no hashtags here']);
+
+    Illuminate\Support\Facades\DB::table('hashtag_question')->truncate();
+
+    $this->artisan('app:sync-missing-hashtags')->assertSuccessful();
+
+    $withHashtags->load('hashtags');
+    $withoutHashtags->load('hashtags');
+
+    expect($withHashtags->every(
+        fn (App\Models\Question $question): bool => $question->hashtags->pluck('name')->all() === ['hashtag'])
+    )
+        ->toBeTrue();
+    expect($withoutHashtags->every(
+        fn (App\Models\Question $question): bool => $question->hashtags->isEmpty())
+    )
+        ->toBeTrue();
+});