Added tag frequency model and handler

Author: AllanKoder

app/Events/TagFrequencyChanged.php

@@ -0,0 +1,33 @@
+<?php
+
+namespace App\Events;
+
+use Illuminate\Broadcasting\Channel;
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Broadcasting\PresenceChannel;
+use Illuminate\Broadcasting\PrivateChannel;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+
+class TagFrequencyChanged
+{
+    use Dispatchable, InteractsWithSockets, SerializesModels;
+
+    /**
+     * Create a new event instance.
+     */
+    public function __construct(public array|null $oldTags, public array|null $newTags) { }
+
+    /**
+     * Get the channels the event should broadcast on.
+     *
+     * @return array<int, \Illuminate\Broadcasting\Channel>
+     */
+    public function broadcastOn(): array
+    {
+        return [
+            new PrivateChannel('channel-name'),
+        ];
+    }
+}

app/Http/Controllers/ComputerScienceResourceController.php

@@ -2,6 +2,7 @@
 
 namespace App\Http\Controllers;
 
+use App\Events\TagFrequencyChanged;
 use App\Http\Requests\ComputerScienceResource\StoreResourceRequest;
 use App\Models\ComputerScienceResource;
 use App\Models\ResourceEdits;
@@ -77,6 +78,9 @@ public function store(StoreResourceRequest $request)
             $resource->general_tags = $validatedData['general_tags'];
         }
 
+        // Change tag frequency
+        TagFrequencyChanged::dispatch(null, $resource->tagCounter());
+
         Log::debug("Created resource " . json_encode($resource));
 
         return redirect(route('resources.show', ['computerScienceResource' => $resource->id]))

app/Http/Controllers/ResourceEditsController.php

@@ -2,6 +2,7 @@
 
 namespace App\Http\Controllers;
 
+use App\Events\TagFrequencyChanged;
 use App\Models\ComputerScienceResource;
 use App\Models\ResourceEdits;
 use App\Services\ResourceEditsService;
@@ -26,7 +27,7 @@ public function create(ComputerScienceResource $computerScienceResource)
     }
 
 
-    // TODO: Make an array facade
+    // TODO: Make an array facade or something
     function normalize($array) {
         ksort($array);
         foreach ($array as &$value) {
@@ -93,6 +94,7 @@ public function merge(ResourceEditsService $editsService, ResourceEdits $resourc
         }
 
         $resource = ComputerScienceResource::findOrFail($resourceEdits->computer_science_resource_id);
+        $old_tag_counter = $resource->tagCounter();
 
         $resource->name = $resourceEdits->name;
         $resource->description = $resourceEdits->description;
@@ -108,6 +110,11 @@ public function merge(ResourceEditsService $editsService, ResourceEdits $resourc
         $resource->programming_language_tags = $resourceEdits->programming_language_tags;
         $resource->general_tags = $resourceEdits->general_tags;
 
+        // Get the new tag counter
+        $new_tags = collect([$resourceEdits->topic_tags, $resourceEdits->programming_language_tags, $resourceEdits->general_tags])->flatten()->countBy()->toArray();
+        // Change tag frequency
+        TagFrequencyChanged::dispatch($old_tag_counter, $new_tags);
+
         // Delete the edit since we successfully merged the changes
         $resourceEdits->delete();
 

app/Http/Controllers/TagFrequencyController.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use Illuminate\Http\Request;
+
+class TagFrequencyController extends Controller
+{
+    //
+}

app/Listeners/ModifyTagFrequency.php

@@ -0,0 +1,64 @@
+<?php
+
+namespace App\Listeners;
+
+use App\Events\TagFrequencyChanged;
+use App\Models\TagFrequency;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Support\Facades\DB;
+
+class ModifyTagFrequency
+{
+    /**
+     * Create the event listener.
+     */
+    public function __construct()
+    {
+        //
+    }
+
+    /**
+     * Handle the event.
+     */
+    public function handle(TagFrequencyChanged $event): void
+    {
+        $old = $event->oldTags ?? [];
+        $new = $event->newTags ?? [];
+
+        // 1. Build diffs for every tag
+        $diffs = [];
+        foreach (array_unique(array_merge(array_keys($old), array_keys($new))) as $tag) {
+            $diff = ($new[$tag] ?? 0) - ($old[$tag] ?? 0);
+            if ($diff !== 0) {
+                $diffs[$tag] = $diff;
+            }
+        }
+
+        if (empty($diffs)) {
+            return;
+        }
+
+        // 2. One upsert: increment (or decrement) existing, insert new
+        $upserts = [];
+        foreach ($diffs as $tag => $count) {
+            $upserts[] = [
+                'tag' => $tag,
+                'count' => $count,
+            ];
+        }
+
+        DB::table('tag_frequencies')->upsert(
+            $upserts,
+            ['tag'],
+            [
+                'count' => DB::raw('tag_frequencies.count + VALUES(count)'),
+            ]
+        );
+
+        // 3. Clean out any zero-or-negative counts
+        DB::table('tag_frequencies')
+            ->where('count', '<=', 0)
+            ->delete();
+    }
+}

app/Models/ComputerScienceResource.php

@@ -104,4 +104,10 @@ protected function generalTags(): Attribute
             set: fn(array $value) => $this->syncTagsWithType($value, 'general_tags')
         );
     }
+
+    public function tagCounter(): array
+    {
+        $tag_collection = collect([$this->topic_tags, $this->programming_language_tags, $this->general_tags]);
+        return $tag_collection->flatten()->countBy()->toArray();
+    }
 }

app/Models/TagFrequency.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace App\Models;
+
+use Illuminate\Database\Eloquent\Model;
+
+class TagFrequency extends Model
+{
+    public $timestamps = false;
+}

app/Services/ResourceEditsService.php

@@ -16,13 +16,11 @@ class ResourceEditsService
      */
     public function requiredVotes(int $totalVotes): int
     {
-        // So little votes, so we only need 1 vote to approve
-        if ($totalVotes <= 1) return 1;
-
-        // Dropoff
-        return min($totalVotes,
+        // Either the current votes, or the log equation
+        $votes = min($totalVotes,
             floor(log($totalVotes, 1.25)) + 1
         );
+        return max(3, $votes); // Need to be 3 votes minimum
     }
 
     /**
@@ -31,6 +29,10 @@ public function requiredVotes(int $totalVotes): int
      */
     public function canMergeEdits(ResourceEdits $edits) : bool
     {
+        if (app()->isLocal()) {
+            return true;
+        }
+
         $totalVotes = $edits->resource->votes_count;
         $neededApprovals = $this->requiredVotes($totalVotes);
 

database/migrations/2025_04_30_202718_create_tag_frequencies_table.php

@@ -0,0 +1,28 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    /**
+     * Run the migrations.
+     */
+    public function up(): void
+    {
+        Schema::create('tag_frequencies', function (Blueprint $table) {
+            $table->char('tag', 100)->primary();
+            $table->bigInteger('count')->default(0);
+            $table->timestamps();
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     */
+    public function down(): void
+    {
+        Schema::dropIfExists('tag_frequencies');
+    }
+};

tests/Unit/ResourceEditsServiceTest.php

@@ -17,19 +17,19 @@ protected function setUp(): void
     }
 
     /**
-     * Zero votes on a resource, so 1 approval is enough to merge
+     * Zero votes on a resource, 3 approval is minimum to merge
      */
     public function test_zero_votes_on_edit(): void
     {
-        $this->assertEquals($this->service->requiredVotes(0), 1);
+        $this->assertEquals($this->service->requiredVotes(0), 3);
     }
 
     /**
-     * 1 vote on a resource, so 1 approval is enough to merge
+     * 1 vote on a resource, 3 approvals is minimum to merge
      */
     public function test_one_vote_on_edit(): void
     {
-        $this->assertEquals($this->service->requiredVotes(1), 1);
+        $this->assertEquals($this->service->requiredVotes(1), 3);
     }