feat&fix(add Listmonk service and sync part 1, fix association email on member sync)

2026-04-07 16:52:18 +02:00
parent 703a75a11a
commit 6754d8684a
14 changed files with 298 additions and 240 deletions
--- a/app/Console/Commands/SyncListmonkMembers.php
+++ b/app/Console/Commands/SyncListmonkMembers.php
@@ -0,0 +1,119 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Models\ListmonkMember;
+use App\Models\Member;
+use App\Services\ListMonk\ListMonkService;
+use Illuminate\Console\Command;
+use Illuminate\Http\Client\ConnectionException;
+use Illuminate\Support\Facades\Log;
+use Symfony\Component\Console\Command\Command as CommandAlias;
+
+use function Laravel\Prompts\progress;
+
+class SyncListmonkMembers extends Command
+{
+    protected $signature = 'listmonk:sync-members
+        {--dry-run : Run without writing to the database}
+        {--member= : Sync a single member by member_id}';
+
+    protected $description = 'Sync Listmonk user accounts with members';
+
+    public function __construct(
+        protected ListMonkService $listmonk
+    ) {
+        parent::__construct();
+    }
+
+    /**
+     * @throws ConnectionException
+     */
+    public function handle(): int
+    {
+        $dryRun = $this->option('dry-run');
+        $memberFilter = $this->option('member');
+
+        $this->info(
+            $dryRun
+                ? 'DRY-RUN enabled'
+                : 'Syncing Listmonk → Members'
+        );
+
+        $members = Member::query()
+            ->when($memberFilter, fn ($q) => $q->where('id', $memberFilter))
+            ->get()
+            ->filter(fn (Member $m) => ! empty($m->retzien_email))
+            ->keyBy(fn (Member $m) => strtolower($m->retzien_email));
+
+        if ($members->isEmpty()) {
+            $this->warn('No members to sync');
+
+            return CommandAlias::SUCCESS;
+        }
+
+        $this->info("{$members->count()} members to sync");
+
+        $listmonkUsers = $this->listmonk->getUsers();
+
+        dd($listmonkUsers);
+
+        $this->info(count($listmonkUsers).' Listmonk users found');
+
+        $progress = null;
+
+        if (! $dryRun) {
+            $progress = progress(
+                label: 'Syncing members',
+                steps: $members->count()
+            );
+            $progress->start();
+        }
+
+        $synced = 0;
+
+        foreach ($listmonkUsers as $user) {
+            try {
+                $email = strtolower($user['email'] ?? '');
+
+                if (! $email || ! $members->has($email)) {
+                    continue;
+                }
+
+                $member = $members[$email];
+
+                if ($dryRun) {
+                    $this->line("[DRY-RUN] {$member->id} ({$email}) ← Listmonk user #{$user['id']}");
+                } else {
+                    ListmonkMember::query()->updateOrCreate(
+                        ['member_id' => $member->id],
+                        [
+                            'listmonk_user_id' => $user['id'],
+                            'data' => $user,
+                        ]
+                    );
+
+                    $progress?->advance();
+                }
+
+                $synced++;
+            } catch (\Throwable $e) {
+                Log::error('Listmonk sync error', [
+                    'user' => $user['id'] ?? null,
+                    'error' => $e->getMessage(),
+                ]);
+
+                $progress?->advance();
+            }
+        }
+
+        if ($progress) {
+            $progress->finish();
+            $this->newLine();
+        }
+
+        $this->info("Sync complete — {$synced} accounts linked");
+
+        return CommandAlias::SUCCESS;
+    }
+}