Data Import/Export API: Extend import API

src/backend/app/Http/Controllers/ApplianceImportController.php

@@ -0,0 +1,72 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use App\Http\Requests\ApplianceImportRequest;
+use App\Http\Resources\ApiResource;
+use App\Jobs\ImportJob;
+use App\Services\ImportServices\ApplianceImportService;
+use Illuminate\Http\JsonResponse;
+use Illuminate\Support\Facades\Cache;
+use Illuminate\Support\Str;
+
+class ApplianceImportController extends Controller {
+    private const ASYNC_THRESHOLD = 50;
+    private const CACHE_TTL_SECONDS = 3600;
+
+    public function __construct(
+        private ApplianceImportService $applianceImportService,
+    ) {}
+
+    public function import(ApplianceImportRequest $request): JsonResponse|ApiResource {
+        $data = $request->input('data');
+
+        if (isset($data['data']) && is_array($data['data'])) {
+            $data = $data['data'];
+        }
+
+        if (count($data) >= self::ASYNC_THRESHOLD) {
+            return $this->dispatchAsync($data, $request);
+        }
+
+        $result = $this->applianceImportService->import($data);
+
+        if (!$result['success'] && isset($result['errors'])) {
+            return response()->json([
+                'success' => false,
+                'errors' => $result['errors'],
+            ], 422);
+        }
+
+        return ApiResource::make($result);
+    }
+
+    /**
+     * @param array<int, array<string, mixed>> $data
+     */
+    private function dispatchAsync(array $data, ApplianceImportRequest $request): JsonResponse {
+        $companyId = (int) $request->attributes->get('companyId');
+        $jobId = Str::uuid()->toString();
+
+        Cache::put("import:{$companyId}:{$jobId}", [
+            'job_id' => $jobId,
+            'status' => 'pending',
+            'type' => 'appliances',
+            'total' => count($data),
+            'result' => null,
+            'error' => null,
+            'created_at' => now()->toISOString(),
+            'completed_at' => null,
+        ], self::CACHE_TTL_SECONDS);
+
+        dispatch(new ImportJob($companyId, $jobId, ApplianceImportService::class, $data));
+
+        return response()->json([
+            'data' => [
+                'job_id' => $jobId,
+                'status' => 'pending',
+                'message' => 'Import queued for background processing',
+            ],
+        ], 202);
+    }
+}

src/backend/app/Http/Controllers/ClusterImportController.php

@@ -0,0 +1,72 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use App\Http\Requests\ClusterImportRequest;
+use App\Http\Resources\ApiResource;
+use App\Jobs\ImportJob;
+use App\Services\ImportServices\ClusterImportService;
+use Illuminate\Http\JsonResponse;
+use Illuminate\Support\Facades\Cache;
+use Illuminate\Support\Str;
+
+class ClusterImportController extends Controller {
+    private const ASYNC_THRESHOLD = 50;
+    private const CACHE_TTL_SECONDS = 3600;
+
+    public function __construct(
+        private ClusterImportService $clusterImportService,
+    ) {}
+
+    public function import(ClusterImportRequest $request): JsonResponse|ApiResource {
+        $data = $request->input('data');
+
+        if (isset($data['data']) && is_array($data['data'])) {
+            $data = $data['data'];
+        }
+
+        if (count($data) >= self::ASYNC_THRESHOLD) {
+            return $this->dispatchAsync($data, $request);
+        }
+
+        $result = $this->clusterImportService->import($data);
+
+        if (!$result['success'] && isset($result['errors'])) {
+            return response()->json([
+                'success' => false,
+                'errors' => $result['errors'],
+            ], 422);
+        }
+
+        return ApiResource::make($result);
+    }
+
+    /**
+     * @param array<int, array<string, mixed>> $data
+     */
+    private function dispatchAsync(array $data, ClusterImportRequest $request): JsonResponse {
+        $companyId = (int) $request->attributes->get('companyId');
+        $jobId = Str::uuid()->toString();
+
+        Cache::put("import:{$companyId}:{$jobId}", [
+            'job_id' => $jobId,
+            'status' => 'pending',
+            'type' => 'clusters',
+            'total' => count($data),
+            'result' => null,
+            'error' => null,
+            'created_at' => now()->toISOString(),
+            'completed_at' => null,
+        ], self::CACHE_TTL_SECONDS);
+
+        dispatch(new ImportJob($companyId, $jobId, ClusterImportService::class, $data));
+
+        return response()->json([
+            'data' => [
+                'job_id' => $jobId,
+                'status' => 'pending',
+                'message' => 'Import queued for background processing',
+            ],
+        ], 202);
+    }
+}

src/backend/app/Http/Controllers/CustomerImportController.php

@@ -0,0 +1,72 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use App\Http\Requests\CustomerImportRequest;
+use App\Http\Resources\ApiResource;
+use App\Jobs\ImportJob;
+use App\Services\ImportServices\CustomerImportService;
+use Illuminate\Http\JsonResponse;
+use Illuminate\Support\Facades\Cache;
+use Illuminate\Support\Str;
+
+class CustomerImportController extends Controller {
+    private const ASYNC_THRESHOLD = 50;
+    private const CACHE_TTL_SECONDS = 3600;
+
+    public function __construct(
+        private CustomerImportService $customerImportService,
+    ) {}
+
+    public function import(CustomerImportRequest $request): JsonResponse|ApiResource {
+        $data = $request->input('data');
+
+        if (isset($data['data']) && is_array($data['data'])) {
+            $data = $data['data'];
+        }
+
+        if (count($data) >= self::ASYNC_THRESHOLD) {
+            return $this->dispatchAsync($data, $request);
+        }
+
+        $result = $this->customerImportService->import($data);
+
+        if (!$result['success'] && isset($result['errors'])) {
+            return response()->json([
+                'success' => false,
+                'errors' => $result['errors'],
+            ], 422);
+        }
+
+        return ApiResource::make($result);
+    }
+
+    /**
+     * @param array<int, array<string, mixed>> $data
+     */
+    private function dispatchAsync(array $data, CustomerImportRequest $request): JsonResponse {
+        $companyId = (int) $request->attributes->get('companyId');
+        $jobId = Str::uuid()->toString();
+
+        Cache::put("import:{$companyId}:{$jobId}", [
+            'job_id' => $jobId,
+            'status' => 'pending',
+            'type' => 'customers',
+            'total' => count($data),
+            'result' => null,
+            'error' => null,
+            'created_at' => now()->toISOString(),
+            'completed_at' => null,
+        ], self::CACHE_TTL_SECONDS);
+
+        dispatch(new ImportJob($companyId, $jobId, CustomerImportService::class, $data));
+
+        return response()->json([
+            'data' => [
+                'job_id' => $jobId,
+                'status' => 'pending',
+                'message' => 'Import queued for background processing',
+            ],
+        ], 202);
+    }
+}

src/backend/app/Http/Controllers/DeviceImportController.php

@@ -0,0 +1,72 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use App\Http\Requests\DeviceImportRequest;
+use App\Http\Resources\ApiResource;
+use App\Jobs\ImportJob;
+use App\Services\ImportServices\DeviceImportService;
+use Illuminate\Http\JsonResponse;
+use Illuminate\Support\Facades\Cache;
+use Illuminate\Support\Str;
+
+class DeviceImportController extends Controller {
+    private const ASYNC_THRESHOLD = 50;
+    private const CACHE_TTL_SECONDS = 3600;
+
+    public function __construct(
+        private DeviceImportService $deviceImportService,
+    ) {}
+
+    public function import(DeviceImportRequest $request): JsonResponse|ApiResource {
+        $data = $request->input('data');
+
+        if (isset($data['data']) && is_array($data['data'])) {
+            $data = $data['data'];
+        }
+
+        if (count($data) >= self::ASYNC_THRESHOLD) {
+            return $this->dispatchAsync($data, $request);
+        }
+
+        $result = $this->deviceImportService->import($data);
+
+        if (!$result['success'] && isset($result['errors'])) {
+            return response()->json([
+                'success' => false,
+                'errors' => $result['errors'],
+            ], 422);
+        }
+
+        return ApiResource::make($result);
+    }
+
+    /**
+     * @param array<int, array<string, mixed>> $data
+     */
+    private function dispatchAsync(array $data, DeviceImportRequest $request): JsonResponse {
+        $companyId = (int) $request->attributes->get('companyId');
+        $jobId = Str::uuid()->toString();
+
+        Cache::put("import:{$companyId}:{$jobId}", [
+            'job_id' => $jobId,
+            'status' => 'pending',
+            'type' => 'devices',
+            'total' => count($data),
+            'result' => null,
+            'error' => null,
+            'created_at' => now()->toISOString(),
+            'completed_at' => null,
+        ], self::CACHE_TTL_SECONDS);
+
+        dispatch(new ImportJob($companyId, $jobId, DeviceImportService::class, $data));
+
+        return response()->json([
+            'data' => [
+                'job_id' => $jobId,
+                'status' => 'pending',
+                'message' => 'Import queued for background processing',
+            ],
+        ], 202);
+    }
+}

src/backend/app/Http/Controllers/ImportStatusController.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use Illuminate\Http\JsonResponse;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\Cache;
+
+class ImportStatusController extends Controller {
+    public function show(string $jobId, Request $request): JsonResponse {
+        $companyId = (int) $request->attributes->get('companyId');
+        $cacheKey = "import:{$companyId}:{$jobId}";
+
+        $status = Cache::get($cacheKey);
+
+        if ($status === null) {
+            return response()->json(['message' => 'Import job not found'], 404);
+        }
+
+        return response()->json(['data' => $status]);
+    }
+}

src/backend/app/Http/Controllers/TransactionImportController.php

@@ -0,0 +1,72 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use App\Http\Requests\TransactionImportRequest;
+use App\Http\Resources\ApiResource;
+use App\Jobs\ImportJob;
+use App\Services\ImportServices\TransactionImportService;
+use Illuminate\Http\JsonResponse;
+use Illuminate\Support\Facades\Cache;
+use Illuminate\Support\Str;
+
+class TransactionImportController extends Controller {
+    private const ASYNC_THRESHOLD = 50;
+    private const CACHE_TTL_SECONDS = 3600;
+
+    public function __construct(
+        private TransactionImportService $transactionImportService,
+    ) {}
+
+    public function import(TransactionImportRequest $request): JsonResponse|ApiResource {
+        $data = $request->input('data');
+
+        if (isset($data['data']) && is_array($data['data'])) {
+            $data = $data['data'];
+        }
+
+        if (count($data) >= self::ASYNC_THRESHOLD) {
+            return $this->dispatchAsync($data, $request);
+        }
+
+        $result = $this->transactionImportService->import($data);
+
+        if (!$result['success'] && isset($result['errors'])) {
+            return response()->json([
+                'success' => false,
+                'errors' => $result['errors'],
+            ], 422);
+        }
+
+        return ApiResource::make($result);
+    }
+
+    /**
+     * @param array<int, array<string, mixed>> $data
+     */
+    private function dispatchAsync(array $data, TransactionImportRequest $request): JsonResponse {
+        $companyId = (int) $request->attributes->get('companyId');
+        $jobId = Str::uuid()->toString();
+
+        Cache::put("import:{$companyId}:{$jobId}", [
+            'job_id' => $jobId,
+            'status' => 'pending',
+            'type' => 'transactions',
+            'total' => count($data),
+            'result' => null,
+            'error' => null,
+            'created_at' => now()->toISOString(),
+            'completed_at' => null,
+        ], self::CACHE_TTL_SECONDS);
+
+        dispatch(new ImportJob($companyId, $jobId, TransactionImportService::class, $data));
+
+        return response()->json([
+            'data' => [
+                'job_id' => $jobId,
+                'status' => 'pending',
+                'message' => 'Import queued for background processing',
+            ],
+        ], 202);
+    }
+}