Add admin instance stats collector

Author: dansup

app/Console/Commands/InstanceStatsCollectorCommand.php

@@ -0,0 +1,60 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Models\Comment;
+use App\Models\CommentReply;
+use App\Models\Follower;
+use App\Models\Instance;
+use App\Models\Profile;
+use App\Models\Report;
+use App\Models\Video;
+use Illuminate\Console\Command;
+
+class InstanceStatsCollectorCommand extends Command
+{
+    protected $signature = 'app:instance-stats-collector-command';
+
+    protected $description = 'Collect statistics for instances that need updating';
+
+    public function handle()
+    {
+        $count = 0;
+        $now = now();
+
+        Instance::query()
+            ->where(function ($query) {
+                $query->whereNull('stats_last_collected_at')
+                    ->orWhere('stats_last_collected_at', '<', now()->subDay());
+            })
+            ->limit(250)
+            ->lazyById()
+            ->each(function ($instance) use (&$count, $now) {
+                $instance->user_count = Profile::whereDomain($instance->domain)->count();
+                $instance->video_count = Video::join('profiles', 'videos.profile_id', '=', 'profiles.id')
+                    ->where('profiles.domain', $instance->domain)
+                    ->count();
+                $instance->comment_count = Comment::join('profiles', 'comments.profile_id', '=', 'profiles.id')
+                    ->where('profiles.domain', $instance->domain)
+                    ->count();
+                $instance->reply_count = CommentReply::join('profiles', 'comment_replies.profile_id', '=', 'profiles.id')
+                    ->where('profiles.domain', $instance->domain)
+                    ->count();
+                $instance->follower_count = Follower::join('profiles', 'followers.following_id', '=', 'profiles.id')
+                    ->where('profiles.domain', $instance->domain)
+                    ->count();
+                $instance->following_count = Follower::join('profiles', 'followers.profile_id', '=', 'profiles.id')
+                    ->where('profiles.domain', $instance->domain)
+                    ->count();
+                $instance->report_count = Report::join('profiles', 'reports.reported_profile_id', '=', 'profiles.id')
+                    ->where('profiles.domain', $instance->domain)
+                    ->count();
+                $instance->stats_last_collected_at = $now;
+                $instance->save();
+
+                $count++;
+            });
+
+        $this->info("Collected stats for {$count} instances");
+    }
+}

app/Models/Instance.php

@@ -29,6 +29,7 @@
  * @property int $failure_count
  * @property \Illuminate\Support\Carbon|null $created_at
  * @property \Illuminate\Support\Carbon|null $updated_at
+ * @property \Illuminate\Support\Carbon|null $stats_last_collected_at
  *
  * @method static \Illuminate\Database\Eloquent\Builder<static>|Instance newModelQuery()
  * @method static \Illuminate\Database\Eloquent\Builder<static>|Instance newQuery()
@@ -84,6 +85,7 @@ class Instance extends Model
         'admin_notes',
         'allow_video_posts',
         'allow_videos_in_fyf',
+        'stats_last_collected_at',
     ];
 
     protected $casts = [
@@ -95,6 +97,7 @@ class Instance extends Model
         'last_failure_at' => 'datetime',
         'failure_count' => 'integer',
         'federation_state' => 'integer',
+        'stats_last_collected_at' => 'datetime',
     ];
 
     /* Federation State

database/migrations/2026_02_04_081542_add_instance_stats_last_collected_at_timestamp_to_instances_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::table('instances', function (Blueprint $table) {
+            $table->timestamp('stats_last_collected_at')->nullable()->index();
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     */
+    public function down(): void
+    {
+        Schema::table('instances', function (Blueprint $table) {
+            $table->dropColumn('stats_last_collected_at');
+        });
+    }
+};

routes/console.php

@@ -13,6 +13,7 @@
 Schedule::command('passport:purge --revoked')->daily()->onOneServer();
 Schedule::command('version:check --force')->twiceDaily(9, 17)->withoutOverlapping()->runInBackground()->onOneServer();
 Schedule::command('videos:retry-failed')->everyThirtyMinutes()->onOneServer();
+Schedule::command('app:instance-stats-collector-command')->hourlyAt(20)->onOneServer();
 
 if (config('loops.admin_dashboard.autoUpdate')) {
     Schedule::command('admin:refresh-dashboard-30d')->everyThirtyMinutes()->onOneServer();