Add command to grant new plugins to existing bundle owners

Artisan command `plugins:grant-to-bundle-owners` creates free licenses
for users who purchased a bundle and sends staggered email notifications.
Integrated into Filament's AttachAction with an opt-in toggle so it
triggers automatically when adding a plugin to a bundle.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: simonhamp

app/Console/Commands/GrantPluginToBundleOwners.php

@@ -0,0 +1,118 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Models\Plugin;
+use App\Models\PluginBundle;
+use App\Models\PluginLicense;
+use App\Models\User;
+use App\Notifications\BundlePluginAdded;
+use Illuminate\Console\Command;
+
+class GrantPluginToBundleOwners extends Command
+{
+    protected $signature = 'plugins:grant-to-bundle-owners
+        {bundle : The bundle slug}
+        {plugin : The plugin name (vendor/package)}
+        {--dry-run : Preview what would happen without making changes}
+        {--no-email : Grant the plugin without sending notification emails}';
+
+    protected $description = 'Grant a plugin to all users who have purchased a specific bundle and notify them via email';
+
+    public function handle(): int
+    {
+        $bundle = PluginBundle::where('slug', $this->argument('bundle'))->first();
+
+        if (! $bundle) {
+            $this->error("Bundle not found: {$this->argument('bundle')}");
+
+            return Command::FAILURE;
+        }
+
+        $plugin = Plugin::where('name', $this->argument('plugin'))->first();
+
+        if (! $plugin) {
+            $this->error("Plugin not found: {$this->argument('plugin')}");
+
+            return Command::FAILURE;
+        }
+
+        $dryRun = $this->option('dry-run');
+        $noEmail = $this->option('no-email');
+
+        // Find all unique users who have purchased this bundle
+        // (they have at least one active PluginLicense linked to this bundle)
+        $userIds = PluginLicense::where('plugin_bundle_id', $bundle->id)
+            ->active()
+            ->distinct()
+            ->pluck('user_id');
+
+        $users = User::whereIn('id', $userIds)->get();
+
+        if ($users->isEmpty()) {
+            $this->warn('No users found who have purchased this bundle.');
+
+            return Command::SUCCESS;
+        }
+
+        $this->info("Bundle: {$bundle->name} (slug: {$bundle->slug})");
+        $this->info("Plugin: {$plugin->name}");
+        $this->info("Users found: {$users->count()}");
+
+        if ($dryRun) {
+            $this->warn('[DRY RUN] No changes will be made.');
+        }
+
+        $this->newLine();
+
+        $granted = 0;
+        $skipped = 0;
+
+        foreach ($users as $user) {
+            // Check if user already has an active license for this plugin
+            $existingLicense = PluginLicense::where('user_id', $user->id)
+                ->where('plugin_id', $plugin->id)
+                ->active()
+                ->exists();
+
+            if ($existingLicense) {
+                $this->line("  Skipped {$user->email} — already has an active license");
+                $skipped++;
+
+                continue;
+            }
+
+            if (! $dryRun) {
+                PluginLicense::create([
+                    'user_id' => $user->id,
+                    'plugin_id' => $plugin->id,
+                    'plugin_bundle_id' => $bundle->id,
+                    'price_paid' => 0,
+                    'currency' => 'USD',
+                    'is_grandfathered' => false,
+                    'purchased_at' => now(),
+                ]);
+
+                if (! $noEmail) {
+                    $user->notify(
+                        (new BundlePluginAdded($plugin, $bundle))
+                            ->delay(now()->addSeconds($granted * 2))
+                    );
+                }
+            }
+
+            $this->line("  Granted to {$user->email}");
+            $granted++;
+        }
+
+        $this->newLine();
+        $this->info("Granted: {$granted}");
+        $this->info("Skipped (already licensed): {$skipped}");
+
+        if ($dryRun) {
+            $this->warn('This was a dry run. Run again without --dry-run to apply changes.');
+        }
+
+        return Command::SUCCESS;
+    }
+}

app/Filament/Resources/PluginBundleResource/RelationManagers/PluginsRelationManager.php

@@ -2,9 +2,11 @@
 
 namespace App\Filament\Resources\PluginBundleResource\RelationManagers;
 
+use Filament\Forms;
 use Filament\Resources\RelationManagers\RelationManager;
 use Filament\Tables;
 use Filament\Tables\Table;
+use Illuminate\Support\Facades\Artisan;
 
 class PluginsRelationManager extends RelationManager
 {
@@ -46,7 +48,33 @@ public function table(Table $table): Table
             ->headerActions([
                 Tables\Actions\AttachAction::make()
                     ->preloadRecordSelect()
-                    ->recordSelectSearchColumns(['name']),
+                    ->recordSelectSearchColumns(['name'])
+                    ->form(fn (Tables\Actions\AttachAction $action): array => [
+                        $action->getRecordSelect(),
+                        Forms\Components\Toggle::make('grant_to_existing_owners')
+                            ->label('Grant to existing bundle owners')
+                            ->helperText('Create free licenses for users who already purchased this bundle and send them an email.')
+                            ->default(true),
+                    ])
+                    ->after(function (array $data) {
+                        if (! ($data['grant_to_existing_owners'] ?? false)) {
+                            return;
+                        }
+
+                        /** @var \App\Models\PluginBundle $bundle */
+                        $bundle = $this->getOwnerRecord();
+
+                        $plugin = \App\Models\Plugin::find($data['recordId']);
+
+                        if (! $plugin) {
+                            return;
+                        }
+
+                        Artisan::call('plugins:grant-to-bundle-owners', [
+                            'bundle' => $bundle->slug,
+                            'plugin' => $plugin->name,
+                        ]);
+                    }),
             ])
             ->actions([
                 Tables\Actions\DetachAction::make(),

app/Notifications/BundlePluginAdded.php

@@ -0,0 +1,57 @@
+<?php
+
+namespace App\Notifications;
+
+use App\Models\Plugin;
+use App\Models\PluginBundle;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Notifications\Messages\MailMessage;
+use Illuminate\Notifications\Notification;
+
+class BundlePluginAdded extends Notification implements ShouldQueue
+{
+    use Queueable;
+
+    public function __construct(
+        public Plugin $plugin,
+        public PluginBundle $bundle,
+    ) {}
+
+    /**
+     * @return array<int, string>
+     */
+    public function via(object $notifiable): array
+    {
+        return ['mail'];
+    }
+
+    public function toMail(object $notifiable): MailMessage
+    {
+        $parts = explode('/', $this->plugin->name ?? '');
+        $vendor = $parts[0] ?? '';
+        $package = $parts[1] ?? '';
+
+        $pluginUrl = "https://nativephp.com/plugins/{$vendor}/{$package}";
+
+        return (new MailMessage)
+            ->subject("New plugin added to your {$this->bundle->name} bundle!")
+            ->greeting('Great news!')
+            ->line("We've added **{$this->plugin->name}** to the **{$this->bundle->name}** bundle — and because you already own the bundle, it's yours for free.")
+            ->action('Check it out', $pluginUrl)
+            ->line('Thank you for being a NativePHP customer!');
+    }
+
+    /**
+     * @return array<string, mixed>
+     */
+    public function toArray(object $notifiable): array
+    {
+        return [
+            'plugin_id' => $this->plugin->id,
+            'plugin_name' => $this->plugin->name,
+            'bundle_id' => $this->bundle->id,
+            'bundle_name' => $this->bundle->name,
+        ];
+    }
+}