Import via API.

src/.env.example

@@ -18,7 +18,7 @@ DB_PASSWORD=
 BROADCAST_DRIVER=log
 CACHE_DRIVER=file
 FILESYSTEM_DISK=local
-QUEUE_CONNECTION=sync
+QUEUE_CONNECTION=database
 SESSION_DRIVER=file
 SESSION_LIFETIME=120
 

src/app/Enums/Imports/ImportSources.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace App\Enums\Imports;
+
+enum ImportSources: string
+{
+    case OPEN_LIBRARY = 'openlibrary';
+}

src/app/Http/Controllers/IndexController.php

@@ -4,10 +4,13 @@
 
 use Illuminate\Http\Request;
 use Inertia\Inertia;
+use App\Traits\Imports\OpenLibraryTrait;
 
 class IndexController extends Controller
 {
+    use OpenLibraryTrait;
     public function index() {
+        $this->importOpenLibrary();
         return Inertia::render('index');
     }
 }

src/app/Jobs/ImportFromApiJob.php

@@ -0,0 +1,47 @@
+<?php
+
+namespace App\Jobs;
+
+use App\Enums\Imports\ImportSources;
+use Exception;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldBeUnique;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+use App\Traits\Imports\OpenLibraryTrait;
+
+class ImportFromApiJob implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+    use OpenLibraryTrait;
+
+    /**
+     * Create a new job instance.
+     */
+    public function __construct(
+        private ImportSources $source = ImportSources::OPEN_LIBRARY,
+        private array $query = ['first_publish_year:[0 TO 2024]'],
+    )
+    {}
+
+    /**
+     * Execute the job.
+     * @throws Exception
+     */
+    public function handle(): void
+    {
+        // validate if query array is key only and not key-value pair
+        foreach ($this->query as $key => $value) {
+            if (is_string($key)) {
+                throw new Exception('Query array must not be key-value pair');
+            }
+        }
+
+        // replace with switch statement once more sources are added
+        if ($this->source == ImportSources::OPEN_LIBRARY) {
+            $this->importOpenLibrary($this->query);
+        }
+    }
+}

src/app/Traits/CommonLibraryTrait.php

@@ -2,6 +2,7 @@
 
 namespace App\Traits;
 
+use App\Models\Item;
 use App\Models\LibraryPass;
 use Illuminate\Support\Env;
 
@@ -49,5 +50,26 @@ private function isLibraryPassBarCodeAlreadyInUse($barcode): bool
     {
         return LibraryPass::where('barcode', $barcode)->exists();
     }
+
+
+    public function generateValidItemIdentifier(): string
+    {
+        $identifier = $this->generateItemIdentifier();
+        while($this->isItemIdentifierAlreadyInUse($identifier)) {
+            $identifier = $this->generateItemIdentifier();
+        }
+        return $identifier;
+    }
+
+    private function generateItemIdentifier(): string
+    {
+        $prefix = "ITM";
+        return $prefix . $this->generateRandomNumber(16);
+    }
+
+    private function isItemIdentifierAlreadyInUse($identifier): bool
+    {
+        return Item::where('identifier', $identifier)->exists();
+    }
 }
 

src/app/Traits/Imports/OpenLibraryTrait.php

@@ -0,0 +1,63 @@
+<?php
+
+namespace App\Traits\Imports;
+
+use App\Models\Item;
+use App\Models\User;
+use App\Traits\CommonLibraryTrait;
+
+trait OpenLibraryTrait
+{
+    use CommonLibraryTrait;
+    public function importOpenLibrary($tries = 3) {
+        if ($tries < 1) $tries = 3;
+
+        $maxOffset = (int) ceil(100 * $tries / 100) * 100;
+        $offset = 100;
+        $loop = (int) ceil($offset / 100);
+
+        for ($i = 0; $i < $loop; $i++) {
+            $this->import($offset);
+            if ($offset >= $maxOffset) {
+                break;
+            }
+            $offset += 100;
+        };
+    }
+
+    private function import($offset) {
+        $books = $this->getData($offset);
+
+        foreach ($books as $book) {
+            $this->importBook($book);
+        }
+    }
+
+    private function importBook($book) {
+        Item::create([
+            'identifier' => $this->generateValidItemIdentifier(),
+            'type' => 'book',
+            'name' => $book['title'],
+            'description' => "Dit boek is geschreven door {$book['author_name'][0]} en is uitgegeven in {$book['first_publish_year']}.",
+            'category' => 1,
+            'ISBN' => $book['isbn'][0],
+            'rating' => 1,
+            'borrowing_time' => 30,
+            'modified_kind' => 'I',
+            'modified_user' => User::where('email', '[email protected]')->first()->id,
+        ]);
+    }
+
+    private function getData($offset)
+    {
+        $baseUrl = "https://openlibrary.org/search.json?q=language%3Adut&sort=new&lang=nl&offset=" . $offset;
+        $curl = curl_init();
+        curl_setopt($curl, CURLOPT_URL, $baseUrl);
+        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
+        $response = curl_exec($curl);
+        curl_close($curl);
+
+        $response = json_decode($response, true);
+        return $response['docs'];
+    }
+}

src/composer.json

@@ -11,7 +11,9 @@
         "laravel/framework": "^10.10",
         "laravel/sanctum": "^3.3",
         "laravel/tinker": "^2.8",
-        "spatie/laravel-permission": "^6.1"
+        "mxl/laravel-job": "^1.5",
+        "spatie/laravel-permission": "^6.1",
+        "ext-curl": "*"
     },
     "require-dev": {
         "fakerphp/faker": "^1.9.1",

src/database/migrations/2023_12_20_101128_create_jobs_table.php

@@ -0,0 +1,32 @@
+<?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::create('jobs', function (Blueprint $table) {
+            $table->bigIncrements('id');
+            $table->string('queue')->index();
+            $table->longText('payload');
+            $table->unsignedTinyInteger('attempts');
+            $table->unsignedInteger('reserved_at')->nullable();
+            $table->unsignedInteger('available_at');
+            $table->unsignedInteger('created_at');
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     */
+    public function down(): void
+    {
+        Schema::dropIfExists('jobs');
+    }
+};

src/database/migrations/2023_12_21_105625_add_author_to_items.php

@@ -0,0 +1,29 @@
+<?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('items', function (Blueprint $table) {
+            $table->string('author')->nullable()->after('name');
+            $table->string('publisher')->nullable()->after('author');
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     */
+    public function down(): void
+    {
+        Schema::table('items', function (Blueprint $table) {
+            //
+        });
+    }
+};