feat: Competitor-Aware Content Differentiation (#37)

app/GraphQL/Mutations/CreateCompetitorAlert.php

@@ -0,0 +1,14 @@
+<?php
+
+namespace App\GraphQL\Mutations;
+
+use App\Models\CompetitorAlert;
+
+class CreateCompetitorAlert
+{
+    /** @param array{input: array<string, mixed>} $args */
+    public function __invoke(mixed $root, array $args): CompetitorAlert
+    {
+        return CompetitorAlert::create($args['input']);
+    }
+}

app/GraphQL/Mutations/CreateCompetitorSource.php

@@ -0,0 +1,14 @@
+<?php
+
+namespace App\GraphQL\Mutations;
+
+use App\Models\CompetitorSource;
+
+class CreateCompetitorSource
+{
+    /** @param array{input: array<string, mixed>} $args */
+    public function __invoke(mixed $root, array $args): CompetitorSource
+    {
+        return CompetitorSource::create($args['input']);
+    }
+}

app/GraphQL/Mutations/DeleteCompetitorAlert.php

@@ -0,0 +1,23 @@
+<?php
+
+namespace App\GraphQL\Mutations;
+
+use App\Models\CompetitorAlert;
+
+class DeleteCompetitorAlert
+{
+    /** @param array{id: string} $args */
+    public function __invoke(mixed $root, array $args): ?CompetitorAlert
+    {
+        $alert = CompetitorAlert::find($args['id']);
+
+        if ($alert) {
+            $currentSpace = app()->bound('current_space') ? app('current_space') : null;
+            abort_if($currentSpace && $alert->space_id !== $currentSpace->id, 403);
+
+            $alert->delete();
+        }
+
+        return $alert;
+    }
+}

app/GraphQL/Mutations/DeleteCompetitorSource.php

@@ -0,0 +1,23 @@
+<?php
+
+namespace App\GraphQL\Mutations;
+
+use App\Models\CompetitorSource;
+
+class DeleteCompetitorSource
+{
+    /** @param array{id: string} $args */
+    public function __invoke(mixed $root, array $args): ?CompetitorSource
+    {
+        $source = CompetitorSource::find($args['id']);
+
+        if ($source) {
+            $currentSpace = app()->bound('current_space') ? app('current_space') : null;
+            abort_if($currentSpace && $source->space_id !== $currentSpace->id, 403);
+
+            $source->delete();
+        }
+
+        return $source;
+    }
+}

app/GraphQL/Mutations/TriggerCompetitorCrawl.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace App\GraphQL\Mutations;
+
+use App\Jobs\CrawlCompetitorSourceJob;
+use App\Models\CompetitorSource;
+
+class TriggerCompetitorCrawl
+{
+    /** @param array{source_id: string} $args */
+    public function __invoke(mixed $root, array $args): bool
+    {
+        $source = CompetitorSource::findOrFail($args['source_id']);
+
+        $currentSpace = app()->bound('current_space') ? app('current_space') : null;
+        abort_if($currentSpace && $source->space_id !== $currentSpace->id, 403);
+
+        CrawlCompetitorSourceJob::dispatch($source);
+
+        return true;
+    }
+}

app/GraphQL/Mutations/UpdateCompetitorSource.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace App\GraphQL\Mutations;
+
+use App\Models\CompetitorSource;
+
+class UpdateCompetitorSource
+{
+    /** @param array{id: string, input: array<string, mixed>} $args */
+    public function __invoke(mixed $root, array $args): CompetitorSource
+    {
+        $source = CompetitorSource::findOrFail($args['id']);
+
+        $currentSpace = app()->bound('current_space') ? app('current_space') : null;
+        abort_if($currentSpace && $source->space_id !== $currentSpace->id, 403);
+
+        $source->update($args['input']);
+
+        return $source->fresh() ?? $source;
+    }
+}

app/GraphQL/Queries/CompetitorContent.php

@@ -0,0 +1,27 @@
+<?php
+
+namespace App\GraphQL\Queries;
+
+use App\Models\CompetitorContentItem;
+use Illuminate\Pagination\LengthAwarePaginator;
+
+class CompetitorContent
+{
+    /** @param array{space_id: string, source_id?: string|null, first?: int, page?: int} $args */
+    public function __invoke(mixed $root, array $args): LengthAwarePaginator
+    {
+        $query = CompetitorContentItem::query()
+            ->whereHas('source', fn ($q) => $q->where('space_id', $args['space_id']))
+            ->with('source')
+            ->orderByDesc('crawled_at');
+
+        if (! empty($args['source_id'])) {
+            $query->where('source_id', $args['source_id']);
+        }
+
+        $perPage = (int) ($args['first'] ?? 20);
+        $page = (int) ($args['page'] ?? 1);
+
+        return $query->paginate($perPage, ['*'], 'page', $page);
+    }
+}

app/GraphQL/Queries/DifferentiationAnalyses.php

@@ -0,0 +1,30 @@
+<?php
+
+namespace App\GraphQL\Queries;
+
+use App\Models\DifferentiationAnalysis;
+use Illuminate\Pagination\LengthAwarePaginator;
+
+class DifferentiationAnalyses
+{
+    /** @param array{space_id: string, content_id?: string|null, brief_id?: string|null, first?: int, page?: int} $args */
+    public function __invoke(mixed $root, array $args): LengthAwarePaginator
+    {
+        $query = DifferentiationAnalysis::where('space_id', $args['space_id'])
+            ->with('competitorContent')
+            ->orderByDesc('analyzed_at');
+
+        if (! empty($args['content_id'])) {
+            $query->where('content_id', $args['content_id']);
+        }
+
+        if (! empty($args['brief_id'])) {
+            $query->where('brief_id', $args['brief_id']);
+        }
+
+        $perPage = (int) ($args['first'] ?? 20);
+        $page = (int) ($args['page'] ?? 1);
+
+        return $query->paginate($perPage, ['*'], 'page', $page);
+    }
+}

app/GraphQL/Queries/DifferentiationSummary.php

@@ -0,0 +1,34 @@
+<?php
+
+namespace App\GraphQL\Queries;
+
+use App\Models\DifferentiationAnalysis;
+
+class DifferentiationSummary
+{
+    /** @param array{space_id: string} $args */
+    /** @return array<string, mixed> */
+    public function __invoke(mixed $root, array $args): array
+    {
+        /** @var object{total_analyses: int|string, avg_differentiation_score: float|string|null, avg_similarity_score: float|string|null, max_differentiation_score: float|string|null, min_differentiation_score: float|string|null, last_analyzed_at: string|null}|null $summary */
+        $summary = DifferentiationAnalysis::where('space_id', $args['space_id'])
+            ->selectRaw('
+                COUNT(*) as total_analyses,
+                AVG(differentiation_score) as avg_differentiation_score,
+                AVG(similarity_score) as avg_similarity_score,
+                MAX(differentiation_score) as max_differentiation_score,
+                MIN(differentiation_score) as min_differentiation_score,
+                MAX(analyzed_at) as last_analyzed_at
+            ')
+            ->first();
+
+        return [
+            'total_analyses' => (int) ($summary->total_analyses ?? 0),
+            'avg_differentiation_score' => round((float) ($summary->avg_differentiation_score ?? 0.0), 4),
+            'avg_similarity_score' => round((float) ($summary->avg_similarity_score ?? 0.0), 4),
+            'max_differentiation_score' => round((float) ($summary->max_differentiation_score ?? 0.0), 4),
+            'min_differentiation_score' => round((float) ($summary->min_differentiation_score ?? 0.0), 4),
+            'last_analyzed_at' => $summary->last_analyzed_at ?? null,
+        ];
+    }
+}

app/Http/Controllers/Api/CompetitorController.php

@@ -0,0 +1,108 @@
+<?php
+
+namespace App\Http\Controllers\Api;
+
+use App\Http\Controllers\Controller;
+use App\Http\Requests\StoreCompetitorAlertRequest;
+use App\Http\Resources\CompetitorAlertResource;
+use App\Http\Resources\CompetitorContentItemResource;
+use App\Jobs\CrawlCompetitorSourceJob;
+use App\Models\CompetitorAlert;
+use App\Models\CompetitorContentItem;
+use App\Models\CompetitorSource;
+use Illuminate\Http\JsonResponse;
+use Illuminate\Http\Request;
+use Illuminate\Http\Resources\Json\AnonymousResourceCollection;
+
+class CompetitorController extends Controller
+{
+    /**
+     * GET /api/v1/competitor/content
+     * List competitor content items for a space.
+     */
+    public function content(Request $request): AnonymousResourceCollection
+    {
+        $validated = $request->validate([
+            'space_id' => ['required', 'string'],
+            'source_id' => ['nullable', 'string'],
+            'per_page' => ['nullable', 'integer', 'min:1', 'max:100'],
+        ]);
+
+        $currentSpace = app()->bound('current_space') ? app('current_space') : null;
+        abort_if($currentSpace && $validated['space_id'] !== $currentSpace->id, 403);
+
+        $query = CompetitorContentItem::query()
+            ->whereHas('source', fn ($q) => $q->where('space_id', $validated['space_id']))
+            ->with('source')
+            ->orderByDesc('crawled_at');
+
+        if (! empty($validated['source_id'])) {
+            $query->where('source_id', $validated['source_id']);
+        }
+
+        return CompetitorContentItemResource::collection(
+            $query->paginate((int) ($validated['per_page'] ?? 20))
+        );
+    }
+
+    /**
+     * POST /api/v1/competitor/sources/{id}/crawl
+     * Trigger an immediate crawl for a source.
+     */
+    public function crawl(string $id): JsonResponse
+    {
+        $source = CompetitorSource::findOrFail($id);
+
+        $currentSpace = app()->bound('current_space') ? app('current_space') : null;
+        abort_if($currentSpace && $source->space_id !== $currentSpace->id, 403);
+
+        CrawlCompetitorSourceJob::dispatch($source);
+
+        return response()->json(['message' => 'Crawl job dispatched', 'source_id' => $source->id]);
+    }
+
+    /**
+     * GET /api/v1/competitor/alerts
+     */
+    public function alerts(Request $request): AnonymousResourceCollection
+    {
+        $validated = $request->validate([
+            'space_id' => ['required', 'string'],
+            'per_page' => ['nullable', 'integer', 'min:1', 'max:100'],
+        ]);
+
+        $currentSpace = app()->bound('current_space') ? app('current_space') : null;
+        abort_if($currentSpace && $validated['space_id'] !== $currentSpace->id, 403);
+
+        $alerts = CompetitorAlert::where('space_id', $validated['space_id'])
+            ->orderByDesc('created_at')
+            ->paginate((int) ($validated['per_page'] ?? 20));
+
+        return CompetitorAlertResource::collection($alerts);
+    }
+
+    /**
+     * POST /api/v1/competitor/alerts
+     */
+    public function storeAlert(StoreCompetitorAlertRequest $request): JsonResponse
+    {
+        $alert = CompetitorAlert::create($request->validated());
+
+        return response()->json(['data' => new CompetitorAlertResource($alert)], 201);
+    }
+
+    /**
+     * DELETE /api/v1/competitor/alerts/{id}
+     */
+    public function destroyAlert(string $id): JsonResponse
+    {
+        $alert = CompetitorAlert::findOrFail($id);
+
+        $currentSpace = app()->bound('current_space') ? app('current_space') : null;
+        abort_if($currentSpace && $alert->space_id !== $currentSpace->id, 403);
+
+        $alert->delete();
+
+        return response()->json(null, 204);
+    }
+}